Merge pull request #129 from TogetherCrew/redis-queue-retry-option

[FIXBUG]: set redis attempts to 0

.gitignore

@@ -5,6 +5,7 @@ src/config/*.env
 # compiled output
 /dist
 /node_modules
+/lib    
 
 #migration
 migrate.json

src/functions/fetchMessages.ts

@@ -66,7 +66,7 @@ async function getNeedDataFromMessage(message: Message, threadInfo?: threadInfo)
       channelName: threadInfo?.channelName ? threadInfo?.channelName : '',
       threadId: threadInfo?.threadId ? threadInfo?.threadId : null,
       threadName: threadInfo?.threadName ? threadInfo?.threadName : null,
-      isGeneratedByWebhook: message.webhookId ? true : false
+      isGeneratedByWebhook: message.webhookId ? true : false,
     };
   } else {
     return {
@@ -83,7 +83,7 @@ async function getNeedDataFromMessage(message: Message, threadInfo?: threadInfo)
       channelName: message.channel instanceof TextChannel ? message.channel.name : null,
       threadId: null,
       threadName: null,
-      isGeneratedByWebhook: message.webhookId ? true : false
+      isGeneratedByWebhook: message.webhookId ? true : false,
     };
   }
 }
@@ -152,22 +152,22 @@ async function fetchMessages(
         }
         channel instanceof ThreadChannel
           ? await pushMessagesToArray(connection, messagesToStore, [...fetchedMessages.values()], {
-            threadId: channel.id,
-            threadName: channel.name,
-            channelId: channel.parent?.id,
-            channelName: channel.parent?.name,
-          })
+              threadId: channel.id,
+              threadName: channel.name,
+              channelId: channel.parent?.id,
+              channelName: channel.parent?.name,
+            })
           : await pushMessagesToArray(connection, messagesToStore, [...fetchedMessages.values()]);
         break;
       }
 
       channel instanceof ThreadChannel
         ? await pushMessagesToArray(connection, messagesToStore, [...fetchedMessages.values()], {
-          threadId: channel.id,
-          threadName: channel.name,
-          channelId: channel.parent?.id,
-          channelName: channel.parent?.name,
-        })
+            threadId: channel.id,
+            threadName: channel.name,
+            channelId: channel.parent?.id,
+            channelName: channel.parent?.name,
+          })
         : await pushMessagesToArray(connection, messagesToStore, [...fetchedMessages.values()]);
       options[fetchDirection] = boundaryMessage.id;
       fetchedMessages = await channel.messages.fetch(options);

src/index.ts

@@ -37,8 +37,8 @@ const client = new Client({
 
 const partial =
   (func: any, ...args: any) =>
-    (...rest: any) =>
-      func(...args, ...rest);
+  (...rest: any) =>
+    func(...args, ...rest);
 
 const fetchMethod = async (msg: any) => {
   logger.info({ msg }, 'fetchMethod is running');
@@ -179,7 +179,7 @@ async function app() {
       // every: 10000
     },
     jobId: 'cronJob', // Optional: Provide a unique ID for the job
-    attempts: 1, // Number of times to retry the job if it fails
+    attempts: 0, // Number of times to retry the job if it fails
     backoff: {
       type: 'exponential',
       delay: 1000, // Initial delay between retries in milliseconds

src/migrations/db/1695210587863-add-isgeneratedbyweebhook-to-rawinfo-schema.ts

@@ -1,38 +1,29 @@
 import 'dotenv/config';
-import { Client, GatewayIntentBits, } from 'discord.js';
+import { Client, GatewayIntentBits } from 'discord.js';
 import { guildService } from '../../database/services';
 import { connectDB } from '../../database';
 import { databaseService } from '@togethercrew.dev/db';
 import config from '../../config';
 import { closeConnection } from '../../database/connection';
 import webhookLogic from '../utils/webhookLogic';
 
-const {
-    Guilds,
-    GuildMembers,
-    GuildMessages,
-    GuildPresences,
-    DirectMessages
-} = GatewayIntentBits;
-
+const { Guilds, GuildMembers, GuildMessages, GuildPresences, DirectMessages } = GatewayIntentBits;
 
 export const up = async () => {
-    const client = new Client({
-        intents: [Guilds, GuildMembers, GuildMessages, GuildPresences, DirectMessages],
-    });
+  const client = new Client({
+    intents: [Guilds, GuildMembers, GuildMessages, GuildPresences, DirectMessages],
+  });
 
-    await client.login(config.discord.botToken);
-    await connectDB();
-    const guilds = await guildService.getGuilds({});
-    for (let i = 0; i < guilds.length; i++) {
-        const connection = databaseService.connectionFactory(guilds[i].guildId, config.mongoose.dbURL);
-        await webhookLogic(connection, client, guilds[i].guildId);
-        await closeConnection(connection);
-    }
+  await client.login(config.discord.botToken);
+  await connectDB();
+  const guilds = await guildService.getGuilds({});
+  for (let i = 0; i < guilds.length; i++) {
+    const connection = databaseService.connectionFactory(guilds[i].guildId, config.mongoose.dbURL);
+    await webhookLogic(connection, client, guilds[i].guildId);
+    await closeConnection(connection);
+  }
 };
 
 export const down = async () => {
-    // TODO: Implement rollback logic if needed
+  // TODO: Implement rollback logic if needed
 };
-
-

src/migrations/utils/template.ts

@@ -4,12 +4,11 @@ import 'dotenv/config';
 import config from '../../config';
 
 export const up = async () => {
-    await connectDB();
-    const connection = databaseService.connectionFactory("681946187490000803", config.mongoose.dbURL);
-    await connection.createCollection('my_collection');
+  await connectDB();
+  const connection = databaseService.connectionFactory('681946187490000803', config.mongoose.dbURL);
+  await connection.createCollection('my_collection');
 };
 
 export const down = async () => {
-    await connectDB()
-
-};
+  await connectDB();
+};