updated package info

.gitignore

@@ -1,5 +1,4 @@
 node_modules
-token.txt
+token
-queues.json
 .DS_Store
 log

README.md

@@ -1,6 +1,8 @@
 <!-- markdownlint-disable MD033 -->
 
-# 1800queue
+# 1800queue alt
+
+This version does not run continuously, and requires each tourney to be started with a command
 
 ## Prerequirements
 

dist/discord.js

@@ -7,12 +7,13 @@ const v9_1 = require("discord-api-types/v9");
 const commands = [
     {
         name: 'queue',
-        description: 'get queue info or initialize a queue for this channel',
+        description: 'create a queue',
         options: [
             {
                 type: 4,
                 name: 'teamsize',
                 description: 'size of each team',
+                required: true,
                 min_value: 1
             }
         ]
@@ -26,8 +27,12 @@ const commands = [
         description: 'leave the active queue'
     },
     {
-        name: 'stop',
+        name: 'ready',
-        description: 'stops the current queue (must have the Manage Messages permission)'
+        description: 'ready the queue and display team info'
+    },
+    {
+        name: 'cancel',
+        description: 'cancels the current queue (must have the Manage Messages permission)'
     },
     {
         name: 'player',

dist/index.js

@@ -29,30 +29,31 @@ const CLIENT = new discord_js_1.Client({ intents: [discord_js_1.Intents.FLAGS.GU
 //init logs with a timestamp
 console.log(new Date().toISOString() + '\n\n');
 //get token
-if (!fs.existsSync('./token.txt')) {
+if (!fs.existsSync('./token')) {
-    fs.writeFileSync('./token.txt', '');
+    fs.writeFileSync('./token', '');
     console.error('Missing Discord Token, please enter the bot token into the token file');
     process.exit(1);
 }
-const TOKEN = fs.readFileSync('./token.txt').toString();
+const TOKEN = fs.readFileSync('./token').toString();
 //discord connections
 CLIENT.on('ready', client => {
     console.log(`Logged in as ${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('interactionCreate', async (interaction) => {
     if (!interaction.isCommand())
         return;
     try {
         if (interaction.commandName === 'queue')
-            await queue_1.QueueCommands.queue(interaction);
+            await (0, queue_1.createQueue)(interaction);
         else if (interaction.commandName === 'join')
-            await queue_1.QueueCommands.join(interaction);
+            await (0, queue_1.joinQueue)(interaction);
         else if (interaction.commandName === 'leave')
-            await queue_1.QueueCommands.leave(interaction);
+            await (0, queue_1.leaveQueue)(interaction);
-        else if (interaction.commandName === 'stop')
+        else if (interaction.commandName === 'ready')
-            await queue_1.QueueCommands.stop(interaction);
+            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);
     }

dist/queue.js

@@ -1,218 +1,189 @@
 "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.QueueCommands = exports.discordInit = void 0;
+exports.cancelQueue = exports.readyQueue = exports.leaveQueue = exports.joinQueue = exports.createQueue = exports.queueContains = exports.getAll = exports.getInfo = void 0;
 const discord_js_1 = require("discord.js");
-const fs = __importStar(require("fs"));
 const util_1 = require("./util");
-//load queues from file
+//maps ChannelID to QueueInfo
-if (!fs.existsSync('./queues.json'))
+const QUEUE = new Map();
-    fs.writeFileSync('./queues.json', '{}');
+/**
-const _QUEUE = fs.readFileSync('./queues.json').toString(), QUEUE = new Map();
+ * get the queueInfo of an interaction
-try {
+ * @param interaction
-    let queueJson = JSON.parse(_QUEUE);
+ * @throws errorMessage class if it does not exist
-    for (let channelId of queueJson) {
+ * @returns queue info
-        let { teamsize } = queueJson[channelId];
+ */
-        if (teamsize)
+function getInfo(interaction) {
-            QUEUE.set(channelId, { teamsize, players: [] });
+    let info = QUEUE.get(interaction.channelId);
-    }
-}
-catch (e) { }
-function SaveQueue() {
-    let queueJson = Object.fromEntries(QUEUE), queueFileJson = {};
-    for (let channelId in QUEUE.keys())
-        queueFileJson[channelId] = { teamsize: queueJson[channelId].teamsize };
-    fs.writeFileSync('./queues.json', JSON.stringify(queueFileJson, null, 2));
-}
-async function checkQueue(channel) {
-    let info = QUEUE.get(channel.id);
     if (!info)
-        return;
+        throw (0, util_1.emsg)('There is not an active queue in this channel, type `/queue` to create one');
-    if (info.players.length > info.teamsize) {
+    return info;
-        let team = info.players.splice(0, info.teamsize).map(m => m.toString());
-        let embed = new discord_js_1.MessageEmbed()
-            .setTitle('Team')
-            .setDescription(team.join('\n'));
-        await channel.send({ embeds: [embed] });
-    }
 }
-var Queue;
+exports.getInfo = getInfo;
-(function (Queue) {
+/**
-    function create(channelId, teamsize) {
+ * compiles all the get functions above
-        if (!QUEUE.has(channelId)) {
+ * @param interaction
-            QUEUE.set(channelId, { teamsize, players: [] });
+ * @throws if another get function throws
-            SaveQueue();
+ * @returns object containing each
-        }
+ */
-    }
+const getAll = (interaction) => ({
-    Queue.create = create;
+    member: (0, util_1.getMember)(interaction),
-    function remove(channelId) {
+    channel: (0, util_1.getChannel)(interaction),
-        if (QUEUE.has(channelId)) {
+    info: getInfo(interaction)
-            QUEUE.delete(channelId);
+});
-            SaveQueue();
+exports.getAll = getAll;
-        }
+/**
-    }
+ * checks if the interaction data is already in the queue
-    Queue.remove = remove;
+ * @param interaction
-    function addPlayer(channelId, member) {
+ * @returns boolean
-        if (QUEUE.has(channelId)) {
+ */
-            QUEUE.delete(channelId);
+function queueContains(interaction) {
-        }
+    let { member, info } = (0, exports.getAll)(interaction);
-    }
+    if (info.players.map(m => m.id).includes(member.id))
-    Queue.addPlayer = addPlayer;
+        return true;
-    function removePlayer(channelId, member) {
+    return false;
-        if (QUEUE.has(channelId)) {
-            QUEUE.delete(channelId);
-        }
-    }
-    Queue.removePlayer = removePlayer;
-})(Queue || (Queue = {}));
-SaveQueue();
-async function discordInit(client) {
-    for (let channelId in QUEUE.keys()) {
-        let info = QUEUE.get(channelId), channel = await client.channels.fetch(channelId);
-        if (!info) { //no idea what could cause this but TS complains
-            Queue.remove(channelId);
-            continue;
-        }
-        if (!channel || !(channel instanceof discord_js_1.TextChannel)) {
-            console.error(`Unable to find channel ${channelId} for teams of ${info?.teamsize}`);
-            Queue.remove(channelId);
-            continue;
-        }
-        channel.send('The bot has just restarted and anybody in the queues have been reset');
-    }
 }
-exports.discordInit = discordInit;
+exports.queueContains = queueContains;
-var QueueCommands;
+/**
-(function (QueueCommands) {
+ * creates the timeout for the queue
-    /**
+ * @param interaction
-     * get the queueInfo of an interaction
+ * @returns time timeout identifier
-     * @param interaction
+ */
-     * @throws errorMessage class if it does not exist
+function setQueueTimeout(interaction) {
-     * @returns queue info
+    let channel = (0, util_1.getChannel)(interaction);
-     */
+    return setTimeout(() => {
-    function getInfo(interaction) {
+        clearQueue(interaction);
-        let info = QUEUE.get(interaction.channelId);
+        channel.send('Queue has been reset due to inactivity');
-        if (!info)
+    }, 5 * 60 * 1000); //5 minutes
-            throw (0, util_1.emsg)('There is not an active queue in this channel, type `/queue` to create one');
+}
-        return info;
+/**
-    }
+ * updates the rich embed for the current queue
-    /**
+ * @param interaction
-     * compiles all the get functions above
+ */
-     * @param interaction
+async function sendQueueEmbed(interaction, closed = false) {
-     * @throws if another get function throws
+    let info = getInfo(interaction), origInteraction = info.initiator.interaction;
-     * @returns object containing each
+    let embed = new discord_js_1.MessageEmbed()
-     */
+        .setTitle('Queue')
-    const getAll = (interaction) => ({
+        .setAuthor({
-        member: (0, util_1.getMember)(interaction),
+        name: info.initiator.member.displayName,
-        channel: (0, util_1.getChannel)(interaction),
+        iconURL: info.initiator.member.displayAvatarURL({ dynamic: true })
-        info: getInfo(interaction)
+    })
+        .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] });
-     * checks if the interaction data is already in the queue
+}
-     * @param interaction
+/**
-     * @returns boolean
+ * sends the list of teams
-     */
+ * @param interaction
-    function queueContains(interaction) {
+ */
-        let { member, info } = getAll(interaction);
+async function clearQueue(interaction) {
-        if (info.players.map(m => m.id).includes(member.id))
+    let info = getInfo(interaction);
-            return true;
+    sendQueueEmbed(interaction, true);
-        return false;
+    clearTimeout(info.timeout);
-    }
+    QUEUE.delete(interaction.channelId);
-    QueueCommands.queueContains = queueContains;
+}
-    /**
+/**
-     * creates a queue from an interaction
+ * creates a queue from an interaction
-     * @param interaction
+ * @param interaction
-     * @throws errorMessage class if it cannot be left
+ * @throws errorMessage class if it cannot be created
-     */
+ */
-    function queueCreate(interaction) {
+async function createQueue(interaction) {
-        (0, util_1.memberIsModThrow)(interaction);
+    let member = (0, util_1.getMember)(interaction), { channelId } = interaction, teamsize = interaction.options.getInteger('teamsize', true);
-        let { channelId } = interaction, teamsize = interaction.options.getInteger('teamsize', true);
+    if (QUEUE.has(channelId))
-        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'));
-            throw (0, util_1.emsg)(`There is already an active queue in this channel for teams of ${QUEUE.get(channelId)?.teamsize}`);
+    QUEUE.set(channelId, {
-        Queue.create(channelId, teamsize);
+        players: [
-        interaction.reply(`A queue for teams of ${teamsize} has been started`);
+            member
-    }
+        ],
-    QueueCommands.queueCreate = queueCreate;
+        initiator: {
-    /**
+            interaction,
-     * creates a queue from an interaction
+            member
-     * @param interaction
+        },
-     * @throws errorMessage class if it cannot be left
+        teamsize: teamsize,
-     */
+        timeout: setQueueTimeout(interaction)
-    async function queue(interaction) {
+    });
-        let teamsize = interaction.options.getInteger('teamsize');
+    sendQueueEmbed(interaction);
-        if (teamsize) {
+}
-            queueCreate(interaction);
+exports.createQueue = createQueue;
-            return;
+/**
-        }
+ * joins a queue from an interaction
-        let info = getInfo(interaction);
+ * @param interaction
-        let embed = new discord_js_1.MessageEmbed()
+ * @throws errorMessage class if it cannot be joined
-            .setTitle('Active Queue')
+ */
-            .addField('Team Size', info.teamsize.toString(), true)
+async function joinQueue(interaction) {
-            .addField('Players Joined', info.players.length.toString(), true)
+    let { member, info } = (0, exports.getAll)(interaction);
-            .setFooter({ text: 'type /join' });
+    if (queueContains(interaction))
-        await interaction.reply({ embeds: [embed], ephemeral: true });
+        throw (0, util_1.emsg)('You are already in the active queue');
-    }
+    info.players.push(member);
-    QueueCommands.queue = queue;
+    clearTimeout(info.timeout);
-    /**
+    info.timeout = setQueueTimeout(interaction);
-     * stops a queue from an interaction
+    QUEUE.set(interaction.channelId, info);
-     * @param interaction
+    sendQueueEmbed(interaction);
-     * @throws errorMessage class if it cannot be joined
+    await interaction.reply('Joined the queue');
-     */
+}
-    async function stop(interaction) {
+exports.joinQueue = joinQueue;
-        (0, util_1.memberIsModThrow)(interaction);
+/**
-        QUEUE.delete(interaction.channelId);
+ * leaves a queue from an interaction
-        await interaction.reply('Queue has been reset');
+ * @param interaction
-    }
+ * @throws errorMessage class if it cannot be left
-    QueueCommands.stop = stop;
+ */
-    /**
+async function leaveQueue(interaction) {
-     * joins a queue from an interaction
+    let { member, info } = (0, exports.getAll)(interaction);
-     * @param interaction
+    if (!queueContains(interaction))
-     * @throws errorMessage class if it cannot be readied
+        throw (0, util_1.emsg)('You aren\'t in the active queue');
-     */
+    info.players.splice(info.players.indexOf(member), 1);
-    async function join(interaction) {
+    clearTimeout(info.timeout);
-        let { member, info, channel } = getAll(interaction);
+    info.timeout = setQueueTimeout(interaction);
-        if (queueContains(interaction))
+    QUEUE.set(interaction.channelId, info);
-            throw (0, util_1.emsg)('You are already in the queue');
+    sendQueueEmbed(interaction);
-        info.players.push(member);
+    await interaction.reply('Left the queue');
-        QUEUE.set(interaction.channelId, info);
+}
-        await interaction.reply('Joined the queue');
+exports.leaveQueue = leaveQueue;
-        checkQueue(channel);
+/**
-    }
+ * readys a queue from an interaction
-    QueueCommands.join = join;
+ * @param interaction
-    /**
+ * @throws errorMessage class if it cannot be readied
-     * leaves a queue from an interaction
+ */
-     * @param interaction
+async function readyQueue(interaction) {
-     * @throws errorMessage class if it cannot be reset
+    let { member, info } = (0, exports.getAll)(interaction), { initiator } = info;
-     */
+    if (member.id !== initiator.member.id)
-    async function leave(interaction) {
+        throw (0, util_1.emsg)('Only the queue initiator can ready the queue');
-        let { member, info } = getAll(interaction);
+    clearQueue(interaction);
-        if (!queueContains(interaction))
+    if (info.players.filter(m => m.id !== initiator.member.id).length === 0)
-            throw (0, util_1.emsg)('You aren\'t in the queue');
+        throw (0, util_1.emsg)('Nobody signed up for the queue, the queue has been reset');
-        info.players.splice(info.players.indexOf(member), 1);
+    //team data
-        QUEUE.set(interaction.channelId, info);
+    let playerlist = (0, util_1.shuffle)(info.players), teams = [];
-        await interaction.reply('Left the queue');
+    //fill team data
-    }
+    for (let i = 0; i < playerlist.length; i += info.teamsize)
-    QueueCommands.leave = leave;
+        teams.push(playerlist.slice(i, i + info.teamsize));
-})(QueueCommands = exports.QueueCommands || (exports.QueueCommands = {}));
+    sendTeamsEmbed(interaction, teams);
+}
+exports.readyQueue = readyQueue;
+/**
+ * readys a queue from an interaction
+ * @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');
+}
+exports.cancelQueue = cancelQueue;

dist/util.js

@@ -1,6 +1,6 @@
 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.memberIsModThrow = exports.memberIsMod = exports.getChannel = exports.getMember = exports.emsg = exports.errorMessage = exports.shuffle = void 0;
+exports.getChannel = exports.getMember = exports.emsg = exports.errorMessage = exports.shuffle = void 0;
 const discord_js_1 = require("discord.js");
 /**
  * shuffles an array
@@ -64,13 +64,3 @@ function getChannel(interaction) {
     return channel;
 }
 exports.getChannel = getChannel;
-function memberIsMod(interaction) {
-    let member = getMember(interaction);
-    return member.permissionsIn(interaction.channelId).has('MANAGE_MESSAGES');
-}
-exports.memberIsMod = memberIsMod;
-function memberIsModThrow(interaction) {
-    if (!memberIsMod(interaction))
-        throw (0, exports.emsg)('Member is not a moderator');
-}
-exports.memberIsModThrow = memberIsModThrow;

package-lock.json

@@ -1,11 +1,11 @@
 {
-    "name": "1800queue",
+    "name": "1800queue-alt",
     "version": "1.0.0",
     "lockfileVersion": 2,
     "requires": true,
     "packages": {
         "": {
-            "name": "1800queue",
+            "name": "1800queue-alt",
             "version": "1.0.0",
             "license": "MIT",
             "dependencies": {

package.json

@@ -1,5 +1,5 @@
 {
-    "name": "1800queue",
+    "name": "1800queue-alt",
     "version": "1.0.0",
     "description": "",
     "main": "dist/index.js",

scripts/mac-linux/install

@@ -8,11 +8,11 @@ cd ../..
 npm install
 
 #discord token
-[ ! -f "token.txt" ] && touch "token.txt"
+[ ! -f "token" ] && touch "token"
 
-if [ ! -s "token.txt" ]
+if [ ! -s "token" ]
 then
     printf "Enter your discord bot token: "
     read token
-    printf $token > "token.txt"
+    printf $token > "token"
 fi

scripts/windows/install.bat

@@ -4,12 +4,12 @@
 cd %~f0\..\..\..\
 
 @REM discord token
-if not exist "token.txt" copy NUL "token.txt"
+if not exist "token" copy NUL "token"
 
-for /f %%i in ("token.txt") do set size=%%~zi
+for /f %%i in ("token") do set size=%%~zi
 if %size% equ 0 (
     set /p token="Enter your discord bot token: "
-    echo | set /p=%id% > "token.txt"
+    echo | set /p=%id% > "token"
 )
 
 @REM run

src/discord.ts

@@ -5,12 +5,13 @@ import { Routes } from 'discord-api-types/v9';
 const commands = [
     {
         name: 'queue',
-        description: 'get queue info or initialize a queue for this channel',
+        description: 'create a queue',
         options: [
             {
                 type: 4, //INTEGER
                 name: 'teamsize',
                 description: 'size of each team',
+                required: true,
                 min_value: 1
             }
         ]
@@ -24,8 +25,12 @@ const commands = [
         description: 'leave the active queue'
     },
     {
-        name: 'stop',
+        name: 'ready',
-        description: 'stops the current queue (must have the Manage Messages permission)'
+        description: 'ready the queue and display team info'
+    },
+    {
+        name: 'cancel',
+        description: 'cancels the current queue (must have the Manage Messages permission)'
     },
     {
         name: 'player',

src/index.ts

@@ -3,7 +3,7 @@ import { Client, Intents } from 'discord.js';
 import * as fs from 'fs';
 import { getPlayerInteraction } from './api';
 import { registerCommands } from './discord';
-import { discordInit, QueueCommands } from './queue';
+import { cancelQueue, createQueue, joinQueue, leaveQueue, readyQueue } from './queue';
 import { errorMessage } from './util';
 const CLIENT = new Client({ intents: [Intents.FLAGS.GUILDS] });
 
@@ -11,19 +11,18 @@ const CLIENT = new Client({ intents: [Intents.FLAGS.GUILDS] });
 console.log(new Date().toISOString()+'\n\n');
 
 //get token
-if (!fs.existsSync('./token.txt')) {
+if (!fs.existsSync('./token')) {
-    fs.writeFileSync('./token.txt', '');
+    fs.writeFileSync('./token', '');
     console.error('Missing Discord Token, please enter the bot token into the token file');
     process.exit(1);
 }
-const TOKEN = fs.readFileSync('./token.txt').toString();
+const TOKEN = fs.readFileSync('./token').toString();
 
 //discord connections
 CLIENT.on('ready', client => {
     console.log(`Logged in as ${client.user.tag}`);
     client.guilds.fetch().then(guilds =>
         registerCommands(TOKEN, client.user.id, guilds.map(g => g.id)));
-    discordInit(client);
 });
 
 CLIENT.on('interactionCreate', async interaction => {
@@ -32,13 +31,15 @@ CLIENT.on('interactionCreate', async interaction => {
     try {
 
         if (interaction.commandName === 'queue')
-            await QueueCommands.queue(interaction);
+            await createQueue(interaction);
         else if (interaction.commandName === 'join')
-            await QueueCommands.join(interaction);
+            await joinQueue(interaction);
         else if (interaction.commandName === 'leave')
-            await QueueCommands.leave(interaction);
+            await leaveQueue(interaction);
-        else if (interaction.commandName === 'stop')
+        else if (interaction.commandName === 'ready')
-            await QueueCommands.stop(interaction);
+            await readyQueue(interaction);
+        else if (interaction.commandName === 'cancel')
+            await cancelQueue(interaction);
         else if (interaction.commandName === 'player')
             await getPlayerInteraction(interaction);
 

src/queue.ts

@@ -1,262 +1,236 @@
-/* TODO
+import { CommandInteraction, GuildMember, MessageEmbed } from "discord.js";
+import { emsg, getChannel, getMember, queueInfo, shuffle } from "./util";
 
-join message should contain your current position in the queue, editing it to keep it current
+//maps ChannelID to QueueInfo
-*/
+const QUEUE = new Map<string, queueInfo>();
 
-import { Client, CommandInteraction, GuildMember, MessageEmbed, TextChannel } from "discord.js";
+/**
-import * as fs from 'fs';
+ * get the queueInfo of an interaction
-import { emsg, getChannel, getMember, memberIsModThrow, queueInfo, queueInfoBase } from "./util";
+ * @param interaction 
-
+ * @throws errorMessage class if it does not exist
-//load queues from file
+ * @returns queue info
-if (!fs.existsSync('./queues.json'))
+ */
-    fs.writeFileSync('./queues.json', '{}');
+export function getInfo(interaction: CommandInteraction): queueInfo {
-
+    let info = QUEUE.get(interaction.channelId);
-const _QUEUE = fs.readFileSync('./queues.json').toString(),
-    QUEUE = new Map<string, queueInfo>();
-
-try {
-
-    let queueJson = JSON.parse(_QUEUE);
-
-    for (let channelId of queueJson) {
-        let {teamsize} = queueJson[channelId] as queueInfoBase;
-        if (teamsize)
-            QUEUE.set(channelId, { teamsize, players: [] })
-    }
-
-} catch(e) {}
-
-function SaveQueue() {
-
-    let queueJson = Object.fromEntries(QUEUE),
-        queueFileJson: {[keys: string]: queueInfoBase} = {};
-
-    for (let channelId in QUEUE.keys())
-        queueFileJson[channelId] = { teamsize: queueJson[channelId].teamsize };
-    
-    fs.writeFileSync('./queues.json', JSON.stringify(queueFileJson, null, 2));
-
-}
-
-async function checkQueue(channel: TextChannel) {
-    let info = QUEUE.get(channel.id);
 
     if (!info)
-        return;
+        throw emsg('There is not an active queue in this channel, type `/queue` to create one');
+
+    return info;
+}
+
+/**
+ * compiles all the get functions above
+ * @param interaction 
+ * @throws if another get function throws
+ * @returns object containing each
+ */
+export const getAll = (interaction: CommandInteraction) => ({
+        member: getMember(interaction),
+        channel: getChannel(interaction),
+        info: getInfo(interaction)
+    });
+
+/**
+ * checks if the interaction data is already in the queue
+ * @param interaction 
+ * @returns boolean
+ */
+export function queueContains(interaction: CommandInteraction): boolean {
+
+    let {member, info} = getAll(interaction);
+
+    if (info.players.map(m=>m.id).includes(member.id))
+        return true;
+
+    return false;
+
+}
+
+/**
+ * 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;
     
-    if (info.players.length > info.teamsize) {
+    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'});
 
-        let team = info.players.splice(0, info.teamsize).map(m => m.toString());
+    if (origInteraction.deferred || origInteraction.replied)
-
+        await origInteraction.editReply({embeds: [embed]});
-        let embed = new MessageEmbed()
+    else
-            .setTitle('Team')
+        await origInteraction.reply({embeds: [embed]});
-            .setDescription(team.join('\n'));
-
-        await channel.send({embeds: [embed]});
-
-    }
-    
 }
-namespace Queue {
 
-    export function create(channelId: string, teamsize: number) {
+/**
-        if (!QUEUE.has(channelId)) {
+ * sends the list of teams
-            QUEUE.set(channelId, {teamsize, players: []});
+ * @param interaction
-            SaveQueue();
+ */
-        }
+async function sendTeamsEmbed(interaction: CommandInteraction, teams: GuildMember[][]) {
-    }
+    let embed = new MessageEmbed()
+        .setTitle('Teams');
 
-    export function remove(channelId: string) {
+    teams.forEach((team, i) => {
-        if (QUEUE.has(channelId)) {
+        team.map(m => m.user.tag);
-            QUEUE.delete(channelId);
+        embed.addField(`Team ${i+1}`, team.join('\n'))
-            SaveQueue();
+    });
-        }
-    }
 
-    export function addPlayer(channelId: string, member: GuildMember) {
+    interaction.reply({embeds: [embed]});
-        if (QUEUE.has(channelId)) {
+}
-            QUEUE.delete(channelId);
-        }
-    }
 
-    export function removePlayer(channelId: string, member: GuildMember) {
+/**
-        if (QUEUE.has(channelId)) {
+ * sends the list of teams
-            QUEUE.delete(channelId);
+ * @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);
 
 }
 
-SaveQueue();
+/**
+ * joins a queue from an interaction
+ * @param interaction 
+ * @throws errorMessage class if it cannot be joined
+ */
+export async function joinQueue(interaction: CommandInteraction) {
 
-export async function discordInit(client: Client) {
+    let {member, info} = getAll(interaction);
 
-    for (let channelId in QUEUE.keys()) {
+    if (queueContains(interaction))
+        throw emsg('You are already in the active queue');
 
-        let info = QUEUE.get(channelId),
+    info.players.push(member);
-            channel = await client.channels.fetch(channelId);
+    clearTimeout(info.timeout);
+    info.timeout = setQueueTimeout(interaction)
 
-        if (!info) { //no idea what could cause this but TS complains
+    QUEUE.set(interaction.channelId, info);
-            Queue.remove(channelId);
-            continue;
-        }
 
-        if (!channel || !(channel instanceof TextChannel)) {
+    sendQueueEmbed(interaction);
-            console.error(`Unable to find channel ${channelId} for teams of ${info?.teamsize}`);
+    await interaction.reply('Joined the queue');
-            Queue.remove(channelId);
+
-            continue;
+}
-        }
+
-
+/**
-        channel.send('The bot has just restarted and anybody in the queues have been reset')
+ * leaves a queue from an interaction
-
+ * @param interaction 
-    }
+ * @throws errorMessage class if it cannot be left
-        
+ */
-}
+export async function leaveQueue(interaction: CommandInteraction) {
-export namespace QueueCommands {
+
-
+    let {member, info} = getAll(interaction);
-    /**
+
-     * get the queueInfo of an interaction
+    if (!queueContains(interaction))
-     * @param interaction 
+        throw emsg('You aren\'t in the active queue');
-     * @throws errorMessage class if it does not exist
+
-     * @returns queue info
+    info.players.splice(info.players.indexOf(member), 1);
-     */
+    clearTimeout(info.timeout);
-    function getInfo(interaction: CommandInteraction): queueInfo {
+    info.timeout = setQueueTimeout(interaction)
-        let info = QUEUE.get(interaction.channelId);
+
-
+    QUEUE.set(interaction.channelId, info);
-        if (!info)
+
-            throw emsg('There is not an active queue in this channel, type `/queue` to create one');
+    sendQueueEmbed(interaction);
-
+    await interaction.reply('Left the queue');
-        return info;
+
-    }
+}
-
+
-    /**
+/**
-     * compiles all the get functions above
+ * readys a queue from an interaction
-     * @param interaction 
+ * @param interaction 
-     * @throws if another get function throws
+ * @throws errorMessage class if it cannot be readied
-     * @returns object containing each
+ */
-     */
+export async function readyQueue(interaction: CommandInteraction) {
-    const getAll = (interaction: CommandInteraction) => ({
+
-            member: getMember(interaction),
+    let {member, info} = getAll(interaction),
-            channel: getChannel(interaction),
+        {initiator} = info;
-            info: getInfo(interaction)
+
-        });
+    if (member.id !== initiator.member.id)
-
+        throw emsg('Only the queue initiator can ready the queue');
-    /**
+
-     * checks if the interaction data is already in the queue
+    clearQueue(interaction);
-     * @param interaction 
+
-     * @returns boolean
+    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');
-    export function queueContains(interaction: CommandInteraction): boolean {
+
-
+    //team data
-        let {member, info} = getAll(interaction);
+    let playerlist: GuildMember[] = shuffle(info.players),
-
+        teams: GuildMember[][] = [];
-        if (info.players.map(m=>m.id).includes(member.id))
+
-            return true;
+    //fill team data
-
+    for (let i = 0; i < playerlist.length; i+= info.teamsize)
-        return false;
+        teams.push(playerlist.slice(i, i+info.teamsize));
-
+
-    }
+    sendTeamsEmbed(interaction, teams);
-
+
-    /**
+}
-     * creates a queue from an interaction
+
-     * @param interaction 
+/**
-     * @throws errorMessage class if it cannot be left
+ * readys a queue from an interaction
-     */
+ * @param interaction 
-    export function queueCreate(interaction: CommandInteraction) {
+ * @throws errorMessage class if it cannot be reset
-        memberIsModThrow(interaction);
+ */
-
+export async function cancelQueue(interaction: CommandInteraction) {
-        let {channelId} = interaction,
+
-            teamsize = interaction.options.getInteger('teamsize', true);
+    let {info, member, channel} = getAll(interaction);
-
+
-        if (QUEUE.has(channelId))
+    if (!member.permissionsIn(channel).has('MANAGE_MESSAGES'))
-            throw emsg(`There is already an active queue in this channel for teams of ${QUEUE.get(channelId)?.teamsize}`);
+        throw emsg('You do not have permission to run this command');
-
+
-        Queue.create(channelId, teamsize);
+    clearQueue(interaction);
-
+
-        interaction.reply(`A queue for teams of ${teamsize} has been started`)
+    await interaction.reply('Queue has been reset');
-
-    }
-
-    /**
-     * creates a queue from an interaction
-     * @param interaction 
-     * @throws errorMessage class if it cannot be left
-     */
-    export async function queue(interaction: CommandInteraction) {
-
-        let teamsize = interaction.options.getInteger('teamsize');
-
-        if (teamsize) {
-            queueCreate(interaction);
-            return;
-        }
-
-        let info = getInfo(interaction);
-
-        let 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'});
-
-        await interaction.reply({embeds: [embed], ephemeral: true});
-
-    }
-
-    /**
-     * stops a queue from an interaction
-     * @param interaction 
-     * @throws errorMessage class if it cannot be joined
-     */
-    export async function stop(interaction: CommandInteraction) {
-        memberIsModThrow(interaction);
-
-        QUEUE.delete(interaction.channelId);
-
-        await interaction.reply('Queue has been reset');
-
-    }
-
-    /**
-     * joins a queue from an interaction
-     * @param interaction 
-     * @throws errorMessage class if it cannot be readied
-     */
-    export async function join(interaction: CommandInteraction) {
-
-        let {member, info, channel} = getAll(interaction);
-
-        if (queueContains(interaction))
-            throw emsg('You are already in the queue');
-
-        info.players.push(member);
-
-        QUEUE.set(interaction.channelId, info);
-
-        await interaction.reply('Joined the queue');
-
-        checkQueue(channel);
-
-    }
-
-    /**
-     * leaves a queue from an interaction
-     * @param interaction 
-     * @throws errorMessage class if it cannot be reset
-     */
-    export async function leave(interaction: CommandInteraction) {
-
-        let {member, info} = getAll(interaction);
-
-        if (!queueContains(interaction))
-            throw emsg('You aren\'t in the queue');
-
-        info.players.splice(info.players.indexOf(member), 1);
-
-        QUEUE.set(interaction.channelId, info);
-
-        await interaction.reply('Left the queue');
-        
-    }
 
 }

src/util.ts

@@ -46,11 +46,14 @@ export const emsg = (msg: string, ephemeral: boolean = true) => new errorMessage
 
 
 
-export interface queueInfoBase {
+export type queueInfo = {
-    teamsize: number
+    players: GuildMember[],
-}
+    initiator: {
-export interface queueInfo extends queueInfoBase{
+        interaction: CommandInteraction,
-    players: GuildMember[]
+        member: GuildMember
+    },
+    teamsize: number,
+    timeout: NodeJS.Timeout
 }
 
 /**
@@ -81,15 +84,4 @@ export function getChannel(interaction: CommandInteraction): TextChannel {
         throw emsg('Unable to retrieve text channel information, please try again');
 
     return channel;
-}
+}
-
-
-export function memberIsMod(interaction: CommandInteraction): boolean {
-    let member = getMember(interaction);
-    return member.permissionsIn(interaction.channelId).has('MANAGE_MESSAGES');
-}
-
-export function memberIsModThrow(interaction: CommandInteraction) {
-    if (!memberIsMod(interaction))
-        throw emsg('Member is not a moderator');
-}