mirror of
https://github.com/certd/certd.git
synced 2026-04-24 12:27:25 +08:00
perf: dns支持新网域名解析
This commit is contained in:
@@ -17,10 +17,26 @@ function base64(data: string) {
|
|||||||
function base64Decode(data: string) {
|
function base64Decode(data: string) {
|
||||||
return Buffer.from(data, "base64").toString("utf8");
|
return Buffer.from(data, "base64").toString("utf8");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
function toHex(data: number | string) {
|
||||||
|
if (typeof data === "number") {
|
||||||
|
return data.toString(16);
|
||||||
|
}
|
||||||
|
return Buffer.from(data).toString("hex");
|
||||||
|
}
|
||||||
|
function hexToStr(data: string) {
|
||||||
|
return Buffer.from(data, "hex").toString("utf8");
|
||||||
|
}
|
||||||
|
function hexToNumber(data: string) {
|
||||||
|
return parseInt(data, 16);
|
||||||
|
}
|
||||||
export const hashUtils = {
|
export const hashUtils = {
|
||||||
md5,
|
md5,
|
||||||
sha256,
|
sha256,
|
||||||
base64,
|
base64,
|
||||||
base64Decode,
|
base64Decode,
|
||||||
hmacSha256,
|
hmacSha256,
|
||||||
|
toHex,
|
||||||
|
hexToStr,
|
||||||
|
hexToNumber,
|
||||||
};
|
};
|
||||||
|
|||||||
@@ -0,0 +1,40 @@
|
|||||||
|
import { IsAccess, AccessInput, BaseAccess } from '@certd/pipeline';
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 这个注解将注册一个授权配置
|
||||||
|
* 在certd的后台管理系统中,用户可以选择添加此类型的授权
|
||||||
|
*/
|
||||||
|
@IsAccess({
|
||||||
|
name: 'xinnet',
|
||||||
|
title: '新网授权',
|
||||||
|
icon: 'arcticons:dns-changer-3',
|
||||||
|
desc: '',
|
||||||
|
})
|
||||||
|
export class XinnetAccess extends BaseAccess {
|
||||||
|
/**
|
||||||
|
* 授权属性配置
|
||||||
|
*/
|
||||||
|
@AccessInput({
|
||||||
|
title: '用户名',
|
||||||
|
component: {
|
||||||
|
placeholder: '用户名或手机号',
|
||||||
|
},
|
||||||
|
required: true,
|
||||||
|
encrypt: false,
|
||||||
|
})
|
||||||
|
username = '';
|
||||||
|
|
||||||
|
@AccessInput({
|
||||||
|
title: '登录密码',
|
||||||
|
component: {
|
||||||
|
name:"a-input-password",
|
||||||
|
vModel:"value",
|
||||||
|
placeholder: '密码',
|
||||||
|
},
|
||||||
|
required: true,
|
||||||
|
encrypt: true,
|
||||||
|
})
|
||||||
|
password = '';
|
||||||
|
}
|
||||||
|
|
||||||
|
new XinnetAccess();
|
||||||
@@ -0,0 +1,98 @@
|
|||||||
|
import { AbstractDnsProvider, CreateRecordOptions, IsDnsProvider, RemoveRecordOptions } from "@certd/plugin-cert";
|
||||||
|
import { XinnetAccess } from "./access.js";
|
||||||
|
import { XinnetClient } from "@certd/plugin-plus";
|
||||||
|
|
||||||
|
export type XinnetRecord = {
|
||||||
|
id: number;
|
||||||
|
domainId: number,
|
||||||
|
};
|
||||||
|
|
||||||
|
// 这里通过IsDnsProvider注册一个dnsProvider
|
||||||
|
@IsDnsProvider({
|
||||||
|
name: 'xinnet',
|
||||||
|
title: '新网',
|
||||||
|
desc: '新网域名解析',
|
||||||
|
icon: 'arcticons:dns-changer-3',
|
||||||
|
// 这里是对应的 cloudflare的access类型名称
|
||||||
|
accessType: 'xinnet',
|
||||||
|
order:7,
|
||||||
|
})
|
||||||
|
export class XinnetProvider extends AbstractDnsProvider<XinnetRecord> {
|
||||||
|
access!: XinnetAccess;
|
||||||
|
|
||||||
|
client!:XinnetClient;
|
||||||
|
async onInstance() {
|
||||||
|
//一些初始化的操作
|
||||||
|
// 也可以通过ctx成员变量传递context
|
||||||
|
this.access = this.ctx.access as XinnetAccess;
|
||||||
|
this.client = new XinnetClient({
|
||||||
|
logger: this.logger,
|
||||||
|
access: this.access,
|
||||||
|
http: this.http
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 创建dns解析记录,用于验证域名所有权
|
||||||
|
*/
|
||||||
|
async createRecord(options: CreateRecordOptions): Promise<XinnetRecord> {
|
||||||
|
/**
|
||||||
|
* fullRecord: '_acme-challenge.test.example.com',
|
||||||
|
* value: 一串uuid
|
||||||
|
* type: 'TXT',
|
||||||
|
* domain: 'example.com'
|
||||||
|
*/
|
||||||
|
const { fullRecord,hostRecord, value, type, domain } = options;
|
||||||
|
this.logger.info('添加域名解析:', fullRecord, value, type, domain);
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
const domainId = await this.client.getDomainId(domain);
|
||||||
|
this.logger.info('获取domainId成功:', domainId);
|
||||||
|
|
||||||
|
const res = await this.client.createRecord({
|
||||||
|
domain: domain,
|
||||||
|
domainId: domainId,
|
||||||
|
type: 'TXT',
|
||||||
|
host: hostRecord,
|
||||||
|
data: value,
|
||||||
|
ttl: 300,
|
||||||
|
})
|
||||||
|
return {
|
||||||
|
id: res.id,
|
||||||
|
domainId: domainId,
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 删除dns解析记录,清理申请痕迹
|
||||||
|
* @param options
|
||||||
|
*/
|
||||||
|
async removeRecord(options: RemoveRecordOptions<Dns51Record>): Promise<void> {
|
||||||
|
const { fullRecord, value } = options.recordReq;
|
||||||
|
const record = options.recordRes;
|
||||||
|
this.logger.info('删除域名解析:', fullRecord, value);
|
||||||
|
if (!record) {
|
||||||
|
this.logger.info('record为空,不执行删除');
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
//这里调用删除txt dns解析记录接口
|
||||||
|
/**
|
||||||
|
* 请求示例
|
||||||
|
* DELETE /api/record?id=85371689655342080 HTTP/1.1
|
||||||
|
* Authorization: Basic {token}
|
||||||
|
* 请求参数
|
||||||
|
*/
|
||||||
|
const {id,domainId} = record
|
||||||
|
await this.client.deleteRecord({
|
||||||
|
id,
|
||||||
|
domainId
|
||||||
|
})
|
||||||
|
this.logger.info(`删除域名解析成功:fullRecord=${fullRecord},id=${id}`);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
//实例化这个provider,将其自动注册到系统中
|
||||||
|
new Dns51DnsProvider();
|
||||||
@@ -0,0 +1,3 @@
|
|||||||
|
export * from './dns-provider.js';
|
||||||
|
export * from './access.js';
|
||||||
|
export * from './client.js';
|
||||||
Reference in New Issue
Block a user