v1.25.9

CHANGELOG.md

@@ -3,6 +3,37 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.25.9](https://github.com/certd/certd/compare/v1.25.8...v1.25.9) (2024-10-01)
+
+### Bug Fixes
+
+* 修复西部数码账户级别apikey不可用的bug ([f8f3e8b](https://github.com/certd/certd/commit/f8f3e8b43fd5d815887bcb53b95f46dc96424b79))
+
+### Performance Improvements
+
+* 增加等待插件 ([3ef0541](https://github.com/certd/certd/commit/3ef0541cc85ab6abf698ead3b258ae1ac156ef98))
+
+## [1.25.8](https://github.com/certd/certd/compare/v1.25.7...v1.25.8) (2024-09-30)
+
+### Bug Fixes
+
+* 修复pfxPassword无效的bug ([251e450](https://github.com/certd/certd/commit/251e450fabfe62405bac13e39f2153736c081ef0))
+
+### Performance Improvements
+
+* 群晖获取deviceid优化 ([8d42273](https://github.com/certd/certd/commit/8d4227366548eb70f6bc04303829e6933168f906))
+
+## [1.25.7](https://github.com/certd/certd/compare/v1.25.6...v1.25.7) (2024-09-29)
+
+### Bug Fixes
+
+* 修复某些地区被屏蔽无法激活专业版的bug ([7532a96](https://github.com/certd/certd/commit/7532a960851b84d4f2cc3dba02353c5235e1a364))
+
+### Performance Improvements
+
+* 上传到主机，支持socks代理 ([d91026d](https://github.com/certd/certd/commit/d91026dc4fbfe5fedc4ee8e43dc0d08f1cf88356))
+* 支持上传到七牛云oss ([bf024bd](https://github.com/certd/certd/commit/bf024bdda8bc2a463475be5761acf0da7317a08a))
+
 ## [1.25.6](https://github.com/certd/certd/compare/v1.25.5...v1.25.6) (2024-09-29)
 
 ### Bug Fixes

LICENSE.md

@@ -1,4 +1,6 @@
-# Certd Open Source License
+
+                    Certd Open Source License
+                  
 
 - This project is licensed under the **GNU Affero General Public License (AGPL)** with the following additional terms.  
 - 本项目遵循 GNU Affero General Public License（AGPL），并附加以下条款。

README.md

@@ -5,22 +5,6 @@ Certd 是一个免费全自动申请和自动部署更新SSL证书的工具。
 
 关键字：证书自动申请、证书自动更新、证书自动续期、证书自动续签
 
-************************
-支持开源，为爱发电，我已入驻爱发电   
-https://afdian.com/a/greper
-
-发电权益：
-1. 可加入发电专属群，可以获得作者一对一技术支持
-2. 您的需求我们将优先实现，并且将作为专业版功能提供
-3. 一年期专业版激活码
-4. 赠送国外免费服务器部署方案（0成本使用Certd，可能需要翻墙，不过现在性能越来越差了）
-
-专业版特权
-1. 证书流水线条数无限制（免费版限制10条）
-2. 免配置发邮件功能
-3. FTP上传、cdnfly、宝塔等部署插件
-4. 更多功能增加中...
-************************
 
 ## 一、特性
 本项目不仅支持证书申请过程自动化，还可以自动化部署更新证书，让你的证书永不过期。     
@@ -45,11 +29,11 @@ https://certd.handsfree.work/
 ## 三、使用教程
 本案例演示，如何配置自动申请证书，并部署到阿里云CDN，然后快要到期前自动更新证书并重新部署     
 
-![演示](./doc/images/5-view.png)
-![演示](./doc/images/9-start.png)
-![演示](./doc/images/10-1-log.png)
-![演示](./doc/images/13-3-download.png)
-![演示](./doc/images/13-1-result.png)
+![演示](./packages/ui/certd-client/public/doc/images/5-view.png)
+![演示](./packages/ui/certd-client/public/doc/images/9-start.png)
+![演示](./packages/ui/certd-client/public/doc/images/10-1-log.png)
+![演示](./packages/ui/certd-client/public/doc/images/13-3-download.png)
+![演示](./packages/ui/certd-client/public/doc/images/13-1-result.png)
 
 ↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓      
 -------> [点我查看详细使用步骤演示](./step.md)   <--------      
@@ -138,8 +122,10 @@ http://your_server_ip:7001
 # 克隆代码
 git clone https://github.com/certd/certd
 cd certd
+# 启动服务
 ./start.sh  
 ```
+如果是windows，请先安装`git for windows` ，然后右键，选择`open git bash here`打开终端，再执行`./start.sh`命令
 
 
 ## 五、 升级
@@ -220,16 +206,28 @@ docker compose up -d
 </p>
 
 ## 十、捐赠
+************************
 支持开源，为爱发电，我已入驻爱发电   
 https://afdian.com/a/greper
 
 发电权益：
-1. 可加入发电专属群（先加我好友，发送发电截图，我拉你进群）
-2. 你的需求优先实现
-3. 可以获得作者一对一技术支持
-4. 更多权益陆续增加中...
+1. 可加入发电专属群，可以获得作者一对一技术支持
+2. 您的需求我们将优先实现，并且将作为专业版功能提供
+3. 一年期专业版激活码
+4. 赠送国外免费服务器部署方案（0成本使用Certd，可能需要翻墙，不过现在性能越来越差了）
 
 
+专业版特权对比
+
+| 功能      | 免费版                    | 专业版                   |
+|---------|------------------------|-----------------------|
+| 免费证书申请  | 免费无限制                  | 免费无限制                 |
+| 自动部署插件  | 阿里云CDN、腾讯云、七牛CDN、主机部署等 | 支持群晖、宝塔、1Panel等，持续开发中 |
+| 发邮件功能   | 需要配置                   | 免配置                   |
+| 证书流水线条数 | 10条                    | 无限制                   |
+
+************************
+
 ## 十一、贡献代码
 
 1. 本地开发 [贡献插件教程](./doc/dev/development.md)

build.trigger

@@ -1 +1 @@
-14:27
+18:06

lerna.json

@@ -9,5 +9,5 @@
     }
   },
   "npmClient": "pnpm",
-  "version": "1.25.6"
+  "version": "1.25.9"
 }

package.json

@@ -12,11 +12,13 @@
   "scripts": {
     "start": "lerna bootstrap --hoist",
     "i-all": "lerna link && lerna exec npm install  ",
-    "publish": "npm run prepublishOnly2  && lerna publish --conventional-commits --create-release github && npm run afterpublishOnly",
+    "publish": "npm run prepublishOnly2  && lerna publish --force-publish=pro/plus-core --conventional-commits --create-release github && npm run afterpublishOnly && npm run commitAll",
     "afterpublishOnly": "time /t >build.trigger && git add ./build.trigger && git commit -m \"build: trigger build image\" && TIMEOUT /T 10 && git push",
+    "commitAll" : "git add . && git commit -m \"build: publish\" && git push && npm run commitPro",
+    "commitPro" : "cd ./packages/core/ && git add . && git commit -m \"build: publish\" && git push",
     "prepublishOnly1": "npm run check && lerna run build ",
     "prepublishOnly2": "npm run check && npm run before-build && lerna run build ",
-    "before-build": "cd ./packages/pro/plus-core && time /t >build.md && git add ./build.md && git commit -m \"build: prepare to build\"",
+    "before-build": "cd ./packages/core/basic && time /t >build.md && git add ./build.md && git commit -m \"build: prepare to build\"",
     "deploy1": "node --experimental-json-modules deploy.js ",
     "check": "node --experimental-json-modules publish-check.js",
     "init": "lerna run build"

packages/core/acme-client/CHANGELOG.md

@@ -3,6 +3,18 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.25.9](https://github.com/publishlab/node-acme-client/compare/v1.25.8...v1.25.9) (2024-10-01)
+
+**Note:** Version bump only for package @certd/acme-client
+
+## [1.25.8](https://github.com/publishlab/node-acme-client/compare/v1.25.7...v1.25.8) (2024-09-30)
+
+**Note:** Version bump only for package @certd/acme-client
+
+## [1.25.7](https://github.com/publishlab/node-acme-client/compare/v1.25.6...v1.25.7) (2024-09-29)
+
+**Note:** Version bump only for package @certd/acme-client
+
 ## [1.25.6](https://github.com/publishlab/node-acme-client/compare/v1.25.5...v1.25.6) (2024-09-29)
 
 ### Performance Improvements

packages/core/acme-client/package.json

@@ -3,7 +3,7 @@
     "description": "Simple and unopinionated ACME client",
     "private": false,
     "author": "nmorsman",
-    "version": "1.25.6",
+    "version": "1.25.9",
     "main": "src/index.js",
     "types": "types/index.d.ts",
     "license": "MIT",
@@ -59,5 +59,5 @@
     "bugs": {
         "url": "https://github.com/publishlab/node-acme-client/issues"
     },
-    "gitHead": "be13390b3a9177c9d99f1efabfc285d0c377b013"
+    "gitHead": "f548fe70117c7b56f40c66a3021e63b6cb264fb3"
 }

packages/core/basic/CHANGELOG.md

@@ -0,0 +1,10 @@
+# Change Log
+
+All notable changes to this project will be documented in this file.
+See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
+
+## [1.25.9](https://github.com/certd/certd/compare/v1.25.8...v1.25.9) (2024-10-01)
+
+### Bug Fixes
+
+* 修复西部数码账户级别apikey不可用的bug ([f8f3e8b](https://github.com/certd/certd/commit/f8f3e8b43fd5d815887bcb53b95f46dc96424b79))

packages/core/basic/build.md

@@ -0,0 +1 @@
+02:02

packages/core/basic/package.json

@@ -0,0 +1,11 @@
+{
+  "name": "@certd/basic",
+  "version": "1.25.9",
+  "main": "src/index.js",
+  "scripts": {
+    "build": "echo 'basic'"
+  },
+  "author": "",
+  "license": "MIT",
+  "description": ""
+}

packages/core/pipeline/CHANGELOG.md

@@ -3,6 +3,20 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.25.9](https://github.com/certd/certd/compare/v1.25.8...v1.25.9) (2024-10-01)
+
+**Note:** Version bump only for package @certd/pipeline
+
+## [1.25.8](https://github.com/certd/certd/compare/v1.25.7...v1.25.8) (2024-09-30)
+
+**Note:** Version bump only for package @certd/pipeline
+
+## [1.25.7](https://github.com/certd/certd/compare/v1.25.6...v1.25.7) (2024-09-29)
+
+### Bug Fixes
+
+* 修复某些地区被屏蔽无法激活专业版的bug ([7532a96](https://github.com/certd/certd/commit/7532a960851b84d4f2cc3dba02353c5235e1a364))
+
 ## [1.25.6](https://github.com/certd/certd/compare/v1.25.5...v1.25.6) (2024-09-29)
 
 ### Performance Improvements

packages/core/pipeline/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@certd/pipeline",
   "private": false,
-  "version": "1.25.6",
+  "version": "1.25.9",
   "type": "module",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -15,7 +15,8 @@
     "test": "mocha   --loader=ts-node/esm"
   },
   "dependencies": {
-    "@certd/plus-core": "^1.25.4",
+    "@certd/basic": "^1.25.9",
+    "@certd/plus-core": "^1.25.9",
     "axios": "^1.7.2",
     "fix-path": "^4.0.0",
     "http-proxy-agent": "^7.0.2",
@@ -63,5 +64,5 @@
     "vite": "^4.3.8",
     "vue-tsc": "^1.6.5"
   },
-  "gitHead": "be13390b3a9177c9d99f1efabfc285d0c377b013"
+  "gitHead": "f548fe70117c7b56f40c66a3021e63b6cb264fb3"
 }

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

@@ -1,5 +1,8 @@
 import { Registrable } from "../registry/index.js";
 import { FormItemProps } from "../dt/index.js";
+import { HttpClient, ILogger, utils } from "../utils/index.js";
+import _ from "lodash-es";
+import { AccessRequestHandleReq } from "../core";
 
 export type AccessInputDefine = FormItemProps & {
   title: string;
@@ -15,5 +18,36 @@ export interface IAccessService {
   getById<T = any>(id: any): Promise<T>;
 }
 
-// eslint-disable-next-line @typescript-eslint/no-empty-interface
-export interface IAccess {}
+export interface IAccess {
+  ctx: AccessContext;
+  [key: string]: any;
+}
+
+export type AccessContext = {
+  http: HttpClient;
+  logger: ILogger;
+  utils: typeof utils;
+};
+
+export abstract class BaseAccess implements IAccess {
+  ctx!: AccessContext;
+
+  async onRequest(req: AccessRequestHandleReq) {
+    if (!req.action) {
+      throw new Error("action is required");
+    }
+
+    let methodName = req.action;
+    if (!req.action.startsWith("on")) {
+      methodName = `on${_.upperFirst(req.action)}`;
+    }
+
+    // @ts-ignore
+    const method = this[methodName];
+    if (method) {
+      // @ts-ignore
+      return await this[methodName](req.data);
+    }
+    throw new Error(`action ${req.action} not found`);
+  }
+}

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

@@ -1,8 +1,9 @@
 // src/decorator/memoryCache.decorator.ts
-import { AccessDefine, AccessInputDefine } from "./api.js";
+import { AccessContext, AccessDefine, AccessInputDefine } from "./api.js";
 import { Decorator } from "../decorator/index.js";
 import _ from "lodash-es";
 import { accessRegistry } from "./registry.js";
+import { http, logger, utils } from "../utils/index.js";
 
 // 提供一个唯一 key
 export const ACCESS_CLASS_KEY = "pipeline:access";
@@ -37,3 +38,24 @@ export function AccessInput(input?: AccessInputDefine): PropertyDecorator {
     Reflect.defineMetadata(ACCESS_INPUT_KEY, input, target, propertyKey);
   };
 }
+
+export function newAccess(type: string, input: any, ctx?: AccessContext) {
+  const register = accessRegistry.get(type);
+  if (register == null) {
+    throw new Error(`access ${type} not found`);
+  }
+  // @ts-ignore
+  const access = new register.target();
+  for (const key in input) {
+    access[key] = input[key];
+  }
+  if (!ctx) {
+    ctx = {
+      http,
+      logger,
+      utils,
+    };
+  }
+  access.ctx = ctx;
+  return access;
+}

packages/core/pipeline/src/core/handler.ts

@@ -1,5 +1,4 @@
-import _ from "lodash-es";
-import { HttpClient, ILogger, utils } from "../utils";
+import { HttpClient, ILogger, utils } from "../utils/index.js";
 
 export type PluginRequestHandleReq<T = any> = {
   typeName: string;
@@ -13,29 +12,10 @@ export type AccessRequestHandleReqInput<T = any> = {
   title?: string;
   access: T;
 };
-export type AccessRequestHandleReq<T = any> = PluginRequestHandleReq<AccessRequestHandleReqInput<T>>;
-
 export type AccessRequestHandleContext = {
   http: HttpClient;
   logger: ILogger;
   utils: typeof utils;
 };
 
-export class AccessRequestHandler<T = any> {
-  async onRequest(req: AccessRequestHandleReq<T>, ctx: AccessRequestHandleContext) {
-    if (!req.action) {
-      throw new Error("action is required");
-    }
-
-    const methodName = `on${_.upperFirst(req.action)}`;
-
-    // @ts-ignore
-    const method = this[methodName];
-    if (method) {
-      // @ts-ignore
-      return await this[methodName](req.data, ctx);
-    }
-    throw new Error(`action ${req.action} not found`);
-  }
-}
-
+export type AccessRequestHandleReq<T = any> = PluginRequestHandleReq<AccessRequestHandleReqInput<T>>;

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

@@ -4,9 +4,9 @@ import { FileStore } from "../core/file-store.js";
 import { Logger } from "log4js";
 import { IAccessService } from "../access/index.js";
 import { IEmailService } from "../service/index.js";
-import { IContext, PluginRequestHandleReq } from "../core/index.js";
+import { IContext, PluginRequestHandleReq, RunnableCollection } from "../core/index.js";
 import { ILogger, logger, utils } from "../utils/index.js";
-import { HttpClient } from "../utils/util.request";
+import { HttpClient } from "../utils/util.request.js";
 import dayjs from "dayjs";
 import _ from "lodash-es";
 export type UserInfo = {
@@ -165,7 +165,10 @@ export abstract class AbstractTaskPlugin implements ITaskPlugin {
       throw new Error("action is required");
     }
 
-    const methodName = `on${_.upperFirst(req.action)}`;
+    let methodName = req.action;
+    if (!req.action.startsWith("on")) {
+      methodName = `on${_.upperFirst(req.action)}`;
+    }
 
     // @ts-ignore
     const method = this[methodName];
@@ -179,6 +182,21 @@ export abstract class AbstractTaskPlugin implements ITaskPlugin {
   isAdmin() {
     return this.ctx.user.role === "admin";
   }
+
+  getStepFromPipeline(stepId: string) {
+    let found: any = null;
+    RunnableCollection.each(this.ctx.pipeline.stages, (step) => {
+      if (step.id === stepId) {
+        found = step;
+        return;
+      }
+    });
+    return found;
+  }
+
+  getStepIdFromRefInput(ref = ".") {
+    return ref.split(".")[1];
+  }
 }
 
 export type OutputVO = {

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

@@ -5,6 +5,7 @@ export type Registrable = {
   title: string;
   desc?: string;
   group?: string;
+  deprecated?: string;
 };
 
 export type RegistryItem<T> = {
@@ -67,6 +68,9 @@ export class Registry<T> {
     for (const key in this.storage) {
       const define = this.getDefine(key);
       if (define) {
+        if (define?.deprecated) {
+          continue;
+        }
         list.push({ ...define, key });
       }
     }

packages/core/pipeline/src/utils/util.request.ts

@@ -8,7 +8,7 @@ export class HttpError extends Error {
   status?: number;
   statusText?: string;
   code?: string;
-  request?: { url: string; method: string; params?: any; data?: any };
+  request?: { baseURL: string; url: string; method: string; params?: any; data?: any };
   response?: { data: any };
   cause?: any;
   constructor(error: any) {
@@ -23,6 +23,7 @@ export class HttpError extends Error {
     this.status = error.response?.status;
     this.statusText = error.response?.statusText;
     this.request = {
+      baseURL: error.config?.baseURL,
       url: error.config?.url,
       method: error.config?.method,
       params: error.config?.params,
@@ -138,6 +139,7 @@ export const http = createAxiosService({ logger }) as HttpClient;
 export type HttpClientResponse<R> = any;
 export type HttpRequestConfig<D> = {
   skipSslVerify?: boolean;
+  skipCheckRes?: boolean;
 } & AxiosRequestConfig<D>;
 export type HttpClient = {
   request<D = any, R = any>(config: HttpRequestConfig<D>): Promise<HttpClientResponse<R>>;

packages/libs/lib-huawei/CHANGELOG.md

@@ -3,6 +3,18 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.25.9](https://github.com/certd/certd/compare/v1.25.8...v1.25.9) (2024-10-01)
+
+**Note:** Version bump only for package @certd/lib-huawei
+
+## [1.25.8](https://github.com/certd/certd/compare/v1.25.7...v1.25.8) (2024-09-30)
+
+**Note:** Version bump only for package @certd/lib-huawei
+
+## [1.25.7](https://github.com/certd/certd/compare/v1.25.6...v1.25.7) (2024-09-29)
+
+**Note:** Version bump only for package @certd/lib-huawei
+
 ## [1.25.6](https://github.com/certd/certd/compare/v1.25.5...v1.25.6) (2024-09-29)
 
 **Note:** Version bump only for package @certd/lib-huawei

packages/libs/lib-huawei/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@certd/lib-huawei",
   "private": false,
-  "version": "1.25.6",
+  "version": "1.25.9",
   "main": "./dist/bundle.js",
   "module": "./dist/bundle.js",
   "types": "./dist/d/index.d.ts",
@@ -17,5 +17,5 @@
     "rimraf": "^5.0.5",
     "rollup": "^3.7.4"
   },
-  "gitHead": "be13390b3a9177c9d99f1efabfc285d0c377b013"
+  "gitHead": "f548fe70117c7b56f40c66a3021e63b6cb264fb3"
 }

packages/libs/lib-iframe/CHANGELOG.md

@@ -3,6 +3,18 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.25.9](https://github.com/certd/certd/compare/v1.25.8...v1.25.9) (2024-10-01)
+
+**Note:** Version bump only for package @certd/lib-iframe
+
+## [1.25.8](https://github.com/certd/certd/compare/v1.25.7...v1.25.8) (2024-09-30)
+
+**Note:** Version bump only for package @certd/lib-iframe
+
+## [1.25.7](https://github.com/certd/certd/compare/v1.25.6...v1.25.7) (2024-09-29)
+
+**Note:** Version bump only for package @certd/lib-iframe
+
 ## [1.25.6](https://github.com/certd/certd/compare/v1.25.5...v1.25.6) (2024-09-29)
 
 ### Performance Improvements

packages/libs/lib-iframe/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@certd/lib-iframe",
   "private": false,
-  "version": "1.25.6",
+  "version": "1.25.9",
   "type": "module",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -38,5 +38,5 @@
     "tslib": "^2.5.2",
     "typescript": "^5.4.2"
   },
-  "gitHead": "be13390b3a9177c9d99f1efabfc285d0c377b013"
+  "gitHead": "f548fe70117c7b56f40c66a3021e63b6cb264fb3"
 }

packages/libs/lib-jdcloud/CHANGELOG.md

@@ -3,6 +3,18 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.25.9](https://github.com/certd/certd/compare/v1.25.8...v1.25.9) (2024-10-01)
+
+**Note:** Version bump only for package @certd/lib-jdcloud
+
+## [1.25.8](https://github.com/certd/certd/compare/v1.25.7...v1.25.8) (2024-09-30)
+
+**Note:** Version bump only for package @certd/lib-jdcloud
+
+## [1.25.7](https://github.com/certd/certd/compare/v1.25.6...v1.25.7) (2024-09-29)
+
+**Note:** Version bump only for package @certd/lib-jdcloud
+
 ## [1.25.6](https://github.com/certd/certd/compare/v1.25.5...v1.25.6) (2024-09-29)
 
 **Note:** Version bump only for package @certd/lib-jdcloud

packages/libs/lib-jdcloud/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@certd/lib-jdcloud",
   "private": false,
-  "version": "1.25.6",
+  "version": "1.25.9",
   "main": "./dist/bundle.mjs",
   "module": "./dist/bundle.mjs",
   "types": "./dist/d/index.d.ts",
@@ -27,5 +27,5 @@
     "rimraf": "^5.0.5",
     "rollup": "^3.7.4"
   },
-  "gitHead": "be13390b3a9177c9d99f1efabfc285d0c377b013"
+  "gitHead": "f548fe70117c7b56f40c66a3021e63b6cb264fb3"
 }

packages/libs/lib-k8s/CHANGELOG.md

@@ -3,6 +3,18 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.25.9](https://github.com/certd/certd/compare/v1.25.8...v1.25.9) (2024-10-01)
+
+**Note:** Version bump only for package @certd/lib-k8s
+
+## [1.25.8](https://github.com/certd/certd/compare/v1.25.7...v1.25.8) (2024-09-30)
+
+**Note:** Version bump only for package @certd/lib-k8s
+
+## [1.25.7](https://github.com/certd/certd/compare/v1.25.6...v1.25.7) (2024-09-29)
+
+**Note:** Version bump only for package @certd/lib-k8s
+
 ## [1.25.6](https://github.com/certd/certd/compare/v1.25.5...v1.25.6) (2024-09-29)
 
 ### Performance Improvements

packages/libs/lib-k8s/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@certd/lib-k8s",
   "private": false,
-  "version": "1.25.6",
+  "version": "1.25.9",
   "type": "module",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -17,7 +17,7 @@
     "@kubernetes/client-node": "0.21.0"
   },
   "devDependencies": {
-    "@certd/pipeline": "^1.25.6",
+    "@certd/pipeline": "^1.25.9",
     "@rollup/plugin-commonjs": "^23.0.4",
     "@rollup/plugin-json": "^6.0.0",
     "@rollup/plugin-node-resolve": "^15.0.1",
@@ -39,5 +39,5 @@
     "tslib": "^2.5.2",
     "typescript": "^5.4.2"
   },
-  "gitHead": "be13390b3a9177c9d99f1efabfc285d0c377b013"
+  "gitHead": "f548fe70117c7b56f40c66a3021e63b6cb264fb3"
 }

packages/libs/midway-flyway-js/CHANGELOG.md

@@ -3,6 +3,18 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.25.9](https://github.com/certd/certd/compare/v1.25.8...v1.25.9) (2024-10-01)
+
+**Note:** Version bump only for package @certd/midway-flyway-js
+
+## [1.25.8](https://github.com/certd/certd/compare/v1.25.7...v1.25.8) (2024-09-30)
+
+**Note:** Version bump only for package @certd/midway-flyway-js
+
+## [1.25.7](https://github.com/certd/certd/compare/v1.25.6...v1.25.7) (2024-09-29)
+
+**Note:** Version bump only for package @certd/midway-flyway-js
+
 ## [1.25.6](https://github.com/certd/certd/compare/v1.25.5...v1.25.6) (2024-09-29)
 
 ### Performance Improvements

packages/libs/midway-flyway-js/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@certd/midway-flyway-js",
-  "version": "1.25.6",
+  "version": "1.25.9",
   "description": "midway with flyway, sql upgrade way ",
   "private": false,
   "type": "module",
@@ -55,5 +55,5 @@
     "typeorm": "^0.3.11",
     "typescript": "^5.4.2"
   },
-  "gitHead": "be13390b3a9177c9d99f1efabfc285d0c377b013"
+  "gitHead": "f548fe70117c7b56f40c66a3021e63b6cb264fb3"
 }

packages/plugins/plugin-cert/CHANGELOG.md

@@ -3,6 +3,22 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.25.9](https://github.com/certd/certd/compare/v1.25.8...v1.25.9) (2024-10-01)
+
+### Bug Fixes
+
+* 修复西部数码账户级别apikey不可用的bug ([f8f3e8b](https://github.com/certd/certd/commit/f8f3e8b43fd5d815887bcb53b95f46dc96424b79))
+
+## [1.25.8](https://github.com/certd/certd/compare/v1.25.7...v1.25.8) (2024-09-30)
+
+### Bug Fixes
+
+* 修复pfxPassword无效的bug ([251e450](https://github.com/certd/certd/commit/251e450fabfe62405bac13e39f2153736c081ef0))
+
+## [1.25.7](https://github.com/certd/certd/compare/v1.25.6...v1.25.7) (2024-09-29)
+
+**Note:** Version bump only for package @certd/plugin-cert
+
 ## [1.25.6](https://github.com/certd/certd/compare/v1.25.5...v1.25.6) (2024-09-29)
 
 ### Performance Improvements

packages/plugins/plugin-cert/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@certd/plugin-cert",
   "private": false,
-  "version": "1.25.6",
+  "version": "1.25.9",
   "type": "module",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -14,8 +14,9 @@
     "preview": "vite preview"
   },
   "dependencies": {
-    "@certd/acme-client": "^1.25.6",
-    "@certd/pipeline": "^1.25.6",
+    "@certd/acme-client": "^1.25.9",
+    "@certd/pipeline": "^1.25.9",
+    "dayjs": "^1.11.7",
     "jszip": "^3.10.1",
     "node-forge": "^0.10.0",
     "psl": "^1.9.0",
@@ -37,7 +38,6 @@
     "@typescript-eslint/eslint-plugin": "^5.38.1",
     "@typescript-eslint/parser": "^5.38.1",
     "chai": "^4.3.6",
-    "dayjs": "^1.11.6",
     "eslint": "^8.24.0",
     "eslint-config-prettier": "^8.5.0",
     "eslint-plugin-import": "^2.26.0",
@@ -55,5 +55,5 @@
     "vite": "^3.1.0",
     "vue-tsc": "^0.38.9"
   },
-  "gitHead": "be13390b3a9177c9d99f1efabfc285d0c377b013"
+  "gitHead": "f548fe70117c7b56f40c66a3021e63b6cb264fb3"
 }

packages/plugins/plugin-cert/src/access/eab-access.ts

@@ -1,11 +1,11 @@
-import { IsAccess, AccessInput } from "@certd/pipeline";
+import { IsAccess, AccessInput, BaseAccess } from "@certd/pipeline";
 
 @IsAccess({
   name: "eab",
   title: "EAB授权",
   desc: "ZeroSSL证书申请需要EAB授权",
 })
-export class EabAccess {
+export class EabAccess extends BaseAccess {
   @AccessInput({
     title: "KID",
     component: {

packages/plugins/plugin-cert/src/dns-provider/api.ts

@@ -1,4 +1,4 @@
-import { HttpClient, IAccess, ILogger, Registrable } from "@certd/pipeline";
+import { HttpClient, IAccess, ILogger, Registrable, utils } from "@certd/pipeline";
 
 export type DnsProviderDefine = Registrable & {
   accessType: string;
@@ -22,6 +22,7 @@ export type DnsProviderContext = {
   access: IAccess;
   logger: ILogger;
   http: HttpClient;
+  utils: typeof utils;
 };
 
 export interface IDnsProvider<T = any> {

packages/plugins/plugin-cert/src/plugin/cert-plugin/cert-reader.ts

@@ -65,6 +65,13 @@ export class CertReader {
     return { detail, expires };
   }
 
+  getAllDomains() {
+    const { detail } = this.getCrtDetail();
+    const domains = [detail.domains.commonName];
+    domains.push(...detail.domains.altNames);
+    return domains;
+  }
+
   saveToFile(type: "crt" | "key" | "pfx" | "der" | "ic", filepath?: string) {
     if (!this.cert[type]) {
       return;

packages/plugins/plugin-cert/src/plugin/cert-plugin/convert.ts

@@ -21,12 +21,12 @@ export class CertConverter {
     const certReader = new CertReader(opts.cert);
     let pfxPath: string;
     let derPath: string;
-    const handle = async (opts: CertReaderHandleContext) => {
+    const handle = async (ctx: CertReaderHandleContext) => {
       // 调用openssl 转pfx
-      pfxPath = await this.convertPfx(opts);
+      pfxPath = await this.convertPfx(ctx, opts.pfxPassword);
 
       // 转der
-      derPath = await this.convertDer(opts);
+      derPath = await this.convertDer(ctx);
     };
 
     await certReader.readCertFile({ logger: this.logger, handle });
@@ -44,7 +44,7 @@ export class CertConverter {
     });
   }
 
-  private async convertPfx(opts: CertReaderHandleContext, pfxPassword?: string) {
+  private async convertPfx(opts: CertReaderHandleContext, pfxPassword: string) {
     const { tmpCrtPath, tmpKeyPath } = opts;
 
     const pfxPath = path.join(os.tmpdir(), "/certd/tmp/", Math.floor(Math.random() * 1000000) + "", "cert.pfx");

packages/plugins/plugin-cert/src/plugin/cert-plugin/index.ts

@@ -1,4 +1,4 @@
-import { Decorator, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput } from "@certd/pipeline";
+import { Decorator, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput, utils } from "@certd/pipeline";
 import type { CertInfo, PrivateKeyType, SSLProvider } from "./acme.js";
 import { AcmeService } from "./acme.js";
 import _ from "lodash-es";
@@ -174,11 +174,14 @@ export class CertApplyPlugin extends CertApplyBasePlugin {
     const dnsProviderPlugin = dnsProviderRegistry.get(dnsProviderType);
     const DnsProviderClass = dnsProviderPlugin.target;
     const dnsProviderDefine = dnsProviderPlugin.define as DnsProviderDefine;
+    if (dnsProviderDefine.deprecated) {
+      throw new Error(dnsProviderDefine.deprecated);
+    }
     const access = await this.accessService.getById(dnsProviderAccessId);
 
     // @ts-ignore
     const dnsProvider: IDnsProvider = new DnsProviderClass();
-    const context: DnsProviderContext = { access, logger: this.logger, http: this.http };
+    const context: DnsProviderContext = { access, logger: this.logger, http: this.http, utils };
     Decorator.inject(dnsProviderDefine.autowire, dnsProvider, context);
     dnsProvider.setCtx(context);
     await dnsProvider.onInstance();

packages/ui/certd-client/CHANGELOG.md

@@ -3,6 +3,22 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.25.9](https://github.com/certd/certd/compare/v1.25.8...v1.25.9) (2024-10-01)
+
+### Bug Fixes
+
+* 修复西部数码账户级别apikey不可用的bug ([f8f3e8b](https://github.com/certd/certd/commit/f8f3e8b43fd5d815887bcb53b95f46dc96424b79))
+
+## [1.25.8](https://github.com/certd/certd/compare/v1.25.7...v1.25.8) (2024-09-30)
+
+### Performance Improvements
+
+* 群晖获取deviceid优化 ([8d42273](https://github.com/certd/certd/commit/8d4227366548eb70f6bc04303829e6933168f906))
+
+## [1.25.7](https://github.com/certd/certd/compare/v1.25.6...v1.25.7) (2024-09-29)
+
+**Note:** Version bump only for package @certd/ui-client
+
 ## [1.25.6](https://github.com/certd/certd/compare/v1.25.5...v1.25.6) (2024-09-29)
 
 ### Performance Improvements

packages/ui/certd-client/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@certd/ui-client",
-  "version": "1.25.6",
+  "version": "1.25.9",
   "private": true,
   "scripts": {
     "dev": "vite --open",
@@ -58,8 +58,8 @@
     "vuedraggable": "^4.1.0"
   },
   "devDependencies": {
-    "@certd/lib-iframe": "^1.25.6",
-    "@certd/pipeline": "^1.25.6",
+    "@certd/lib-iframe": "^1.25.9",
+    "@certd/pipeline": "^1.25.9",
     "@rollup/plugin-commonjs": "^25.0.7",
     "@rollup/plugin-node-resolve": "^15.2.3",
     "@types/chai": "^4.3.12",

packages/ui/certd-client/src/components/index.ts

@@ -9,7 +9,7 @@ import CronEditor from "./cron-editor/index.vue";
 import { CronLight } from "@vue-js-cron/light";
 import "@vue-js-cron/light/dist/light.css";
 import Plugins from "./plugins/index";
-import TutorialButton from "./tutorial/index.vue";
+
 export default {
   install(app: any) {
     app.component("PiContainer", PiContainer);
@@ -25,8 +25,6 @@ export default {
     app.component("InfoCircleOutlined", InfoCircleOutlined);
     app.component("UndoOutlined", UndoOutlined);
 
-    app.component("TutorialButton", TutorialButton);
-
     app.use(vip);
     app.use(Plugins);
   }

packages/ui/certd-client/src/components/plugins/common/cert-domains-getter.vue

@@ -0,0 +1,61 @@
+<script setup lang="ts">
+import { inject, ref, watch } from "vue";
+
+const props = defineProps<{
+  inputKey?: string;
+  modelValue?: string[];
+}>();
+
+const emit = defineEmits<{
+  "update:modelValue": any;
+}>();
+
+const pipeline: any = inject("pipeline");
+
+function findStepFromPipeline(targetStepId: string) {
+  for (const stage of pipeline.value.stages) {
+    for (const task of stage.tasks) {
+      for (const step of task.steps) {
+        if (step.id === targetStepId) {
+          return step;
+        }
+      }
+    }
+  }
+}
+
+const errorRef = ref("");
+function getDomainFromPipeline(inputKey: string) {
+  if (!inputKey) {
+    errorRef.value = "请先选择域名证书";
+    return;
+  }
+  const targetStepId = inputKey.split(".")[1];
+  const certStep = findStepFromPipeline(targetStepId);
+  if (!certStep) {
+    errorRef.value = "找不到目标步骤，请先选择域名证书";
+    return;
+  }
+  const domain = certStep.input["domains"];
+  emit("update:modelValue", domain);
+}
+
+watch(
+  () => {
+    return props.inputKey;
+  },
+  (inputKey: string) => {
+    getDomainFromPipeline(inputKey);
+  },
+  {
+    immediate: true
+  }
+);
+</script>
+
+<template>
+  <a-select mode="tags" readonly :value="modelValue" />
+  <div>{{ errorRef }}</div>
+</template>
+
+<style lang="less"></style>

packages/ui/certd-client/src/components/plugins/common/remote-select.vue

@@ -22,6 +22,19 @@ const getOptions = async () => {
   });
 };
 
+const filterOption = (input: string, option: any) => {
+  return option.label.toLowerCase().indexOf(input.toLowerCase()) >= 0 || String(option.value).toLowerCase().indexOf(input.toLowerCase());
+};
+
+let isFirst = true;
+async function onClick() {
+  if (!isFirst) {
+    return;
+  }
+  isFirst = false;
+  optionsRef.value = await getOptions();
+}
+
 watch(
   () => {
     const values = [];
@@ -35,13 +48,20 @@ watch(
   },
   async () => {
     optionsRef.value = await getOptions();
-  },
-  { immediate: true }
+  }
 );
 </script>
 
 <template>
-  <a-select class="remote-select" :options="optionsRef" :value="value" @update:value="emit('update:value', $event)" />
+  <a-select
+    class="remote-select"
+    show-search
+    :filter-option="filterOption"
+    :options="optionsRef"
+    :value="value"
+    @click="onClick"
+    @update:value="emit('update:value', $event)"
+  />
 </template>
 
 <style lang="less"></style>

packages/ui/certd-client/src/components/plugins/index.ts

@@ -1,8 +1,10 @@
 import SynologyIdDeviceGetter from "./synology/device-id-getter.vue";
 import RemoteSelect from "./common/remote-select.vue";
+import CertDomainsGetter from "./common/cert-domains-getter.vue";
 export default {
   install(app: any) {
     app.component("SynologyDeviceIdGetter", SynologyIdDeviceGetter);
     app.component("RemoteSelect", RemoteSelect);
+    app.component("CertDomainsGetter", CertDomainsGetter);
   }
 };

packages/ui/certd-client/src/components/plugins/lib/index.ts

@@ -7,10 +7,10 @@ export type ComponentPropsType = {
   value?: any;
 };
 export type RequestHandleReq<T = any> = {
-  type: strin;
+  type: string;
   typeName: string;
   action: string;
-  data: any;
+  data?: any;
   input: T;
 };
 

packages/ui/certd-client/src/components/plugins/synology/device-id-getter.vue

@@ -32,7 +32,7 @@ async function loginWithOTPCode(otpCode: string) {
     data: {
       otpCode
     },
-    form: props.form
+    input: props.form
   });
 }
 
@@ -42,6 +42,7 @@ async function getDeviceId() {
 
   modal.confirm({
     title: "请输入OTP验证码",
+    maskClosable: true,
     content: () => {
       return (
         <a-form-item-rest>

packages/ui/certd-client/src/components/tutorial/index.vue

@@ -30,8 +30,9 @@ function next() {
 
 <style lang="less">
 .tutorial-modal {
+  top: 50px;
   .ant-modal-body {
-    height: 70vh;
+    height: 80vh;
   }
 }
 </style>

packages/ui/certd-client/src/components/tutorial/tutorial-steps.vue

@@ -11,7 +11,7 @@
       </div>
 
       <div class="image-box">
-        <a-image :src="currentStepItem.image" />
+        <a-image :src="currentStepItem.image" :preview-mask="previewMask" />
       </div>
     </div>
 
@@ -22,7 +22,7 @@
   </div>
 </template>
 
-<script setup lang="ts">
+<script setup lang="tsx">
 type Step = {
   title: string;
   subTitle?: string;
@@ -256,19 +256,26 @@ function stepChanged(index: number) {
   current.value = index;
   currentItem.value = 0;
 }
+function previewMask() {
+  return (
+    <div title="点击放大" class="h-100 w-100">
+      {" "}
+    </div>
+  );
+}
 </script>
 
 <style lang="less">
 .tutorial-steps {
   .step-item {
     display: flex !important;
-    flex-direction: column;
+    flex-direction: row;
     align-items: center;
     justify-content: center;
     flex: 1;
     padding: 20px;
     .text {
-      width: 100%;
+      width: 350px;
       display: flex;
       flex-direction: column;
       align-items: center;
@@ -285,10 +292,20 @@ function stepChanged(index: number) {
       background: #eee;
       width: 100%;
       height: 100%;
-      img {
-        height: 100%;
+      .ant-image-mask {
+        background: rgba(255, 255, 255, 0);
+      }
+      .ant-image {
         width: 100%;
-        object-fit: contain;
+        height: 100%;
+        display: flex;
+        justify-content: center;
+        align-items: center;
+        img {
+          width: 100%;
+          height: 100%;
+          object-fit: contain;
+        }
       }
     }
     .desc {

packages/ui/certd-client/src/components/vip-button/index.vue

@@ -135,6 +135,7 @@ function openUpgrade() {
     async onOk() {
       return await doActive();
     },
+    maskClosable: true,
     okText: "激活",
     width: 500,
     content: () => {

packages/ui/certd-client/src/layout/layout-framework.vue

@@ -18,8 +18,8 @@
             <MenuFoldOutlined v-else />
           </div>
           <fs-menu class="header-menu" mode="horizontal" :expand-selected="false" :selectable="false" :menus="frameworkMenus" />
-          <vip-button class="flex-center header-btn" mode="nav" />
           <tutorial-button class="flex-center header-btn" />
+          <vip-button class="flex-center header-btn" mode="nav" />
         </div>
         <div class="header-right header-buttons">
           <!--          <button-->
@@ -85,12 +85,12 @@ import FsThemeSet from "/@/layout/components/theme/index.vue";
 import { env } from "../utils/util.env";
 import FsThemeModeSet from "./components/theme/mode-set.vue";
 import VipButton from "/@/components/vip-button/index.vue";
-import TutorialSteps from "/@/components/tutorial/tutorial-steps.vue";
+import TutorialButton from "/@/components/tutorial/index.vue";
 export default {
   name: "LayoutFramework",
   // eslint-disable-next-line vue/no-unused-components
   components: {
-    TutorialSteps,
+    TutorialButton,
     FsThemeSet,
     MenuFoldOutlined,
     MenuUnfoldOutlined,

packages/ui/certd-client/src/plugin/fast-crud/index.tsx

@@ -68,6 +68,9 @@ function install(app: App, options: any = {}) {
           },
           conditionalRender: {
             match(scope) {
+              if (scope.key === "__blank__") {
+                return false;
+              }
               //不能用 !scope.value ， 否则switch组件设置为关之后就消失了
               const { value, key, props } = scope;
               return !value && key != "_index" && value != false;
@@ -147,17 +150,18 @@ function install(app: App, options: any = {}) {
           }
         },
         columns: {
-          // createdAt: {
-          //   title: "创建时间",
-          //   type: "datetime",
-          //   form: {
-          //     show: false
-          //   },
-          //   column: {
-          //     show: false,
-          //     order: 1000
-          //   }
-          // }
+          __blank__: {
+            title: "",
+            type: "text",
+            form: {
+              show: false
+            },
+            column: {
+              show: true,
+              order: 999999,
+              width: -1
+            }
+          }
         }
       };
 

packages/ui/certd-client/src/store/modules/user.ts

@@ -130,7 +130,7 @@ export const useUserStore = defineStore({
      */
     confirmLoginOut() {
       const { t } = useI18n();
-      Modal.config({
+      Modal.confirm({
         iconType: "warning",
         title: t("app.login.logoutTip"),
         content: t("app.login.logoutMessage"),

packages/ui/certd-client/src/views/certd/access/access-selector/access/crud.tsx

@@ -64,7 +64,7 @@ export default function ({ crudExpose, context }: CreateCrudOptionsProps): Creat
         }
       },
       rowHandle: {
-        width: "130px"
+        width: 200
       },
       table: {
         scroll: {

packages/ui/certd-client/src/views/certd/access/crud.tsx

@@ -42,6 +42,9 @@ export default function ({ crudExpose }: CreateCrudOptionsProps): CreateCrudOpti
           span: 6
         }
       },
+      rowHandle: {
+        width: 200
+      },
       columns: {
         id: {
           title: "ID",

packages/ui/certd-client/src/views/certd/pipeline/crud.tsx

@@ -5,7 +5,7 @@ import { useRouter } from "vue-router";
 import { AddReq, CreateCrudOptionsProps, CreateCrudOptionsRet, DelReq, dict, EditReq, UserPageQuery, UserPageRes, useUi } from "@fast-crud/fast-crud";
 import { statusUtil } from "/@/views/certd/pipeline/pipeline/utils/util.status";
 import { nanoid } from "nanoid";
-import { message, Modal } from "ant-design-vue";
+import { message, Modal, notification } from "ant-design-vue";
 import { env } from "/@/utils/util.env";
 import { useUserStore } from "/@/store/modules/user";
 import dayjs from "dayjs";
@@ -181,10 +181,29 @@ export default function ({ crudExpose, context: { certdFormRef } }: CreateCrudOp
           }
         }
       },
+      table: {
+        scroll: { x: 1500 }
+      },
       rowHandle: {
-        minWidth: 200,
+        width: 300,
         fixed: "right",
         buttons: {
+          play: {
+            order: -999,
+            title: null,
+            type: "link",
+            icon: "ant-design:play-circle-outlined",
+            click({ row }) {
+              Modal.confirm({
+                title: "确认",
+                content: `确定要触发运行吗？`,
+                async onOk() {
+                  await api.Trigger(row.id);
+                  notification.success({ message: "管道已经开始运行" });
+                }
+              });
+            }
+          },
           view: {
             click({ row }) {
               router.push({ path: "/certd/pipeline/detail", query: { id: row.id, editMode: "false" } });
@@ -227,6 +246,7 @@ export default function ({ crudExpose, context: { certdFormRef } }: CreateCrudOp
               const files = await api.GetFiles(row.id);
               Modal.success({
                 title: "文件下载",
+                maskClosable: true,
                 okText: "↑↑↑ 点击上面链接下载",
                 content: () => {
                   const children = [];
@@ -260,7 +280,7 @@ export default function ({ crudExpose, context: { certdFormRef } }: CreateCrudOp
             show: true
           },
           column: {
-            width: 50
+            width: 100
           },
           form: {
             show: false
@@ -280,7 +300,8 @@ export default function ({ crudExpose, context: { certdFormRef } }: CreateCrudOp
           column: {
             show: computed(() => {
               return userStore.isAdmin && settingStore.sysPublic.managerOtherUserPipeline;
-            })
+            }),
+            width: 100
           }
         },
         title: {
@@ -293,7 +314,7 @@ export default function ({ crudExpose, context: { certdFormRef } }: CreateCrudOp
             }
           },
           column: {
-            width: 300,
+            width: 350,
             sorter: true,
             component: {
               on: {
@@ -306,9 +327,11 @@ export default function ({ crudExpose, context: { certdFormRef } }: CreateCrudOp
           }
         },
         content: {
-          title: "定时任务数量",
+          title: "定时任务数",
           type: "number",
           column: {
+            align: "center",
+            width: 100,
             cellRender({ value }) {
               if (value && value.triggers) {
                 return value.triggers?.length > 0 ? value.triggers.length : "-";
@@ -346,7 +369,7 @@ export default function ({ crudExpose, context: { certdFormRef } }: CreateCrudOp
               const percent = (leftDays / 90) * 100;
               return <a-progress percent={percent} strokeColor={color} format={(percent: number) => `${leftDays} 天`} />;
             },
-            width: 110
+            width: 150
           }
         },
         lastHistoryTime: {
@@ -357,7 +380,7 @@ export default function ({ crudExpose, context: { certdFormRef } }: CreateCrudOp
           },
           column: {
             sorter: true,
-            width: 120,
+            width: 150,
             align: "center"
           }
         },
@@ -415,6 +438,7 @@ export default function ({ crudExpose, context: { certdFormRef } }: CreateCrudOp
             helper: "历史记录保持条数，多余的会被删除"
           },
           column: {
+            width: 130,
             show: false
           }
         },
@@ -438,7 +462,7 @@ export default function ({ crudExpose, context: { certdFormRef } }: CreateCrudOp
           },
           column: {
             sorter: true,
-            width: 125,
+            width: 155,
             align: "center"
           }
         },
@@ -449,6 +473,7 @@ export default function ({ crudExpose, context: { certdFormRef } }: CreateCrudOp
             show: false
           },
           column: {
+            width: 125,
             show: false
           }
         }

packages/ui/certd-client/src/views/certd/pipeline/pipeline/index.vue

@@ -583,8 +583,22 @@ export default defineComponent({
       const saveLoading = ref();
       const run = async (stepId?: string) => {
         if (props.editMode) {
-          message.warn("请先保存，再运行管道");
-          return;
+          const res = await new Promise((resolve, reject) => {
+            Modal.confirm({
+              title: "需要保存才能运行管道",
+              content: "是否先保存",
+              onOk() {
+                save();
+                resolve(true);
+              },
+              onCancel() {
+                resolve(false);
+              }
+            });
+          });
+          if (!res) {
+            return;
+          }
         }
         if (!props.options.doTrigger) {
           message.warn("暂不支持运行");

packages/ui/certd-server/.env.development.yaml

@@ -3,9 +3,24 @@
 #plus:
 #  server:
 #    baseUrl: 'http://127.0.0.1:11007'
+
+#flyway:
+#  scriptDir: './db/migration-pg'
+
+#typeorm:
+#  dataSource:
+#    default:
+#      type: postgres
+#      host: localhost
+#      port: 5433
+#      username: postgres
+#      password: root
+#      database: postgres
+
+
 plus:
   server:
-     baseUrl: 'https://api.ai.handsfree.work'
+    baseUrls: ['https://api.ai.handsfree.work', 'https://api.ai.docmirror.cn']
 #typeorm:
 #  dataSource:
 #    default:

packages/ui/certd-server/.env.production.yaml

@@ -9,8 +9,7 @@ typeorm:
 
 plus:
   server:
-    baseUrl: 'https://api.ai.handsfree.work'
-
+    baseUrls: ['https://api.ai.handsfree.work', 'https://api.ai.docmirror.cn']
 account:
   server:
     baseUrl: 'https://ai.handsfree.work/subject'

packages/ui/certd-server/CHANGELOG.md

@@ -3,6 +3,31 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.25.9](https://github.com/certd/certd/compare/v1.25.8...v1.25.9) (2024-10-01)
+
+### Bug Fixes
+
+* 修复西部数码账户级别apikey不可用的bug ([f8f3e8b](https://github.com/certd/certd/commit/f8f3e8b43fd5d815887bcb53b95f46dc96424b79))
+
+### Performance Improvements
+
+* 增加等待插件 ([3ef0541](https://github.com/certd/certd/commit/3ef0541cc85ab6abf698ead3b258ae1ac156ef98))
+
+## [1.25.8](https://github.com/certd/certd/compare/v1.25.7...v1.25.8) (2024-09-30)
+
+**Note:** Version bump only for package @certd/ui-server
+
+## [1.25.7](https://github.com/certd/certd/compare/v1.25.6...v1.25.7) (2024-09-29)
+
+### Bug Fixes
+
+* 修复某些地区被屏蔽无法激活专业版的bug ([7532a96](https://github.com/certd/certd/commit/7532a960851b84d4f2cc3dba02353c5235e1a364))
+
+### Performance Improvements
+
+* 上传到主机，支持socks代理 ([d91026d](https://github.com/certd/certd/commit/d91026dc4fbfe5fedc4ee8e43dc0d08f1cf88356))
+* 支持上传到七牛云oss ([bf024bd](https://github.com/certd/certd/commit/bf024bdda8bc2a463475be5761acf0da7317a08a))
+
 ## [1.25.6](https://github.com/certd/certd/compare/v1.25.5...v1.25.6) (2024-09-29)
 
 ### Bug Fixes

packages/ui/certd-server/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@certd/ui-server",
-  "version": "1.25.6",
+  "version": "1.25.9",
   "description": "fast-server base midway",
   "private": true,
   "type": "module",
@@ -16,21 +16,21 @@
     "build": "mwtsc --cleanOutDir --skipLibCheck",
     "build-on-docker": "node ./before-build.js && npm run build",
     "up-mw-deps": "npx midway-version -u -w",
-    "heap": "clinic heapprofiler   -- node ./bootstrap.js",
+    "heap": "clinic heapprofiler    --  node ./bootstrap.js",
     "flame": "clinic flame   -- node ./bootstrap.js"
   },
   "dependencies": {
     "@alicloud/cs20151215": "^3.0.3",
     "@alicloud/pop-core": "^1.7.10",
-    "@certd/acme-client": "^1.25.6",
-    "@certd/lib-huawei": "^1.25.6",
-    "@certd/lib-jdcloud": "^1.25.6",
-    "@certd/lib-k8s": "^1.25.6",
-    "@certd/midway-flyway-js": "^1.25.6",
-    "@certd/pipeline": "^1.25.6",
-    "@certd/plugin-cert": "^1.25.6",
-    "@certd/plugin-plus": "^1.25.6",
-    "@certd/plus-core": "^1.25.4",
+    "@certd/acme-client": "^1.25.9",
+    "@certd/lib-huawei": "^1.25.9",
+    "@certd/lib-jdcloud": "^1.25.9",
+    "@certd/lib-k8s": "^1.25.9",
+    "@certd/midway-flyway-js": "^1.25.9",
+    "@certd/pipeline": "^1.25.9",
+    "@certd/plugin-cert": "^1.25.9",
+    "@certd/plugin-plus": "^1.25.9",
+    "@certd/plus-core": "^1.25.9",
     "@koa/cors": "^5.0.0",
     "@midwayjs/bootstrap": "^3.16.2",
     "@midwayjs/cache": "^3.14.0",
@@ -70,6 +70,8 @@
     "querystring": "^0.2.1",
     "reflect-metadata": "^0.1.13",
     "rimraf": "^5.0.5",
+    "socks": "^2.8.3",
+    "socks-proxy-agent": "^8.0.4",
     "ssh2": "^1.15.0",
     "strip-ansi": "^7.1.0",
     "svg-captcha": "^1.4.0",

packages/ui/certd-server/src/config/config.default.ts

@@ -86,7 +86,7 @@ const development = {
     resetAdminPasswd: false,
   },
   plus: {
-    serverBaseUrl: 'http://127.0.0.1:11007',
+    serverBaseUrls: ['http://127.0.0.1:11007'],
   },
 } as MidwayConfig;
 mergeConfig(development, 'development');

packages/ui/certd-server/src/modules/basic/service/plus-service.ts

@@ -9,8 +9,8 @@ import { logger } from '../../../utils/logger.js';
 export class PlusService {
   @Inject()
   sysSettingsService: SysSettingsService;
-  @Config('plus.server.baseUrl')
-  plusServerBaseUrl;
+  @Config('plus.server.baseUrls')
+  plusServerBaseUrls: string[];
 
   plusRequestService: PlusRequestService;
 
@@ -18,7 +18,7 @@ export class PlusService {
   async init() {
     const installInfo: SysInstallInfo = await this.sysSettingsService.getSetting(SysInstallInfo);
     this.plusRequestService = new PlusRequestService({
-      plusServerBaseUrl: this.plusServerBaseUrl,
+      plusServerBaseUrls: this.plusServerBaseUrls,
       http: http,
       logger,
       subjectId: installInfo.siteId,

packages/ui/certd-server/src/modules/pipeline/controller/access-controller.ts

@@ -53,7 +53,7 @@ export class AccessController extends CrudController<AccessService> {
   }
 
   @Post('/define', { summary: Constants.per.authOnly })
-  async define(@Query('type') type:string) {
+  async define(@Query('type') type: string) {
     const access = this.service.getDefineByType(type);
     return this.ok(access);
   }
@@ -63,6 +63,9 @@ export class AccessController extends CrudController<AccessService> {
     const list = this.service.getDefineList();
     const dict = [];
     for (const item of list) {
+      if (item?.deprecated) {
+        continue;
+      }
       dict.push({
         value: item.name,
         label: item.title,

packages/ui/certd-server/src/modules/pipeline/controller/dns-provider-controller.ts

@@ -13,7 +13,7 @@ export class DnsProviderController extends BaseController {
   service: DnsProviderService;
 
   @Post('/list', { summary: Constants.per.authOnly })
-  async list(@Query(ALL) query:any) {
+  async list(@Query(ALL) query: any) {
     query.userId = this.ctx.user.id;
     const list = this.service.getList();
     return this.ok(list);

packages/ui/certd-server/src/modules/pipeline/controller/handle-controller.ts

@@ -1,13 +1,12 @@
 import { ALL, Body, Controller, Inject, Post, Provide } from '@midwayjs/core';
 import { Constants } from '../../../basic/constants.js';
 import {
-  accessRegistry,
-  AccessRequestHandleContext,
   AccessRequestHandleReq,
   http,
   ITaskPlugin,
   logger,
   mergeUtils,
+  newAccess,
   pluginRegistry,
   PluginRequestHandleReq,
   TaskInstanceContext,
@@ -28,38 +27,22 @@ export class HandleController extends BaseController {
 
   @Post('/access', { summary: Constants.per.authOnly })
   async accessRequest(@Body(ALL) body: AccessRequestHandleReq) {
-    const accessItem = accessRegistry.get(body.typeName);
-    const accessCls = accessItem.target;
-    if (accessCls == null) {
-      throw new Error(`access ${body.typeName} not found`);
-    }
-    //实例化access
-    //@ts-ignore
-    const access = new accessCls();
-
-    let isNew = true;
+    let inputAccess = body.input.access;
     if (body.input.id > 0) {
       const oldEntity = await this.accessService.info(body.input.id);
-      if (!oldEntity) {
-        isNew = false;
-        const param = {
+      if (oldEntity) {
+        const param: any = {
           type: body.typeName,
           setting: JSON.stringify(body.input.access),
         };
         this.accessService.encryptSetting(param, oldEntity);
-        body.input.access = JSON.parse(param.setting);
+        inputAccess = this.accessService.decryptAccessEntity(param);
       }
     }
-    if (isNew) {
-      mergeUtils.merge(access, body.input.access);
-    }
 
-    const ctx: AccessRequestHandleContext = {
-      http: http,
-      logger: logger,
-      utils,
-    };
-    const res = await access.onRequest(body, ctx);
+    const access = newAccess(body.typeName, inputAccess);
+
+    const res = await access.onRequest(body);
 
     return this.ok(res);
   }

packages/ui/certd-server/src/modules/pipeline/service/access-service.ts

@@ -3,7 +3,7 @@ import { InjectEntityModel } from '@midwayjs/typeorm';
 import { Repository } from 'typeorm';
 import { BaseService } from '../../../basic/base-service.js';
 import { AccessEntity } from '../entity/access.js';
-import { AccessDefine, accessRegistry, IAccessService } from '@certd/pipeline';
+import { AccessDefine, accessRegistry, IAccessService, newAccess } from '@certd/pipeline';
 import { EncryptService } from './encrypt-service.js';
 import { ValidateException } from '../../../basic/exception/validation-exception.js';
 
@@ -60,7 +60,7 @@ export class AccessService extends BaseService<AccessEntity> implements IAccessS
       const value = json[key];
       const accessInputDefine = accessDefine.input[key];
       if (!accessInputDefine) {
-        throw new ValidateException(`授权类型${accessType}不存在字段${key}`);
+        continue;
       }
       if (!accessInputDefine.encrypt || !value || typeof value !== 'string') {
         //定义无需加密、value为空、不是字符串 这些不需要加密
@@ -108,6 +108,15 @@ export class AccessService extends BaseService<AccessEntity> implements IAccessS
       throw new Error(`该授权配置不存在,请确认是否已被删除:id=${id}`);
     }
     // const access = accessRegistry.get(entity.type);
+    const setting = this.decryptAccessEntity(entity);
+    const input = {
+      id: entity.id,
+      ...setting,
+    };
+    return newAccess(entity.type, input);
+  }
+
+  decryptAccessEntity(entity: AccessEntity): any {
     let setting = {};
     if (entity.encryptSetting && entity.encryptSetting !== '{}') {
       setting = JSON.parse(entity.encryptSetting);
@@ -123,10 +132,7 @@ export class AccessService extends BaseService<AccessEntity> implements IAccessS
     } else if (entity.setting) {
       setting = JSON.parse(entity.setting);
     }
-    return {
-      id: entity.id,
-      ...setting,
-    };
+    return setting;
   }
 
   getDefineList() {

packages/ui/certd-server/src/modules/pipeline/service/plugin-service.ts

@@ -8,6 +8,9 @@ export class PluginService {
     const list = [];
     for (const key in collection) {
       const Plugin = collection[key];
+      if (Plugin?.define?.deprecated) {
+        continue;
+      }
       list.push({ ...Plugin.define, key });
     }
     return list;

packages/ui/certd-server/src/plugins/plugin-cloudflare/access.ts

@@ -1,4 +1,4 @@
-import { IsAccess, AccessInput } from '@certd/pipeline';
+import { IsAccess, AccessInput, BaseAccess } from '@certd/pipeline';
 
 /**
  * 这个注解将注册一个授权配置
@@ -9,7 +9,7 @@ import { IsAccess, AccessInput } from '@certd/pipeline';
   title: 'cloudflare授权',
   desc: '',
 })
-export class CloudflareAccess {
+export class CloudflareAccess extends BaseAccess {
   /**
    * 授权属性配置
    */

packages/ui/certd-server/src/plugins/plugin-demo/access.ts

@@ -1,4 +1,4 @@
-import { IsAccess, AccessInput, IAccess } from '@certd/pipeline';
+import { AccessInput, BaseAccess, IsAccess } from '@certd/pipeline';
 
 /**
  * 这个注解将注册一个授权配置
@@ -9,7 +9,7 @@ import { IsAccess, AccessInput, IAccess } from '@certd/pipeline';
   title: '授权插件示例',
   desc: '',
 })
-export class DemoAccess implements IAccess {
+export class DemoAccess extends BaseAccess {
   /**
    * 授权属性配置
    */
@@ -41,4 +41,7 @@ export class DemoAccess implements IAccess {
   demoKeySecret = '';
 }
 
-new DemoAccess();
+if (process.env.NODE_ENV === 'development') {
+  //你的实现 要去掉这个if，不然生产环境将不会显示
+  new DemoAccess();
+}

packages/ui/certd-server/src/plugins/plugin-demo/dns-provider.ts

@@ -1,9 +1,4 @@
-import {
-  AbstractDnsProvider,
-  CreateRecordOptions,
-  IsDnsProvider,
-  RemoveRecordOptions,
-} from '@certd/plugin-cert';
+import { AbstractDnsProvider, CreateRecordOptions, IsDnsProvider, RemoveRecordOptions } from '@certd/plugin-cert';
 import { Autowire, HttpClient, ILogger } from '@certd/pipeline';
 import { DemoAccess } from './access.js';
 
@@ -83,4 +78,7 @@ export class DemoDnsProvider extends AbstractDnsProvider<DemoRecord> {
 }
 
 //TODO 实例化这个provider，将其自动注册到系统中
-new DemoDnsProvider();
+if (process.env.NODE_ENV === 'development') {
+  //你的实现 要去掉这个if，不然生产环境将不会显示
+  new DemoDnsProvider();
+}

packages/ui/certd-server/src/plugins/plugin-demo/plugins/plugin-test.ts

@@ -98,4 +98,7 @@ export class DemoTestPlugin extends AbstractTaskPlugin {
   }
 }
 //TODO 这里实例化插件，进行注册
-new DemoTestPlugin();
+if (process.env.NODE_ENV === 'development') {
+  //你的实现 要去掉这个if，不然生产环境将不会显示
+  new DemoTestPlugin();
+}

packages/ui/certd-server/src/plugins/plugin-doge/access.ts

@@ -1,4 +1,4 @@
-import { IsAccess, AccessInput } from '@certd/pipeline';
+import { IsAccess, AccessInput, BaseAccess } from '@certd/pipeline';
 
 /**
  * 这个注解将注册一个授权配置
@@ -9,7 +9,7 @@ import { IsAccess, AccessInput } from '@certd/pipeline';
   title: '多吉云',
   desc: '',
 })
-export class DogeCloudAccess {
+export class DogeCloudAccess extends BaseAccess {
   /**
    * 授权属性配置
    */

packages/ui/certd-server/src/plugins/plugin-dynadot/access.ts

@@ -1,4 +1,4 @@
-import { AccessInput, IsAccess } from '@certd/pipeline';
+import { AccessInput, BaseAccess, IsAccess } from '@certd/pipeline';
 
 /**
  * 这个注解将注册一个授权配置
@@ -9,7 +9,7 @@ import { AccessInput, IsAccess } from '@certd/pipeline';
   title: 'dynadot授权',
   desc: '************\n注意：申请证书时会覆盖已有的域名解析配置，慎用\n************\n待优化，主要是dynadot的接口一言难尽',
 })
-export class DynadotAccess {
+export class DynadotAccess extends BaseAccess {
   /**
    * 授权属性配置
    */

packages/ui/certd-server/src/plugins/plugin-host/access/ssh-access.ts

@@ -1,4 +1,4 @@
-import { AccessInput, IAccess, IsAccess } from '@certd/pipeline';
+import { AccessInput, BaseAccess, IsAccess } from '@certd/pipeline';
 import { ConnectConfig } from 'ssh2';
 
 @IsAccess({
@@ -7,7 +7,7 @@ import { ConnectConfig } from 'ssh2';
   desc: '',
   input: {},
 })
-export class SshAccess implements IAccess, ConnectConfig {
+export class SshAccess extends BaseAccess implements ConnectConfig {
   @AccessInput({
     title: '主机地址',
     component: {
@@ -18,7 +18,7 @@ export class SshAccess implements IAccess, ConnectConfig {
   host!: string;
   @AccessInput({
     title: '端口',
-    value: '22',
+    value: 22,
     component: {
       name: 'a-input-number',
       placeholder: '22',
@@ -64,6 +64,17 @@ export class SshAccess implements IAccess, ConnectConfig {
   })
   passphrase!: string;
 
+  @AccessInput({
+    title: 'socks代理',
+    helper: 'socks代理配置，格式：socks5://user:password@host:port',
+    component: {
+      name: 'a-input',
+      vModel: 'value',
+    },
+    encrypt: false,
+  })
+  socksProxy!: string;
+
   @AccessInput({
     title: '是否Windows',
     helper: '如果是Windows主机，请勾选此项',

packages/ui/certd-server/src/plugins/plugin-host/lib/ssh.ts

@@ -5,10 +5,13 @@ import * as _ from 'lodash-es';
 import { ILogger } from '@certd/pipeline';
 import { SshAccess } from '../access/index.js';
 import stripAnsi from 'strip-ansi';
+import { SocksClient } from 'socks';
+import { SocksProxy, SocksProxyType } from 'socks/typings/common/constants.js';
+
 export class AsyncSsh2Client {
   conn: ssh2.Client;
   logger: ILogger;
-  connConf: ssh2.ConnectConfig;
+  connConf: SshAccess & ssh2.ConnectConfig;
   windows = false;
   encoding: string;
   constructor(connConf: SshAccess, logger: ILogger) {
@@ -27,6 +30,23 @@ export class AsyncSsh2Client {
 
   async connect() {
     this.logger.info(`开始连接，${this.connConf.host}:${this.connConf.port}`);
+    if (this.connConf.socksProxy) {
+      this.logger.info(`使用代理${this.connConf.socksProxy}`);
+      if (typeof this.connConf.port === 'string') {
+        this.connConf.port = parseInt(this.connConf.port);
+      }
+      const proxyOption: SocksProxy = this.parseSocksProxyFromUri(this.connConf.socksProxy);
+      const info = await SocksClient.createConnection({
+        proxy: proxyOption,
+        command: 'connect',
+        destination: {
+          host: this.connConf.host,
+          port: this.connConf.port,
+        },
+      });
+      this.logger.info('代理连接成功');
+      this.connConf.sock = info.socket;
+    }
     return new Promise((resolve, reject) => {
       try {
         const conn = new ssh2.Client();
@@ -160,6 +180,26 @@ export class AsyncSsh2Client {
       this.conn.end();
     }
   }
+
+  private parseSocksProxyFromUri(socksProxyUri: string): SocksProxy {
+    const url = new URL(socksProxyUri);
+    let type: SocksProxyType = 5;
+    if (url.protocol.startsWith('socks4')) {
+      type = 4;
+    }
+    const proxy: SocksProxy = {
+      host: url.hostname,
+      port: parseInt(url.port),
+      type,
+    };
+    if (url.username) {
+      proxy.userId = url.username;
+    }
+    if (url.password) {
+      proxy.password = url.password;
+    }
+    return proxy;
+  }
 }
 
 export class SshClient {

packages/ui/certd-server/src/plugins/plugin-huawei/access/huawei-access.ts

@@ -1,11 +1,11 @@
-import { IsAccess, AccessInput } from '@certd/pipeline';
+import { IsAccess, AccessInput, BaseAccess } from '@certd/pipeline';
 
 @IsAccess({
   name: 'huawei',
   title: '华为云授权',
   desc: '',
 })
-export class HuaweiAccess {
+export class HuaweiAccess extends BaseAccess {
   @AccessInput({
     title: 'accessKeyId',
     component: {

packages/ui/certd-server/src/plugins/plugin-jdcloud/access.ts

@@ -1,4 +1,4 @@
-import { AccessInput, IsAccess } from '@certd/pipeline';
+import { AccessInput, BaseAccess, IsAccess } from '@certd/pipeline';
 
 /**
  * 这个注解将注册一个授权配置
@@ -9,7 +9,7 @@ import { AccessInput, IsAccess } from '@certd/pipeline';
   title: '京东云授权',
   desc: '暂时无法成功申请，还没测试通过',
 })
-export class JDCloudAccess {
+export class JDCloudAccess extends BaseAccess {
   /**
    * 授权属性配置
    */

packages/ui/certd-server/src/plugins/plugin-other/plugins/index.ts

@@ -1,2 +1,3 @@
 export * from './plugin-restart.js';
 export * from './plugin-script.js';
+export * from './plugin-wait.js';

packages/ui/certd-server/src/plugins/plugin-other/plugins/plugin-wait.ts

@@ -0,0 +1,35 @@
+import { AbstractTaskPlugin, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput } from '@certd/pipeline';
+
+@IsTaskPlugin({
+  name: 'WaitPlugin',
+  title: '等待',
+  icon: 'ri:rest-time-line',
+  desc: '等待一段时间',
+  group: pluginGroups.other.key,
+  default: {
+    strategy: {
+      runStrategy: RunStrategy.SkipWhenSucceed,
+    },
+  },
+})
+export class WaitPlugin extends AbstractTaskPlugin {
+  @TaskInput({
+    title: '等待时长',
+    value: 30,
+    component: {
+      name: 'a-input-number',
+      vModel: 'value',
+    },
+    helper: '单位：秒',
+    required: true,
+  })
+  waitTime!: number;
+
+  async onInstance() {}
+  async execute(): Promise<void> {
+    this.logger.info(`等待${this.waitTime}s`);
+    await this.ctx.utils.sleep(this.waitTime * 1000);
+    this.logger.info('等待结束');
+  }
+}
+new WaitPlugin();

packages/ui/certd-server/src/plugins/plugin-qiniu/access/access.ts

@@ -1,24 +0,0 @@
-import { AccessInput, IAccess, IsAccess } from '@certd/pipeline';
-
-@IsAccess({
-  name: 'qiniu',
-  title: '七牛云授权',
-  desc: '',
-  input: {},
-})
-export class QiniuAccess implements IAccess {
-  @AccessInput({
-    title: 'AccessKey',
-    rules: [{ required: true, message: '此项必填' }],
-    helper: 'AK，前往[密钥管理](https://portal.qiniu.com/developer/user/key)获取',
-  })
-  accessKey!: string;
-  @AccessInput({
-    title: 'SecretKey',
-    encrypt: true,
-    helper: 'SK',
-  })
-  secretKey!: string;
-}
-
-new QiniuAccess();

packages/ui/certd-server/src/plugins/plugin-qiniu/access/index.ts

@@ -1 +0,0 @@
-export * from './access.js';

packages/ui/certd-server/src/plugins/plugin-qiniu/index.ts

@@ -1,2 +1 @@
 export * from './plugin/index.js';
-export * from './access/index.js';

packages/ui/certd-server/src/plugins/plugin-qiniu/plugin/deploy-to-cdn/index.ts

@@ -1,7 +1,6 @@
 import { AbstractTaskPlugin, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput } from '@certd/pipeline';
-import { QiniuAccess } from '../../access/index.js';
+import { QiniuAccess, QiniuClient } from '@certd/plugin-plus';
 import { CertInfo } from '@certd/plugin-cert';
-import { doRequest, uploadCert } from '../lib/sdk.js';
 
 @IsTaskPlugin({
   name: 'QiniuDeployCertToCDN',
@@ -49,24 +48,27 @@ export class QiniuDeployCertToCDN extends AbstractTaskPlugin {
   async execute(): Promise<void> {
     this.logger.info('开始部署证书到七牛云cdn');
     const access = await this.accessService.getById<QiniuAccess>(this.accessId);
-
+    const qiniuClient = new QiniuClient({
+      http: this.ctx.http,
+      access,
+    });
     const url = `https://api.qiniu.com/domain/${this.domainName}/httpsconf`;
     let certId = null;
     if (typeof this.cert !== 'string') {
       // 是证书id，直接上传即可
       this.logger.info('先上传证书');
-      certId = await uploadCert(this.ctx.http, access, this.cert, this.appendTimeSuffix('certd'));
+      certId = await qiniuClient.uploadCert(this.cert, this.appendTimeSuffix('certd'));
     } else {
       certId = this.cert;
     }
 
     //开始修改证书
-    this.logger.info('开始修改证书');
+    this.logger.info(`开始修改证书,certId:${certId},domain:${this.domainName}`);
     const body = {
       certID: certId,
     };
 
-    await doRequest(this.ctx.http, access, url, 'put', body);
+    await qiniuClient.doRequest(url, 'put', body);
 
     this.logger.info('部署完成');
   }

packages/ui/certd-server/src/plugins/plugin-qiniu/plugin/lib/sdk.ts

@@ -1,36 +0,0 @@
-import { HttpClient } from '@certd/pipeline';
-import { QiniuAccess } from '../../access/index.js';
-import { CertInfo } from '@certd/plugin-cert';
-
-export async function doRequest(http: HttpClient, access: QiniuAccess, url: string, method: string, body: any) {
-  const { generateAccessToken } = await import('qiniu/qiniu/util.js');
-  const token = generateAccessToken(access, url);
-  const res = await http.request({
-    url,
-    method: method,
-    headers: {
-      Authorization: token,
-    },
-    data: body,
-  });
-
-  if (res.code !== 200 || res.error) {
-    throw new Error('请求失败：' + res.error);
-  }
-  return res;
-}
-
-export async function uploadCert(http: HttpClient, access: QiniuAccess, cert: CertInfo, certName?: string) {
-  const url = 'https://api.qiniu.com/sslcert';
-
-  const body = {
-    name: certName,
-    common_name: 'certd',
-    pri: cert.key,
-    ca: cert.crt,
-  };
-
-  const res = await doRequest(http, access, url, 'post', body);
-
-  return res.certID;
-}

packages/ui/certd-server/src/plugins/plugin-qiniu/plugin/upload-cert/index.ts

@@ -1,7 +1,6 @@
 import { AbstractTaskPlugin, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput, TaskOutput } from '@certd/pipeline';
-import { QiniuAccess } from '../../access/index.js';
+import { QiniuAccess, QiniuClient } from '@certd/plugin-plus';
 import { CertInfo } from '@certd/plugin-cert';
-import { uploadCert } from '../lib/sdk.js';
 
 @IsTaskPlugin({
   name: 'QiniuCertUpload',
@@ -53,7 +52,11 @@ export class QiniuCertUpload extends AbstractTaskPlugin {
   async execute(): Promise<void> {
     this.logger.info('开始上传证书到七牛云');
     const access = (await this.accessService.getById(this.accessId)) as QiniuAccess;
-    this.qiniuCertId = await uploadCert(this.ctx.http, access, this.cert, this.appendTimeSuffix(this.certName));
+    const qiniuClient = new QiniuClient({
+      http: this.ctx.http,
+      access,
+    });
+    this.qiniuCertId = await qiniuClient.uploadCert(this.cert, this.appendTimeSuffix(this.certName));
     this.logger.info('上传完成,id:', this.qiniuCertId);
   }
 }

packages/ui/certd-server/src/plugins/plugin-tencent/access/dnspod-access.ts

@@ -1,11 +1,12 @@
-import { IsAccess, AccessInput } from '@certd/pipeline';
+import { IsAccess, AccessInput, BaseAccess } from '@certd/pipeline';
 
 @IsAccess({
   name: 'dnspod',
-  title: 'dnspod',
+  title: 'dnspod(已废弃)',
   desc: '腾讯云的域名解析接口已迁移到dnspod',
+  deprecated: 'dnspod已废弃，请换成腾讯云',
 })
-export class DnspodAccess {
+export class DnspodAccess extends BaseAccess {
   @AccessInput({
     title: '端点',
     component: {

packages/ui/certd-server/src/plugins/plugin-tencent/dns-provider/dnspod-dns-provider.ts

@@ -6,8 +6,9 @@ import { DnspodAccess } from '../access/index.js';
 @IsDnsProvider({
   name: 'dnspod',
   title: 'dnspod(已过时,请尽快换成腾讯云)',
-  desc: '请尽快换成腾讯云类型',
+  desc: '已废弃，请尽快换成腾讯云类型',
   accessType: 'dnspod',
+  deprecated: 'dnspod已废弃，请换成腾讯云',
 })
 export class DnspodDnsProvider extends AbstractDnsProvider {
   @Autowire()

packages/ui/certd-server/src/plugins/plugin-tencent/dns-provider/index.ts

@@ -1 +1,2 @@
 import './dnspod-dns-provider.js';
+import './tencent-dns-provider.js';

packages/ui/certd-server/src/plugins/plugin-west/access.ts

@@ -1,4 +1,4 @@
-import { IsAccess, AccessInput } from '@certd/pipeline';
+import { IsAccess, AccessInput, BaseAccess } from '@certd/pipeline';
 
 /**
  * 这个注解将注册一个授权配置
@@ -9,7 +9,7 @@ import { IsAccess, AccessInput } from '@certd/pipeline';
   title: '西部数码授权',
   desc: '',
 })
-export class WestAccess {
+export class WestAccess extends BaseAccess {
   /**
    * 授权属性配置
    */

packages/ui/certd-server/src/plugins/plugin-west/dns-provider.ts

@@ -37,7 +37,7 @@ export class WestDnsProvider extends AbstractDnsProvider<westRecord> {
 
   private async doRequestApi(url: string, data: any = null, method = 'post') {
     if (this.access.scope === 'account') {
-      data.apikey = this.access.apikey;
+      data.apikey = this.ctx.utils.hash.md5(this.access.apikey);
       data.username = this.access.username;
     } else {
       data.apidomainkey = this.access.apidomainkey;

step.md

@@ -13,10 +13,10 @@
 ## 自动化流水线创建
 
 ### 1. 创建证书申请部署流水线
-![创建证书申请任务](./doc/images/1-add.png)
+![创建证书申请任务](./packages/ui/certd-client/public/doc/images/1-add.png)
 
 需要添加域名的DNS解析服务商的授权
-![添加域名的DNS解析服务商的授权](./doc/images/2-access-provider.png)
+![添加域名的DNS解析服务商的授权](./packages/ui/certd-client/public/doc/images/2-access-provider.png)
 
 填写accessKey和accessSecret
 ![](./packages/ui/certd-client/public/doc/images/3-add-access.png)