Implements issue retrieval for Bitbucket to show on StartWork list

(#4047, #4119)

Author: sergeibbb

src/plus/integrations/providers/bitbucket.ts

@@ -283,10 +283,39 @@ export class BitbucketIntegration extends HostingIntegration<
 	}
 
 	protected override async searchProviderMyIssues(
-		_session: AuthenticationSession,
-		_repos?: BitbucketRepositoryDescriptor[],
+		session: AuthenticationSession,
+		requestedRepositories?: BitbucketRepositoryDescriptor[],
 	): Promise<IssueShape[] | undefined> {
-		return Promise.resolve(undefined);
+		let repoPaths: undefined | Map<string, boolean> = undefined;
+		if (requestedRepositories != null) {
+			repoPaths = new Map<string, boolean>();
+			for (const repo of requestedRepositories) {
+				repoPaths.set(`${repo.owner}/${repo.name}`, true);
+			}
+		}
+
+		const user = await this.getProviderCurrentAccount(session);
+		if (user?.username == null) return undefined;
+
+		const workspaces = await this.getProviderResourcesForUser(session);
+		if (workspaces == null || workspaces.length === 0) return undefined;
+
+		const repos = (await this.getProviderProjectsForResources(session, workspaces))?.filter(
+			r => repoPaths === undefined || repoPaths.has(`${r.owner}/${r.name}`),
+		);
+		if (repos == null || repos.length === 0) return undefined;
+
+		const api = await this.container.bitbucket;
+		if (!api) return undefined;
+		const issueResult = await Promise.allSettled(
+			repos.map(repo =>
+				api.getUsersIssuesForRepo(this, session.accessToken, user.id, repo.owner, repo.name, this.apiBaseUrl),
+			),
+		);
+		return issueResult
+			.map(r => getSettledValue(r))
+			.filter(r => r != null)
+			.flat();
 	}
 
 	protected override async providerOnConnect(): Promise<void> {

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

@@ -13,6 +13,7 @@ import {
 	RequestClientError,
 	RequestNotFoundError,
 } from '../../../../errors';
+import type { Issue } from '../../../../git/models/issue';
 import type { IssueOrPullRequest, IssueOrPullRequestType } from '../../../../git/models/issueOrPullRequest';
 import type { PullRequest } from '../../../../git/models/pullRequest';
 import type { Provider } from '../../../../git/models/remoteProvider';
@@ -25,7 +26,7 @@ import type { LogScope } from '../../../../system/logger.scope';
 import { getLogScope } from '../../../../system/logger.scope';
 import { maybeStopWatch } from '../../../../system/stopwatch';
 import type { BitbucketIssue, BitbucketPullRequest, BitbucketRepository } from './models';
-import { bitbucketIssueStateToState, fromBitbucketPullRequest } from './models';
+import { bitbucketIssueStateToState, fromBitbucketIssue, fromBitbucketPullRequest } from './models';
 
 export class BitbucketApi implements Disposable {
 	private readonly _disposable: Disposable;
@@ -92,6 +93,73 @@ export class BitbucketApi implements Disposable {
 		return fromBitbucketPullRequest(response.values[0], provider);
 	}
 
+	@debug<BitbucketApi['getUsersIssuesForRepo']>({ args: { 0: p => p.name, 1: '<token>' } })
+	async getUsersIssuesForRepo(
+		provider: Provider,
+		token: string,
+		userUuid: string,
+		owner: string,
+		repo: string,
+		baseUrl: string,
+	): Promise<Issue[] | undefined> {
+		const scope = getLogScope();
+		const query = encodeURIComponent(`assignee.uuid="${userUuid}" OR reporter.uuid="${userUuid}"`);
+
+		const response = await this.request<{
+			values: BitbucketIssue[];
+			pagelen: number;
+			size: number;
+			page: number;
+		}>(
+			provider,
+			token,
+			baseUrl,
+			`repositories/${owner}/${repo}/issues?q=${query}`,
+			{
+				method: 'GET',
+			},
+			scope,
+		);
+
+		if (!response?.values?.length) {
+			return undefined;
+		}
+		return response.values.map(issue => fromBitbucketIssue(issue, provider));
+	}
+
+	@debug<BitbucketApi['getIssue']>({ args: { 0: p => p.name, 1: '<token>' } })
+	async getIssue(
+		provider: Provider,
+		token: string,
+		owner: string,
+		repo: string,
+		id: string,
+		baseUrl: string,
+	): Promise<Issue | undefined> {
+		const scope = getLogScope();
+
+		try {
+			const response = await this.request<BitbucketIssue>(
+				provider,
+				token,
+				baseUrl,
+				`repositories/${owner}/${repo}/issues/${id}`,
+				{
+					method: 'GET',
+				},
+				scope,
+			);
+
+			if (response) {
+				return fromBitbucketIssue(response, provider);
+			}
+			return undefined;
+		} catch (ex) {
+			Logger.error(ex, scope);
+			return undefined;
+		}
+	}
+
 	@debug<BitbucketApi['getIssueOrPullRequest']>({ args: { 0: p => p.name, 1: '<token>' } })
 	public async getIssueOrPullRequest(
 		provider: Provider,

src/plus/startWork/startWork.ts

@@ -21,6 +21,7 @@ import {
 import {
 	ConnectIntegrationButton,
 	OpenOnAzureDevOpsQuickInputButton,
+	OpenOnBitbucketQuickInputButton,
 	OpenOnGitHubQuickInputButton,
 	OpenOnGitLabQuickInputButton,
 	OpenOnJiraQuickInputButton,
@@ -96,6 +97,7 @@ export const supportedStartWorkIntegrations = [
 	HostingIntegrationId.GitLab,
 	SelfHostedIntegrationId.CloudGitLabSelfHosted,
 	HostingIntegrationId.AzureDevOps,
+	HostingIntegrationId.Bitbucket,
 	IssueIntegrationId.Jira,
 ];
 export type SupportedStartWorkIntegrationIds = (typeof supportedStartWorkIntegrations)[number];
@@ -483,6 +485,7 @@ export abstract class StartWorkBaseCommand extends QuickCommand<State> {
 			onDidClickItemButton: (_quickpick, button, { item }) => {
 				switch (button) {
 					case OpenOnAzureDevOpsQuickInputButton:
+					case OpenOnBitbucketQuickInputButton:
 					case OpenOnGitHubQuickInputButton:
 					case OpenOnGitLabQuickInputButton:
 					case OpenOnJiraQuickInputButton:
@@ -716,6 +719,8 @@ function getOpenOnWebQuickInputButton(integrationId: string): QuickInputButton |
 	switch (integrationId) {
 		case HostingIntegrationId.AzureDevOps:
 			return OpenOnAzureDevOpsQuickInputButton;
+		case HostingIntegrationId.Bitbucket:
+			return OpenOnBitbucketQuickInputButton;
 		case HostingIntegrationId.GitHub:
 		case SelfHostedIntegrationId.CloudGitHubEnterprise:
 			return OpenOnGitHubQuickInputButton;