Skip to content

Commit

Permalink
issue评论如果包含collaborator，不算危险issue (#49)
Browse files Browse the repository at this point in the history 
Co-authored-by: [email protected] <[email protected]>
Co-authored-by: [email protected] <[email protected]>
  • Loading branch information
@15669072513
3 people authored Jul 31, 2024
1 parent ab98b64 commit 17fceaa
Show file tree
Hide file tree
Showing 9 changed files with 393 additions and 184 deletions.
39 changes: 20 additions & 19 deletions README.md
View file
Original file line number Diff line number Diff line change
Expand Up @@ -130,27 +130,28 @@ issue 被 assign 后，在 IM 群中提醒当事人。
```javascript
if(group['type']==='dingtalk'){
return dingtalk.sendMarkdown(group,content,atUid,uidArr);
}else{
// 其他IM接入示例
return otherim.sendMarkdown(group,content,atUid,uidArr);
}
```
}else{
// 其他IM接入示例
return otherim.sendMarkdown(group,content,atUid,uidArr);
}
```
- 配置：在config.json里面填写im的type为自己的im类型。
```json
"good-first-issue-notifier": {
"enable": true,
"channels": [
{
"type": "dingtalk",
"urls": [
"https://oapi.dingtalk.com/robot/send?access_token=your_token"
],
"title": "goodFirstIssue认领",
"atUid": [],
"atAll": true
}
]
}

