Compare commits

...

3 Commits

Author SHA1 Message Date
猫爪子 c0be4d702c fix(certd-server): 修复 AWS 中国区 CloudFront 证书部署问题 (#764) @yw-mao
- 修复证书链拆分,保留 END CERTIFICATE 结尾标记,避免 MalformedCertificate
- 更新 CloudFront 时构造干净的 IAM ViewerCertificate,强制 sni-only,
  解决 InvalidViewerCertificate 及中国区不支持 vip 的报错
- 部署完成后清理被替换掉的旧 IAM 证书,避免续期堆积
- IAM/CloudFront 权限不足时抛出可读中文提示,便于运维排查

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-07-07 16:20:07 +08:00
xiaojunnuo 2a606fdb1d build: publish 2026-07-07 00:22:06 +08:00
xiaojunnuo 3b86f30bcf build: trigger build image 2026-07-07 00:21:54 +08:00
15 changed files with 259 additions and 38 deletions
+13
View File
@@ -3,6 +3,19 @@
All notable changes to this project will be documented in this file. All notable changes to this project will be documented in this file.
See [Conventional Commits](https://conventionalcommits.org) for commit guidelines. See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
## [1.42.1](https://github.com/certd/certd/compare/v1.42.0...v1.42.1) (2026-07-06)
### Bug Fixes
* 修复多域名无法使用passkey登录的bug ([d176f9c](https://github.com/certd/certd/commit/d176f9cc0ebd051a614bfac74d1616d1945fc9a3))
* 修复企业模式下登录报projectId不能为空的问题 ([a65366b](https://github.com/certd/certd/commit/a65366bbe1aadea8baaffbdadab58a5b631d9417))
* **login:** 修复输入法 composing 状态下回车触发提交的问题 ([b74db81](https://github.com/certd/certd/commit/b74db81304bbe68476bbec5ea4307a2264060e92))
### Performance Improvements
* **certd-server:** 使用 jks-go转换jks证书,大幅精简镜像大小 ([c78898e](https://github.com/certd/certd/commit/c78898e4c10dd1701467d2e42e3f72bd8f2a352f))
* **pipeline:** 将默认历史保留条数从30调整为100 ([d3e4677](https://github.com/certd/certd/commit/d3e4677ea4fac8e7533749d7f4187e410489e536))
# [1.42.0](https://github.com/certd/certd/compare/v1.41.4...v1.42.0) (2026-07-05) # [1.42.0](https://github.com/certd/certd/compare/v1.41.4...v1.42.0) (2026-07-05)
### Bug Fixes ### Bug Fixes
+1 -1
View File
@@ -75,5 +75,5 @@
"bugs": { "bugs": {
"url": "https://github.com/publishlab/node-acme-client/issues" "url": "https://github.com/publishlab/node-acme-client/issues"
}, },
"gitHead": "b46948c0ba67069ebcd2bb71b21b6c289d99f1b8" "gitHead": "7808d028e9c7e1b1e3ebc41f12b023d7b553300b"
} }
+1 -1
View File
@@ -54,5 +54,5 @@
"tslib": "^2.8.1", "tslib": "^2.8.1",
"typescript": "^5.4.2" "typescript": "^5.4.2"
}, },
"gitHead": "b46948c0ba67069ebcd2bb71b21b6c289d99f1b8" "gitHead": "7808d028e9c7e1b1e3ebc41f12b023d7b553300b"
} }
+1 -1
View File
@@ -51,5 +51,5 @@
"tslib": "^2.8.1", "tslib": "^2.8.1",
"typescript": "^5.4.2" "typescript": "^5.4.2"
}, },
"gitHead": "b46948c0ba67069ebcd2bb71b21b6c289d99f1b8" "gitHead": "7808d028e9c7e1b1e3ebc41f12b023d7b553300b"
} }
+1 -1
View File
@@ -30,5 +30,5 @@
"prettier": "3.3.3", "prettier": "3.3.3",
"tslib": "^2.8.1" "tslib": "^2.8.1"
}, },
"gitHead": "b46948c0ba67069ebcd2bb71b21b6c289d99f1b8" "gitHead": "7808d028e9c7e1b1e3ebc41f12b023d7b553300b"
} }
+1 -1
View File
@@ -37,5 +37,5 @@
"tslib": "^2.8.1", "tslib": "^2.8.1",
"typescript": "^5.4.2" "typescript": "^5.4.2"
}, },
"gitHead": "b46948c0ba67069ebcd2bb71b21b6c289d99f1b8" "gitHead": "7808d028e9c7e1b1e3ebc41f12b023d7b553300b"
} }
+1 -1
View File
@@ -62,5 +62,5 @@
"fetch" "fetch"
] ]
}, },
"gitHead": "b46948c0ba67069ebcd2bb71b21b6c289d99f1b8" "gitHead": "7808d028e9c7e1b1e3ebc41f12b023d7b553300b"
} }
+1 -1
View File
@@ -38,5 +38,5 @@
"tslib": "^2.8.1", "tslib": "^2.8.1",
"typescript": "^5.4.2" "typescript": "^5.4.2"
}, },
"gitHead": "b46948c0ba67069ebcd2bb71b21b6c289d99f1b8" "gitHead": "7808d028e9c7e1b1e3ebc41f12b023d7b553300b"
} }
+1 -1
View File
@@ -69,5 +69,5 @@
"typeorm": "^0.3.20", "typeorm": "^0.3.20",
"typescript": "^5.4.2" "typescript": "^5.4.2"
}, },
"gitHead": "b46948c0ba67069ebcd2bb71b21b6c289d99f1b8" "gitHead": "7808d028e9c7e1b1e3ebc41f12b023d7b553300b"
} }
+1 -1
View File
@@ -52,5 +52,5 @@
"typeorm": "^0.3.20", "typeorm": "^0.3.20",
"typescript": "^5.4.2" "typescript": "^5.4.2"
}, },
"gitHead": "b46948c0ba67069ebcd2bb71b21b6c289d99f1b8" "gitHead": "7808d028e9c7e1b1e3ebc41f12b023d7b553300b"
} }
+1 -1
View File
@@ -38,5 +38,5 @@
"tslib": "^2.8.1", "tslib": "^2.8.1",
"typescript": "^5.4.2" "typescript": "^5.4.2"
}, },
"gitHead": "b46948c0ba67069ebcd2bb71b21b6c289d99f1b8" "gitHead": "7808d028e9c7e1b1e3ebc41f12b023d7b553300b"
} }
+1 -1
View File
@@ -45,5 +45,5 @@
"tslib": "^2.8.1", "tslib": "^2.8.1",
"typescript": "^5.4.2" "typescript": "^5.4.2"
}, },
"gitHead": "b46948c0ba67069ebcd2bb71b21b6c289d99f1b8" "gitHead": "7808d028e9c7e1b1e3ebc41f12b023d7b553300b"
} }
@@ -1,21 +1,107 @@
// 导入所需的 SDK 模块 // 导入所需的 SDK 模块
import { AwsCNAccess } from "../access.js"; import { AwsCNAccess } from "../access.js";
import { CertInfo } from "@certd/plugin-cert"; import { CertInfo } from "@certd/plugin-cert";
import { ILogger } from "@certd/basic";
type AwsIAMClientOptions = { access: AwsCNAccess; region: string }; type AwsIAMClientOptions = { access: AwsCNAccess; region: string; logger?: ILogger };
// IAM ListServerCertificates 返回的证书元信息(仅保留本插件用到的字段)
export type ServerCertificateMetadata = {
ServerCertificateName?: string;
ServerCertificateId?: string;
Expiration?: Date | string;
};
/**
* 拆分完整 PEM,得到叶子证书和证书链。
* 使用 lookbehind 分割,保留每段结尾的 -----END CERTIFICATE-----
* 避免证书链丢失结尾标记而变成非法 PEM(AWS 会报 MalformedCertificate)。
*/
export function splitCertAndChain(crt: string): { cert: string; chain: string } {
const pemBlocks = crt.split(/(?<=-----END CERTIFICATE-----)/);
const cert = pemBlocks[0].trim();
const chain = pemBlocks.slice(1).join("").trim();
return { cert, chain };
}
/**
* 从 IAM 证书元信息列表中,挑出"本次被替换掉"的旧证书名称。
* distribution 已改用新证书,旧证书不再被其引用,因此无论是否过期都应清理,
* 否则提前续期/手动重部署产生的旧证书会在 IAM 中不断堆积。
* 过滤规则:
* - ServerCertificateId 必须命中 targetCertIds(即本次部署前 CloudFront 引用的旧证书)
* - 不能等于 excludeCertId(本次新上传的证书,避免误删)
* 返回去重后的 ServerCertificateName 列表。
*/
export function pickReplacedCertNames(params: { metadataList: ServerCertificateMetadata[]; targetCertIds: Set<string> | string[]; excludeCertId?: string }): string[] {
const { metadataList, targetCertIds, excludeCertId } = params;
const targetIdSet = targetCertIds instanceof Set ? targetCertIds : new Set(targetCertIds);
const names = new Set<string>();
for (const metadata of metadataList) {
const certId = metadata.ServerCertificateId;
const certName = metadata.ServerCertificateName;
if (!certId || !certName) {
continue;
}
if (!targetIdSet.has(certId)) {
continue;
}
if (excludeCertId && certId === excludeCertId) {
continue;
}
names.add(certName);
}
return [...names];
}
// CloudFront ViewerCertificate 字段(仅保留本插件用到的字段)
export type ViewerCertificate = {
CloudFrontDefaultCertificate?: boolean;
ACMCertificateArn?: string;
IAMCertificateId?: string;
Certificate?: string;
CertificateSource?: string;
SSLSupportMethod?: string;
MinimumProtocolVersion?: string;
};
/**
* 基于旧 ViewerCertificate 构造使用 IAM 证书的新配置。
* - CloudFront 要求 ACMCertificateArn、IAMCertificateId、CloudFrontDefaultCertificate 三者只能存在其一,
* 因此这里只保留 IAM 证书,并显式将 CloudFrontDefaultCertificate 置为 false、不携带 ACMCertificateArn。
* - Certificate/CertificateSource 为 AWS 已废弃字段,更新时不再携带,避免旧的 ACM 值残留导致校验冲突。
* - SSLSupportMethod 强制为 sni-onlyAWS 中国区 CloudFront 只支持 SNI,不支持 vip(专用IP),
* 若沿用旧的 vip 值会报 "The parameter ViewerCertificate with the specified SSL support method isn't available in this region"。
* - MinimumProtocolVersion 沿用旧值,缺失时给出安全默认值。
*/
export function buildIamViewerCertificate(params: { oldViewerCertificate?: ViewerCertificate; certId: string }): ViewerCertificate {
const { oldViewerCertificate, certId } = params;
const old = oldViewerCertificate || {};
return {
CloudFrontDefaultCertificate: false,
IAMCertificateId: certId,
SSLSupportMethod: "sni-only",
MinimumProtocolVersion: old.MinimumProtocolVersion || "TLSv1.2_2021",
};
}
export class AwsIAMClient { export class AwsIAMClient {
options: AwsIAMClientOptions; options: AwsIAMClientOptions;
access: AwsCNAccess; access: AwsCNAccess;
region: string; region: string;
logger?: ILogger;
constructor(options: AwsIAMClientOptions) { constructor(options: AwsIAMClientOptions) {
this.options = options; this.options = options;
this.access = options.access; this.access = options.access;
this.region = options.region; this.region = options.region;
this.logger = options.logger;
} }
async importCertificate(certInfo: CertInfo, certName: string) {
// 创建 IAM 客户端 // 统一创建 IAM 客户端,供上传/查询/删除复用
const { IAMClient, UploadServerCertificateCommand } = await this.access.importRuntime("@aws-sdk/client-iam"); private async createIamClient() {
const iamModule = await this.access.importRuntime("@aws-sdk/client-iam");
const { IAMClient } = iamModule;
const iamClient = new IAMClient({ const iamClient = new IAMClient({
region: this.region, // 替换为您的 AWS 区域 region: this.region, // 替换为您的 AWS 区域
credentials: { credentials: {
@@ -23,20 +109,99 @@ export class AwsIAMClient {
secretAccessKey: this.access.secretAccessKey, secretAccessKey: this.access.secretAccessKey,
}, },
}); });
return { iamClient, iamModule };
}
const cert = certInfo.crt.split("-----END CERTIFICATE-----")[0] + "-----END CERTIFICATE-----"; async importCertificate(certInfo: CertInfo, certName: string) {
const chain = certInfo.crt.split("-----END CERTIFICATE-----\n")[1]; const { iamClient, iamModule } = await this.createIamClient();
const { UploadServerCertificateCommand } = iamModule;
const { cert, chain } = splitCertAndChain(certInfo.crt);
// 构建上传参数 // 构建上传参数
const command = new UploadServerCertificateCommand({ const command = new UploadServerCertificateCommand({
Path: "/cloudfront/", Path: "/cloudfront/",
ServerCertificateName: certName, ServerCertificateName: certName,
CertificateBody: cert, CertificateBody: cert,
PrivateKey: certInfo.key, PrivateKey: certInfo.key,
CertificateChain: chain, CertificateChain: chain || undefined,
}); });
try {
const data = await iamClient.send(command); const data = await iamClient.send(command);
console.log("Upload successful:", data);
// 返回证书 ID // 返回证书 ID
return data.ServerCertificateMetadata.ServerCertificateId; return data.ServerCertificateMetadata.ServerCertificateId;
} catch (err) {
const message = err.message || String(err);
const requestId = err.$metadata?.requestId || err.requestId;
console.error(`IAM 调用失败: ${message}, requestId: ${requestId}`);
throw err;
}
}
// 拉取 /cloudfront/ path 下的全部 server certificate 元信息(处理分页)
async listCloudFrontServerCertificates(): Promise<ServerCertificateMetadata[]> {
const { iamClient, iamModule } = await this.createIamClient();
const { ListServerCertificatesCommand } = iamModule;
const metadataList: ServerCertificateMetadata[] = [];
let marker: string | undefined = undefined;
do {
const command = new ListServerCertificatesCommand({
PathPrefix: "/cloudfront/",
Marker: marker,
});
const data: any = await iamClient.send(command);
const pageList: ServerCertificateMetadata[] = data.ServerCertificateMetadataList || [];
metadataList.push(...pageList);
marker = data.IsTruncated ? data.Marker : undefined;
} while (marker);
return metadataList;
}
// 按名称删除 IAM server certificate
async deleteServerCertificate(serverCertificateName: string) {
const { iamClient, iamModule } = await this.createIamClient();
const { DeleteServerCertificateCommand } = iamModule;
const command = new DeleteServerCertificateCommand({
ServerCertificateName: serverCertificateName,
});
await iamClient.send(command);
}
/**
* 清理本次被替换掉的旧证书(无论是否过期)。
* distribution 已改用新证书,旧证书不再被其引用,直接删除以避免 IAM 堆积。
* 必须在更新完 CloudFront 引用之后调用,否则旧证书仍被引用会报 DeleteConflict。
* 删除失败(如仍被其他分配引用)时只告警,不阻断部署流程。
*/
async deleteReplacedCerts(params: { oldCertIds: Set<string> | string[]; newCertId?: string }) {
const { oldCertIds, newCertId } = params;
const targetIdSet = oldCertIds instanceof Set ? oldCertIds : new Set(oldCertIds);
if (targetIdSet.size === 0) {
return;
}
const metadataList = await this.listCloudFrontServerCertificates();
const replacedCertNames = pickReplacedCertNames({
metadataList,
targetCertIds: targetIdSet,
excludeCertId: newCertId,
});
if (replacedCertNames.length === 0) {
this.logger?.info("没有需要清理的旧证书");
return;
}
for (const certName of replacedCertNames) {
try {
await this.deleteServerCertificate(certName);
this.logger?.info(`已删除被替换的旧证书: ${certName}`);
} catch (err: any) {
const message = err?.message || String(err);
this.logger?.warn(`删除旧证书失败(可能仍被其他分配引用),已跳过: ${certName}, 原因: ${message}`);
}
}
} }
} }
@@ -1,7 +1,7 @@
import { AbstractTaskPlugin, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput } from "@certd/pipeline"; import { AbstractTaskPlugin, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput } from "@certd/pipeline";
import { CertApplyPluginNames, CertInfo } from "@certd/plugin-cert"; import { CertApplyPluginNames, CertInfo } from "@certd/plugin-cert";
import { AwsCNAccess } from "../access.js"; import { AwsCNAccess } from "../access.js";
import { AwsIAMClient } from "../libs/aws-iam-client.js"; import { AwsIAMClient, buildIamViewerCertificate } from "../libs/aws-iam-client.js";
import { createCertDomainGetterInputDefine, createRemoteSelectInputDefine } from "@certd/plugin-lib"; import { createCertDomainGetterInputDefine, createRemoteSelectInputDefine } from "@certd/plugin-lib";
import { AwsCNRegions } from "../constants.js"; import { AwsCNRegions } from "../constants.js";
@@ -77,10 +77,19 @@ export class AwsCNDeployToCloudFront extends AbstractTaskPlugin {
async execute(): Promise<void> { async execute(): Promise<void> {
const access = await this.getAccess<AwsCNAccess>(this.accessId); const access = await this.getAccess<AwsCNAccess>(this.accessId);
const iamClient = new AwsIAMClient({
access,
region: this.region,
logger: this.logger,
});
// 本次是否真正上传了新证书(cert 为字符串时表示直接使用已有证书ID,不涉及替换过期旧证书)
const uploadedNewCert = typeof this.cert !== "string";
let certId = this.cert as string; let certId = this.cert as string;
if (typeof this.cert !== "string") { if (uploadedNewCert) {
//先上传 //先上传
certId = await this.uploadToIAM(access, this.cert); certId = await this.uploadToIAM(iamClient, this.cert as CertInfo);
} }
//部署到CloudFront //部署到CloudFront
@@ -93,6 +102,9 @@ export class AwsCNDeployToCloudFront extends AbstractTaskPlugin {
}, },
}); });
// 记录每个分配部署前引用的旧 IAM 证书ID,部署完成后清理其中已过期的
const oldCertIds = new Set<string>();
// update-distribution // update-distribution
for (const distributionId of this.distributionIds) { for (const distributionId of this.distributionIds) {
// get-distribution-config // get-distribution-config
@@ -100,30 +112,61 @@ export class AwsCNDeployToCloudFront extends AbstractTaskPlugin {
Id: distributionId, Id: distributionId,
}); });
const configData = await cloudFrontClient.send(getDistributionConfigCommand); const configData: any = await this.sendCloudFrontCommand(() => cloudFrontClient.send(getDistributionConfigCommand), `获取CloudFront配置(${distributionId})`);
const oldViewerCertificate = configData.DistributionConfig?.ViewerCertificate;
const oldCertId = oldViewerCertificate?.IAMCertificateId;
if (oldCertId) {
oldCertIds.add(oldCertId);
}
// 使用干净的 IAM ViewerCertificate,避免与旧的 ACM/默认证书字段冲突导致 InvalidViewerCertificate
const viewerCertificate = buildIamViewerCertificate({ oldViewerCertificate, certId });
const updateDistributionCommand = new UpdateDistributionCommand({ const updateDistributionCommand = new UpdateDistributionCommand({
DistributionConfig: { DistributionConfig: {
...configData.DistributionConfig, ...configData.DistributionConfig,
ViewerCertificate: { ViewerCertificate: viewerCertificate,
...configData.DistributionConfig.ViewerCertificate,
IAMCertificateId: certId,
},
}, },
Id: distributionId, Id: distributionId,
IfMatch: configData.ETag, IfMatch: configData.ETag,
}); });
await cloudFrontClient.send(updateDistributionCommand); await this.sendCloudFrontCommand(() => cloudFrontClient.send(updateDistributionCommand), `更新CloudFront证书(${distributionId})`);
this.logger.info(`部署${distributionId}完成:`); this.logger.info(`部署${distributionId}完成:`);
} }
this.logger.info("部署完成"); this.logger.info("部署完成");
// 仅当本次上传了新证书时,清理被替换掉的旧证书(无论是否过期);清理失败不影响部署结果
if (uploadedNewCert) {
try {
await iamClient.deleteReplacedCerts({ oldCertIds, newCertId: certId });
} catch (err: any) {
this.logger.warn(`清理旧证书失败,已忽略: ${err?.message || err}`);
}
}
} }
private async uploadToIAM(access: AwsCNAccess, cert: CertInfo) { /**
const acmClient = new AwsIAMClient({ * 统一包装 CloudFront 调用错误。
access, * 命中 AWS 权限不足(AccessDenied / not authorized)时,抛出可读的中文提示,
region: this.region, * 指明该 IAM 用户需要补充的 CloudFront 与 IAM 权限,方便运维在 AWS 控制台排查。
}); */
const awsCertID = await acmClient.importCertificate(cert, this.appendTimeSuffix(this.certName)); private async sendCloudFrontCommand<T>(action: () => Promise<T>, actionDesc: string): Promise<T> {
try {
return await action();
} catch (err: any) {
const message = err?.message || String(err);
const isAuthError = err?.name === "AccessDenied" || /not authorized to perform|no identity-based policy/i.test(message);
if (isAuthError) {
const requiredPermissions = ["cloudfront:ListDistributions", "cloudfront:GetDistributionConfig", "cloudfront:UpdateDistribution", "iam:UploadServerCertificate"].join("、");
throw new Error(`${actionDesc}失败:AWS 账号权限不足,请为该 IAM 用户附加 CloudFront 部署所需权限(${requiredPermissions})。原始错误:${message}`);
}
throw err;
}
}
private async uploadToIAM(iamClient: AwsIAMClient, cert: CertInfo) {
const awsCertID = await iamClient.importCertificate(cert, this.appendTimeSuffix(this.certName));
this.logger.info("证书上传成功,id=", awsCertID); this.logger.info("证书上传成功,id=", awsCertID);
return awsCertID; return awsCertID;
} }
+1 -1
View File
@@ -1 +1 @@
19:31 00:21