FilesExpand file tree

main

/

commentHandlerResolver.ts

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

72 lines (59 loc) · 2.74 KB

main

/

commentHandlerResolver.ts

Copy path

Top

File metadata and controls

• Code
• Blame

72 lines (59 loc) · 2.74 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

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

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

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

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

'use strict';

import * as vscode from 'vscode';

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

import Logger from './common/logger';

import { GHPRComment, GHPRCommentThread, TemporaryComment } from './github/prComment';

export interface CommentHandler {

commentController: vscode.CommentController;

hasCommentThread(thread: GHPRCommentThread): boolean;

createOrReplyComment(thread: GHPRCommentThread, input: string, isSingleComment: boolean): Promise<void>;

editComment(thread: GHPRCommentThread, comment: GHPRComment | TemporaryComment): Promise<void>;

deleteComment(thread: GHPRCommentThread, comment: GHPRComment | TemporaryComment): Promise<void>;

startReview(thread: GHPRCommentThread, input: string): Promise<void>;

openReview(thread: GHPRCommentThread): Promise<void>;

resolveReviewThread(thread: GHPRCommentThread, input?: string): Promise<void>;

unresolveReviewThread(thread: GHPRCommentThread, input?: string): Promise<void>;

}

export interface CommentReply {

thread: GHPRCommentThread;

text: string;

}

export namespace CommentReply {

export function is(commentReply: any): commentReply is CommentReply {

return commentReply && commentReply.thread && (commentReply.text !== undefined);

}

}

const commentHandlers = new Map<string, { handler: CommentHandler, repoRootUri: string }>();

export function registerCommentHandler(key: string, commentHandler: CommentHandler, repository: Repository) {

commentHandlers.set(key, { handler: commentHandler, repoRootUri: repository.rootUri.toString() });

}

export function unregisterCommentHandler(key: string) {

commentHandlers.delete(key);

}

export function resolveCommentHandler(commentThread: GHPRCommentThread): CommentHandler | undefined {

const possibleHandlers: { handler: CommentHandler, repoRootUri: string }[] = [];

for (const commentHandler of commentHandlers.values()) {

if (commentHandler.handler.hasCommentThread(commentThread)) {

possibleHandlers.push(commentHandler);

}

}

if (possibleHandlers.length > 0) {

possibleHandlers.sort((a, b) => {

return b.repoRootUri.length - a.repoRootUri.length;

});

return possibleHandlers[0].handler;

}

Logger.warn(`Unable to find handler for comment thread ${commentThread.gitHubThreadId}`);

return;

}

export function findActiveHandler() {

for (const commentHandler of commentHandlers.values()) {

if (commentHandler.handler.commentController.activeCommentThread) {

return commentHandler.handler;

}

}

}