Adding a !list command (#16)

* Adding list command

* Adding test

* Adding a total list

README.md

@@ -61,7 +61,11 @@ The shuffler can be configured by adding a `config.json` file (an example is pro
 
 #### chatCommand
 
-> Configures the chat command (e.g !swap) to respond to (default: ^swap$)
+> Configures the swap chat command (e.g !swap) to respond to (default: ^swap$)
+
+#### chatListCommand
+
+> Configures the list chat command (e.g !list) to respond to (default: ^list$)
 
 #### redemptionName
 

src/config.js

@@ -32,6 +32,7 @@ const getDefaultConfig = () => {
     "port": 7070,
     "host": "127.0.0.1",
     "chatCommand": "^swap$",
+    "chatListCommand": "^list$",
     "chatCooldownGlobal": "60000",
     "chatCooldownUser": "60000",
     "redemptionName": "^swap$",

src/index.js

@@ -41,14 +41,39 @@ const startServer = async () => {
     if(!rom) {
       return;
     }
-    const romName = rom.replace(/\./g, '_');
+    const romName = rom.replace(/\.[a-zA-Z]+$/, '')
 
     twitchShufflerListener.say(`/me Swapping to "${romName}" (${cause})`);
     sockets.forEach((sock) => {
       sock.write(`switchRom\t${rom}\n`);
     });
   };
 
+  const list = async () => {
+    let roms = await romShuffler.fetchCurrentRoms();
+
+    let filteredRoms = roms
+      .map((rom) => rom.replace(/\.[a-zA-Z]+$/, ''))
+      .filter((rom) => rom !== 'DeleteMe')
+    ;
+
+    let total = filteredRoms.length;
+
+    let partition = filteredRoms;
+
+    const join = () => {
+      return partition.join(', ');
+    };
+
+    while(join().length >= 500) {
+      partition.pop();
+    }
+
+    let chatText = `ExtraLife ${join()} (${total}/${total})`;
+
+    return chatText;
+  };
+
   const swap = async (index, cause) => {
     const rom = await romShuffler.shuffle(index);
 
@@ -78,7 +103,10 @@ const startServer = async () => {
   };
 
   const romShuffler = new RomShuffler();
-  const twitchShufflerListener = new TwitchShufflerListener({ swap });
+  const twitchShufflerListener = new TwitchShufflerListener({
+    swap,
+    list,
+  });
 
   logger.info(chalk.blue(`TCP Server is starting on ${config.host} ${config.port}`));
 

src/twitch.js

@@ -7,12 +7,16 @@ const ComfyJS = require("comfy.js");
 
 const chatCommandRegExp = new RegExp(config.chatCommand);
 
+const chatListCommandRegExp = new RegExp(config.chatListCommand);
+
 const rewardNameRegExp = new RegExp(config.rewardNameRegExp);
 
 class TwitchShufflerListener {
   constructor(props = {}) {
     this.swap = props.swap;
 
+    this.list = props.list;
+
     this.lastCommandTimestamps = {};
   }
 
@@ -55,6 +59,10 @@ class TwitchShufflerListener {
         this.swap(message, `${user} via command`);
       }
     }
+
+    if(chatListCommandRegExp.test(command)) {
+      this.say(await this.list(message));
+    }
   }
 
   async onReward( user, reward, cost, extra ) {

src/twitch.spec.js

@@ -14,6 +14,30 @@ describe('twitch', () => {
       listener = new TwitchShufflerListener();
     });
 
+    describe('list', () => {
+      it('should list games on !list', () => {
+        listener.list = sinon.spy();
+
+        listener.isCoolingDown = sinon.spy(() => false);
+
+        listener.onCommand(
+          "fake_user",
+          "list", // TODO
+          "fake_message",
+          {},
+          {
+            sinceLastCommand: {
+              any: 0
+            }
+          }
+        );
+
+        // expect(listener.isCoolingDown.called).to.eql(true);
+        expect(listener.list.called).to.eql(true);
+        expect(listener.list.calledWith("fake_message")).to.eql(true);
+      });
+    });
+
     it('should swap on !swap', () => {
       listener.swap = sinon.spy();