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
|
const moment = require('moment');
const threads = require("../data/threads");
const utils = require('../utils');
const config = require('../config');
const {THREAD_STATUS} = require('../data/constants');
module.exports = ({ bot, knex, config, commands }) => {
// Check for threads that are scheduled to be suspended and suspend them
async function applyScheduledSuspensions() {
const threadsToBeSuspended = await threads.getThreadsThatShouldBeSuspended();
for (const thread of threadsToBeSuspended) {
if (thread.status === THREAD_STATUS.OPEN) {
await thread.suspend();
await thread.postSystemMessage(`**Thread suspended** as scheduled by ${thread.scheduled_suspend_name}. This thread will act as closed until unsuspended with \`!unsuspend\`.`);
}
}
}
async function scheduledSuspendLoop() {
try {
await applyScheduledSuspensions();
} catch (e) {
console.error(e);
}
setTimeout(scheduledSuspendLoop, 2000);
}
scheduledSuspendLoop();
commands.addInboxThreadCommand('suspend cancel', [], async (msg, args, thread) => {
// Cancel timed suspend
if (thread.scheduled_suspend_at) {
await thread.cancelScheduledSuspend();
thread.postSystemMessage(`Cancelled scheduled suspension.`);
} else {
thread.postSystemMessage(`Thread is not scheduled to be suspended.`);
}
});
commands.addInboxThreadCommand('suspend', '[delay:delay]', async (msg, args, thread) => {
if (args.delay) {
const suspendAt = moment.utc().add(args.delay, 'ms');
await thread.scheduleSuspend(suspendAt.format('YYYY-MM-DD HH:mm:ss'), msg.author);
thread.postSystemMessage(`Thread will be suspended in ${utils.humanizeDelay(args.delay)}. Use \`${config.prefix}suspend cancel\` to cancel.`);
return;
}
await thread.suspend();
thread.postSystemMessage(`**Thread suspended!** This thread will act as closed until unsuspended with \`!unsuspend\`.`);
});
commands.addInboxServerCommand('unsuspend', [], async (msg, args, thread) => {
if (thread) {
thread.postSystemMessage(`Thread is not suspended.`);
return;
}
thread = await threads.findSuspendedThreadByChannelId(msg.channel.id);
if (! thread) {
thread.postSystemMessage(`Not in a thread.`);
return;
}
const otherOpenThread = await threads.findOpenThreadByUserId(thread.user_id);
if (otherOpenThread) {
thread.postSystemMessage(`Cannot unsuspend; there is another open thread with this user: <#${otherOpenThread.channel_id}>.`);
return;
}
await thread.unsuspend();
thread.postSystemMessage(`**Thread unsuspended!**.`);
});
};
|