Discord chunks (#18)

* Fix typo

* Automatically send chunks to discord.

* Fix typo

Author: webbertakken

functions/src/config/discord.ts

@@ -30,20 +30,29 @@ export class Discord {
 
   static async sendMessage(
     channelId: string,
-    message: Eris.MessageContent,
+    messageContent: Eris.MessageContent,
     files: Eris.MessageFile | Eris.MessageFile[] | undefined = undefined,
   ): Promise<boolean> {
+    let success = false;
     try {
-      const i = await this.getInstance();
+      const discord = await this.getInstance();
+
+      if (typeof messageContent === 'string') {
+        for (const message of Discord.splitMessage(messageContent)) {
+          await discord.createMessage(channelId, message, files);
+        }
+      } else {
+        await discord.createMessage(channelId, messageContent, files);
+      }
 
-      // Todo - retry mechanism
-      await i.createMessage(channelId, message, files);
-      await this.disconnect();
-      return true;
+      success = true;
     } catch (err) {
       firebase.logger.error('An error occurred while trying to send a message to discord.', err);
-      return false;
+    } finally {
+      await this.disconnect();
     }
+
+    return success;
   }
 
   static async getInstance(): Promise<Eris.Client> {
@@ -84,4 +93,30 @@ export class Discord {
     instance.disconnect({ reconnect: false });
     instance = null;
   }
+
+  static splitMessage(message: string, maxMessageSize: number = 1950): Array<string> {
+    const numberOfMessages = Math.ceil(message.length / maxMessageSize);
+    const messages: Array<string> = new Array<string>(numberOfMessages);
+
+    for (let i = 0, pointer = 0; i < numberOfMessages; i++) {
+      let messageSize = maxMessageSize;
+
+      let prefix = '';
+      if (i !== 0) {
+        prefix = '...';
+        messageSize -= 3;
+      }
+
+      let suffix = '';
+      if (i !== numberOfMessages - 1) {
+        suffix = '...';
+        messageSize -= 3;
+      }
+
+      messages[i] = `${prefix}${message.substr(pointer, messageSize)}${suffix}`;
+      pointer += messageSize;
+    }
+
+    return messages;
+  }
 }

functions/src/logic/ingestRepoVersions/updateDatabase.ts

@@ -34,7 +34,7 @@ export const updateDatabase = async (ingestedInfoList: RepoVersionInfo[]): Promi
     await RepoVersionInfo.createMany(newVersions);
     message += `
       ${newVersions.length} new repository ${plural(newVersions.length)} detected.
-      (${newVersions.map((version) => version.version).join(', ')}`;
+      (${newVersions.map((version) => version.version).join(', ')})`;
   }
 
   if (updatedVersions.length >= 1) {

functions/src/logic/ingestUnityVersions/updateDatabase.ts

@@ -34,7 +34,7 @@ export const updateDatabase = async (ingestedInfoList: EditorVersionInfo[]): Pro
     await EditorVersionInfo.createMany(newVersions);
     message += `
       ${newVersions.length} new Unity editor ${plural(newVersions.length)} detected.
-      (${newVersions.map((version) => version.version).join(', ')}`;
+      (${newVersions.map((version) => version.version).join(', ')})`;
   }
 
   if (updatedVersions.length >= 1) {