Added support for url lists

This commit is contained in:
zneix 2021-03-23 03:02:31 +01:00
parent 56bb0d47a2
commit 2ad6627e02
WARNING! Although there is a key with this ID in the database it does not verify this commit! This commit is SUSPICIOUS.
GPG key ID: 911916E0523B22F6
2 changed files with 51 additions and 27 deletions

View file

@ -2,6 +2,7 @@
"Username": "",
"Password": "",
"PNSLToken": "",
"UsePNSL": true,
"Users": [],
"Prefix": "!!",
"MaxConnections": 30,

View file

@ -19,6 +19,8 @@ const pnslClient = createGotClient({
},
});
const urlClient = createGotClient();
const fetchList = async (list) => {
const listID = uuidRegex.exec(list)?.[0];
if (!listID) {
@ -44,6 +46,19 @@ const fetchList = async (list) => {
return {listMeta, listData};
};
const fetchUrlList = async (list) => {
const {body: listMetaBody, statusCode} = await urlClient(list);
if (statusCode === 404) {
throw new Error('List was not found.');
}
if (statusCode !== 200) {
throw new Error('Unexpected error occured!');
}
return listMetaBody;
};
const runList = async (listData, listID, channel) => {
const banArr = listData.split('\n');
@ -106,6 +121,7 @@ const say = (channel, message) => {
getConnection().say(channel, message);
};
if (Config.UsePNSL){
const pnslWebSocket = new WS('wss://bot.tetyys.com/api/wss', [], {headers: {Authorization: `Bearer ${Config.PNSLToken}`}});
pnslWebSocket.on('open', () => {
@ -133,6 +149,7 @@ pnslWebSocket.on('message', async (data) => {
break;
}
});
}
(async () => {
await Promise.all([...Array(Config.MaxConnections)].map(async (_, i) => {
@ -193,8 +210,14 @@ pnslWebSocket.on('message', async (data) => {
const mods = await getConnection().getMods(channel);
if (!mods.includes(Config.Username)) return say(Config.Username, `I am not a moderator in channel ${channel}!`);
}
if (Config.UsePNSL) {
const data = await fetchList(listID);
await runList(data.listData, listID, channel || channelName);
}
else {
const data = await fetchUrlList(listID);
await runList(data, listID, channel || channelName);
}
say(Config.Username, `List ${listID} executed successfully on channel ${channel || channelName}`);
} catch (error) {
console.error(error);