Compare commits
26 Commits
alt
...
8503f274bd
| Author | SHA1 | Date | |
|---|---|---|---|
| 8503f274bd | |||
| f5ab2b4297 | |||
| 983f742f0d | |||
| 84482be886 | |||
| 3d69a9375e | |||
| 39deb13f5a | |||
| ab76d7edbc | |||
| 343ed640ae | |||
| b1d01b414e | |||
| 17643dc730 | |||
| f225bf924a | |||
| 9da9650f92 | |||
| a1a387880c | |||
| 943512d354 | |||
| edb786ec04 | |||
| 525904de5a | |||
| 4fdb233bd6 | |||
| 00c3fa8219 | |||
| 610ca41195 | |||
| 827dafbb99 | |||
| 3ed56b7927 | |||
| e444167f07 | |||
| fcdf8dea06 | |||
| 148d93aaab | |||
| 81ea71328a | |||
| cf453957e9 |
55
.eslintrc.json
Normal file
55
.eslintrc.json
Normal file
@@ -0,0 +1,55 @@
|
||||
{
|
||||
"root": true,
|
||||
"extends": [
|
||||
"eslint:recommended",
|
||||
"plugin:@typescript-eslint/recommended"
|
||||
],
|
||||
"parser": "@typescript-eslint/parser",
|
||||
"parserOptions": { "project": ["./tsconfig.json"] },
|
||||
"plugins": [
|
||||
"@typescript-eslint"
|
||||
],
|
||||
"rules": {
|
||||
"@typescript-eslint/strict-boolean-expressions": [
|
||||
2,
|
||||
{
|
||||
"allowString" : false,
|
||||
"allowNumber" : false
|
||||
}
|
||||
],
|
||||
/* important */
|
||||
"prefer-const": "error",
|
||||
"quotes": ["error", "single"],
|
||||
|
||||
"block-scoped-var": "error",
|
||||
"camelcase": "error",
|
||||
"consistent-this": ["error", "that"],
|
||||
"no-else-return": "error",
|
||||
"no-eq-null": "error",
|
||||
"no-floating-decimal": "error",
|
||||
"no-implicit-coercion": "error",
|
||||
"no-implied-eval": "error",
|
||||
"no-invalid-this": "error",
|
||||
"require-await": "error",
|
||||
"yoda": "error",
|
||||
|
||||
"semi": ["error", "always"],
|
||||
"semi-style": ["error", "last"],
|
||||
|
||||
/* less important */
|
||||
"no-unreachable-loop": "error",
|
||||
"no-unused-private-class-members": "error",
|
||||
"no-use-before-define": "error",
|
||||
"no-unmodified-loop-condition": "error",
|
||||
"no-duplicate-imports": "error",
|
||||
"no-promise-executor-return": "error",
|
||||
"no-self-compare": "error",
|
||||
"no-constructor-return": "error",
|
||||
"no-template-curly-in-string": "error",
|
||||
"array-callback-return": "error",
|
||||
"no-eval": "error",
|
||||
"no-extend-native": "error",
|
||||
"no-extra-bind": "error"
|
||||
},
|
||||
"ignorePatterns": ["src/**/*.test.ts", "src/frontend/generated/*"]
|
||||
}
|
||||
8
.gitignore
vendored
8
.gitignore
vendored
@@ -1,4 +1,6 @@
|
||||
node_modules
|
||||
token
|
||||
.DS_Store
|
||||
log
|
||||
.vscode
|
||||
log
|
||||
node_modules
|
||||
queues.json
|
||||
token.txt
|
||||
@@ -2,6 +2,10 @@
|
||||
|
||||
# 1800queue
|
||||
|
||||
## Invite info
|
||||
|
||||
needs: create commands/send messages
|
||||
|
||||
## Prerequirements
|
||||
|
||||
Download and install [Node.js](https://nodejs.org/en/)
|
||||
|
||||
68
dist/api.js
vendored
68
dist/api.js
vendored
@@ -23,6 +23,7 @@ var __importDefault = (this && this.__importDefault) || function (mod) {
|
||||
};
|
||||
Object.defineProperty(exports, "__esModule", { value: true });
|
||||
exports.getPlayerInteraction = exports.getPlayer = void 0;
|
||||
/*eslint prefer-const: "error"*/
|
||||
const cheerio = __importStar(require("cheerio"));
|
||||
const discord_js_1 = require("discord.js");
|
||||
const https_1 = __importDefault(require("https"));
|
||||
@@ -73,25 +74,25 @@ function getHTML(name) {
|
||||
* @throws errorMessage class if the request fails
|
||||
*/
|
||||
function readHTML(html) {
|
||||
let $ = cheerio.load(html);
|
||||
let metaElems = $('meta').toArray(), foundData = {
|
||||
name: "",
|
||||
id: "",
|
||||
avatar: "",
|
||||
level: "",
|
||||
rank: "",
|
||||
const $ = cheerio.load(html), foundData = {
|
||||
name: '',
|
||||
id: '',
|
||||
avatar: '',
|
||||
level: '',
|
||||
rank: '',
|
||||
elo: null,
|
||||
class: null,
|
||||
battles: "",
|
||||
wins: "",
|
||||
winrate: ""
|
||||
battles: '',
|
||||
wins: '',
|
||||
winrate: ''
|
||||
};
|
||||
let metaElems = $('meta').toArray();
|
||||
//filter down to just ones named "og:..."
|
||||
metaElems = metaElems.filter(el => el.attribs.property?.startsWith('og:'));
|
||||
metaElems.forEach(el => {
|
||||
let attr = el.attribs;
|
||||
const attr = el.attribs;
|
||||
if (attr.property === 'og:title') {
|
||||
let data = uniteApiRegex.ogtitle.exec(attr.content);
|
||||
const data = uniteApiRegex.ogtitle.exec(attr.content);
|
||||
if (data !== null && data.length >= 3) {
|
||||
foundData.name = data[1];
|
||||
foundData.id = data[2];
|
||||
@@ -99,14 +100,15 @@ function readHTML(html) {
|
||||
}
|
||||
else if (attr.property === 'og:description') {
|
||||
//all lines
|
||||
let lines = attr.content.split('\n').map(l => l.trim()), extraLines = [];
|
||||
let lines = attr.content.split('\n').map(l => l.trim());
|
||||
const extraLines = [];
|
||||
//ensure first line is correct
|
||||
while (lines.length && !/pok.mon unite/i.test(lines[0])) {
|
||||
let line = lines.shift();
|
||||
if (line)
|
||||
while ((lines.length > 0) && !/pok.mon unite/i.test(lines[0])) {
|
||||
const line = lines.shift();
|
||||
if (line !== undefined)
|
||||
extraLines.push(line);
|
||||
}
|
||||
if (!lines.length)
|
||||
if (lines.length === 0)
|
||||
throw (0, util_1.emsg)('Unable to read data, please try again');
|
||||
//bring the first lines removed back into the data
|
||||
lines = [
|
||||
@@ -116,10 +118,9 @@ function readHTML(html) {
|
||||
//first line
|
||||
{
|
||||
//will be only text after "pokemon unite:"
|
||||
let line = lines[0].split(':').slice(1).join(':').trim();
|
||||
let regex = uniteApiRegex.ogdescription;
|
||||
const line = lines[0].split(':').slice(1).join(':').trim(), regex = uniteApiRegex.ogdescription;
|
||||
if (regex[0].test(line)) { //is master/has elo
|
||||
let regexData = line.match(regex[0]);
|
||||
const regexData = line.match(regex[0]);
|
||||
if (!regexData || regexData.length < 4)
|
||||
throw (0, util_1.emsg)('Unable to read data, please try again');
|
||||
foundData.level = regexData[1];
|
||||
@@ -127,7 +128,7 @@ function readHTML(html) {
|
||||
foundData.elo = regexData[3];
|
||||
}
|
||||
else { //is not master/has a class
|
||||
let regexData = line.match(regex[1]);
|
||||
const regexData = line.match(regex[1]);
|
||||
if (!regexData || regexData.length < 4)
|
||||
throw (0, util_1.emsg)('Unable to read data, please try again');
|
||||
foundData.level = regexData[1];
|
||||
@@ -138,7 +139,7 @@ function readHTML(html) {
|
||||
lines.shift();
|
||||
//rest of lines
|
||||
lines.forEach(line => {
|
||||
let split = line.split(':').map(l => l.trim()), key = split[0].toLowerCase().replace(/[^\w]/g, ''), value = split[1];
|
||||
const split = line.split(':').map(l => l.trim()), key = split[0].toLowerCase().replace(/[^\w]/g, ''), value = split[1];
|
||||
switch (key) {
|
||||
case 'battles':
|
||||
foundData.battles = value;
|
||||
@@ -153,7 +154,8 @@ function readHTML(html) {
|
||||
});
|
||||
}
|
||||
});
|
||||
foundData.avatar = $('.player-card-image img').attr('src') || "";
|
||||
const imgSrc = $('.player-card-image img').attr('src');
|
||||
foundData.avatar = imgSrc !== undefined ? imgSrc : '';
|
||||
foundData.avatar = foundData.avatar.replace('../', 'https://uniteapi.dev/');
|
||||
return foundData;
|
||||
}
|
||||
@@ -163,7 +165,7 @@ function readHTML(html) {
|
||||
* @returns boolean, valid or invalid
|
||||
*/
|
||||
function verifyData(data) {
|
||||
if (data.id.length)
|
||||
if (data.id.length > 0)
|
||||
return true;
|
||||
return false;
|
||||
}
|
||||
@@ -173,21 +175,25 @@ function verifyData(data) {
|
||||
* @returns player data
|
||||
*/
|
||||
async function getPlayer(name) {
|
||||
let html = await getHTML(name);
|
||||
let data = readHTML(html);
|
||||
const html = await getHTML(name), data = readHTML(html);
|
||||
if (verifyData(data))
|
||||
return data;
|
||||
return null;
|
||||
}
|
||||
exports.getPlayer = getPlayer;
|
||||
async function sendPlayerEmbed(interaction, data) {
|
||||
let embed = new discord_js_1.MessageEmbed()
|
||||
let eloStr;
|
||||
if (data.elo !== null)
|
||||
eloStr = `(${data.elo})`;
|
||||
else
|
||||
eloStr = `Class ${data.class}`;
|
||||
const embed = new discord_js_1.MessageEmbed()
|
||||
.setTitle(`${data.name} (${data.id})`)
|
||||
.setURL(`https://uniteapi.dev/p/${encodeURIComponent(data.name)}`)
|
||||
.setTimestamp()
|
||||
.setThumbnail(data.avatar)
|
||||
.setDescription(`Level ${data.level}
|
||||
${data.rank} ${data.elo ? `(${data.elo})` : `Class ${data.class}`}
|
||||
${data.rank} ${eloStr}
|
||||
|
||||
**Battles** ${data.battles}
|
||||
**Wins** ${data.wins}
|
||||
@@ -200,11 +206,11 @@ ${data.rank} ${data.elo ? `(${data.elo})` : `Class ${data.class}`}
|
||||
* @throws errorMessage class if the user cannot be found
|
||||
*/
|
||||
async function getPlayerInteraction(interaction) {
|
||||
let username = interaction.options.getString('username', true);
|
||||
const username = interaction.options.getString('username', true);
|
||||
await interaction.deferReply();
|
||||
let data = await getPlayer(username);
|
||||
const data = await getPlayer(username);
|
||||
if (data === null)
|
||||
throw (0, util_1.emsg)('Unable to find user');
|
||||
throw (0, util_1.emsg)('api.noUser');
|
||||
else
|
||||
sendPlayerEmbed(interaction, data);
|
||||
}
|
||||
|
||||
27
dist/discord.js
vendored
27
dist/discord.js
vendored
@@ -1,23 +1,32 @@
|
||||
"use strict";
|
||||
Object.defineProperty(exports, "__esModule", { value: true });
|
||||
exports.registerCommands = void 0;
|
||||
/* eslint-disable camelcase */
|
||||
const rest_1 = require("@discordjs/rest");
|
||||
const v9_1 = require("discord-api-types/v9");
|
||||
// list of commands to register with discord
|
||||
const commands = [
|
||||
{
|
||||
name: 'queue',
|
||||
description: 'create a queue',
|
||||
name: 'open',
|
||||
description: 'open a queue for this channel',
|
||||
options: [
|
||||
{
|
||||
type: 4,
|
||||
name: 'teamsize',
|
||||
description: 'size of each team',
|
||||
required: true,
|
||||
min_value: 1
|
||||
min_value: 1,
|
||||
required: true
|
||||
}
|
||||
]
|
||||
},
|
||||
{
|
||||
name: 'close',
|
||||
description: 'close the queue for this channel'
|
||||
},
|
||||
{
|
||||
name: 'queue',
|
||||
description: 'view queue info'
|
||||
},
|
||||
{
|
||||
name: 'join',
|
||||
description: 'join the active queue'
|
||||
@@ -26,14 +35,6 @@ const commands = [
|
||||
name: 'leave',
|
||||
description: 'leave the active queue'
|
||||
},
|
||||
{
|
||||
name: 'ready',
|
||||
description: 'ready the queue and display team info'
|
||||
},
|
||||
{
|
||||
name: 'cancel',
|
||||
description: 'cancels the current queue (must have the Manage Messages permission)'
|
||||
},
|
||||
{
|
||||
name: 'player',
|
||||
description: 'display player information',
|
||||
@@ -47,6 +48,7 @@ const commands = [
|
||||
]
|
||||
}
|
||||
];
|
||||
/*commandNames = commands.map(c => c.name);*/
|
||||
/**
|
||||
* register/reload commands on guild(s)
|
||||
* @param token discord bot token
|
||||
@@ -60,7 +62,6 @@ async function registerCommands(token, clientId, guildIds) {
|
||||
for (let i = 0; i < guildIds.length; i++) {
|
||||
try {
|
||||
await rest.put(v9_1.Routes.applicationGuildCommands(clientId, guildIds[i]), { body: commands });
|
||||
console.log(`[${guildIds[i]}] registered command`);
|
||||
}
|
||||
catch (error) {
|
||||
console.error(error);
|
||||
|
||||
52
dist/index.js
vendored
52
dist/index.js
vendored
@@ -23,39 +23,57 @@ const discord_js_1 = require("discord.js");
|
||||
const fs = __importStar(require("fs"));
|
||||
const api_1 = require("./api");
|
||||
const discord_1 = require("./discord");
|
||||
const Lang = __importStar(require("./lang"));
|
||||
const queue_1 = require("./queue");
|
||||
const util_1 = require("./util");
|
||||
const CLIENT = new discord_js_1.Client({ intents: [discord_js_1.Intents.FLAGS.GUILDS] });
|
||||
//init logs with a timestamp
|
||||
console.log(new Date().toISOString() + '\n\n');
|
||||
//get token
|
||||
if (!fs.existsSync('./token')) {
|
||||
fs.writeFileSync('./token', '');
|
||||
console.error('Missing Discord Token, please enter the bot token into the token file');
|
||||
if (!fs.existsSync('./token.txt')) {
|
||||
fs.writeFileSync('./token.txt', '');
|
||||
console.error(Lang.get('error.main.missingToken'));
|
||||
process.exit(1);
|
||||
}
|
||||
const TOKEN = fs.readFileSync('./token').toString();
|
||||
const TOKEN = fs.readFileSync('./token.txt').toString();
|
||||
//discord connections
|
||||
CLIENT.on('ready', client => {
|
||||
console.log(`Logged in as ${client.user.tag}`);
|
||||
console.log(Lang.get('main.login', {
|
||||
user: client.user.tag
|
||||
}));
|
||||
client.guilds.fetch().then(guilds => (0, discord_1.registerCommands)(TOKEN, client.user.id, guilds.map(g => g.id)));
|
||||
(0, queue_1.discordInit)(client);
|
||||
});
|
||||
CLIENT.on('guildCreate', guild => {
|
||||
if (guild.client.user)
|
||||
(0, discord_1.registerCommands)(TOKEN, guild.client.user.id, guild.id);
|
||||
});
|
||||
CLIENT.on('interactionCreate', async (interaction) => {
|
||||
if (!interaction.isCommand())
|
||||
return;
|
||||
try {
|
||||
if (interaction.commandName === 'queue')
|
||||
await (0, queue_1.createQueue)(interaction);
|
||||
else if (interaction.commandName === 'join')
|
||||
await (0, queue_1.joinQueue)(interaction);
|
||||
else if (interaction.commandName === 'leave')
|
||||
await (0, queue_1.leaveQueue)(interaction);
|
||||
else if (interaction.commandName === 'ready')
|
||||
await (0, queue_1.readyQueue)(interaction);
|
||||
else if (interaction.commandName === 'cancel')
|
||||
await (0, queue_1.cancelQueue)(interaction);
|
||||
else if (interaction.commandName === 'player')
|
||||
await (0, api_1.getPlayerInteraction)(interaction);
|
||||
switch (interaction.commandName) {
|
||||
//mod commands
|
||||
case 'open':
|
||||
await queue_1.QueueCommands.open(interaction);
|
||||
break;
|
||||
case 'close':
|
||||
await queue_1.QueueCommands.close(interaction);
|
||||
break;
|
||||
//general commands
|
||||
case 'queue':
|
||||
await queue_1.QueueCommands.queue(interaction);
|
||||
break;
|
||||
case 'join':
|
||||
await queue_1.QueueCommands.join(interaction);
|
||||
break;
|
||||
case 'leave':
|
||||
await queue_1.QueueCommands.leave(interaction);
|
||||
break;
|
||||
case 'player':
|
||||
await (0, api_1.getPlayerInteraction)(interaction);
|
||||
break;
|
||||
}
|
||||
}
|
||||
catch (e) {
|
||||
if (e instanceof util_1.errorMessage) {
|
||||
|
||||
76
dist/lang.js
vendored
Normal file
76
dist/lang.js
vendored
Normal file
@@ -0,0 +1,76 @@
|
||||
"use strict";
|
||||
Object.defineProperty(exports, "__esModule", { value: true });
|
||||
exports.get = exports.setLang = void 0;
|
||||
const LANG = {
|
||||
en: {
|
||||
main: {
|
||||
login: 'Logged in as {user}'
|
||||
},
|
||||
discord: {
|
||||
botRestart: 'The bot has just restarted, anybody previously in the queue has been reset',
|
||||
create: 'A queue for teams of {teamsize} has been created',
|
||||
close: 'Queue has been closed',
|
||||
join: 'Joined the queue',
|
||||
leave: 'Left the queue'
|
||||
},
|
||||
error: {
|
||||
main: {
|
||||
missingToken: 'Missing Discord Token, please enter the bot token into the token file'
|
||||
},
|
||||
discord: {
|
||||
noQueue: 'There is not an active queue in this channel, type `/open` to create one',
|
||||
noChannel: 'Unable to find channel {channelId} for teams of {teamsize}',
|
||||
noCreate: 'There is already an active queue in this channel for teams of {teamsize}',
|
||||
inQueue: 'You are already in the queue',
|
||||
notInQueue: 'You aren\'t in the queue',
|
||||
notMod: 'Member is not a moderator'
|
||||
},
|
||||
general: {
|
||||
noMember: 'Unable to retrieve guild member information, please try again',
|
||||
noChannel: 'Unable to retrieve text channel information, please try again'
|
||||
},
|
||||
api: {
|
||||
noUser: 'Unable to find user'
|
||||
}
|
||||
}
|
||||
}
|
||||
};
|
||||
let LANGID = 'en';
|
||||
if (!(LANGID in LANG))
|
||||
throw 'language id does not exist';
|
||||
function setLang(langid) {
|
||||
if (langid in LANG)
|
||||
LANGID = langid;
|
||||
else
|
||||
throw 'language id does not exist';
|
||||
}
|
||||
exports.setLang = setLang;
|
||||
function template(str, args) {
|
||||
return str.replace(/{\w+}/g, str => {
|
||||
const key = str.substring(1, str.length - 1);
|
||||
if (key in args)
|
||||
return args[key];
|
||||
return key;
|
||||
});
|
||||
}
|
||||
/**
|
||||
* reads language json
|
||||
* @param id ex: discord.error.noActiveQueue
|
||||
* @returns language value, defaults to `id` parameter
|
||||
*/
|
||||
function get(id, args = {}) {
|
||||
const keySpl = id.split('.').map(k => k.trim()).filter(k => k);
|
||||
let finding = LANG[LANGID];
|
||||
for (const key of keySpl) {
|
||||
if (key in finding) {
|
||||
const found = finding[key];
|
||||
if (typeof found === 'string')
|
||||
return template(found, args);
|
||||
finding = found;
|
||||
}
|
||||
else
|
||||
break;
|
||||
}
|
||||
return id;
|
||||
}
|
||||
exports.get = get;
|
||||
296
dist/queue.js
vendored
296
dist/queue.js
vendored
@@ -1,10 +1,101 @@
|
||||
"use strict";
|
||||
/* TODO
|
||||
|
||||
join message should contain your current position in the queue, editing it to keep it current
|
||||
*/
|
||||
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
|
||||
if (k2 === undefined) k2 = k;
|
||||
Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
|
||||
}) : (function(o, m, k, k2) {
|
||||
if (k2 === undefined) k2 = k;
|
||||
o[k2] = m[k];
|
||||
}));
|
||||
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
|
||||
Object.defineProperty(o, "default", { enumerable: true, value: v });
|
||||
}) : function(o, v) {
|
||||
o["default"] = v;
|
||||
});
|
||||
var __importStar = (this && this.__importStar) || function (mod) {
|
||||
if (mod && mod.__esModule) return mod;
|
||||
var result = {};
|
||||
if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
|
||||
__setModuleDefault(result, mod);
|
||||
return result;
|
||||
};
|
||||
Object.defineProperty(exports, "__esModule", { value: true });
|
||||
exports.cancelQueue = exports.readyQueue = exports.leaveQueue = exports.joinQueue = exports.createQueue = exports.queueContains = exports.getAll = exports.getInfo = void 0;
|
||||
exports.QueueCommands = exports.queueContains = exports.discordInit = exports.queueRemove = exports.queueCreate = void 0;
|
||||
const discord_js_1 = require("discord.js");
|
||||
const fs = __importStar(require("fs"));
|
||||
const util_1 = require("./util");
|
||||
//maps ChannelID to QueueInfo
|
||||
const QUEUE = new Map();
|
||||
const Lang = __importStar(require("./lang"));
|
||||
//load queues from file
|
||||
if (!fs.existsSync('./queues.json'))
|
||||
fs.writeFileSync('./queues.json', '{}');
|
||||
const _QUEUE = fs.readFileSync('./queues.json').toString(), QUEUE = new Map();
|
||||
try {
|
||||
const queueJson = JSON.parse(_QUEUE);
|
||||
for (const channelId in queueJson) {
|
||||
const { teamsize } = queueJson[channelId];
|
||||
if (teamsize !== 0)
|
||||
QUEUE.set(channelId, { teamsize, players: [] });
|
||||
}
|
||||
}
|
||||
catch (e) {
|
||||
//do nothing
|
||||
}
|
||||
function SaveQueue() {
|
||||
const queueJson = Object.fromEntries(QUEUE), queueFileJson = {};
|
||||
for (const channelId of QUEUE.keys())
|
||||
queueFileJson[channelId] = { teamsize: queueJson[channelId].teamsize };
|
||||
fs.writeFileSync('./queues.json', JSON.stringify(queueFileJson, null, 2));
|
||||
}
|
||||
async function checkQueue(channel) {
|
||||
const info = QUEUE.get(channel.id);
|
||||
if (!info)
|
||||
return;
|
||||
if (info.players.length >= info.teamsize) {
|
||||
const team = info.players.splice(0, info.teamsize).map(m => m.toString());
|
||||
//TODO add embeds to lang.ts
|
||||
const embed = new discord_js_1.MessageEmbed()
|
||||
.setTitle('Team')
|
||||
.setDescription(team.join('\n'));
|
||||
await channel.send({ embeds: [embed] });
|
||||
}
|
||||
}
|
||||
function queueCreate(channelId, teamsize) {
|
||||
if (!QUEUE.has(channelId)) {
|
||||
QUEUE.set(channelId, { teamsize, players: [] });
|
||||
SaveQueue();
|
||||
}
|
||||
}
|
||||
exports.queueCreate = queueCreate;
|
||||
function queueRemove(channelId) {
|
||||
if (QUEUE.has(channelId)) {
|
||||
QUEUE.delete(channelId);
|
||||
SaveQueue();
|
||||
}
|
||||
}
|
||||
exports.queueRemove = queueRemove;
|
||||
SaveQueue();
|
||||
async function discordInit(client) {
|
||||
for (const channelId of QUEUE.keys()) {
|
||||
const info = QUEUE.get(channelId), channel = await client.channels.fetch(channelId);
|
||||
if (!info) { //no idea what could cause this but TS complains
|
||||
queueRemove(channelId);
|
||||
continue;
|
||||
}
|
||||
if (!channel || !(channel instanceof discord_js_1.TextChannel)) {
|
||||
console.error(Lang.get('error.discord.noChannel'), {
|
||||
channelId,
|
||||
teamsize: info.teamsize
|
||||
});
|
||||
queueRemove(channelId);
|
||||
continue;
|
||||
}
|
||||
channel.send(Lang.get('discord.botRestart'));
|
||||
}
|
||||
}
|
||||
exports.discordInit = discordInit;
|
||||
/**
|
||||
* get the queueInfo of an interaction
|
||||
* @param interaction
|
||||
@@ -12,12 +103,11 @@ const QUEUE = new Map();
|
||||
* @returns queue info
|
||||
*/
|
||||
function getInfo(interaction) {
|
||||
let info = QUEUE.get(interaction.channelId);
|
||||
const info = QUEUE.get(interaction.channelId);
|
||||
if (!info)
|
||||
throw (0, util_1.emsg)('There is not an active queue in this channel, type `/queue` to create one');
|
||||
throw (0, util_1.emsg)('discord.noQueue');
|
||||
return info;
|
||||
}
|
||||
exports.getInfo = getInfo;
|
||||
/**
|
||||
* compiles all the get functions above
|
||||
* @param interaction
|
||||
@@ -29,161 +119,91 @@ const getAll = (interaction) => ({
|
||||
channel: (0, util_1.getChannel)(interaction),
|
||||
info: getInfo(interaction)
|
||||
});
|
||||
exports.getAll = getAll;
|
||||
/**
|
||||
* checks if the interaction data is already in the queue
|
||||
* @param interaction
|
||||
* @returns boolean
|
||||
*/
|
||||
function queueContains(interaction) {
|
||||
let { member, info } = (0, exports.getAll)(interaction);
|
||||
const { member, info } = getAll(interaction);
|
||||
if (info.players.map(m => m.id).includes(member.id))
|
||||
return true;
|
||||
return false;
|
||||
}
|
||||
exports.queueContains = queueContains;
|
||||
/**
|
||||
* creates the timeout for the queue
|
||||
* @param interaction
|
||||
* @returns time timeout identifier
|
||||
*/
|
||||
function setQueueTimeout(interaction) {
|
||||
let channel = (0, util_1.getChannel)(interaction);
|
||||
return setTimeout(() => {
|
||||
clearQueue(interaction);
|
||||
channel.send('Queue has been reset due to inactivity');
|
||||
}, 5 * 60 * 1000); //5 minutes
|
||||
}
|
||||
/**
|
||||
* updates the rich embed for the current queue
|
||||
* @param interaction
|
||||
*/
|
||||
async function sendQueueEmbed(interaction, closed = false) {
|
||||
let info = getInfo(interaction), origInteraction = info.initiator.interaction;
|
||||
let embed = new discord_js_1.MessageEmbed()
|
||||
.setTitle('Queue')
|
||||
.setAuthor({
|
||||
name: info.initiator.member.displayName,
|
||||
iconURL: info.initiator.member.displayAvatarURL({ dynamic: true })
|
||||
})
|
||||
.addField('Team Size', info.teamsize.toString(), true)
|
||||
.addField('Players Joined', info.players.length.toString(), true)
|
||||
.setFooter({ text: closed ? 'queue is finished' : 'type /join' });
|
||||
if (origInteraction.deferred || origInteraction.replied)
|
||||
await origInteraction.editReply({ embeds: [embed] });
|
||||
else
|
||||
await origInteraction.reply({ embeds: [embed] });
|
||||
}
|
||||
/**
|
||||
* sends the list of teams
|
||||
* @param interaction
|
||||
*/
|
||||
async function sendTeamsEmbed(interaction, teams) {
|
||||
let embed = new discord_js_1.MessageEmbed()
|
||||
.setTitle('Teams');
|
||||
teams.forEach((team, i) => {
|
||||
team.map(m => m.user.tag);
|
||||
embed.addField(`Title ${i + 1}`, team.join('\n'));
|
||||
});
|
||||
interaction.reply({ embeds: [embed] });
|
||||
}
|
||||
/**
|
||||
* sends the list of teams
|
||||
* @param interaction
|
||||
*/
|
||||
async function clearQueue(interaction) {
|
||||
let info = getInfo(interaction);
|
||||
sendQueueEmbed(interaction, true);
|
||||
clearTimeout(info.timeout);
|
||||
QUEUE.delete(interaction.channelId);
|
||||
}
|
||||
/**
|
||||
* creates a queue from an interaction
|
||||
* @param interaction
|
||||
* @throws errorMessage class if it cannot be created
|
||||
*/
|
||||
async function createQueue(interaction) {
|
||||
let member = (0, util_1.getMember)(interaction), { channelId } = interaction, teamsize = interaction.options.getInteger('teamsize', true);
|
||||
if (QUEUE.has(channelId))
|
||||
throw (0, util_1.emsg)('There is already an active queue in this channel, ' + (queueContains(interaction) ? 'and you are already in it' : 'type `/join` to join'));
|
||||
QUEUE.set(channelId, {
|
||||
players: [
|
||||
member
|
||||
],
|
||||
initiator: {
|
||||
interaction,
|
||||
member
|
||||
},
|
||||
teamsize: teamsize,
|
||||
timeout: setQueueTimeout(interaction)
|
||||
});
|
||||
sendQueueEmbed(interaction);
|
||||
}
|
||||
exports.createQueue = createQueue;
|
||||
/**
|
||||
* joins a queue from an interaction
|
||||
* @param interaction
|
||||
* @throws errorMessage class if it cannot be joined
|
||||
*/
|
||||
async function joinQueue(interaction) {
|
||||
let { member, info } = (0, exports.getAll)(interaction);
|
||||
if (queueContains(interaction))
|
||||
throw (0, util_1.emsg)('You are already in the active queue');
|
||||
info.players.push(member);
|
||||
clearTimeout(info.timeout);
|
||||
info.timeout = setQueueTimeout(interaction);
|
||||
QUEUE.set(interaction.channelId, info);
|
||||
sendQueueEmbed(interaction);
|
||||
await interaction.reply('Joined the queue');
|
||||
}
|
||||
exports.joinQueue = joinQueue;
|
||||
/**
|
||||
* leaves a queue from an interaction
|
||||
* opens a queue
|
||||
* @param interaction
|
||||
* @throws errorMessage class if it cannot be left
|
||||
*/
|
||||
async function leaveQueue(interaction) {
|
||||
let { member, info } = (0, exports.getAll)(interaction);
|
||||
if (!queueContains(interaction))
|
||||
throw (0, util_1.emsg)('You aren\'t in the active queue');
|
||||
info.players.splice(info.players.indexOf(member), 1);
|
||||
clearTimeout(info.timeout);
|
||||
info.timeout = setQueueTimeout(interaction);
|
||||
QUEUE.set(interaction.channelId, info);
|
||||
sendQueueEmbed(interaction);
|
||||
await interaction.reply('Left the queue');
|
||||
function open(interaction) {
|
||||
(0, util_1.memberIsModThrow)(interaction);
|
||||
const { channelId } = interaction, teamsize = interaction.options.getInteger('teamsize', true);
|
||||
const existing = QUEUE.get(channelId);
|
||||
if (existing)
|
||||
throw (0, util_1.emsg)(Lang.get('error.discord.noCreate', {
|
||||
teamsize: existing.teamsize.toString()
|
||||
}));
|
||||
queueCreate(channelId, teamsize);
|
||||
interaction.reply(Lang.get('discord.create', {
|
||||
teamsize: teamsize.toString()
|
||||
}));
|
||||
}
|
||||
exports.leaveQueue = leaveQueue;
|
||||
/**
|
||||
* readys a queue from an interaction
|
||||
* closes a queue
|
||||
* @param interaction
|
||||
* @throws errorMessage class if it cannot be joined
|
||||
*/
|
||||
async function close(interaction) {
|
||||
(0, util_1.memberIsModThrow)(interaction);
|
||||
QUEUE.delete(interaction.channelId);
|
||||
await interaction.reply(Lang.get('discord.close'));
|
||||
}
|
||||
/**
|
||||
* gives info about the queue
|
||||
* @param interaction
|
||||
* @throws errorMessage class if it cannot be left
|
||||
*/
|
||||
async function queue(interaction) {
|
||||
const info = getInfo(interaction);
|
||||
const embed = new discord_js_1.MessageEmbed()
|
||||
.setTitle('Active Queue')
|
||||
.addField('Team Size', info.teamsize.toString(), true)
|
||||
.addField('Players Joined', info.players.length.toString(), true)
|
||||
.setFooter({ text: 'type /join' }); //TODO
|
||||
await interaction.reply({ embeds: [embed], ephemeral: true });
|
||||
}
|
||||
/**
|
||||
* joins a queue
|
||||
* @param interaction
|
||||
* @throws errorMessage class if it cannot be readied
|
||||
*/
|
||||
async function readyQueue(interaction) {
|
||||
let { member, info } = (0, exports.getAll)(interaction), { initiator } = info;
|
||||
if (member.id !== initiator.member.id)
|
||||
throw (0, util_1.emsg)('Only the queue initiator can ready the queue');
|
||||
clearQueue(interaction);
|
||||
if (info.players.filter(m => m.id !== initiator.member.id).length === 0)
|
||||
throw (0, util_1.emsg)('Nobody signed up for the queue, the queue has been reset');
|
||||
//team data
|
||||
let playerlist = (0, util_1.shuffle)(info.players), teams = [];
|
||||
//fill team data
|
||||
for (let i = 0; i < playerlist.length; i += info.teamsize)
|
||||
teams.push(playerlist.slice(i, i + info.teamsize));
|
||||
sendTeamsEmbed(interaction, teams);
|
||||
async function join(interaction) {
|
||||
const { member, info, channel } = getAll(interaction);
|
||||
if (queueContains(interaction))
|
||||
throw (0, util_1.emsg)('discord.inQueue');
|
||||
info.players.push(member);
|
||||
QUEUE.set(interaction.channelId, info);
|
||||
await interaction.reply(Lang.get('discord.join'));
|
||||
checkQueue(channel);
|
||||
}
|
||||
exports.readyQueue = readyQueue;
|
||||
/**
|
||||
* readys a queue from an interaction
|
||||
* leaves a queue
|
||||
* @param interaction
|
||||
* @throws errorMessage class if it cannot be reset
|
||||
*/
|
||||
async function cancelQueue(interaction) {
|
||||
let { info, member, channel } = (0, exports.getAll)(interaction);
|
||||
if (!member.permissionsIn(channel).has('MANAGE_MESSAGES'))
|
||||
throw (0, util_1.emsg)('You do not have permission to run this command');
|
||||
clearQueue(interaction);
|
||||
await interaction.reply('Queue has been reset');
|
||||
async function leave(interaction) {
|
||||
const { member, info } = getAll(interaction);
|
||||
if (!queueContains(interaction))
|
||||
throw (0, util_1.emsg)('discord.notInQueue');
|
||||
info.players.splice(info.players.indexOf(member), 1);
|
||||
QUEUE.set(interaction.channelId, info);
|
||||
await interaction.reply(Lang.get('discord.leave'));
|
||||
}
|
||||
exports.cancelQueue = cancelQueue;
|
||||
exports.QueueCommands = {
|
||||
open,
|
||||
close,
|
||||
queue,
|
||||
join,
|
||||
leave
|
||||
};
|
||||
|
||||
1
dist/queueCommands.js
vendored
Normal file
1
dist/queueCommands.js
vendored
Normal file
@@ -0,0 +1 @@
|
||||
"use strict";
|
||||
43
dist/util.js
vendored
43
dist/util.js
vendored
@@ -1,13 +1,34 @@
|
||||
"use strict";
|
||||
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
|
||||
if (k2 === undefined) k2 = k;
|
||||
Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
|
||||
}) : (function(o, m, k, k2) {
|
||||
if (k2 === undefined) k2 = k;
|
||||
o[k2] = m[k];
|
||||
}));
|
||||
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
|
||||
Object.defineProperty(o, "default", { enumerable: true, value: v });
|
||||
}) : function(o, v) {
|
||||
o["default"] = v;
|
||||
});
|
||||
var __importStar = (this && this.__importStar) || function (mod) {
|
||||
if (mod && mod.__esModule) return mod;
|
||||
var result = {};
|
||||
if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
|
||||
__setModuleDefault(result, mod);
|
||||
return result;
|
||||
};
|
||||
Object.defineProperty(exports, "__esModule", { value: true });
|
||||
exports.getChannel = exports.getMember = exports.emsg = exports.errorMessage = exports.shuffle = void 0;
|
||||
exports.memberIsModThrow = exports.memberIsMod = exports.getChannel = exports.getMember = exports.emsg = exports.errorMessage = exports.shuffle = void 0;
|
||||
const discord_js_1 = require("discord.js");
|
||||
const Lang = __importStar(require("./lang"));
|
||||
/**
|
||||
* shuffles an array
|
||||
* https://stackoverflow.com/a/2450976/2856416
|
||||
* @param array an array
|
||||
* @returns an array but shuffled
|
||||
*/
|
||||
// eslint-disable-next-line @typescript-eslint/no-explicit-any
|
||||
function shuffle(array) {
|
||||
let currentIndex = array.length, randomIndex;
|
||||
// While there remain elements to shuffle...
|
||||
@@ -36,7 +57,7 @@ exports.errorMessage = errorMessage;
|
||||
* @param ephemeral (default=true)
|
||||
* @returns new errorMessage
|
||||
*/
|
||||
const emsg = (msg, ephemeral = true) => new errorMessage(msg, ephemeral);
|
||||
const emsg = (msg, ephemeral = true) => new errorMessage(Lang.get(`error.${msg}`), ephemeral);
|
||||
exports.emsg = emsg;
|
||||
/**
|
||||
* get the GuildMember of an interaction
|
||||
@@ -45,9 +66,9 @@ exports.emsg = emsg;
|
||||
* @returns member
|
||||
*/
|
||||
function getMember(interaction) {
|
||||
let member = interaction.member;
|
||||
const member = interaction.member;
|
||||
if (!(member instanceof discord_js_1.GuildMember))
|
||||
throw (0, exports.emsg)('Unable to retrieve guild member information, please try again');
|
||||
throw (0, exports.emsg)('general.noMember');
|
||||
return member;
|
||||
}
|
||||
exports.getMember = getMember;
|
||||
@@ -58,9 +79,19 @@ exports.getMember = getMember;
|
||||
* @returns member
|
||||
*/
|
||||
function getChannel(interaction) {
|
||||
let channel = interaction.channel;
|
||||
const channel = interaction.channel;
|
||||
if (!(channel instanceof discord_js_1.TextChannel))
|
||||
throw (0, exports.emsg)('Unable to retrieve text channel information, please try again');
|
||||
throw (0, exports.emsg)('general.noChannel');
|
||||
return channel;
|
||||
}
|
||||
exports.getChannel = getChannel;
|
||||
function memberIsMod(interaction) {
|
||||
const member = getMember(interaction);
|
||||
return member.permissionsIn(interaction.channelId).has('MANAGE_MESSAGES');
|
||||
}
|
||||
exports.memberIsMod = memberIsMod;
|
||||
function memberIsModThrow(interaction) {
|
||||
if (!memberIsMod(interaction))
|
||||
throw (0, exports.emsg)('discord.notMod');
|
||||
}
|
||||
exports.memberIsModThrow = memberIsModThrow;
|
||||
|
||||
2472
package-lock.json
generated
2472
package-lock.json
generated
File diff suppressed because it is too large
Load Diff
@@ -30,7 +30,9 @@
|
||||
"author": "",
|
||||
"license": "MIT",
|
||||
"devDependencies": {
|
||||
"@types/node": "^17.0.13",
|
||||
"@types/node": "^17.0.17",
|
||||
"@typescript-eslint/eslint-plugin": "^5.11.0",
|
||||
"discord-api-types": "^0.26.1",
|
||||
"npm-watch": "^0.11.0",
|
||||
"ts-node": "^10.4.0",
|
||||
"typescript": "^4.5.5"
|
||||
@@ -38,7 +40,6 @@
|
||||
"dependencies": {
|
||||
"@discordjs/rest": "^0.3.0",
|
||||
"cheerio": "^1.0.0-rc.10",
|
||||
"discord-api-types": "^0.26.1",
|
||||
"discord.js": "^13.6.0"
|
||||
}
|
||||
}
|
||||
|
||||
@@ -8,11 +8,11 @@ cd ../..
|
||||
npm install
|
||||
|
||||
#discord token
|
||||
[ ! -f "token" ] && touch "token"
|
||||
[ ! -f "token.txt" ] && touch "token.txt"
|
||||
|
||||
if [ ! -s "token" ]
|
||||
if [ ! -s "token.txt" ]
|
||||
then
|
||||
printf "Enter your discord bot token: "
|
||||
read token
|
||||
printf $token > "token"
|
||||
printf $token > "token.txt"
|
||||
fi
|
||||
@@ -4,12 +4,12 @@
|
||||
cd %~f0\..\..\..\
|
||||
|
||||
@REM discord token
|
||||
if not exist "token" copy NUL "token"
|
||||
if not exist "token.txt" copy NUL "token.txt"
|
||||
|
||||
for /f %%i in ("token") do set size=%%~zi
|
||||
for /f %%i in ("token.txt") do set size=%%~zi
|
||||
if %size% equ 0 (
|
||||
set /p token="Enter your discord bot token: "
|
||||
echo | set /p=%id% > "token"
|
||||
echo | set /p=%id% > "token.txt"
|
||||
)
|
||||
|
||||
@REM run
|
||||
|
||||
76
src/api.ts
76
src/api.ts
@@ -1,3 +1,4 @@
|
||||
/*eslint prefer-const: "error"*/
|
||||
import * as cheerio from 'cheerio';
|
||||
import { CommandInteraction, MessageEmbed } from 'discord.js';
|
||||
import { IncomingMessage } from 'http';
|
||||
@@ -12,7 +13,7 @@ const uniteApiRegex = {
|
||||
/lv\.(\d+) (\w+) \((\d+)\)/i, //master
|
||||
/lv\.(\d+) (\w+): class (\d+)/i //other
|
||||
]
|
||||
}
|
||||
};
|
||||
|
||||
type uniteApiData = {
|
||||
name: string,
|
||||
@@ -76,30 +77,30 @@ function getHTML(name: string): Promise<string> {
|
||||
* @throws errorMessage class if the request fails
|
||||
*/
|
||||
function readHTML(html: string): uniteApiData {
|
||||
let $ = cheerio.load(html)
|
||||
let metaElems = $('meta').toArray(),
|
||||
const $ = cheerio.load(html),
|
||||
foundData: uniteApiData = {
|
||||
name: "",
|
||||
id: "",
|
||||
avatar: "",
|
||||
name: '',
|
||||
id: '',
|
||||
avatar: '',
|
||||
|
||||
level: "",
|
||||
rank: "",
|
||||
level: '',
|
||||
rank: '',
|
||||
elo: null,
|
||||
class: null,
|
||||
battles: "",
|
||||
wins: "",
|
||||
winrate: ""
|
||||
battles: '',
|
||||
wins: '',
|
||||
winrate: ''
|
||||
};
|
||||
let metaElems = $('meta').toArray();
|
||||
|
||||
//filter down to just ones named "og:..."
|
||||
metaElems = metaElems.filter(el => el.attribs.property?.startsWith('og:'));
|
||||
|
||||
metaElems.forEach(el => {
|
||||
let attr = el.attribs;
|
||||
const attr = el.attribs;
|
||||
|
||||
if (attr.property === 'og:title') {
|
||||
let data = uniteApiRegex.ogtitle.exec(attr.content);
|
||||
const data = uniteApiRegex.ogtitle.exec(attr.content);
|
||||
if (data !== null && data.length >= 3) {
|
||||
foundData.name = data[1];
|
||||
foundData.id = data[2];
|
||||
@@ -107,17 +108,17 @@ function readHTML(html: string): uniteApiData {
|
||||
} else if (attr.property === 'og:description') {
|
||||
|
||||
//all lines
|
||||
let lines = attr.content.split('\n').map(l => l.trim()),
|
||||
extraLines: string[] = [];
|
||||
let lines = attr.content.split('\n').map(l => l.trim());
|
||||
const extraLines: string[] = [];
|
||||
|
||||
//ensure first line is correct
|
||||
while (lines.length && !/pok.mon unite/i.test(lines[0])) {
|
||||
let line = lines.shift();
|
||||
if (line)
|
||||
while ((lines.length > 0) && !/pok.mon unite/i.test(lines[0])) {
|
||||
const line = lines.shift();
|
||||
if (line !== undefined)
|
||||
extraLines.push(line);
|
||||
}
|
||||
|
||||
if (!lines.length)
|
||||
if (lines.length === 0)
|
||||
throw emsg('Unable to read data, please try again');
|
||||
|
||||
//bring the first lines removed back into the data
|
||||
@@ -129,13 +130,12 @@ function readHTML(html: string): uniteApiData {
|
||||
//first line
|
||||
{
|
||||
//will be only text after "pokemon unite:"
|
||||
let line = lines[0].split(':').slice(1).join(':').trim();
|
||||
|
||||
let regex = uniteApiRegex.ogdescription;
|
||||
const line = lines[0].split(':').slice(1).join(':').trim(),
|
||||
regex = uniteApiRegex.ogdescription;
|
||||
|
||||
if (regex[0].test(line)) { //is master/has elo
|
||||
|
||||
let regexData = line.match(regex[0]);
|
||||
const regexData = line.match(regex[0]);
|
||||
|
||||
if (!regexData || regexData.length < 4)
|
||||
throw emsg('Unable to read data, please try again');
|
||||
@@ -146,7 +146,7 @@ function readHTML(html: string): uniteApiData {
|
||||
|
||||
} else { //is not master/has a class
|
||||
|
||||
let regexData = line.match(regex[1]);
|
||||
const regexData = line.match(regex[1]);
|
||||
|
||||
if (!regexData || regexData.length < 4)
|
||||
throw emsg('Unable to read data, please try again');
|
||||
@@ -164,7 +164,7 @@ function readHTML(html: string): uniteApiData {
|
||||
//rest of lines
|
||||
lines.forEach(line => {
|
||||
|
||||
let split = line.split(':').map(l => l.trim()),
|
||||
const split = line.split(':').map(l => l.trim()),
|
||||
key = split[0].toLowerCase().replace(/[^\w]/g, ''),
|
||||
value = split[1];
|
||||
|
||||
@@ -186,7 +186,9 @@ function readHTML(html: string): uniteApiData {
|
||||
|
||||
});
|
||||
|
||||
foundData.avatar = $('.player-card-image img').attr('src') || "";
|
||||
const imgSrc = $('.player-card-image img').attr('src');
|
||||
|
||||
foundData.avatar = imgSrc !== undefined ? imgSrc : '';
|
||||
foundData.avatar = foundData.avatar.replace('../', 'https://uniteapi.dev/');
|
||||
|
||||
return foundData;
|
||||
@@ -199,7 +201,7 @@ function readHTML(html: string): uniteApiData {
|
||||
* @returns boolean, valid or invalid
|
||||
*/
|
||||
function verifyData(data: uniteApiData): boolean {
|
||||
if (data.id.length)
|
||||
if (data.id.length > 0)
|
||||
return true;
|
||||
return false;
|
||||
}
|
||||
@@ -210,8 +212,8 @@ function verifyData(data: uniteApiData): boolean {
|
||||
* @returns player data
|
||||
*/
|
||||
export async function getPlayer(name: string): Promise<uniteApiData|null> {
|
||||
let html = await getHTML(name);
|
||||
let data = readHTML(html);
|
||||
const html = await getHTML(name),
|
||||
data = readHTML(html);
|
||||
if (verifyData(data))
|
||||
return data;
|
||||
return null;
|
||||
@@ -219,13 +221,19 @@ export async function getPlayer(name: string): Promise<uniteApiData|null> {
|
||||
|
||||
async function sendPlayerEmbed(interaction: CommandInteraction, data: uniteApiData) {
|
||||
|
||||
let embed = new MessageEmbed()
|
||||
let eloStr: string;
|
||||
if (data.elo !== null)
|
||||
eloStr = `(${data.elo})`;
|
||||
else
|
||||
eloStr = `Class ${data.class}`;
|
||||
|
||||
const embed = new MessageEmbed()
|
||||
.setTitle(`${data.name} (${data.id})`)
|
||||
.setURL(`https://uniteapi.dev/p/${encodeURIComponent(data.name)}`)
|
||||
.setTimestamp()
|
||||
.setThumbnail(data.avatar)
|
||||
.setDescription(`Level ${data.level}
|
||||
${data.rank} ${data.elo ? `(${data.elo})` : `Class ${data.class}`}
|
||||
${data.rank} ${eloStr}
|
||||
|
||||
**Battles** ${data.battles}
|
||||
**Wins** ${data.wins}
|
||||
@@ -240,12 +248,12 @@ ${data.rank} ${data.elo ? `(${data.elo})` : `Class ${data.class}`}
|
||||
* @throws errorMessage class if the user cannot be found
|
||||
*/
|
||||
export async function getPlayerInteraction(interaction: CommandInteraction) {
|
||||
let username = interaction.options.getString('username', true);
|
||||
const username = interaction.options.getString('username', true);
|
||||
await interaction.deferReply();
|
||||
|
||||
let data = await getPlayer(username);
|
||||
const data = await getPlayer(username);
|
||||
if (data === null)
|
||||
throw emsg('Unable to find user');
|
||||
throw emsg('api.noUser');
|
||||
else
|
||||
sendPlayerEmbed(interaction, data);
|
||||
}
|
||||
|
||||
@@ -1,21 +1,31 @@
|
||||
/* eslint-disable camelcase */
|
||||
import { REST } from '@discordjs/rest';
|
||||
import { Routes } from 'discord-api-types/v9';
|
||||
|
||||
// list of commands to register with discord
|
||||
const commands = [
|
||||
{
|
||||
name: 'queue',
|
||||
description: 'create a queue',
|
||||
name: 'open',
|
||||
description: 'open a queue for this channel',
|
||||
options: [
|
||||
{
|
||||
type: 4, //INTEGER
|
||||
name: 'teamsize',
|
||||
description: 'size of each team',
|
||||
required: true,
|
||||
min_value: 1
|
||||
min_value: 1,
|
||||
required: true
|
||||
}
|
||||
]
|
||||
},
|
||||
{
|
||||
name: 'close',
|
||||
description: 'close the queue for this channel'
|
||||
},
|
||||
|
||||
{
|
||||
name: 'queue',
|
||||
description: 'view queue info'
|
||||
},
|
||||
{
|
||||
name: 'join',
|
||||
description: 'join the active queue'
|
||||
@@ -24,14 +34,6 @@ const commands = [
|
||||
name: 'leave',
|
||||
description: 'leave the active queue'
|
||||
},
|
||||
{
|
||||
name: 'ready',
|
||||
description: 'ready the queue and display team info'
|
||||
},
|
||||
{
|
||||
name: 'cancel',
|
||||
description: 'cancels the current queue (must have the Manage Messages permission)'
|
||||
},
|
||||
{
|
||||
name: 'player',
|
||||
description: 'display player information',
|
||||
@@ -44,7 +46,8 @@ const commands = [
|
||||
}
|
||||
]
|
||||
}
|
||||
];
|
||||
];
|
||||
/*commandNames = commands.map(c => c.name);*/
|
||||
|
||||
/**
|
||||
* register/reload commands on guild(s)
|
||||
@@ -65,7 +68,6 @@ export async function registerCommands(token: string, clientId: string, guildIds
|
||||
Routes.applicationGuildCommands(clientId, guildIds[i]),
|
||||
{ body: commands },
|
||||
);
|
||||
console.log(`[${guildIds[i]}] registered command`);
|
||||
} catch (error) {
|
||||
console.error(error);
|
||||
}
|
||||
|
||||
58
src/index.ts
58
src/index.ts
@@ -3,7 +3,8 @@ import { Client, Intents } from 'discord.js';
|
||||
import * as fs from 'fs';
|
||||
import { getPlayerInteraction } from './api';
|
||||
import { registerCommands } from './discord';
|
||||
import { cancelQueue, createQueue, joinQueue, leaveQueue, readyQueue } from './queue';
|
||||
import * as Lang from './lang';
|
||||
import { discordInit, QueueCommands } from './queue';
|
||||
import { errorMessage } from './util';
|
||||
const CLIENT = new Client({ intents: [Intents.FLAGS.GUILDS] });
|
||||
|
||||
@@ -11,18 +12,26 @@ const CLIENT = new Client({ intents: [Intents.FLAGS.GUILDS] });
|
||||
console.log(new Date().toISOString()+'\n\n');
|
||||
|
||||
//get token
|
||||
if (!fs.existsSync('./token')) {
|
||||
fs.writeFileSync('./token', '');
|
||||
console.error('Missing Discord Token, please enter the bot token into the token file');
|
||||
if (!fs.existsSync('./token.txt')) {
|
||||
fs.writeFileSync('./token.txt', '');
|
||||
console.error(Lang.get('error.main.missingToken'));
|
||||
process.exit(1);
|
||||
}
|
||||
const TOKEN = fs.readFileSync('./token').toString();
|
||||
const TOKEN = fs.readFileSync('./token.txt').toString();
|
||||
|
||||
//discord connections
|
||||
CLIENT.on('ready', client => {
|
||||
console.log(`Logged in as ${client.user.tag}`);
|
||||
console.log(Lang.get('main.login', {
|
||||
user: client.user.tag
|
||||
}));
|
||||
client.guilds.fetch().then(guilds =>
|
||||
registerCommands(TOKEN, client.user.id, guilds.map(g => g.id)));
|
||||
discordInit(client);
|
||||
});
|
||||
|
||||
CLIENT.on('guildCreate', guild => {
|
||||
if (guild.client.user)
|
||||
registerCommands(TOKEN, guild.client.user.id, guild.id);
|
||||
});
|
||||
|
||||
CLIENT.on('interactionCreate', async interaction => {
|
||||
@@ -30,18 +39,31 @@ CLIENT.on('interactionCreate', async interaction => {
|
||||
|
||||
try {
|
||||
|
||||
if (interaction.commandName === 'queue')
|
||||
await createQueue(interaction);
|
||||
else if (interaction.commandName === 'join')
|
||||
await joinQueue(interaction);
|
||||
else if (interaction.commandName === 'leave')
|
||||
await leaveQueue(interaction);
|
||||
else if (interaction.commandName === 'ready')
|
||||
await readyQueue(interaction);
|
||||
else if (interaction.commandName === 'cancel')
|
||||
await cancelQueue(interaction);
|
||||
else if (interaction.commandName === 'player')
|
||||
await getPlayerInteraction(interaction);
|
||||
switch (interaction.commandName) {
|
||||
|
||||
//mod commands
|
||||
case 'open':
|
||||
await QueueCommands.open(interaction);
|
||||
break;
|
||||
case 'close':
|
||||
await QueueCommands.close(interaction);
|
||||
break;
|
||||
|
||||
//general commands
|
||||
case 'queue':
|
||||
await QueueCommands.queue(interaction);
|
||||
break;
|
||||
case 'join':
|
||||
await QueueCommands.join(interaction);
|
||||
break;
|
||||
case 'leave':
|
||||
await QueueCommands.leave(interaction);
|
||||
break;
|
||||
case 'player':
|
||||
await getPlayerInteraction(interaction);
|
||||
break;
|
||||
|
||||
}
|
||||
|
||||
} catch (e) {
|
||||
|
||||
|
||||
105
src/lang.ts
Normal file
105
src/lang.ts
Normal file
@@ -0,0 +1,105 @@
|
||||
type LangObj = { [keys:string]: LangObj | string }
|
||||
type LangObjWhole = { [langid:string]: LangObj }
|
||||
|
||||
const LANG: LangObjWhole = {
|
||||
|
||||
en: {
|
||||
|
||||
main: {
|
||||
login: 'Logged in as {user}'
|
||||
},
|
||||
|
||||
discord: {
|
||||
botRestart: 'The bot has just restarted, anybody previously in the queue has been reset',
|
||||
create: 'A queue for teams of {teamsize} has been created',
|
||||
close: 'Queue has been closed',
|
||||
join: 'Joined the queue',
|
||||
leave: 'Left the queue'
|
||||
},
|
||||
|
||||
error: {
|
||||
|
||||
main: {
|
||||
missingToken: 'Missing Discord Token, please enter the bot token into the token file'
|
||||
},
|
||||
|
||||
discord: {
|
||||
noQueue: 'There is not an active queue in this channel, type `/open` to create one',
|
||||
noChannel: 'Unable to find channel {channelId} for teams of {teamsize}',
|
||||
noCreate: 'There is already an active queue in this channel for teams of {teamsize}',
|
||||
inQueue: 'You are already in the queue',
|
||||
notInQueue: 'You aren\'t in the queue',
|
||||
notMod: 'Member is not a moderator'
|
||||
},
|
||||
|
||||
general: {
|
||||
noMember: 'Unable to retrieve guild member information, please try again',
|
||||
noChannel: 'Unable to retrieve text channel information, please try again'
|
||||
},
|
||||
|
||||
api: {
|
||||
noUser: 'Unable to find user'
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
};
|
||||
|
||||
|
||||
let LANGID = 'en';
|
||||
if (!(LANGID in LANG))
|
||||
throw 'language id does not exist';
|
||||
|
||||
export function setLang(langid: string) {
|
||||
if (langid in LANG)
|
||||
LANGID = langid;
|
||||
else
|
||||
throw 'language id does not exist';
|
||||
}
|
||||
|
||||
function template(str: string, args: {[keys: string]: string}): string {
|
||||
|
||||
return str.replace(/{\w+}/g, str => {
|
||||
|
||||
const key = str.substring(1, str.length-1);
|
||||
|
||||
if (key in args)
|
||||
return args[key];
|
||||
|
||||
return key;
|
||||
|
||||
});
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* reads language json
|
||||
* @param id ex: discord.error.noActiveQueue
|
||||
* @returns language value, defaults to `id` parameter
|
||||
*/
|
||||
export function get(id: string, args: {[keys: string]: string} = {}): string {//discord.error.noActiveQueue
|
||||
|
||||
const keySpl = id.split('.').map(k => k.trim()).filter(k => k);
|
||||
|
||||
let finding = LANG[LANGID];
|
||||
|
||||
for (const key of keySpl) {
|
||||
|
||||
if (key in finding) {
|
||||
|
||||
const found = finding[key];
|
||||
|
||||
if (typeof found === 'string')
|
||||
return template(found, args);
|
||||
|
||||
finding = found;
|
||||
|
||||
} else
|
||||
break;
|
||||
|
||||
}
|
||||
|
||||
return id;
|
||||
}
|
||||
345
src/queue.ts
345
src/queue.ts
@@ -1,8 +1,110 @@
|
||||
import { CommandInteraction, GuildMember, MessageEmbed } from "discord.js";
|
||||
import { emsg, getChannel, getMember, queueInfo, shuffle } from "./util";
|
||||
/* TODO
|
||||
|
||||
//maps ChannelID to QueueInfo
|
||||
const QUEUE = new Map<string, queueInfo>();
|
||||
join message should contain your current position in the queue, editing it to keep it current
|
||||
*/
|
||||
|
||||
import { Client, CommandInteraction, MessageEmbed, TextChannel } from 'discord.js';
|
||||
import * as fs from 'fs';
|
||||
import { emsg, getChannel, getMember, memberIsModThrow, queueInfo, queueInfoBase } from './util';
|
||||
import * as Lang from './lang';
|
||||
|
||||
//load queues from file
|
||||
if (!fs.existsSync('./queues.json'))
|
||||
fs.writeFileSync('./queues.json', '{}');
|
||||
|
||||
const _QUEUE = fs.readFileSync('./queues.json').toString(),
|
||||
QUEUE = new Map<string, queueInfo>();
|
||||
|
||||
try {
|
||||
|
||||
const queueJson = JSON.parse(_QUEUE);
|
||||
|
||||
for (const channelId in queueJson) {
|
||||
const {teamsize} = queueJson[channelId] as queueInfoBase;
|
||||
if (teamsize !== 0)
|
||||
QUEUE.set(channelId, { teamsize, players: [] });
|
||||
}
|
||||
|
||||
} catch(e) {
|
||||
//do nothing
|
||||
}
|
||||
|
||||
function SaveQueue() {
|
||||
|
||||
const queueJson = Object.fromEntries(QUEUE),
|
||||
queueFileJson: {[keys: string]: queueInfoBase} = {};
|
||||
|
||||
for (const channelId of QUEUE.keys())
|
||||
queueFileJson[channelId] = { teamsize: queueJson[channelId].teamsize };
|
||||
|
||||
fs.writeFileSync('./queues.json', JSON.stringify(queueFileJson, null, 2));
|
||||
|
||||
}
|
||||
|
||||
async function checkQueue(channel: TextChannel) {
|
||||
const info = QUEUE.get(channel.id);
|
||||
|
||||
if (!info)
|
||||
return;
|
||||
|
||||
if (info.players.length >= info.teamsize) {
|
||||
|
||||
const team = info.players.splice(0, info.teamsize).map(m => m.toString());
|
||||
|
||||
//TODO add embeds to lang.ts
|
||||
const embed = new MessageEmbed()
|
||||
.setTitle('Team')
|
||||
.setDescription(team.join('\n'));
|
||||
|
||||
await channel.send({embeds: [embed]});
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
|
||||
export function queueCreate(channelId: string, teamsize: number) {
|
||||
if (!QUEUE.has(channelId)) {
|
||||
QUEUE.set(channelId, {teamsize, players: []});
|
||||
SaveQueue();
|
||||
}
|
||||
}
|
||||
|
||||
export function queueRemove(channelId: string) {
|
||||
if (QUEUE.has(channelId)) {
|
||||
QUEUE.delete(channelId);
|
||||
SaveQueue();
|
||||
}
|
||||
}
|
||||
|
||||
SaveQueue();
|
||||
|
||||
export async function discordInit(client: Client) {
|
||||
|
||||
for (const channelId of QUEUE.keys()) {
|
||||
|
||||
const info = QUEUE.get(channelId),
|
||||
channel = await client.channels.fetch(channelId);
|
||||
|
||||
if (!info) { //no idea what could cause this but TS complains
|
||||
queueRemove(channelId);
|
||||
continue;
|
||||
}
|
||||
|
||||
if (!channel || !(channel instanceof TextChannel)) {
|
||||
console.error(Lang.get('error.discord.noChannel'), {
|
||||
channelId,
|
||||
teamsize: info.teamsize
|
||||
});
|
||||
queueRemove(channelId);
|
||||
continue;
|
||||
}
|
||||
|
||||
channel.send(Lang.get('discord.botRestart'));
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* get the queueInfo of an interaction
|
||||
@@ -10,11 +112,11 @@ const QUEUE = new Map<string, queueInfo>();
|
||||
* @throws errorMessage class if it does not exist
|
||||
* @returns queue info
|
||||
*/
|
||||
export function getInfo(interaction: CommandInteraction): queueInfo {
|
||||
let info = QUEUE.get(interaction.channelId);
|
||||
function getInfo(interaction: CommandInteraction): queueInfo {
|
||||
const info = QUEUE.get(interaction.channelId);
|
||||
|
||||
if (!info)
|
||||
throw emsg('There is not an active queue in this channel, type `/queue` to create one');
|
||||
throw emsg('discord.noQueue');
|
||||
|
||||
return info;
|
||||
}
|
||||
@@ -25,7 +127,7 @@ export function getInfo(interaction: CommandInteraction): queueInfo {
|
||||
* @throws if another get function throws
|
||||
* @returns object containing each
|
||||
*/
|
||||
export const getAll = (interaction: CommandInteraction) => ({
|
||||
const getAll = (interaction: CommandInteraction) => ({
|
||||
member: getMember(interaction),
|
||||
channel: getChannel(interaction),
|
||||
info: getInfo(interaction)
|
||||
@@ -38,7 +140,7 @@ export const getAll = (interaction: CommandInteraction) => ({
|
||||
*/
|
||||
export function queueContains(interaction: CommandInteraction): boolean {
|
||||
|
||||
let {member, info} = getAll(interaction);
|
||||
const {member, info} = getAll(interaction);
|
||||
|
||||
if (info.players.map(m=>m.id).includes(member.id))
|
||||
return true;
|
||||
@@ -48,189 +150,110 @@ export function queueContains(interaction: CommandInteraction): boolean {
|
||||
}
|
||||
|
||||
/**
|
||||
* creates the timeout for the queue
|
||||
* @param interaction
|
||||
* @returns time timeout identifier
|
||||
*/
|
||||
function setQueueTimeout(interaction: CommandInteraction) {
|
||||
let channel = getChannel(interaction);
|
||||
return setTimeout(() => {
|
||||
clearQueue(interaction);
|
||||
channel.send('Queue has been reset due to inactivity');
|
||||
}, 5*60*1000) //5 minutes
|
||||
}
|
||||
|
||||
/**
|
||||
* updates the rich embed for the current queue
|
||||
* @param interaction
|
||||
*/
|
||||
async function sendQueueEmbed(interaction: CommandInteraction, closed: boolean = false) {
|
||||
let info = getInfo(interaction),
|
||||
origInteraction = info.initiator.interaction;
|
||||
|
||||
let embed = new MessageEmbed()
|
||||
.setTitle('Queue')
|
||||
.setAuthor({
|
||||
name: info.initiator.member.displayName,
|
||||
iconURL: info.initiator.member.displayAvatarURL({dynamic: true})
|
||||
})
|
||||
.addField('Team Size', info.teamsize.toString(), true)
|
||||
.addField('Players Joined', info.players.length.toString(), true)
|
||||
.setFooter({text: closed ? 'queue is finished' : 'type /join'});
|
||||
|
||||
if (origInteraction.deferred || origInteraction.replied)
|
||||
await origInteraction.editReply({embeds: [embed]});
|
||||
else
|
||||
await origInteraction.reply({embeds: [embed]});
|
||||
}
|
||||
|
||||
/**
|
||||
* sends the list of teams
|
||||
* @param interaction
|
||||
*/
|
||||
async function sendTeamsEmbed(interaction: CommandInteraction, teams: GuildMember[][]) {
|
||||
let embed = new MessageEmbed()
|
||||
.setTitle('Teams');
|
||||
|
||||
teams.forEach((team, i) => {
|
||||
team.map(m => m.user.tag);
|
||||
embed.addField(`Team ${i+1}`, team.join('\n'))
|
||||
});
|
||||
|
||||
interaction.reply({embeds: [embed]});
|
||||
}
|
||||
|
||||
/**
|
||||
* sends the list of teams
|
||||
* @param interaction
|
||||
*/
|
||||
async function clearQueue(interaction: CommandInteraction) {
|
||||
let info = getInfo(interaction);
|
||||
sendQueueEmbed(interaction, true);
|
||||
clearTimeout(info.timeout);
|
||||
QUEUE.delete(interaction.channelId);
|
||||
}
|
||||
|
||||
/**
|
||||
* creates a queue from an interaction
|
||||
* @param interaction
|
||||
* @throws errorMessage class if it cannot be created
|
||||
*/
|
||||
export async function createQueue(interaction: CommandInteraction) {
|
||||
|
||||
let member = getMember(interaction),
|
||||
{channelId} = interaction,
|
||||
teamsize = interaction.options.getInteger('teamsize', true);
|
||||
|
||||
if (QUEUE.has(channelId))
|
||||
throw emsg('There is already an active queue in this channel, ' + (queueContains(interaction) ? 'and you are already in it' : 'type `/join` to join'));
|
||||
|
||||
QUEUE.set(channelId, {
|
||||
players: [
|
||||
member
|
||||
],
|
||||
initiator: {
|
||||
interaction,
|
||||
member
|
||||
},
|
||||
teamsize: teamsize,
|
||||
timeout: setQueueTimeout(interaction)
|
||||
});
|
||||
|
||||
sendQueueEmbed(interaction);
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* joins a queue from an interaction
|
||||
* @param interaction
|
||||
* @throws errorMessage class if it cannot be joined
|
||||
*/
|
||||
export async function joinQueue(interaction: CommandInteraction) {
|
||||
|
||||
let {member, info} = getAll(interaction);
|
||||
|
||||
if (queueContains(interaction))
|
||||
throw emsg('You are already in the active queue');
|
||||
|
||||
info.players.push(member);
|
||||
clearTimeout(info.timeout);
|
||||
info.timeout = setQueueTimeout(interaction)
|
||||
|
||||
QUEUE.set(interaction.channelId, info);
|
||||
|
||||
sendQueueEmbed(interaction);
|
||||
await interaction.reply('Joined the queue');
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* leaves a queue from an interaction
|
||||
* opens a queue
|
||||
* @param interaction
|
||||
* @throws errorMessage class if it cannot be left
|
||||
*/
|
||||
export async function leaveQueue(interaction: CommandInteraction) {
|
||||
function open(interaction: CommandInteraction) {
|
||||
|
||||
let {member, info} = getAll(interaction);
|
||||
memberIsModThrow(interaction);
|
||||
|
||||
if (!queueContains(interaction))
|
||||
throw emsg('You aren\'t in the active queue');
|
||||
const {channelId} = interaction,
|
||||
teamsize = interaction.options.getInteger('teamsize', true);
|
||||
|
||||
info.players.splice(info.players.indexOf(member), 1);
|
||||
clearTimeout(info.timeout);
|
||||
info.timeout = setQueueTimeout(interaction)
|
||||
const existing = QUEUE.get(channelId);
|
||||
if (existing)
|
||||
throw emsg(Lang.get('error.discord.noCreate', {
|
||||
teamsize: existing.teamsize.toString()
|
||||
}));
|
||||
|
||||
QUEUE.set(interaction.channelId, info);
|
||||
queueCreate(channelId, teamsize);
|
||||
|
||||
sendQueueEmbed(interaction);
|
||||
await interaction.reply('Left the queue');
|
||||
interaction.reply(Lang.get('discord.create', {
|
||||
teamsize: teamsize.toString()
|
||||
}));
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* readys a queue from an interaction
|
||||
* closes a queue
|
||||
* @param interaction
|
||||
* @throws errorMessage class if it cannot be joined
|
||||
*/
|
||||
async function close(interaction: CommandInteraction) {
|
||||
memberIsModThrow(interaction);
|
||||
|
||||
QUEUE.delete(interaction.channelId);
|
||||
|
||||
await interaction.reply(Lang.get('discord.close'));
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* gives info about the queue
|
||||
* @param interaction
|
||||
* @throws errorMessage class if it cannot be left
|
||||
*/
|
||||
async function queue(interaction: CommandInteraction) {
|
||||
|
||||
const info = getInfo(interaction);
|
||||
|
||||
const embed = new MessageEmbed()
|
||||
.setTitle('Active Queue')
|
||||
.addField('Team Size', info.teamsize.toString(), true)
|
||||
.addField('Players Joined', info.players.length.toString(), true)
|
||||
.setFooter({text: 'type /join'}); //TODO
|
||||
|
||||
await interaction.reply({embeds: [embed], ephemeral: true});
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* joins a queue
|
||||
* @param interaction
|
||||
* @throws errorMessage class if it cannot be readied
|
||||
*/
|
||||
export async function readyQueue(interaction: CommandInteraction) {
|
||||
async function join(interaction: CommandInteraction) {
|
||||
|
||||
let {member, info} = getAll(interaction),
|
||||
{initiator} = info;
|
||||
const {member, info, channel} = getAll(interaction);
|
||||
|
||||
if (member.id !== initiator.member.id)
|
||||
throw emsg('Only the queue initiator can ready the queue');
|
||||
if (queueContains(interaction))
|
||||
throw emsg('discord.inQueue');
|
||||
|
||||
clearQueue(interaction);
|
||||
info.players.push(member);
|
||||
|
||||
if (info.players.filter(m => m.id !== initiator.member.id).length === 0)
|
||||
throw emsg('Nobody signed up for the queue, the queue has been reset');
|
||||
QUEUE.set(interaction.channelId, info);
|
||||
|
||||
//team data
|
||||
let playerlist: GuildMember[] = shuffle(info.players),
|
||||
teams: GuildMember[][] = [];
|
||||
await interaction.reply(Lang.get('discord.join'));
|
||||
|
||||
//fill team data
|
||||
for (let i = 0; i < playerlist.length; i+= info.teamsize)
|
||||
teams.push(playerlist.slice(i, i+info.teamsize));
|
||||
|
||||
sendTeamsEmbed(interaction, teams);
|
||||
checkQueue(channel);
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* readys a queue from an interaction
|
||||
* leaves a queue
|
||||
* @param interaction
|
||||
* @throws errorMessage class if it cannot be reset
|
||||
*/
|
||||
export async function cancelQueue(interaction: CommandInteraction) {
|
||||
async function leave(interaction: CommandInteraction) {
|
||||
|
||||
let {info, member, channel} = getAll(interaction);
|
||||
const {member, info} = getAll(interaction);
|
||||
|
||||
if (!member.permissionsIn(channel).has('MANAGE_MESSAGES'))
|
||||
throw emsg('You do not have permission to run this command');
|
||||
if (!queueContains(interaction))
|
||||
throw emsg('discord.notInQueue');
|
||||
|
||||
clearQueue(interaction);
|
||||
info.players.splice(info.players.indexOf(member), 1);
|
||||
|
||||
await interaction.reply('Queue has been reset');
|
||||
QUEUE.set(interaction.channelId, info);
|
||||
|
||||
await interaction.reply(Lang.get('discord.leave'));
|
||||
|
||||
}
|
||||
|
||||
export const QueueCommands = {
|
||||
open,
|
||||
close,
|
||||
queue,
|
||||
join,
|
||||
leave
|
||||
};
|
||||
0
src/queueCommands.ts
Normal file
0
src/queueCommands.ts
Normal file
42
src/util.ts
42
src/util.ts
@@ -1,4 +1,5 @@
|
||||
import { CommandInteraction, GuildMember, TextChannel } from "discord.js";
|
||||
import { CommandInteraction, GuildMember, TextChannel } from 'discord.js';
|
||||
import * as Lang from './lang';
|
||||
|
||||
/**
|
||||
* shuffles an array
|
||||
@@ -6,6 +7,7 @@ import { CommandInteraction, GuildMember, TextChannel } from "discord.js";
|
||||
* @param array an array
|
||||
* @returns an array but shuffled
|
||||
*/
|
||||
// eslint-disable-next-line @typescript-eslint/no-explicit-any
|
||||
export function shuffle(array: any[]) {
|
||||
let currentIndex = array.length, randomIndex;
|
||||
|
||||
@@ -30,7 +32,7 @@ export class errorMessage {
|
||||
public msg: string;
|
||||
public ephemeral: boolean;
|
||||
|
||||
constructor(msg: string, ephemeral: boolean = true) {
|
||||
constructor(msg: string, ephemeral = true) {
|
||||
this.msg = msg;
|
||||
this.ephemeral = ephemeral;
|
||||
}
|
||||
@@ -42,18 +44,15 @@ export class errorMessage {
|
||||
* @param ephemeral (default=true)
|
||||
* @returns new errorMessage
|
||||
*/
|
||||
export const emsg = (msg: string, ephemeral: boolean = true) => new errorMessage(msg, ephemeral);
|
||||
export const emsg = (msg: string, ephemeral = true) => new errorMessage(Lang.get(`error.${msg}`), ephemeral);
|
||||
|
||||
|
||||
|
||||
export type queueInfo = {
|
||||
players: GuildMember[],
|
||||
initiator: {
|
||||
interaction: CommandInteraction,
|
||||
member: GuildMember
|
||||
},
|
||||
teamsize: number,
|
||||
timeout: NodeJS.Timeout
|
||||
export interface queueInfoBase {
|
||||
teamsize: number
|
||||
}
|
||||
export interface queueInfo extends queueInfoBase{
|
||||
players: GuildMember[]
|
||||
}
|
||||
|
||||
/**
|
||||
@@ -63,10 +62,10 @@ export type queueInfo = {
|
||||
* @returns member
|
||||
*/
|
||||
export function getMember(interaction: CommandInteraction): GuildMember {
|
||||
let member = interaction.member;
|
||||
const member = interaction.member;
|
||||
|
||||
if (!(member instanceof GuildMember))
|
||||
throw emsg('Unable to retrieve guild member information, please try again');
|
||||
throw emsg('general.noMember');
|
||||
|
||||
return member;
|
||||
}
|
||||
@@ -78,10 +77,21 @@ export function getMember(interaction: CommandInteraction): GuildMember {
|
||||
* @returns member
|
||||
*/
|
||||
export function getChannel(interaction: CommandInteraction): TextChannel {
|
||||
let channel = interaction.channel;
|
||||
const channel = interaction.channel;
|
||||
|
||||
if (!(channel instanceof TextChannel))
|
||||
throw emsg('Unable to retrieve text channel information, please try again');
|
||||
throw emsg('general.noChannel');
|
||||
|
||||
return channel;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
export function memberIsMod(interaction: CommandInteraction): boolean {
|
||||
const member = getMember(interaction);
|
||||
return member.permissionsIn(interaction.channelId).has('MANAGE_MESSAGES');
|
||||
}
|
||||
|
||||
export function memberIsModThrow(interaction: CommandInteraction) {
|
||||
if (!memberIsMod(interaction))
|
||||
throw emsg('discord.notMod');
|
||||
}
|
||||
|
||||
@@ -6,7 +6,10 @@
|
||||
"outDir": "./dist",
|
||||
"esModuleInterop": true,
|
||||
"forceConsistentCasingInFileNames": true,
|
||||
"skipLibCheck": true,
|
||||
"strict": true,
|
||||
"skipLibCheck": true
|
||||
"noImplicitReturns": true,
|
||||
"noUnusedLocals": true,
|
||||
"noUnusedParameters": true,
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user