feat(code-service): 增加 commit 等 api 和 command

Author: winjo

package.json

@@ -119,6 +119,11 @@
       "publisher": "cloud-ide",
       "name": "vscode-lsif",
       "version": "0.1.6"
+    },
+    {
+      "publisher": "alex",
+      "name": "gitlens",
+      "version": "10.2.3"
     }
   ]
 }

packages/code-api/src/antcode/antcode.service.ts

@@ -11,10 +11,34 @@ import {
   CodePlatform,
   IRepositoryModel,
   BranchOrTag,
+  CommitParams,
+  CommitFileStatus,
 } from '../common/types';
 import { CODE_PLATFORM_CONFIG } from '../common/config';
 import { HelperService } from '../common/service';
 
+const toType = (d: API.ResponseCommitFileChange) => {
+  if (d.new_file) return CommitFileStatus.Added;
+  else if (d.deleted_file) return CommitFileStatus.Deleted;
+  else if (d.renamed_file) return CommitFileStatus.Renamed;
+  return CommitFileStatus.Modified;
+};
+
+const toChangeLines = (diff: string) => {
+  const diffLines = diff ? diff.split('\n') : [];
+  return diffLines.reduce(
+    (obj, line) => {
+      if (line.startsWith('+')) {
+        obj.additions += 1;
+      } else if (line.startsWith('-')) {
+        obj.deletions += 1;
+      }
+      return obj;
+    },
+    { additions: 0, deletions: 0 }
+  );
+};
+
 @Injectable()
 export class AntCodeAPIService implements ICodeAPIService {
   @Autowired(IReporterService)
@@ -140,6 +164,19 @@ export class AntCodeAPIService implements ICodeAPIService {
     return new Uint8Array(buf);
   }
 
+  async getBlobByCommitPath(repo: IRepositoryModel, commit: string, path: string) {
+    const buf = await this.request<ArrayBuffer>(
+      `/api/v3/projects/${this.getProjectId(repo)}/repository/blobs/${commit}`,
+      {
+        responseType: 'arrayBuffer',
+        params: {
+          filepath: path,
+        },
+      }
+    );
+    return new Uint8Array(buf);
+  }
+
   async getEntryInfo(repo: IRepositoryModel, entry: EntryParam) {
     const data = await this.request<API.ResponseGetEntry>(
       `/api/v3/projects/${this.getProjectId(repo)}/repository/tree_entry`,
@@ -162,6 +199,12 @@ export class AntCodeAPIService implements ICodeAPIService {
     );
   }
 
+  async getBranchNames(repo: IRepositoryModel): Promise<string[]> {
+    return this.request<string[]>(
+      `/api/v3/projects/${this.getProjectId(repo)}/repository/branches_names`
+    );
+  }
+
   async getTags(repo: IRepositoryModel): Promise<BranchOrTag[]> {
     return this.request<API.ResponseGetRefs>(
       `/api/v3/projects/${this.getProjectId(repo)}/repository/tags`
@@ -223,4 +266,57 @@ export class AntCodeAPIService implements ICodeAPIService {
       )
     );
   }
+
+  async getCommits(repo: IRepositoryModel, params: CommitParams) {
+    const data = await this.request<API.ResponseCommit[]>(
+      `/api/v3/projects/${this.getProjectId(repo)}/repository/commits`,
+      {
+        params: {
+          ref_name: params.ref,
+          path: params.path,
+          page: params.page,
+          per_page: params.pageSize,
+        },
+      }
+    );
+    return data.map((c) => ({
+      id: c.id,
+      parents: c.parent_ids,
+      author: c.author_name,
+      authorEmail: c.author_email,
+      authorDate: c.authored_date,
+      committer: c.committer_name,
+      committerEmail: c.committer_email,
+      committerDate: c.committed_date,
+      message: c.message,
+      title: c.title,
+    }));
+  }
+
+  async getCommitDiff(repo: IRepositoryModel, sha: string) {
+    const data = await this.request<API.ResponseCommitFileChange[]>(
+      `/api/v3/projects/${this.getProjectId(repo)}/repository/commits/${sha}/diff`
+    );
+    return data.map((d) => ({
+      oldFilePath: d.old_path,
+      newFilePath: d.new_path,
+      type: toType(d),
+      ...toChangeLines(d.diff),
+    }));
+  }
+
+  async getCommitCompare(repo: IRepositoryModel, from: string, to: string) {
+    const data = await this.request<API.ResponseCommitCompare>(
+      `/api/v3/projects/${this.getProjectId(repo)}/repository/compare`,
+      {
+        params: { from, to },
+      }
+    );
+    return (data.diffs || []).map((d) => ({
+      oldFilePath: d.old_path,
+      newFilePath: d.new_path,
+      type: toType(d),
+      ...toChangeLines(d.diff),
+    }));
+  }
 }

packages/code-api/src/antcode/types.ts

@@ -33,4 +33,41 @@ export namespace API {
     path: string;
     ref: string;
   }>;
+
+  export interface ResponseCommit {
+    author_email: string;
+    author_name: string;
+    authored_date: string;
+    committed_date: string;
+    committer_email: string;
+    committer_name: string;
+    created_at: string;
+    id: string;
+    message: string;
+    parent_ids: string[];
+    short_id: string;
+    title: string;
+  }
+
+  export interface ResponseCommitFileChange {
+    a_mode: string;
+    b_mode: string;
+    binary_file: boolean;
+    charset_name: string;
+    deleted_file: boolean;
+    diff: string;
+    new_file: boolean;
+    new_path: string;
+    old_path: string;
+    renamed_file: boolean;
+    too_large: boolean;
+  }
+
+  export interface ResponseCommitCompare extends ResponseCommit {
+    commits: ResponseCommit[];
+    diffs: ResponseCommitFileChange[];
+    compare_overflow: boolean;
+    compare_same_ref: boolean;
+    compare_timeout: boolean;
+  }
 }

