/*---------------------------------------------------------------------------------------------

* Copyright (c) Microsoft Corporation. All rights reserved.

* Licensed under the MIT License. See License.txt in the project root for license information.

*--------------------------------------------------------------------------------------------*/

import * as buffer from 'buffer';

import * as path from 'path';

import equals from 'fast-deep-equal';

import * as vscode from 'vscode';

import { Repository } from '../api/api';

import { DiffSide, IComment, IReviewThread, SubjectType, ViewedState } from '../common/comment';

import { parseDiff } from '../common/diffHunk';

import { GitChangeType, InMemFileChange, SlimFileChange } from '../common/file';

import { GitHubRef } from '../common/githubRef';

import Logger from '../common/logger';

import { Remote } from '../common/remote';

import { ITelemetry } from '../common/telemetry';

import { ReviewEvent as CommonReviewEvent, EventType, TimelineEvent } from '../common/timelineEvent';

import { resolvePath, Schemes, toPRUri, toReviewUri } from '../common/uri';

import { formatError } from '../common/utils';

import { OctokitCommon } from './common';

import { CredentialStore } from './credentials';

import { FolderRepositoryManager } from './folderRepositoryManager';

import { GitHubRepository } from './githubRepository';

import {

AddCommentResponse,

AddReactionResponse,

AddReviewThreadResponse,

DeleteReactionResponse,

DeleteReviewResponse,

EditCommentResponse,

GetReviewRequestsResponse,

LatestReviewCommitResponse,

MarkPullRequestReadyForReviewResponse,

PendingReviewIdResponse,

PullRequestCommentsResponse,

PullRequestFilesResponse,

PullRequestMergabilityResponse,

ReactionGroup,

ResolveReviewThreadResponse,

StartReviewResponse,

SubmitReviewResponse,

TimelineEventsResponse,

UnresolveReviewThreadResponse,

UpdatePullRequestResponse,

} from './graphql';

import {

GithubItemStateEnum,

IAccount,

IRawFileChange,

ISuggestedReviewer,

ITeam,

MergeMethod,

PullRequest,

PullRequestChecks,

PullRequestMergeability,

PullRequestReviewRequirement,

ReviewEvent,

} from './interface';

import { IssueModel } from './issueModel';

import {

convertRESTPullRequestToRawPullRequest,

convertRESTReviewEvent,

getAvatarWithEnterpriseFallback,

getReactionGroup,

insertNewCommitsSinceReview,

parseGraphQLComment,

parseGraphQLReaction,

parseGraphQLReviewEvent,

parseGraphQLReviewThread,

parseGraphQLTimelineEvents,

parseMergeability,

restPaginate,

} from './utils';

interface IPullRequestModel {

head: GitHubRef | null;

}

export interface IResolvedPullRequestModel extends IPullRequestModel {

head: GitHubRef;

}

export interface ReviewThreadChangeEvent {

added: IReviewThread[];

changed: IReviewThread[];

removed: IReviewThread[];

}

export interface FileViewedStateChangeEvent {

changed: {

fileName: string;

viewed: ViewedState;

}[];

}

export type FileViewedState = { [key: string]: ViewedState };

