Adds support for fetching user issues from Linear

(#4543, #4579)

Author: sergeibbb

src/plus/integrations/providers/linear.ts

@@ -4,6 +4,7 @@ import type { Account } from '../../../git/models/author';
 import type { Issue, IssueShape } from '../../../git/models/issue';
 import type { IssueOrPullRequest, IssueOrPullRequestType } from '../../../git/models/issueOrPullRequest';
 import type { IssueResourceDescriptor, ResourceDescriptor } from '../../../git/models/resourceDescriptor';
+import { Logger } from '../../../system/logger';
 import type { IntegrationAuthenticationProviderDescriptor } from '../authentication/integrationAuthenticationProvider';
 import type { ProviderAuthenticationSession } from '../authentication/models';
 import { IssuesIntegration } from '../models/issuesIntegration';
@@ -62,11 +63,44 @@ export class LinearIntegration extends IssuesIntegration<IssuesCloudHostIntegrat
 		return metadata.domain;
 	}
 	protected override async searchProviderMyIssues(
-		_session: ProviderAuthenticationSession,
-		_resources?: ResourceDescriptor[],
-		_cancellation?: CancellationToken,
+		session: ProviderAuthenticationSession,
+		resources?: ResourceDescriptor[],
+		cancellation?: CancellationToken,
 	): Promise<IssueShape[] | undefined> {
-		return Promise.resolve(undefined);
+		if (resources != null) {
+			return undefined;
+		}
+		const api = await this.getProvidersApi();
+		let cursor = undefined;
+		let hasMore = false;
+		let requestCount = 0;
+		const issues = [];
+		try {
+			do {
+				if (cancellation?.isCancellationRequested) {
+					break;
+				}
+				const result = await api.getIssuesForCurrentUser(this.id, {
+					accessToken: session.accessToken,
+					cursor: cursor,
+				});
+				requestCount += 1;
+				hasMore = result.paging?.more ?? false;
+				cursor = result.paging?.cursor;
+				const formattedIssues = result.values
+					.map(issue => toIssueShape(issue, this))
+					.filter((result): result is IssueShape => result != null);
+				if (formattedIssues.length > 0) {
+					issues.push(...formattedIssues);
+				}
+			} while (requestCount < maxPagesPerRequest && hasMore);
+		} catch (ex) {
+			if (issues.length === 0) {
+				throw ex;
+			}
+			Logger.error(ex, 'searchProviderMyIssues');
+		}
+		return issues;
 	}
 	protected override getProviderIssueOrPullRequest(
 		_session: ProviderAuthenticationSession,

src/plus/integrations/providers/models.ts

@@ -281,6 +281,11 @@ export type GetIssuesForReposFn = (
 	options?: EnterpriseOptions,
 ) => Promise<{ data: ProviderIssue[]; pageInfo?: PageInfo }>;
 
+export type GetIssuesForCurrentUserFn = (
+	input: PagingInput,
+	options?: EnterpriseOptions,
+) => Promise<{ data: ProviderIssue[]; pageInfo?: PageInfo }>;
+
 export type GetIssuesForRepoFn = (
 	input: GetIssuesForRepoInput & PagingInput,
 	options?: EnterpriseOptions,
@@ -365,6 +370,7 @@ export interface ProviderInfo extends ProviderMetadata {
 	getPullRequestsForAzureProjectsFn?: GetPullRequestsForAzureProjectsFn;
 	getIssueFn?: GetIssueFn;
 	getIssuesForReposFn?: GetIssuesForReposFn;
+	getIssuesForCurrentUserFn?: GetIssuesForCurrentUserFn;
 	getIssuesForRepoFn?: GetIssuesForRepoFn;
 	getIssuesForAzureProjectFn?: GetIssuesForAzureProjectFn;
 	getCurrentUserFn?: GetCurrentUserFn;

src/plus/integrations/providers/providersApi.ts

@@ -44,6 +44,7 @@ import type {
 	IssueFilter,
 	MergePullRequestFn,
 	PageInfo,
+	PagingInput,
 	PagingMode,
 	ProviderAccount,
 	ProviderAzureProject,
@@ -325,6 +326,7 @@ export class ProvidersApi {
 			[IssuesCloudHostIntegrationId.Linear]: {
 				...providersMetadata[IssuesCloudHostIntegrationId.Linear],
 				provider: providerApis.linear,
+				getIssuesForCurrentUserFn: providerApis.linear.getIssuesForCurrentUser.bind(providerApis.linear),
 			},
 			[IssuesCloudHostIntegrationId.Trello]: {
 				...providersMetadata[IssuesCloudHostIntegrationId.Trello],
@@ -1035,6 +1037,26 @@ export class ProvidersApi {
 		);
 	}
 
+	async getIssuesForCurrentUser(
+		providerId: IntegrationIds,
+		options?: PagingInput & { accessToken?: string; isPAT?: boolean; baseUrl?: string },
+	): Promise<PagedResult<ProviderIssue>> {
+		const { provider, token } = await this.ensureProviderTokenAndFunction(
+			providerId,
+			'getIssuesForCurrentUserFn',
+			options?.accessToken,
+		);
+		return this.getPagedResult<ProviderIssue>(
+			provider,
+			options,
+			provider.getIssuesForCurrentUserFn,
+			token,
+			options?.cursor ?? undefined,
+			options?.isPAT,
+			options?.baseUrl,
+		);
+	}
+
 	async getIssuesForAzureProject(
 		providerId: GitCloudHostIntegrationId.AzureDevOps | GitSelfManagedHostIntegrationId.AzureDevOpsServer,
 		namespace: string,