mirror of https://github.com/certd/certd
138 lines
3.5 KiB
TypeScript
138 lines
3.5 KiB
TypeScript
import { BaseNotification, IsNotification, NotificationBody, NotificationInput } from "@certd/pipeline";
|
||
|
||
@IsNotification({
|
||
name: 'feishu',
|
||
title: '飞书通知',
|
||
desc: '飞书群聊webhook通知',
|
||
needPlus: true,
|
||
})
|
||
// https://open.dingtalk.com/document/orgapp/the-creation-and-installation-of-the-application-robot-in-the?spm=ding_open_doc.document.0.0.242d1563cDgZz3
|
||
export class DingTalkNotification extends BaseNotification {
|
||
@NotificationInput({
|
||
title: 'webhook地址',
|
||
component: {
|
||
placeholder: 'https://open.feishu.cn/open-apis/bot/v2/hook/xxxxxxxxxxxxxxxx',
|
||
},
|
||
helper: '飞书APP->群聊->设置->机器人->添加机器人->自定义webhook->[创建机器人->复制webhook地址](https://open.feishu.cn/document/client-docs/bot-v3/add-custom-bot?lang=zh-CN)',
|
||
required: true,
|
||
})
|
||
webhook = '';
|
||
|
||
@NotificationInput({
|
||
title: '加签密钥',
|
||
component: {
|
||
placeholder: 'SECxxxxxxxxxxxxxxxxxxxxx',
|
||
},
|
||
helper: '必须选择一种安全设置，建议选择加密密钥',
|
||
required: false,
|
||
})
|
||
secret = '';
|
||
|
||
|
||
@NotificationInput({
|
||
title: '@用户',
|
||
component: {
|
||
placeholder: '非必填，支持多个，填写完一个按回车',
|
||
name: 'a-select',
|
||
vModel: 'value',
|
||
mode: 'tags',
|
||
multiple: true,
|
||
open: false,
|
||
},
|
||
helper: '填写要@的用户ID：【ou_xxxxxxxxx】\n用户ID获取方法,[查看OpenId获取方法](https://open.feishu.cn/document/home/user-identity-introduction/open-id)',
|
||
required: false,
|
||
})
|
||
atUserIds:string[];
|
||
|
||
|
||
@NotificationInput({
|
||
title: '@all',
|
||
component: {
|
||
placeholder: '非必填',
|
||
name: 'a-switch',
|
||
vModel:"checked"
|
||
},
|
||
helper: '是否@所有人',
|
||
required: false,
|
||
})
|
||
isAtAll:boolean;
|
||
|
||
|
||
async sign(){
|
||
const crypto = await import('crypto');
|
||
const secret = this.secret;
|
||
const timestamp = Math.floor(Date.now() / 1000);
|
||
const str = Buffer.from(`${timestamp}\n${secret}`, 'utf8');
|
||
const sign = crypto.createHmac('SHA256', str);
|
||
sign.update(Buffer.alloc(0));
|
||
return { timestamp, sign: sign.digest('base64') };
|
||
}
|
||
|
||
async send(body: NotificationBody) {
|
||
if (!this.webhook) {
|
||
throw new Error('webhook地址不能为空');
|
||
}
|
||
/**
|
||
*
|
||
* "msgtype": "text",
|
||
* "text": {
|
||
* "content": "hello world"
|
||
* }
|
||
* }
|
||
*/
|
||
|
||
let webhook = this.webhook;
|
||
|
||
|
||
/*
|
||
// @ 单个用户
|
||
<at user_id="ou_xxx">名字</at>
|
||
// @ 所有人
|
||
<at user_id="all">所有人</at>
|
||
*/
|
||
let atText = ""
|
||
if(this.atUserIds && this.atUserIds.length>0){
|
||
atText = this.atUserIds.map((id:string)=>{
|
||
const nameIndex = id.indexOf(".");
|
||
let name = id
|
||
if(nameIndex>0){
|
||
name = id.substring(nameIndex+1)
|
||
}
|
||
return `<at user_id="${id}">${name}</at>`
|
||
}).join("");
|
||
}
|
||
if(this.isAtAll){
|
||
atText = `<at user_id="all">所有人</at>`
|
||
}
|
||
|
||
if (atText){
|
||
atText = `\n· ${atText}`
|
||
}
|
||
|
||
let sign:any = {}
|
||
if(this.secret){
|
||
const signRet = await this.sign();
|
||
sign = {
|
||
timestamp: signRet.timestamp,
|
||
sign: signRet.sign
|
||
}
|
||
}
|
||
|
||
|
||
const res = await this.http.request({
|
||
url: webhook,
|
||
method: 'POST',
|
||
data: {
|
||
...sign,
|
||
content: {
|
||
text: `· ${body.title}\n· ${body.content}\n· 查看详情: ${body.url}${atText}`,
|
||
},
|
||
msg_type:"text"
|
||
},
|
||
});
|
||
if(res.code>100){
|
||
throw new Error(`发送失败：${res.msg}`);
|
||
}
|
||
}
|
||
}
|