Retrieves Bitbucket PRs where a user is author or reviewer

(#4046)

Author: sergeibbb

src/plus/integrations/providers/bitbucket.ts

@@ -7,12 +7,13 @@ import type { Issue, IssueShape } from '../../../git/models/issue';
 import type { IssueOrPullRequest, IssueOrPullRequestType } from '../../../git/models/issueOrPullRequest';
 import type { PullRequest, PullRequestMergeMethod, PullRequestState } from '../../../git/models/pullRequest';
 import type { RepositoryMetadata } from '../../../git/models/repositoryMetadata';
+import { groupBy } from '../../../system/iterable';
+import { getSettledValue } from '../../../system/promise';
 import type { IntegrationAuthenticationProviderDescriptor } from '../authentication/integrationAuthenticationProvider';
 import type { ProviderAuthenticationSession } from '../authentication/models';
 import type { ResourceDescriptor } from '../integration';
 import { HostingIntegration } from '../integration';
-import type { ProviderPullRequest } from './models';
-import { fromProviderPullRequest, providersMetadata } from './models';
+import { providersMetadata } from './models';
 
 const metadata = providersMetadata[HostingIntegrationId.Bitbucket];
 const authProvider = Object.freeze({ id: metadata.id, scopes: metadata.scopes });
@@ -263,7 +264,6 @@ export class BitbucketIntegration extends HostingIntegration<
 		session: ProviderAuthenticationSession,
 		requestedRepositories?: BitbucketRepositoryDescriptor[],
 	): Promise<PullRequest[] | undefined> {
-		const api = await this.getProvidersApi();
 		if (requestedRepositories != null) {
 			// TODO: implement repos version
 			return undefined;
@@ -278,14 +278,24 @@ export class BitbucketIntegration extends HostingIntegration<
 		const repos = await this.getProviderProjectsForResources(session, workspaces);
 		if (repos == null || repos.length === 0) return undefined;
 
-		const prs = await api.getPullRequestsForRepos(
-			HostingIntegrationId.Bitbucket,
-			repos.map(repo => ({ namespace: repo.owner, name: repo.name })),
-			{
-				accessToken: session.accessToken,
-			},
+		const api = await this.container.bitbucket;
+		if (!api) return undefined;
+		const prsResult = await Promise.allSettled(
+			repos.map(repo =>
+				api.getUsersPullRequestsForRepo(
+					this,
+					session.accessToken,
+					user.id,
+					repo.owner,
+					repo.name,
+					this.apiBaseUrl,
+				),
+			),
 		);
-		return prs.values.map(pr => this.fromBitbucketProviderPullRequest(pr));
+		return prsResult
+			.map(r => getSettledValue(r))
+			.filter(r => r != null)
+			.flat();
 	}
 
 	protected override async searchProviderMyIssues(
@@ -295,14 +305,6 @@ export class BitbucketIntegration extends HostingIntegration<
 		return Promise.resolve(undefined);
 	}
 
-	private fromBitbucketProviderPullRequest(
-		remotePullRequest: ProviderPullRequest,
-		//		repoDescriptors: BitbucketRemoteRepositoryDescriptor[],
-	): PullRequest {
-		remotePullRequest.graphQLId = remotePullRequest.id;
-		return fromProviderPullRequest(remotePullRequest, this);
-	}
-
 	protected override async providerOnConnect(): Promise<void> {
 		if (this._session == null) return;
 

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

@@ -221,6 +221,39 @@ export class BitbucketApi implements Disposable {
 		}
 	}
 
+	public async getUsersPullRequestsForRepo(
+		provider: Provider,
+		token: string,
+		userUuid: string,
+		owner: string,
+		repo: string,
+		baseUrl: string,
+	): Promise<PullRequest[] | undefined> {
+		const scope = getLogScope();
+
+		const query = encodeURIComponent(`reviewers.uuid="${userUuid}" OR author.uuid="${userUuid}"`);
+		const response = await this.request<{
+			values: BitbucketPullRequest[];
+			pagelen: number;
+			size: number;
+			page: number;
+		}>(
+			provider,
+			token,
+			baseUrl,
+			`repositories/${owner}/${repo}/pullrequests?q=${query}&state=OPEN&fields=%2Bvalues.reviewers,%2Bvalues.participants`,
+			{
+				method: 'GET',
+			},
+			scope,
+		);
+
+		if (!response?.values?.length) {
+			return undefined;
+		}
+		return response.values.map(pr => fromBitbucketPullRequest(pr, provider));
+	}
+
 	private async request<T>(
 		provider: Provider,
 		token: string,