feat: cert download

packages/core/pipeline/src/core/executor.ts

@@ -29,6 +29,7 @@ export class Executor {
   logger: Logger;
   pipelineContext!: IContext;
   lastStatusMap!: RunnableCollection;
+  lastRuntime!: RunHistory;
   options: ExecutorOptions;
   onChanged: (history: RunHistory) => void;
   constructor(options: ExecutorOptions) {
@@ -45,6 +46,7 @@ export class Executor {
 
   async init() {
     const lastRuntime = await this.pipelineContext.getObj(`lastRuntime`);
+    this.lastRuntime = lastRuntime;
     this.lastStatusMap = new RunnableCollection(lastRuntime?.pipeline);
   }
 
@@ -59,6 +61,9 @@ export class Executor {
       await this.runWithHistory(this.pipeline, "pipeline", async () => {
         await this.runStages(this.pipeline);
       });
+      if (this.lastRuntime && this.lastRuntime.pipeline.status?.status === ResultType.error) {
+        await this.notification("turnToSuccess");
+      }
       await this.notification("success");
     } catch (e) {
       await this.notification("error", e);
@@ -233,6 +238,9 @@ export class Executor {
     } else if (when === "success") {
       subject = `【CertD】执行成功，${this.pipeline.title}, buildId:${this.runtime.id}`;
       content = subject;
+    } else if (when === "turnToSuccess") {
+      subject = `【CertD】执行成功（错误转成功），${this.pipeline.title}, buildId:${this.runtime.id}`;
+      content = subject;
     } else if (when === "error") {
       subject = `【CertD】执行失败，${this.pipeline.title}, buildId:${this.runtime.id}`;
       content = `<pre>${error.message}</pre>`;

packages/core/pipeline/src/core/run-history.ts

@@ -119,25 +119,25 @@ export class RunnableCollection {
     this.collection = map;
   }
 
-  private each<T extends Runnable>(list: T[], exec: (item: Runnable) => void) {
+  static each<T extends Runnable>(list: T[], exec: (item: Runnable) => void) {
     list.forEach((item) => {
       exec(item);
       if (item.runnableType === "pipeline") {
         // @ts-ignore
-        this.each<Stage>(item.stages, exec);
+        RunnableCollection.each<Stage>(item.stages, exec);
       } else if (item.runnableType === "stage") {
         // @ts-ignore
-        this.each<Task>(item.tasks, exec);
+        RunnableCollection.each<Task>(item.tasks, exec);
       } else if (item.runnableType === "task") {
         // @ts-ignore
-        this.each<Step>(item.steps, exec);
+        RunnableCollection.each<Step>(item.steps, exec);
       }
     });
   }
-  private toMap(pipeline: Pipeline) {
+  public toMap(pipeline: Pipeline) {
     const map: RunnableMap = {};
 
-    this.each(pipeline.stages, (item) => {
+    RunnableCollection.each(pipeline.stages, (item) => {
       map[item.id] = item;
     });
     return map;
@@ -151,7 +151,7 @@ export class RunnableCollection {
     if (!this.pipeline) {
       return;
     }
-    this.each(this.pipeline.stages, (item) => {
+    RunnableCollection.each(this.pipeline.stages, (item) => {
       item.status = undefined;
     });
   }

packages/core/pipeline/src/d.ts/pipeline.ts

@@ -56,6 +56,7 @@ export type Trigger = {
 };
 
 export type FileItem = {
+  id: string;
   filename: string;
   path: string;
 };
@@ -68,13 +69,12 @@ export type Runnable = {
   default?: {
     [key: string]: any;
   };
-  files?: FileItem[];
 };
 
 export type EmailOptions = {
   receivers: string[];
 };
-export type NotificationWhen = "error" | "success" | "start";
+export type NotificationWhen = "error" | "success" | "turnToSuccess" | "start";
 export type NotificationType = "email" | "url";
 export type Notification = {
   type: NotificationType;

packages/core/pipeline/src/plugin/api.ts

@@ -6,7 +6,7 @@ import { IAccessService } from "../access";
 import { IEmailService } from "../service";
 import { IContext } from "../core";
 import { AxiosInstance } from "axios";
-
+import { v4 as uuidv4 } from "uuid";
 export enum ContextScope {
   global,
   pipeline,
@@ -81,6 +81,7 @@ export abstract class AbstractTaskPlugin implements ITaskPlugin {
   saveFile(filename: string, file: Buffer) {
     const filePath = this.ctx.fileStore.writeFile(filename, file);
     this._result.files!.push({
+      id: uuidv4(),
       filename,
       path: filePath,
     });