feat: add cluster header + connection name (#469)

Added a connection name to easily see what cluster is connected to RabbitMQ

Author: 536b656c6c79

package.json

@@ -1,6 +1,6 @@
 {
   "name": "would-you",
-  "version": "1.3.9",
+  "version": "1.3.10",
   "description": "Would you rather die or use this bot. You got the choice",
   "main": "dist/cluster.js",
   "scripts": {

src/global.d.ts

@@ -32,6 +32,10 @@ export interface IQueueMessage {
   };
   channelId: string | null;
   retries: number;
+  location: {
+    shard: number;
+    cluster: number;
+  };
 }
 export type Result<T, E extends Error = Error> =
   | { success: true; result: T }

src/util/dailyMessage.ts

@@ -16,7 +16,7 @@ export default class DailyMessage {
   async listen() {
     console.log(this.client.cluster.count);
     const URL = process.env.RABBITMQ_URL || "fallback";
-    const connection = await amqplib.connect(URL);
+    const connection = await amqplib.connect(URL, { clientProperties: { connection_name: `client-cluster-${this.client.cluster.id}` } });
     let QUEUE = `cluster-${this.client.cluster.id}`;
     if (connection) {
       const channel = await connection.createChannel();
@@ -25,7 +25,6 @@ export default class DailyMessage {
         await channel.assertQueue(QUEUE, {
           durable: false,
           deadLetterExchange: "DLX",
-
           deadLetterRoutingKey: "nVZzaJrwJ9",
         });
         channel.consume(QUEUE, async (message) => {
@@ -74,6 +73,7 @@ export default class DailyMessage {
     message: IQueueMessage,
     properties: MessageProperties,
   ): Promise<Result<string>> {
+    console.log(message)
     if (message.channelId == null) {
       return {
         success: false,
@@ -210,7 +210,7 @@ export default class DailyMessage {
     reason: string,
     message: amqplib.Message,
   ) {
-    const headers = { rejectionCause: reason };
+    const headers = { rejectionCause: reason, cluster: this.client.cluster.id};
     channel.publish("DLX", "key", message.content, {
       headers: headers,
       messageId: message.properties.messageId,