shane/AutoMod
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

make /purge user filter work with uncached users

Browse source
This commit is contained in:
Jan 2022-11-27 19:27:00 +01:00
parent a26d11d832
commit 3dc10d34a4
No known key found for this signature in database
GPG key ID: 5D5E18ACB990F57A
1 changed files with 48 additions and 26 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

72
bot/src/bot/commands/moderation/purge.ts
View file

@ -1,29 +1,33 @@
import SimpleCommand from "../../../struct/commands/SimpleCommand";
import { Message } from "@janderedev/revolt.js/dist/maps/Messages";
import { decodeTime } from 'ulid';
import { isModerator, parseUser } from "../../util";
import { isModerator, parseUserOrId } from "../../util";
import MessageCommandContext from "../../../struct/MessageCommandContext";
import CommandCategory from "../../../struct/commands/CommandCategory";
const SYNTAX = '/purge [number] [user[,user...]]';
const SYNTAX = "/purge [number] [user[,user...]]";
const MAX_PURGE_AMOUNT = 100;
export default {
name: 'purge',
aliases: [ 'clear' ],
description: 'Mass delete messages',
name: "purge",
aliases: ["clear"],
description: "Mass delete messages",
syntax: SYNTAX,
category: CommandCategory.Moderation,
run: async (message: MessageCommandContext, args: string[]) => {
try {
if (!message.member || !await isModerator(message)) return message.reply('🔒 Access denied');
if (!message.member || !(await isModerator(message)))
return message.reply("🔒 Access denied");
let messages: Array<Message> = [];
// X amount of messages from bottom
if (/^[0-9]+$/g.test(args[0])) {
let amount = Number(args[0]);
if (isNaN(amount)) return message.reply('Invalid number');
if (amount > MAX_PURGE_AMOUNT) return message.reply(`Message count exceeds the limit of ${MAX_PURGE_AMOUNT}.`);
if (isNaN(amount)) return message.reply("Invalid number");
if (amount > MAX_PURGE_AMOUNT)
return message.reply(
`Message count exceeds the limit of ${MAX_PURGE_AMOUNT}.`
);
messages = await message.channel!.fetchMessages({
limit: amount,
@ -32,8 +36,12 @@ export default {
}
// delete messages between [id] and [id]
// [0-9A-HJ-KM-NP-TV-Z]{26} -> matches ULIDs
else if (/^[0-9A-HJ-KM-NP-TV-Z]{26}-[0-9A-HJ-KM-NP-TV-Z]{26}$/g.test(args[0])) {
let [id1, id2] = args[0].split('-');
else if (
/^[0-9A-HJ-KM-NP-TV-Z]{26}-[0-9A-HJ-KM-NP-TV-Z]{26}$/g.test(
args[0]
)
) {
let [id1, id2] = args[0].split("-");
let [msg1, msg2] = await Promise.all([
message.channel!.fetchMessage(id1),
@ -49,39 +57,51 @@ export default {
before: id2,
after: id1,
limit: MAX_PURGE_AMOUNT,
sort: 'Latest',
sort: "Latest",
});
if (!messages.find(m => m._id == msg1._id)) messages = [ msg1, ...messages ];
if (!messages.find(m => m._id == msg2._id)) messages = [ ...messages, msg2 ];
if (!messages.find((m) => m._id == msg1._id))
messages = [msg1, ...messages];
if (!messages.find((m) => m._id == msg2._id))
messages = [...messages, msg2];
// Discard messages that are not in the selected range,
// because Revolt returns more messages than expected for some reason
messages = messages.filter(
m => decodeTime(m._id) <= decodeTime(id2) &&
(m) =>
decodeTime(m._id) <= decodeTime(id2) &&
decodeTime(m._id) >= decodeTime(id1)
);
}
// allow single messages too, because why not?
else if (/^[0-9A-HJ-KM-NP-TV-Z]{26}$/g.test(args[0])) {
messages = [ await message.channel!.fetchMessage(args[0]) ];
messages = [await message.channel!.fetchMessage(args[0])];
} else {
return message.reply(`I can't parse that message range.\nSyntax: \`${SYNTAX}\``);
return message.reply(
`I can't parse that message range.\nSyntax: \`${SYNTAX}\``
);
}
if (args[1]) {
let p = args[1].split(',').map(u => parseUser(u));
let p = args[1].split(",").map((u) => parseUserOrId(u));
let users = await Promise.all(p);
if (users.filter(u => !u).length > 0)
return message.reply('At least one of the supplied users could not be found.');
if (users.filter((u) => !u).length > 0)
return message.reply(
"At least one of the supplied users could not be found."
);
messages = messages.filter(m => users.find(u => u?._id == m.author_id));
messages = messages.filter((m) =>
users.find((u) => u?._id == m.author_id)
);
}
await message.channel?.deleteMessages(messages.map(m => m._id));
await message.channel?.deleteMessages(messages.map((m) => m._id));
const replyMsg = await message.channel?.sendMessage({ content: `Deleted ${messages.length} messages.` })
const replyMsg = await message.channel
?.sendMessage({
content: `Deleted ${messages.length} messages.`,
})
.catch(console.error);
setTimeout(async () => {
@ -90,11 +110,13 @@ export default {
replyMsg!._id,
message._id,
]);
} catch(e) { console.error(e) }
} catch (e) {
console.error(e);
}
}, 6000);
} catch(e) {
} catch (e) {
console.error(e);
message.channel?.sendMessage(`An error has occurred: ${e}`);
}
}
},
} as SimpleCommand;