packages/code-api/src/common/types.ts

@@ -74,6 +74,42 @@ export interface IRepositoryModel {
   commit: string;
 }
 
+export interface CommitParams {
+  ref?: string;
+  path?: string;
+  page: number;
+  pageSize: number;
+}
+
+export interface CommitRecord {
+  id: string;
+  parents: ReadonlyArray<string>;
+  author: string;
+  authorEmail: string;
+  authorDate: string;
+  committer: string;
+  committerEmail: string;
+  committerDate: string;
+  // signature: null; // GPA 签名
+  message: string;
+  title?: string;
+}
+
+export interface CommitFileChange {
+  oldFilePath: string;
+  newFilePath: string;
+  type: CommitFileStatus;
+  additions: number | null;
+  deletions: number | null;
+}
+
+export const enum CommitFileStatus {
+  Added = 'A',
+  Modified = 'M',
+  Deleted = 'D',
+  Renamed = 'R',
+}
+
 export const ICodeAPIProvider = Symbol('ICodeAPIProvider');
 
 export interface ICodeAPIProvider {
@@ -101,16 +137,24 @@ export interface ICodeAPIService {
    * 获取 blob
    */
   getBlob(repo: IRepositoryModel, entry: EntryParam): Promise<Uint8Array>;
+  /**
+   * 获取 blob
+   */
+  getBlobByCommitPath(repo: IRepositoryModel, commit: string, path: string): Promise<Uint8Array>;
   /**
    * 获取 entry 相关信息
    */
   getEntryInfo?(repo: IRepositoryModel, entry: EntryParam): Promise<EntryInfo>;
   /**
-   * 获取所有分支和标签
+   * 获取所有分支
    */
   getBranches(repo: IRepositoryModel): Promise<BranchOrTag[]>;
   /**
-   * 获取所有分支和标签
+   * 获取所有分支
+   */
+  getBranchNames?(repo: IRepositoryModel): Promise<string[]>;
+  /**
+   * 获取所有标签
    */
   getTags(repo: IRepositoryModel): Promise<BranchOrTag[]>;
   /**
@@ -136,7 +180,19 @@ export interface ICodeAPIService {
   /**
    * file blame
    */
-  getFileBlame(repo: IRepositoryModel, filepath: string): Promise<Uint8Array | void>;
+  getFileBlame(repo: IRepositoryModel, filepath: string): Promise<Uint8Array>;
+  /**
+   * commits list
+   */
+  getCommits(repo: IRepositoryModel, params: CommitParams): Promise<CommitRecord[]>;
+  /**
+   * commit diff
+   */
+  getCommitDiff(repo: IRepositoryModel, sha: string): Promise<CommitFileChange[]>;
+  /**
+   * compare commit
+   */
+  getCommitCompare(repo: IRepositoryModel, from: string, to: string): Promise<CommitFileChange[]>;
 }
 
 export interface ICodeAPIServiceProvider extends ICodeAPIService {