Add get logs and get workflow run apis (#7427)

* add get logs api * remove return --------- Co-authored-by: Qi Liu <[email protected]>
Azure · Oct 11, 2023 · e9f1cb0 · e9f1cb0
1 parent 2abc336
commit e9f1cb0
Showing 1 changed file with 57 additions and 0 deletions.
diff --git a/server/src/deployment-center/github/github.controller.ts b/server/src/deployment-center/github/github.controller.ts
@@ -296,6 +296,63 @@ export class GithubController {
     await this._makeGetCallWithLinkAndOAuthHeaders(url, gitHubToken, res);
   }
 
+  @Post('api/github/getWorkflowRunLogs')
+  @HttpCode(200)
+  async getJobLogs(
+    @Body('gitHubToken') gitHubToken: string,
+    @Body('org') org: string,
+    @Body('repo') repo: string,
+    @Body('runId') runId: number,
+    @Res() res
+  ) {
+    const url = `${this.githubApiUrl}/repos/${org}/${repo}/actions/runs/${runId}/logs`;
+    try {
+      await this.httpService
+        .get(url, {
+          headers: this._getAuthorizationHeader(gitHubToken),
+          responseType: 'arraybuffer',
+        })
+        .then(response => {
+          res.json(response.data);
+        });
+    } catch (err) {
+      this.loggingService.error(`Failed to get workflow run logs.`);
+
+      if (err.response) {
+        throw new HttpException(err.response.data, err.response.status);
+      }
+      throw new HttpException(err, 500);
+    }
+  }
+
+  @Post('api/github/getWorkflowRun')
+  @HttpCode(200)
+  async getWorkflowRun(
+    @Body('gitHubToken') gitHubToken: string,
+    @Body('org') org: string,
+    @Body('repo') repo: string,
+    @Body('runId') runId: number,
+    @Res() res
+  ) {
+    const url = `${this.githubApiUrl}/repos/${org}/${repo}/actions/runs/${runId}`;
+    try {
+      await this.httpService
+        .get(url, {
+          headers: this._getAuthorizationHeader(gitHubToken),
+        })
+        .then(response => {
+          res.json(response.data);
+        });
+    } catch (err) {
+      this.loggingService.error(`Failed to get workflow run.`);
+
+      if (err.response) {
+        throw new HttpException(err.response.data, err.response.status);
+      }
+      throw new HttpException(err, 500);
+    }
+  }
+
   @Post('api/github/deleteWorkflowRun')
   @HttpCode(200)
   async deleteWorkflowRun(