export class PullRequestModel extends IssueModel<PullRequest> implements IPullRequestModel {

static ID = 'PullRequestModel';

public isDraft?: boolean;

public localBranchName?: string;

public mergeBase?: string;

public suggestedReviewers?: ISuggestedReviewer[];

public hasChangesSinceLastReview?: boolean;

private _showChangesSinceReview: boolean;

private _hasPendingReview: boolean = false;

private _onDidChangePendingReviewState: vscode.EventEmitter<boolean> = new vscode.EventEmitter<boolean>();

public onDidChangePendingReviewState = this._onDidChangePendingReviewState.event;

private _reviewThreadsCache: IReviewThread[] = [];

private _reviewThreadsCacheInitialized = false;

private _onDidChangeReviewThreads = new vscode.EventEmitter<ReviewThreadChangeEvent>();

public onDidChangeReviewThreads = this._onDidChangeReviewThreads.event;

private _fileChangeViewedState: FileViewedState = {};

private _viewedFiles: Set<string> = new Set();

private _unviewedFiles: Set<string> = new Set();

private _onDidChangeFileViewedState = new vscode.EventEmitter<FileViewedStateChangeEvent>();

public onDidChangeFileViewedState = this._onDidChangeFileViewedState.event;

private _onDidChangeChangesSinceReview = new vscode.EventEmitter<void>();

public onDidChangeChangesSinceReview = this._onDidChangeChangesSinceReview.event;

private _comments: readonly IComment[] | undefined;

private _onDidChangeComments: vscode.EventEmitter<void> = new vscode.EventEmitter();

public readonly onDidChangeComments: vscode.Event<void> = this._onDidChangeComments.event;

// Whether the pull request is currently checked out locally

private _isActive: boolean;

public get isActive(): boolean {

return this._isActive;

}

public set isActive(isActive: boolean) {

this._isActive = isActive;

}

_telemetry: ITelemetry;

constructor(

private readonly credentialStore: CredentialStore,

telemetry: ITelemetry,

githubRepository: GitHubRepository,

remote: Remote,

item: PullRequest,

isActive?: boolean,

) {

super(githubRepository, remote, item, true);

this._telemetry = telemetry;

this.isActive = !!isActive;

this._showChangesSinceReview = false;

this.update(item);

}

public clear() {

this.comments = [];

this._reviewThreadsCacheInitialized = false;

this._reviewThreadsCache = [];

}

public async initializeReviewThreadCache(): Promise<void> {

await this.getReviewThreads();

this._reviewThreadsCacheInitialized = true;

}

public get reviewThreadsCache(): IReviewThread[] {

return this._reviewThreadsCache;

}

public get reviewThreadsCacheReady(): boolean {

return this._reviewThreadsCacheInitialized;

}

public get isMerged(): boolean {

return this.state === GithubItemStateEnum.Merged;

}

public get hasPendingReview(): boolean {

return this._hasPendingReview;

}

public set hasPendingReview(hasPendingReview: boolean) {

if (this._hasPendingReview !== hasPendingReview) {

this._hasPendingReview = hasPendingReview;

this._onDidChangePendingReviewState.fire(this._hasPendingReview);

}

}

public get showChangesSinceReview() {

return this._showChangesSinceReview;

}

public set showChangesSinceReview(isChangesSinceReview: boolean) {

if (this._showChangesSinceReview !== isChangesSinceReview) {

this._showChangesSinceReview = isChangesSinceReview;

this._fileChanges.clear();

this._onDidChangeChangesSinceReview.fire();

}

}

get comments(): readonly IComment[] {

return this._comments ?? [];

}

set comments(comments: readonly IComment[]) {

this._comments = comments;

this._onDidChangeComments.fire();

}

get fileChangeViewedState(): FileViewedState {

return this._fileChangeViewedState;

}

public isRemoteHeadDeleted?: boolean;

public head: GitHubRef | null;

public isRemoteBaseDeleted?: boolean;

public base: GitHubRef;

protected updateState(state: string) {

if (state.toLowerCase() === 'open') {

this.state = GithubItemStateEnum.Open;

} else if (state.toLowerCase() === 'merged' || this.item.merged) {

this.state = GithubItemStateEnum.Merged;

} else {

this.state = GithubItemStateEnum.Closed;

}

}

update(item: PullRequest): void {

super.update(item);

this.isDraft = item.isDraft;

this.suggestedReviewers = item.suggestedReviewers;

if (item.isRemoteHeadDeleted != null) {

this.isRemoteHeadDeleted = item.isRemoteHeadDeleted;

}

if (item.head) {

this.head = new GitHubRef(item.head.ref, item.head.label, item.head.sha, item.head.repo.cloneUrl, item.head.repo.owner, item.head.repo.name, item.head.repo.isInOrganization);

}

if (item.isRemoteBaseDeleted != null) {

this.isRemoteBaseDeleted = item.isRemoteBaseDeleted;

}

if (item.base) {

this.base = new GitHubRef(item.base.ref, item.base!.label, item.base!.sha, item.base!.repo.cloneUrl, item.base.repo.owner, item.base.repo.name, item.base.repo.isInOrganization);

}

}

/**

* Validate if the pull request has a valid HEAD.

* Use only when the method can fail silently, otherwise use `validatePullRequestModel`

*/

isResolved(): this is IResolvedPullRequestModel {

return !!this.head;

}

/**

* Validate if the pull request has a valid HEAD. Show a warning message to users when the pull request is invalid.

* @param message Human readable action execution failure message.

*/

validatePullRequestModel(message?: string): this is IResolvedPullRequestModel {

if (!!this.head) {

return true;

}

const reason = vscode.l10n.t('There is no upstream branch for Pull Request #{0}. View it on GitHub for more details', this.number);

if (message) {

message += `: ${reason}`;

} else {

message = reason;

}

const openString = vscode.l10n.t('Open on GitHub');

vscode.window.showWarningMessage(message, openString).then(action => {

if (action && action === openString) {

vscode.commands.executeCommand('vscode.open', vscode.Uri.parse(this.html_url));

}

});

return false;

}

/**

* Approve the pull request.

* @param message Optional approval comment text.

*/

async approve(repository: Repository, message?: string): Promise<CommonReviewEvent> {

// Check that the remote head of the PR branch matches the local head of the PR branch

let remoteHead: string | undefined;

let localHead: string | undefined;

let rejectMessage: string | undefined;

if (this.isActive) {

localHead = repository.state.HEAD?.commit;

remoteHead = (await this.githubRepository.getPullRequest(this.number))?.head?.sha;

rejectMessage = vscode.l10n.t('The remote head of the PR branch has changed. Please pull the latest changes from the remote branch before approving.');

} else {

localHead = this.head?.sha;

remoteHead = (await this.githubRepository.getPullRequest(this.number))?.head?.sha;

rejectMessage = vscode.l10n.t('The remote head of the PR branch has changed. Please refresh the pull request before approving.');

}

if (!remoteHead || remoteHead !== localHead) {

return Promise.reject(rejectMessage);

}

const action: Promise<CommonReviewEvent> = (await this.getPendingReviewId())

? this.submitReview(ReviewEvent.Approve, message)

: this.createReview(ReviewEvent.Approve, message);

return action.then(x => {

/* __GDPR__

"pr.approve" : {}

*/

this._telemetry.sendTelemetryEvent('pr.approve');

this._onDidChangeComments.fire();

return x;

});

}

/**

* Request changes on the pull request.

* @param message Optional comment text to leave with the review.

*/

async requestChanges(message?: string): Promise<CommonReviewEvent> {

const action: Promise<CommonReviewEvent> = (await this.getPendingReviewId())

? this.submitReview(ReviewEvent.RequestChanges, message)

: this.createReview(ReviewEvent.RequestChanges, message);

return action.then(x => {

/* __GDPR__

"pr.requestChanges" : {}

*/

this._telemetry.sendTelemetryEvent('pr.requestChanges');

this._onDidChangeComments.fire();

return x;

});

}

/**

* Close the pull request.

*/

async close(): Promise<PullRequest> {

const { octokit, remote } = await this.githubRepository.ensure();

const ret = await octokit.call(octokit.api.pulls.update, {

owner: remote.owner,

repo: remote.repositoryName,

pull_number: this.number,

state: 'closed',

});

/* __GDPR__

"pr.close" : {}

*/

this._telemetry.sendTelemetryEvent('pr.close');

return convertRESTPullRequestToRawPullRequest(ret.data, this.githubRepository);

}

/**

* Create a new review.

* @param event The type of review to create, an approval, request for changes, or comment.

* @param message The summary comment text.

*/

private async createReview(event: ReviewEvent, message?: string): Promise<CommonReviewEvent> {

const { octokit, remote } = await this.githubRepository.ensure();

const { data } = await octokit.call(octokit.api.pulls.createReview, {

owner: remote.owner,

repo: remote.repositoryName,

pull_number: this.number,

event: event,

body: message,

});

return convertRESTReviewEvent(data, this.githubRepository);

}

/**

* Submit an existing review.

* @param event The type of review to create, an approval, request for changes, or comment.

* @param body The summary comment text.

*/

async submitReview(event?: ReviewEvent, body?: string): Promise<CommonReviewEvent> {

let pendingReviewId = await this.getPendingReviewId();

const { mutate, schema } = await this.githubRepository.ensure();

if (!pendingReviewId && (event === ReviewEvent.Comment)) {

// Create a new review so that we can comment on it.

pendingReviewId = await this.startReview();

}

if (pendingReviewId) {

const { data } = await mutate<SubmitReviewResponse>({

mutation: schema.SubmitReview,

variables: {

id: pendingReviewId,

event: event || ReviewEvent.Comment,

body,

},

});

this.hasPendingReview = false;

await this.updateDraftModeContext();

const reviewEvent = parseGraphQLReviewEvent(data!.submitPullRequestReview.pullRequestReview, this.githubRepository);

const threadWithComment = this._reviewThreadsCache.find(thread =>

thread.comments.length ? (thread.comments[0].pullRequestReviewId === reviewEvent.id) : undefined,

);

if (threadWithComment) {

threadWithComment.comments = reviewEvent.comments;

threadWithComment.viewerCanResolve = true;

this._onDidChangeReviewThreads.fire({ added: [], changed: [threadWithComment], removed: [] });

}

return reviewEvent;

} else {

throw new Error(`Submitting review failed, no pending review for current pull request: ${this.number}.`);

}

}

async updateMilestone(id: string): Promise<void> {

const { mutate, schema } = await this.githubRepository.ensure();

const finalId = id === 'null' ? null : id;

try {

await mutate<UpdatePullRequestResponse>({

mutation: schema.UpdatePullRequest,

variables: {

input: {

pullRequestId: this.item.graphNodeId,

milestoneId: finalId,

},

},

});

} catch (err) {

Logger.error(err, PullRequestModel.ID);

}

}

async addAssignees(assignees: string[]): Promise<void> {

const { octokit, remote } = await this.githubRepository.ensure();

await octokit.call(octokit.api.issues.addAssignees, {

owner: remote.owner,

repo: remote.repositoryName,

issue_number: this.number,

assignees,

});

}

/**

* Query to see if there is an existing review.

*/

async getPendingReviewId(): Promise<string | undefined> {

const { query, schema } = await this.githubRepository.ensure();

const currentUser = await this.githubRepository.getAuthenticatedUser();

try {

const { data } = await query<PendingReviewIdResponse>({

query: schema.GetPendingReviewId,

variables: {

pullRequestId: this.item.graphNodeId,

author: currentUser,

},

});

return data.node.reviews.nodes.length > 0 ? data.node.reviews.nodes[0].id : undefined;

} catch (error) {

return;

}

}

async getViewerLatestReviewCommit(): Promise<{ sha: string } | undefined> {

Logger.debug(`Fetch viewers latest review commit`, IssueModel.ID);

const { query, remote, schema } = await this.githubRepository.ensure();

try {

const { data } = await query<LatestReviewCommitResponse>({

query: schema.LatestReviewCommit,

variables: {

owner: remote.owner,

name: remote.repositoryName,

number: this.number,

},

});

if (data.repository === null) {

Logger.error('Unexpected null repository while getting last review commit', PullRequestModel.ID);

}

return data.repository?.pullRequest.viewerLatestReview ? {

sha: data.repository?.pullRequest.viewerLatestReview.commit.oid,

} : undefined;

}

catch (e) {

return undefined;

}

}

/**

* Delete an existing in progress review.

*/

async deleteReview(): Promise<{ deletedReviewId: number; deletedReviewComments: IComment[] }> {

const pendingReviewId = await this.getPendingReviewId();

const { mutate, schema } = await this.githubRepository.ensure();

const { data } = await mutate<DeleteReviewResponse>({

mutation: schema.DeleteReview,

variables: {

input: { pullRequestReviewId: pendingReviewId },

},

});

const { comments, databaseId } = data!.deletePullRequestReview.pullRequestReview;

this.hasPendingReview = false;

await this.updateDraftModeContext();

this.getReviewThreads();

return {

deletedReviewId: databaseId,

deletedReviewComments: comments.nodes.map(comment => parseGraphQLComment(comment, false, this.githubRepository)),

};

}

/**

* Start a new review.

* @param initialComment The comment text and position information to begin the review with

* @param commitId The optional commit id to start the review on. Defaults to using the current head commit.

*/

async startReview(commitId?: string): Promise<string> {

const { mutate, schema } = await this.githubRepository.ensure();

const { data } = await mutate<StartReviewResponse>({

mutation: schema.StartReview,

variables: {

input: {

body: '',

pullRequestId: this.item.graphNodeId,

commitOID: commitId || this.head?.sha,

},

},

});

if (!data) {

throw new Error('Failed to start review');

}

this.hasPendingReview = true;

this._onDidChangeComments.fire();

return data.addPullRequestReview.pullRequestReview.id;

}

/**

* Creates a new review thread, either adding it to an existing pending review, or creating

* a new review.

* @param body The body of the thread's first comment.

* @param commentPath The path to the file being commented on.

* @param startLine The start line on which to add the comment.

* @param endLine The end line on which to add the comment.

* @param side The side the comment should be deleted on, i.e. the original or modified file.

* @param suppressDraftModeUpdate If a draft mode change should event should be suppressed. In the

* case of a single comment add, the review is created and then immediately submitted, so this prevents

* a "Pending" label from flashing on the comment.

* @returns The new review thread object.

*/

async createReviewThread(

body: string,

commentPath: string,

startLine: number | undefined,

endLine: number | undefined,

side: DiffSide,

suppressDraftModeUpdate?: boolean,

): Promise<IReviewThread | undefined> {

if (!this.validatePullRequestModel('Creating comment failed')) {

return;

}

const pendingReviewId = await this.getPendingReviewId();

const { mutate, schema } = await this.githubRepository.ensure();

const { data } = await mutate<AddReviewThreadResponse>({

mutation: schema.AddReviewThread,

variables: {

input: {

path: commentPath,

body,

pullRequestId: this.graphNodeId,

pullRequestReviewId: pendingReviewId,

startLine: startLine === endLine ? undefined : startLine,

line: (endLine === undefined) ? 0 : endLine,

side,

subjectType: (startLine === undefined || endLine === undefined) ? SubjectType.FILE : SubjectType.LINE

}

}

}, { mutation: schema.LegacyAddReviewThread, deleteProps: ['subjectType'] });

if (!data) {

throw new Error('Creating review thread failed.');

}

if (!data.addPullRequestReviewThread.thread) {

throw new Error('File has been deleted.');

}

if (!suppressDraftModeUpdate) {

this.hasPendingReview = true;

await this.updateDraftModeContext();

}

const thread = data.addPullRequestReviewThread.thread;

const newThread = parseGraphQLReviewThread(thread, this.githubRepository);

this._reviewThreadsCache.push(newThread);

this._onDidChangeReviewThreads.fire({ added: [newThread], changed: [], removed: [] });

return newThread;

}

/**

* Creates a new comment in reply to an existing comment

* @param body The text of the comment to be created

* @param inReplyTo The id of the comment this is in reply to

* @param isSingleComment Whether this is a single comment, i.e. one that

* will be immediately submitted and so should not show a pending label

* @param commitId The commit id the comment was made on

* @returns The new comment

*/

async createCommentReply(

body: string,

inReplyTo: string,

isSingleComment: boolean,

commitId?: string,

): Promise<IComment | undefined> {

if (!this.validatePullRequestModel('Creating comment failed')) {

return;

}

let pendingReviewId = await this.getPendingReviewId();

if (!pendingReviewId) {

pendingReviewId = await this.startReview(commitId);

}

const { mutate, schema } = await this.githubRepository.ensure();

const { data } = await mutate<AddCommentResponse>({

mutation: schema.AddComment,

variables: {

input: {

pullRequestReviewId: pendingReviewId,

body,

inReplyTo,

commitOID: commitId || this.head?.sha,

},

},

});

if (!data) {

throw new Error('Creating comment reply failed.');

}

const { comment } = data.addPullRequestReviewComment;

const newComment = parseGraphQLComment(comment, false, this.githubRepository);

if (isSingleComment) {

newComment.isDraft = false;

}

const threadWithComment = this._reviewThreadsCache.find(thread =>

thread.comments.some(comment => comment.graphNodeId === inReplyTo),

);

if (threadWithComment) {

threadWithComment.comments.push(newComment);

this._onDidChangeReviewThreads.fire({ added: [], changed: [threadWithComment], removed: [] });

}

return newComment;

}

/**

* Check whether there is an existing pending review and update the context key to control what comment actions are shown.

*/

async validateDraftMode(): Promise<boolean> {

const inDraftMode = !!(await this.getPendingReviewId());

if (inDraftMode !== this.hasPendingReview) {

this.hasPendingReview = inDraftMode;

}

await this.updateDraftModeContext();

return inDraftMode;

}

private async updateDraftModeContext() {

if (this.isActive) {

await vscode.commands.executeCommand('setContext', 'reviewInDraftMode', this.hasPendingReview);

}

}

/**

* Edit an existing review comment.

* @param comment The comment to edit

* @param text The new comment text

*/

async editReviewComment(comment: IComment, text: string): Promise<IComment> {

const { mutate, schema } = await this.githubRepository.ensure();

let threadWithComment = this._reviewThreadsCache.find(thread =>

thread.comments.some(c => c.graphNodeId === comment.graphNodeId),

);

if (!threadWithComment) {

return this.editIssueComment(comment, text);

}

const { data } = await mutate<EditCommentResponse>({

mutation: schema.EditComment,

variables: {

input: {

pullRequestReviewCommentId: comment.graphNodeId,

body: text,

},

},

});

if (!data) {

throw new Error('Editing review comment failed.');

}

const newComment = parseGraphQLComment(

data.updatePullRequestReviewComment.pullRequestReviewComment,

!!comment.isResolved,

this.githubRepository

);

if (threadWithComment) {

const index = threadWithComment.comments.findIndex(c => c.graphNodeId === comment.graphNodeId);

threadWithComment.comments.splice(index, 1, newComment);

this._onDidChangeReviewThreads.fire({ added: [], changed: [threadWithComment], removed: [] });

}

return newComment;

}

/**

* Deletes a review comment.

* @param commentId The comment id to delete

*/

async deleteReviewComment(commentId: string): Promise<void> {

try {

const { octokit, remote } = await this.githubRepository.ensure();

const id = Number(commentId);

const threadIndex = this._reviewThreadsCache.findIndex(thread => thread.comments.some(c => c.id === id));

if (threadIndex === -1) {

this.deleteIssueComment(commentId);

} else {

await octokit.call(octokit.api.pulls.deleteReviewComment, {

owner: remote.owner,

repo: remote.repositoryName,

comment_id: id,

});

if (threadIndex > -1) {

const threadWithComment = this._reviewThreadsCache[threadIndex];

const index = threadWithComment.comments.findIndex(c => c.id === id);

threadWithComment.comments.splice(index, 1);

if (threadWithComment.comments.length === 0) {

this._reviewThreadsCache.splice(threadIndex, 1);

this._onDidChangeReviewThreads.fire({ added: [], changed: [], removed: [threadWithComment] });

} else {

this._onDidChangeReviewThreads.fire({ added: [], changed: [threadWithComment], removed: [] });

}

}

}

} catch (e) {

throw new Error(formatError(e));

}

}

/**

* Get existing requests to review.

*/

async getReviewRequests(): Promise<(IAccount | ITeam)[]> {

const githubRepository = this.githubRepository;

const { remote, query, schema } = await githubRepository.ensure();

const { data } = await query<GetReviewRequestsResponse>({

query: this.credentialStore.isAuthenticatedWithAdditionalScopes(githubRepository.remote.authProviderId) ? schema.GetReviewRequestsAdditionalScopes : schema.GetReviewRequests,

variables: {

number: this.number,

owner: remote.owner,

name: remote.repositoryName

},

});

if (data.repository === null) {

Logger.error('Unexpected null repository while getting review requests', PullRequestModel.ID);

return [];

}

const reviewers: (IAccount | ITeam)[] = [];

for (const reviewer of data.repository.pullRequest.reviewRequests.nodes) {

if (reviewer.requestedReviewer?.login) {

const account: IAccount = {

login: reviewer.requestedReviewer.login,

url: reviewer.requestedReviewer.url,

avatarUrl: getAvatarWithEnterpriseFallback(reviewer.requestedReviewer.avatarUrl, undefined, remote.isEnterprise),

email: reviewer.requestedReviewer.email,

name: reviewer.requestedReviewer.name,

id: reviewer.requestedReviewer.id

};

reviewers.push(account);

} else if (reviewer.requestedReviewer) {

const team: ITeam = {

name: reviewer.requestedReviewer.name,

url: reviewer.requestedReviewer.url,

avatarUrl: getAvatarWithEnterpriseFallback(reviewer.requestedReviewer.avatarUrl, undefined, remote.isEnterprise),

id: reviewer.requestedReviewer.id!,

org: remote.owner,

slug: reviewer.requestedReviewer.slug!

};

reviewers.push(team);

}

}

return reviewers;

}

/**

* Add reviewers to a pull request

* @param reviewers A list of GitHub logins

*/

async requestReview(reviewers: string[], teamReviewers: string[]): Promise<void> {

const { mutate, schema } = await this.githubRepository.ensure();

await mutate({

mutation: schema.AddReviewers,

variables: {

input: {

pullRequestId: this.graphNodeId,

teamIds: teamReviewers,

userIds: reviewers

},

},

});

}

/**

* Remove a review request that has not yet been completed

* @param reviewer A GitHub Login

*/

async deleteReviewRequest(reviewers: string[], teamReviewers: string[]): Promise<void> {

const { octokit, remote } = await this.githubRepository.ensure();

await octokit.call(octokit.api.pulls.removeRequestedReviewers, {

owner: remote.owner,

repo: remote.repositoryName,

pull_number: this.number,

reviewers,

team_reviewers: teamReviewers

});

}

async deleteAssignees(assignees: string[]): Promise<void> {

const { octokit, remote } = await this.githubRepository.ensure();

await octokit.call(octokit.api.issues.removeAssignees, {

owner: remote.owner,

repo: remote.repositoryName,

issue_number: this.number,

assignees,

});

}

private diffThreads(oldReviewThreads: IReviewThread[], newReviewThreads: IReviewThread[]): void {

const added: IReviewThread[] = [];

const changed: IReviewThread[] = [];

const removed: IReviewThread[] = [];

newReviewThreads.forEach(thread => {

const existingThread = oldReviewThreads.find(t => t.id === thread.id);

if (existingThread) {

if (!equals(thread, existingThread)) {

changed.push(thread);

}

} else {

added.push(thread);

}

});

oldReviewThreads.forEach(thread => {

if (!newReviewThreads.find(t => t.id === thread.id)) {

removed.push(thread);

}

});

this._onDidChangeReviewThreads.fire({

added,

changed,

removed,

});

}

async getReviewThreads(): Promise<IReviewThread[]> {

const { remote, query, schema } = await this.githubRepository.ensure();

let after: string | null = null;

let hasNextPage = false;

const reviewThreads: IReviewThread[] = [];

try {

do {

const { data } = await query<PullRequestCommentsResponse>({

query: schema.PullRequestComments,

variables: {

owner: remote.owner,

name: remote.repositoryName,

number: this.number,

after

},

}, false, { query: schema.LegacyPullRequestComments });

reviewThreads.push(...data.repository.pullRequest.reviewThreads.nodes.map(node => {

return parseGraphQLReviewThread(node, this.githubRepository);

}));

hasNextPage = data.repository.pullRequest.reviewThreads.pageInfo.hasNextPage;

after = data.repository.pullRequest.reviewThreads.pageInfo.endCursor;

} while (hasNextPage && reviewThreads.length < 1000);

const oldReviewThreads = this._reviewThreadsCache;

this._reviewThreadsCache = reviewThreads;

this.diffThreads(oldReviewThreads, reviewThreads);

return reviewThreads;

} catch (e) {

Logger.error(`Failed to get pull request review comments: ${e}`, PullRequestModel.ID);

return [];

}

}

/**

* Get all review comments.

*/

async initializeReviewComments(): Promise<void> {

const { remote, query, schema } = await this.githubRepository.ensure();

let after: string | null = null;

let hasNextPage = false;

const comments: IComment[] = [];

try {

do {

const { data } = await query<PullRequestCommentsResponse>({

query: schema.PullRequestComments,

variables: {

owner: remote.owner,

name: remote.repositoryName,

number: this.number,

after,

},

}, false, { query: schema.LegacyPullRequestComments });

comments.push(...data.repository.pullRequest.reviewThreads.nodes

.map(node => node.comments.nodes.map(comment => parseGraphQLComment(comment, node.isResolved, this.githubRepository), remote))

.reduce((prev, curr) => prev.concat(curr), [])

.sort((a: IComment, b: IComment) => {

return a.createdAt > b.createdAt ? 1 : -1;

}));

hasNextPage = data.repository.pullRequest.reviewThreads.pageInfo.hasNextPage;

after = data.repository.pullRequest.reviewThreads.pageInfo.endCursor;

} while (hasNextPage && comments.length < 1000);

this.comments = comments;

} catch (e) {

Logger.error(`Failed to get pull request review comments: ${e}`, PullRequestModel.ID);

}

}

/**

* Get a list of the commits within a pull request.

*/

async getCommits(): Promise<OctokitCommon.PullsListCommitsResponseData> {

try {

Logger.debug(`Fetch commits of PR #${this.number} - enter`, PullRequestModel.ID);

const { remote, octokit } = await this.githubRepository.ensure();

const commitData = await octokit.api.paginate(octokit.api.pulls.listCommits, {

pull_number: this.number,

owner: remote.owner,

repo: remote.repositoryName,

});

Logger.debug(`Fetch commits of PR #${this.number} - done`, PullRequestModel.ID);

return commitData;

} catch (e) {

vscode.window.showErrorMessage(`Fetching commits failed: ${formatError(e)}`);

return [];

}

}

/**

* Get all changed files within a commit

* @param commit The commit

*/

async getCommitChangedFiles(

commit: OctokitCommon.PullsListCommitsResponseData[0],

): Promise<OctokitCommon.ReposGetCommitResponseFiles> {

try {

Logger.debug(

`Fetch file changes of commit ${commit.sha} in PR #${this.number} - enter`,

PullRequestModel.ID,

);

const { octokit, remote } = await this.githubRepository.ensure();

const fullCommit = await octokit.call(octokit.api.repos.getCommit, {

owner: remote.owner,