"good-first-issue-notifier": {
"enable": true,
"channels": [
{
"type": "dingtalk",
"urls": [
"https://oapi.dingtalk.com/robot/send?access_token=66113ea1b10247d25149158fb4b765da6c3c57bddca2682215122cc205e2ac70"
],
"title": "goodFirstIssue认领",
"atUid": [],
"atAll": true
}
]
}
```

## 使用文档
Expand Down
3 changes: 1 addition & 2 deletions src/const.js
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@

//这个是固定写死的。
const configNames = ['liveness-check','good-first-issue-notifier','mergeRepo','dangerousIssuesConfig','dingTalkGroupConfig']

const configNames = ['liveness-check','good-first-issue-notifier','issue-notifier','mergeRepo','dangerousIssuesConfig','dingTalkGroupConfig']
/**
* 按照优先级获取配置
* @param repoConfig
Expand Down
198 changes: 185 additions & 13 deletions src/dao/dangerous_issue.js
View file
Original file line number Diff line number Diff line change
@@ -1,8 +1,9 @@
const fs = require("fs");
const moment = require("moment");
const fetch = require("node-fetch");
const config = require("../../configs/config.json");
const {getConfig} = require("../const");
const { getConn, query } = require("./mysql_conn");
const { getImDao } = require("./im");
const {utils} = require("../utils/time_utils");

const mysqlDao = {
Expand Down Expand Up @@ -44,6 +45,7 @@ const mysqlDao = {

const dingTalkDao = {
issuesForDingTalk: new Map(),

livenessCheck: new Map(),
start: function () { },
// put the issue into the memory list
Expand Down Expand Up @@ -76,7 +78,7 @@ const dingTalkDao = {
sendLiveness:async function(livenessCheckElement,owner,ownerDingTalkGroupConfig){
if (livenessCheckElement > 0) {
let livenessContent = this.concatLivenessContent(owner, livenessCheckElement, ownerDingTalkGroupConfig);
await getImDao.send(livenessContent, null, false, true, "liveness", ownerDingTalkGroupConfig);
await this.send(livenessContent, null, false, true, "liveness", ownerDingTalkGroupConfig);
} else {
await this.sendSuccessLivecheck(owner, ownerDingTalkGroupConfig)
}
Expand All @@ -89,7 +91,7 @@ const dingTalkDao = {
const ownerDingTalkGroupConfig = getConfig(null, config.orgRepoConfig[owner]['dingTalkGroupConfig'], config.generalConfig['dingTalkGroupConfig']);
if (value.length > 0) {
let issueContent = this.concatIssueContent(owner, value, ownerDingTalkGroupConfig);
await getImDao().send(issueContent, null, false, true, "issue", ownerDingTalkGroupConfig);
await this.send(issueContent, null, false, true, "issue", ownerDingTalkGroupConfig);
} else {
await this.sendNoIssue(owner, ownerDingTalkGroupConfig)
}
Expand Down Expand Up @@ -207,35 +209,203 @@ const dingTalkDao = {
`注：liveness check会检查每个项目的健康情况，如果满足下列条件会被归类为“腐烂级”项目：\n` +
`- 存在大于30天未回复的 issue \n` +
`- 连续4周活跃度小于20\n`;
await getImDao().send(content, null, false, false, "liveness", dingTalkGroupConfig);
await this.send(content, null, false, false, "liveness", dingTalkGroupConfig);
},
sendNoIssue: async function (owner, dingTalkGroupConfig) {
let awards = [
{
content: `${owner}目前没有舆情 issue ，大家回复很及时，奖励一人一辆特斯拉!\n`,
content: `${owner}社区目前没有舆情 issue ，大家回复很及时，奖励一人一辆特斯拉!\n`,
img: "https://gw.alipayobjects.com/mdn/rms_6ac329/afts/img/A*PXPwR6je8-MAAAAAAAAAAAAAARQnAQ",
},
{
content: `${owner}目前没有舆情 issue ，大家回复很及时，奖励一人一辆 SpaceX 火箭!\n`,
content: `${owner}社区目前没有舆情 issue ，大家回复很及时，奖励一人一辆 SpaceX 火箭!\n`,
img: "https://gw.alipayobjects.com/mdn/rms_6ac329/afts/img/A*J7MsQKCp-H8AAAAAAAAAAAAAARQnAQ",
},
{
content: `${owner}目前没有舆情 issue ，大家回复很及时，奖励一人一个 脑机接口!\n`,
content: `${owner}社区目前没有舆情 issue ，大家回复很及时，奖励一人一个 脑机接口!\n`,
img: "https://img-blog.csdnimg.cn/img_convert/15b784912f4511cbb9d35bb2c1bf5e91.png",
},
{
content: `${owner}目前没有舆情 issue ，大家回复很及时，奖励一人一罐 可口可乐!\n`,
content: `${owner}社区目前没有舆情 issue ，大家回复很及时，奖励一人一罐 可口可乐!\n`,
img: "https://gw.alipayobjects.com/mdn/rms_6ac329/afts/img/A*v6SsRKjmOWYAAAAAAAAAAAAAARQnAQ",
},
];
// give a random award!
let idx = Math.floor(Math.random() * awards.length);
let content = awards[idx].content;
let img = awards[idx].img;
await getImDao().send(content, null, false, false, "issue", dingTalkGroupConfig);
await getImDao().sendImage(img, null, false, false, "issue", owner, dingTalkGroupConfig);
}
await this.send(content, null, false, false, "issue", dingTalkGroupConfig);
await this.sendImage(img, null, false, false, "issue", owner, dingTalkGroupConfig);
},
/**
* 这里的owner等于owner好像
* @param content
* @param atUid
* @param isAtAll
* @param isNegative
* @param topicType
* @param dingTalkGroupConfig
*/
send: async function (content, atUid, isAtAll, isNegative, topicType,dingTalkGroupConfig) {
const topicTypeLiveness = "liveness";
const topicTypeIssue = "issue";
const groups = dingTalkGroupConfig["groups"]

for (let group of groups) {
// 1.validate
// 检查url是否为空
if (group['url'] == null || group['url'].length === 0) {
console.log("DingTalk url is empty");
continue;
}
// check topic projects
// 检查group.topicProjects中是否包含project
// if (!this.interested(group['topicProjects'], project)) {
// continue;
// }
// check topicTypesIgnore
// 检查group['topicTypesIgnore']是否为*或者是否等于topicType
if (this.isIgnoredTopicType(group['topicTypesIgnore'], topicType)) {
continue;
}
// check topicTypesOnly
// 检查group['topicTypesOnly']是否为*或者是否等于topicType
if (!this.interestedTopicType(group['topicTypesOnly'], topicType)) {
continue;
}
// check owner in content
// 检查content中是否有group.owner，没有则替换this.owner
let newContent = content;

// append text
// 添加链接文本
if (topicType === topicTypeIssue) {
if (isNegative) {
newContent += this.nullToEmpty(group['issueWarningText']);
} else {
//没有issue，不会发消息，这个实际没有用到
newContent += this.nullToEmpty(group['issueCongratulationText']);
}
} else if (topicType === topicTypeLiveness) {
if (isNegative) {
newContent += this.nullToEmpty(group['livenessWarningText']);
} else {
newContent += this.nullToEmpty(group['livenessCongratulationText']);
}
}
let uidArr = [];
if (atUid != null) {
uidArr = atUid;
}
// 2. send request
//发送请求
return fetch(group.url, {
method: "POST",
headers: {
"Content-Type": "application/json",
Accept: "application/json",
},
body: JSON.stringify({
at: {
atMobiles: [""],
atUserIds: uidArr,
isAtAll: isAtAll,
},
text: {
content: newContent,
},
msgtype: "text",
title: ``,
}),
})
// 3. parse
.then((res) => {
return res.json();
})
.then((json) => {
console.log( `发送钉钉:${newContent}结果：`)
console.log(json)
});
}
},
nullToEmpty(str) {
// 如果str为null，则返回空字符串
if (str == null) {
return "";
}
// 否则返回str
return str;
},
interested: function (topicProjects, project) {
// 如果topicProjects为空或者长度为0或者topicProjects为*
if (
topicProjects == null ||
topicProjects.length == 0 ||
topicProjects == "*"
) {
// 返回true
return true;
}
// 如果topicProjects中包含project
if (topicProjects.indexOf(project) >= 0) {
// 返回true
return true;
}
// 否则返回false
return false;
},
sendImage: async function (imageUrl, atUid, isAtAll, isNegative, topicType,owner,option) {
const groups = option["groups"]
for (let group of groups) {
// 1.validate
if (group.url == null || group.url.length == 0) {
console.log("send image:DingTalk url is empty");
continue;
}
// check topic project
// if (!this.interested(group['topicProjects'], project)) {
// continue;
// }
// check topicTypesIgnore
if (this.isIgnoredTopicType(group['topicTypesIgnore'], topicType)) {
continue;
}
// check topicTypesOnly
if (!this.interestedTopicType(group['topicTypesOnly'], topicType)) {
continue;
}
// check owner in content
let nickName = owner;
if (group['nickName'] != null) {
nickName = group['nickName'];
}
// 2. send request
return fetch(group.url, {
method: "POST",
headers: {
"Content-Type": "application/json",
Accept: "application/json",
},
body: JSON.stringify({
msgtype: "markdown",
markdown: {
title: nickName+"issue SOFAStack",
text: `![](${imageUrl}) \n`,
},
at: {
atMobiles: [""],
atUserIds: [atUid],
isAtAll: isAtAll,
},
}),
})
// 3. parse
.then((res) => {
return res.json();
})
.then((json) => console.log("发送图片结果：",json));
}
},
};

const fsDAOImpl = {
Expand Down Expand Up @@ -322,8 +492,10 @@ module.exports = {
fsDAOImpl.commit();
dingTalkDao.commit();
},

getDingTalkDao() {
return dingTalkDao;
},
getMysqlDao(){
return mysqlDao;
}
};
};
Loading

0 comments on commit 17fceaa

Please sign in to comment.