feat: 通过插件配置懒加载依赖，动态加载第三方依赖包，精简安装镜像大小

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

@@ -3,6 +3,7 @@ import { FormItemProps } from "../dt/index.js";
 import { HttpClient, ILogger, utils } from "@certd/basic";
 import * as _ from "lodash-es";
 import { PluginRequestHandleReq } from "../plugin/index.js";
+import { IServiceGetter } from "../service/index.js";
 
 // export type AccessRequestHandleReqInput<T = any> = {
 //   id?: number;
@@ -20,6 +21,8 @@ export type AccessInputDefine = FormItemProps & {
 export type AccessDefine = Registrable & {
   icon?: string;
   subtype?: string;
+  dependPlugins?: Record<string, string>;
+  dependPackages?: Record<string, string>;
   input?: {
     [key: string]: AccessInputDefine;
   };
@@ -39,13 +42,32 @@ export type AccessContext = {
   logger: ILogger;
   utils: typeof utils;
   accessService: IAccessService;
+  serviceGetter?: IServiceGetter;
+  define?: AccessDefine;
 };
 
 export abstract class BaseAccess implements IAccess {
   ctx!: AccessContext;
+  runtimeDepsService?: {
+    ensureRuntimeDependencies(pluginKeys: string | string[]): Promise<any>;
+    importRuntime(specifier: string): Promise<any>;
+  };
 
-  setCtx(ctx: AccessContext) {
+  async importRuntime(specifier: string) {
+    if (!this.runtimeDepsService) {
+      return await import(specifier);
+    }
+    return await this.runtimeDepsService.importRuntime(specifier);
+  }
+
+  async setCtx(ctx: AccessContext) {
     this.ctx = ctx;
+    if (!this.runtimeDepsService && this.ctx.serviceGetter) {
+      this.runtimeDepsService = await this.ctx.serviceGetter.get("runtimeDepsService");
+    }
+    if (this.runtimeDepsService && this.ctx.define?.name) {
+      await this.runtimeDepsService.ensureRuntimeDependencies(`access:${this.ctx.define.name}`);
+    }
   }
 
   async onRequest(req: AccessRequestHandleReq) {

packages/core/pipeline/src/access/decorator.ts

@@ -67,7 +67,9 @@ export async function newAccess(type: string, input: any, accessService: IAccess
       accessService,
     };
   }
-  access.setCtx(ctx);
+  ctx.define = ctx.define || register.define;
+  access.runtimeDepsService = (accessService as any).runtimeDepsService;
+  await access.setCtx(ctx);
   access._type = type;
   return access;
 }

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

@@ -387,7 +387,7 @@ export class Executor {
       }),
       serviceGetter: this.options.serviceGetter,
     };
-    instance.setCtx(taskCtx);
+    await instance.setCtx(taskCtx);
 
     await instance.onInstance();
     const result = await instance.execute();

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

@@ -3,7 +3,7 @@ import { Registrable } from "../registry/index.js";
 import { FormItemProps, HistoryResult, Pipeline } from "../dt/index.js";
 import { HttpClient, ILogger, utils } from "@certd/basic";
 import * as _ from "lodash-es";
-import { IEmailService } from "../service/index.js";
+import { IEmailService, IServiceGetter } from "../service/index.js";
 
 export type NotificationBody = {
   userId?: number;
@@ -39,6 +39,8 @@ export type NotificationInputDefine = FormItemProps & {
 };
 export type NotificationDefine = Registrable & {
   needPlus?: boolean;
+  dependPlugins?: Record<string, string>;
+  dependPackages?: Record<string, string>;
   input?: {
     [key: string]: NotificationInputDefine;
   };
@@ -78,6 +80,8 @@ export type NotificationContext = {
   logger: ILogger;
   utils: typeof utils;
   emailService: IEmailService;
+  serviceGetter?: IServiceGetter;
+  define?: NotificationDefine;
 };
 
 export abstract class BaseNotification implements INotification {
@@ -85,6 +89,17 @@ export abstract class BaseNotification implements INotification {
   ctx!: NotificationContext;
   http!: HttpClient;
   logger!: ILogger;
+  runtimeDepsService?: {
+    ensureRuntimeDependencies(pluginKeys: string | string[]): Promise<any>;
+    importRuntime(specifier: string): Promise<any>;
+  };
+
+  async importRuntime(specifier: string) {
+    if (!this.runtimeDepsService) {
+      return await import(specifier);
+    }
+    return await this.runtimeDepsService.importRuntime(specifier);
+  }
 
   async doSend(body: NotificationBody) {
     return await this.send(body);
@@ -93,10 +108,16 @@ export abstract class BaseNotification implements INotification {
 
   // eslint-disable-next-line @typescript-eslint/no-empty-function
   async onInstance() {}
-  setCtx(ctx: NotificationContext) {
+  async setCtx(ctx: NotificationContext) {
     this.ctx = ctx;
     this.http = ctx.http;
     this.logger = ctx.logger;
+    if (!this.runtimeDepsService && this.ctx.serviceGetter) {
+      this.runtimeDepsService = await this.ctx.serviceGetter.get("runtimeDepsService");
+    }
+    if (this.runtimeDepsService && this.ctx.define?.name) {
+      await this.runtimeDepsService.ensureRuntimeDependencies(`notification:${this.ctx.define.name}`);
+    }
   }
   setDefine = (define: NotificationDefine) => {
     this.define = define;

packages/core/pipeline/src/notification/decorator.ts

@@ -61,7 +61,8 @@ export async function newNotification(type: string, input: any, ctx: Notificatio
     throw new Error("ctx is required");
   }
   plugin.setDefine(register.define);
-  plugin.setCtx(ctx);
+  ctx.define = ctx.define || register.define;
+  await plugin.setCtx(ctx);
   await plugin.onInstance();
   return plugin;
 }

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

@@ -46,6 +46,8 @@ export type PluginDefine = Registrable & {
   default?: any;
   group?: string;
   icon?: string;
+  dependPlugins?: Record<string, string>;
+  dependPackages?: Record<string, string>;
   input?: {
     [key: string]: TaskInputDefine;
   };
@@ -73,6 +75,8 @@ export type ITaskPlugin = {
   onInstance(): Promise<void>;
   execute(): Promise<void | string>;
   onRequest(req: PluginRequestHandleReq<any>): Promise<any>;
+  setCtx(ctx: TaskInstanceContext): Promise<void>;
+  importRuntime?(specifier: string): Promise<any>;
   [key: string]: any;
 };
 
@@ -146,6 +150,17 @@ export abstract class AbstractTaskPlugin implements ITaskPlugin {
   logger!: ILogger;
   http!: HttpClient;
   accessService!: IAccessService;
+  runtimeDepsService?: {
+    ensureRuntimeDependencies(pluginKeys: string | string[]): Promise<any>;
+    importRuntime(specifier: string): Promise<any>;
+  };
+
+  async importRuntime(specifier: string) {
+    if (!this.runtimeDepsService) {
+      return await import(specifier);
+    }
+    return await this.runtimeDepsService.importRuntime(specifier);
+  }
 
   clearLastStatus() {
     this._result.clearLastStatus = true;
@@ -161,11 +176,17 @@ export abstract class AbstractTaskPlugin implements ITaskPlugin {
     }
   }
 
-  setCtx(ctx: TaskInstanceContext) {
+  async setCtx(ctx: TaskInstanceContext) {
     this.ctx = ctx;
     this.logger = ctx.logger;
     this.accessService = ctx.accessService;
     this.http = ctx.http;
+    if (!this.runtimeDepsService && this.ctx.serviceGetter) {
+      this.runtimeDepsService = await this.ctx.serviceGetter.get("runtimeDepsService");
+    }
+    if (this.runtimeDepsService && this.ctx.define?.name) {
+      await this.runtimeDepsService.ensureRuntimeDependencies(`plugin:${this.ctx.define.name}`);
+    }
     // 将证书加入secret
     // @ts-ignore
     if (this.cert && this.cert.crt && this.cert.key) {