Uses shared library for fetching authored pull requests from Bitbucket

Integrates changes from
gitkraken/provider-apis-package-js#223
Solves #4128
(#4141)

Author: sergeibbb

package.json

@@ -21451,7 +21451,7 @@
 	},
 	"dependencies": {
 		"@gitkraken/gitkraken-components": "10.7.0",
-		"@gitkraken/provider-apis": "0.26.2",
+		"@gitkraken/provider-apis": "0.26.2+??",
 		"@gitkraken/shared-web-components": "0.1.1-rc.15",
 		"@gk-nzaytsev/fast-string-truncated-width": "1.1.0",
 		"@lit-labs/signals": "0.1.2",

src/plus/integrations/providers/bitbucket.ts

@@ -13,7 +13,7 @@ import type { IntegrationAuthenticationProviderDescriptor } from '../authenticat
 import type { ProviderAuthenticationSession } from '../authentication/models';
 import { HostingIntegration } from '../integration';
 import type { BitbucketRepositoryDescriptor, BitbucketWorkspaceDescriptor } from './bitbucket/models';
-import { providersMetadata } from './models';
+import { fromProviderPullRequest, providersMetadata } from './models';
 
 const metadata = providersMetadata[HostingIntegrationId.Bitbucket];
 const authProvider = Object.freeze({ id: metadata.id, scopes: metadata.scopes });
@@ -218,24 +218,40 @@ export class BitbucketIntegration extends HostingIntegration<
 		const workspaces = await this.getProviderResourcesForUser(session);
 		if (workspaces == null || workspaces.length === 0) return undefined;
 
+		const providersApi = await this.getProvidersApi();
 		const api = await this.container.bitbucket;
-		if (!api) return undefined;
-
-		const authoredPrs = workspaces.map(ws =>
-			api.getPullRequestsForWorkspaceAuthoredByUser(this, session.accessToken, user.id, ws.slug, this.apiBaseUrl),
-		);
+		if (!providersApi && !api) {
+			return undefined;
+		}
 
-		const reviewingPrs = workspaceRepos.map(repo => {
-			const [owner, name] = repo.split('/');
-			return api.getUsersReviewingPullRequestsForRepo(
-				this,
-				session.accessToken,
-				user.id,
-				owner,
-				name,
-				this.apiBaseUrl,
-			);
-		});
+		const integration = await this.container.integrations.get(this.id);
+
+		const authoredPrs = providersApi
+			? workspaces.map(async ws => {
+					const prs = await providersApi.getBitbucketPullRequestsAuthoredByUserForWorkspace(
+						user.id,
+						ws.slug,
+						{
+							accessToken: session.accessToken,
+						},
+					);
+					return prs?.map(pr => fromProviderPullRequest(pr, integration));
+			  })
+			: [];
+
+		const reviewingPrs = api
+			? workspaceRepos.map(repo => {
+					const [owner, name] = repo.split('/');
+					return api.getUsersReviewingPullRequestsForRepo(
+						this,
+						session.accessToken,
+						user.id,
+						owner,
+						name,
+						this.apiBaseUrl,
+					);
+			  })
+			: [];
 
 		return [
 			...uniqueBy(

src/plus/integrations/providers/bitbucket/bitbucket.ts

@@ -289,37 +289,6 @@ export class BitbucketApi implements Disposable {
 		}
 	}
 
-	async getPullRequestsForWorkspaceAuthoredByUser(
-		provider: Provider,
-		token: string,
-		userUuid: string,
-		workspace: string,
-		baseUrl: string,
-	): Promise<PullRequest[] | undefined> {
-		const scope = getLogScope();
-
-		const response = await this.request<{
-			values: BitbucketPullRequest[];
-			pagelen: number;
-			size: number;
-			page: number;
-		}>(
-			provider,
-			token,
-			baseUrl,
-			`workspaces/${workspace}/pullrequests/${userUuid}?state=OPEN&fields=%2Bvalues.reviewers,%2Bvalues.participants`,
-			{
-				method: 'GET',
-			},
-			scope,
-		);
-
-		if (!response?.values?.length) {
-			return undefined;
-		}
-		return response.values.map(pr => fromBitbucketPullRequest(pr, provider));
-	}
-
 	async getUsersReviewingPullRequestsForRepo(
 		provider: Provider,
 		token: string,

src/plus/integrations/providers/models.ts

@@ -18,6 +18,7 @@ import type {
 	Jira,
 	JiraProject,
 	JiraResource,
+	NumberedPageInput,
 	Issue as ProviderApiIssue,
 	PullRequestWithUniqueID,
 	RequestFunction,
@@ -342,6 +343,19 @@ export type GetBitbucketResourcesForUserFn = (
 	input: { userId: string },
 	options?: EnterpriseOptions,
 ) => Promise<{ data: BitbucketWorkspaceStub[] }>;
+export type GetBitbucketPullRequestsAuthoredByUserForWorkspaceFn = (
+	input: {
+		userId: string;
+		workspaceSlug: string;
+	} & NumberedPageInput,
+	options?: EnterpriseOptions,
+) => Promise<{
+	pageInfo: {
+		hasNextPage: boolean;
+		nextPage: number | null;
+	};
+	data: GitPullRequest[];
+}>;
 export type GetIssuesForProjectFn = Jira['getIssuesForProject'];
 export type GetIssuesForResourceForCurrentUserFn = (
 	input: { resourceId: string },
@@ -364,6 +378,7 @@ export interface ProviderInfo extends ProviderMetadata {
 	getJiraResourcesForCurrentUserFn?: GetJiraResourcesForCurrentUserFn;
 	getAzureResourcesForUserFn?: GetAzureResourcesForUserFn;
 	getBitbucketResourcesForUserFn?: GetBitbucketResourcesForUserFn;
+	getBitbucketPullRequestsAuthoredByUserForWorkspaceFn?: GetBitbucketPullRequestsAuthoredByUserForWorkspaceFn;
 	getJiraProjectsForResourcesFn?: GetJiraProjectsForResourcesFn;
 	getAzureProjectsForResourceFn?: GetAzureProjectsForResourceFn;
 	getIssuesForProjectFn?: GetIssuesForProjectFn;
@@ -912,7 +927,7 @@ export function fromProviderPullRequest(
 		integration,
 		fromProviderAccount(pr.author),
 		pr.id,
-		pr.graphQLId,
+		pr.graphQLId || pr.id,
 		pr.title,
 		pr.url ?? '',
 		{

src/plus/integrations/providers/providersApi.ts

@@ -19,6 +19,7 @@ import type { IntegrationAuthenticationService } from '../authentication/integra
 import type {
 	GetAzureProjectsForResourceFn,
 	GetAzureResourcesForUserFn,
+	GetBitbucketPullRequestsAuthoredByUserForWorkspaceFn,
 	GetBitbucketResourcesForUserFn,
 	GetCurrentUserFn,
 	GetCurrentUserForInstanceFn,
@@ -202,6 +203,10 @@ export class ProvidersApi {
 				getBitbucketResourcesForUserFn: providerApis.bitbucket.getWorkspacesForUser.bind(
 					providerApis.bitbucket,
 				) as GetBitbucketResourcesForUserFn,
+				getBitbucketPullRequestsAuthoredByUserForWorkspaceFn:
+					providerApis.bitbucket.getPullRequestsForUserAndWorkspace.bind(
+						providerApis.bitbucket,
+					) as GetBitbucketPullRequestsAuthoredByUserForWorkspaceFn,
 				getPullRequestsForReposFn: providerApis.bitbucket.getPullRequestsForRepos.bind(
 					providerApis.bitbucket,
 				) as GetPullRequestsForReposFn,
@@ -564,6 +569,29 @@ export class ProvidersApi {
 		}
 	}
 
+	async getBitbucketPullRequestsAuthoredByUserForWorkspace(
+		userId: string,
+		workspaceSlug: string,
+		options?: { accessToken?: string },
+	): Promise<ProviderPullRequest[] | undefined> {
+		const { provider, token } = await this.ensureProviderTokenAndFunction(
+			HostingIntegrationId.Bitbucket,
+			'getBitbucketPullRequestsAuthoredByUserForWorkspaceFn',
+			options?.accessToken,
+		);
+
+		try {
+			return (
+				await provider.getBitbucketPullRequestsAuthoredByUserForWorkspaceFn?.(
+					{ userId: userId, workspaceSlug: workspaceSlug },
+					{ token: token },
+				)
+			)?.data;
+		} catch (e) {
+			return this.handleProviderError(HostingIntegrationId.Bitbucket, token, e);
+		}
+	}
+
 	async getJiraProjectsForResources(
 		resourceIds: string[],
 		options?: { accessToken?: string },