[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

@@ -36,11 +36,11 @@
 });
 
 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');
   if (!msg) return;
   const { content } = msg;
@@ -70,7 +70,7 @@
   const guild = await client.guilds.fetch(guildId);
   const channels = await guild.channels.fetch();
 
   const arrayChannels = Array.from(channels, ([name, value]) => ({ ...value } as Channel));
   const textChannels = arrayChannels.filter(channel => channel.type == ChannelType.GuildText) as TextChannel[];
   const rawPositionBasedSortedTextChannels = textChannels.sort((textChannelA, textChannelB) =>
     textChannelA.rawPosition > textChannelB.rawPosition ? 1 : -1
@@ -179,7 +179,7 @@
       // 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
@@ -190,7 +190,7 @@
   // eslint-disable-next-line @typescript-eslint/no-explicit-any
   const worker = new Worker(
     'cronJobQueue',
     async (job: Job<any, any, string> | undefined) => {
       if (job) {
         // Call the extractMessagesDaily function
         await cronJob(client);

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();
+};