-
Notifications
You must be signed in to change notification settings - Fork 0
/
room-inviter.js
92 lines (81 loc) · 2.67 KB
/
room-inviter.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
const { Wechaty, ScanStatus, log } = require("wechaty");
const { RoomInviter, Heartbeat } = require("wechaty-plugin-contrib");
// const { PuppetPadlocal } = require("wechaty-puppet-padlocal");
// const token = "puppet_padlocal_fc94df45c2564fb48c11c4eb2f238a3c" // padlocal token
// const puppet = new PuppetPadlocal({ token })
const 群聊名称特征词 = "SH一起看影展";
const 邀请关键词="SH电影节"
const roomInviterConfig = {
password: 邀请关键词,
room: new RegExp(群聊名称特征词),
rule: "Please be a good people",//发出群聊邀请之前的规则申明
welcome: "Welcome to join the room!",//进入群聊后的欢迎词
repeat: "You have already in our room",//你已经加入了群聊
};
Wechaty.use(RoomInviter(roomInviterConfig));
const heartbeatConfig = {
contact: 'filehelper', // default: filehelper - Contact id who will receive the emoji
emoji: {
heartbeat: '[爱心]', // default: [爱心] - Heartbeat emoji
},
intervalSeconds: 1 * 60, // Default: 1 hour - Send emoji for every 1 hour
}
Wechaty.use(Heartbeat(heartbeatConfig))
function onScan(qrcode, status) {
if (status === ScanStatus.Waiting || status === ScanStatus.Timeout) {
require("qrcode-terminal").generate(qrcode, { small: true }); // show qrcode on console
const qrcodeImageUrl = [
"https://wechaty.js.org/qrcode/",
encodeURIComponent(qrcode),
].join("");
log.info(
"StarterBot",
"onScan: %s(%s) - %s",
ScanStatus[status],
status,
qrcodeImageUrl
);
} else {
log.info("StarterBot", "onScan: %s(%s)", ScanStatus[status], status);
}
}
function onLogin(user) {
log.info("StarterBot", "%s login", user);
}
function onLogout(user) {
log.info("StarterBot", "%s logout", user);
}
async function onMessage(msg) {
if (msg.self()) {
if (msg.text() === "停止运行") {
await bot.stop()
return
}
if (msg.text() === "退出登录") {
await bot.logout()()
await bot.stop()
return
}
return
};
// log.info("StarterBot", msg.toString());
// if (msg.room()) log.info("room", msg.room().id);
if (msg.text() === "列出群") {
let list = await bot.Room.findAll({ topic: new RegExp(群聊名称特征词) });
let topicList = await Promise.all(list.map((room) => room.topic()));
log.info("room", topicList);
await msg.say(topicList.toString());
}
}
const bot = new Wechaty({
name: "room-inviter-bot",
// puppet
});
bot.on("scan", onScan);
bot.on("login", onLogin);
bot.on("logout", onLogout);
bot.on("message", onMessage);
bot
.start()
.then(() => log.info("StarterBot", "Starter Bot Started."))
.catch((e) => log.error("StarterBot", e));