refactor: pipeline edit view

packages/core/pipeline/src/access/access-service.ts

@@ -1,5 +1,5 @@
 import { AbstractAccess } from "./abstract-access";
 
 export interface IAccessService {
-  getById(id: any): AbstractAccess;
+  getById(id: any): Promise<AbstractAccess>;
 }

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

@@ -1,5 +1,6 @@
 import { Registrable } from "../registry";
 import { FormItemProps } from "@fast-crud/fast-crud";
+import { accessRegistry } from "./registry";
 
 export type AccessDefine = Registrable & {
   input: {
@@ -9,5 +10,6 @@ export type AccessDefine = Registrable & {
 export function IsAccess(define: AccessDefine) {
   return function (target: any) {
     target.prototype.define = define;
+    accessRegistry.install(target);
   };
 }

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

@@ -0,0 +1,5 @@
+import { Registry } from "../registry";
+import { AbstractAccess } from "./abstract-access";
+
+// @ts-ignore
+export const accessRegistry = new Registry<typeof AbstractAccess>();

packages/core/pipeline/src/plugin/plugins/deploy-to-cdn/index.ts

@@ -52,7 +52,7 @@ export class DeployCertToAliyunCDN extends AbstractPlugin implements TaskPlugin
 
   async execute(input: TaskInput): Promise<TaskOutput> {
     console.log("开始部署证书到阿里云cdn");
-    const access = this.accessService.getById(input.accessId) as AliyunAccess;
+    const access = (await this.accessService.getById(input.accessId)) as AliyunAccess;
     const client = this.getClient(access);
     const params = await this.buildParams(input);
     await this.doRequest(client, params);