refactor: remove retry kafka

iam-abin · Oct 31, 2024 · a84bbfa · a84bbfa
1 parent 0ffe10f
commit a84bbfa
Show file tree

Hide file tree

Showing 9 changed files with 10 additions and 32 deletions.
diff --git a/auth/src/config/kafka.connection.ts b/auth/src/config/kafka.connection.ts
@@ -3,11 +3,6 @@ import { Kafka } from 'kafkajs';
 const kafkaClient = new Kafka({
     clientId: 'auth-client',
     brokers: ['devhive-kafka:9092'],
-    retry: {
-        retries: 5, // Number of retries
-        initialRetryTime: 300, // Initial time to wait before the first retry (in ms)
-        maxRetryTime: 10000, // Maximum time to wait before giving up (in ms)
-      }
 });
 
 export { kafkaClient };
diff --git a/auth/src/frameworks/database/mongo/models/users.ts b/auth/src/frameworks/database/mongo/models/users.ts
@@ -76,7 +76,7 @@ userSchema.pre('save', async function (next) {
 userSchema.pre('findOneAndUpdate', async function (next) {
     const update = this.getUpdate() as Partial<ISignup>;
     if (!update.password) return next();
-    
+
     try {
         const hashedPassword: string = await generateHashedPassword(update.password);
         this.setUpdate({ ...update, password: hashedPassword });

diff --git a/auth/src/frameworks/repositories/mongo/users.repository.ts b/auth/src/frameworks/repositories/mongo/users.repository.ts
@@ -51,7 +51,6 @@ export = {
     },
 
     updateVerification: async (email: string): Promise<IUserDocument | null> => {
-
         const user = await UserModel.findOneAndUpdate({ email }, { isVerified: true }, { new: true });
         return user;
     },

diff --git a/auth/src/useCases/otp/authEmailVerificationOtp.ts b/auth/src/useCases/otp/authEmailVerificationOtp.ts
@@ -31,7 +31,7 @@ export = (dependencies: IDependency) => {
         await usersRepository.deleteOtp(email);
         // to update user verification status in users collection
         const result = await usersRepository.updateVerification(email);
-        
+
         // to produce a message to kafka topic
         const userCreatedEvent = new UserCreatedEventPublisher(kafkaClient);
         await userCreatedEvent.publish({

diff --git a/chat/src/config/kafka.connection.ts b/chat/src/config/kafka.connection.ts
@@ -3,11 +3,7 @@ import { Kafka } from 'kafkajs';
 const kafkaClient = new Kafka({
     clientId: 'chat-client',
     brokers: ['devhive-kafka:9092'],
-    retry: {
-        retries: 5, // Number of retries
-        initialRetryTime: 300, // Initial time to wait before the first retry (in ms)
-        maxRetryTime: 10000, // Maximum time to wait before giving up (in ms)
-      }
+
 });
 
 export { kafkaClient };
diff --git a/job/src/config/kafka.connection.ts b/job/src/config/kafka.connection.ts
@@ -3,11 +3,7 @@ import { Kafka } from 'kafkajs';
 const kafkaClient = new Kafka({
     clientId: 'job-client',
     brokers: ['devhive-kafka:9092'],
-    retry: {
-        retries: 5, // Number of retries
-        initialRetryTime: 300, // Initial time to wait before the first retry (in ms)
-        maxRetryTime: 10000, // Maximum time to wait before giving up (in ms)
-      }
+
 });
 
 export { kafkaClient };
diff --git a/job/src/frameworks/repositories/mongo/job.repository.ts b/job/src/frameworks/repositories/mongo/job.repository.ts
@@ -4,7 +4,7 @@ import { IFilter, IJob } from '../../types/job';
 
 const { JobModel } = Models;
 
-const JOB_LIST_SELECT_FIELDS: string[] = [
+const JOBS_SELECT_FIELDS: string[] = [
     'title',
     'companyLocation',
     'employmentType',
@@ -47,7 +47,7 @@ export = {
         const filteredJobs = await JobModel.find({...jobFilterData, isDeleted: false})
             .skip(skip)
             .limit(limit)
-            .select(JOB_LIST_SELECT_FIELDS);
+            .select(JOBS_SELECT_FIELDS);
         return filteredJobs;
     },
 
@@ -63,13 +63,13 @@ export = {
         let jobs: Partial<IJobDocument>[] | [];
         if (applicationJobIds) {
             jobs = await JobModel.find({ _id: { $nin: applicationJobIds }, isDeleted: false })
-                .select(JOB_LIST_SELECT_FIELDS)
+                .select(JOBS_SELECT_FIELDS)
                 .sort({ createdAt: -1 })
                 .skip(skip)
                 .limit(limit);
         } else {
             jobs = await JobModel.find({ isActive: true })
-                .select(JOB_LIST_SELECT_FIELDS)
+                .select(JOBS_SELECT_FIELDS)
                 .sort({ createdAt: -1 })
                 .skip(skip)
                 .limit(limit);

diff --git a/payment/src/config/kafka.connection.ts b/payment/src/config/kafka.connection.ts
@@ -3,11 +3,7 @@ import { Kafka } from 'kafkajs';
 const kafkaClient: Kafka = new Kafka({
     clientId: 'payment-client',
     brokers: ['devhive-kafka:9092'],
-    retry: {
-        retries: 5, // Number of retries
-        initialRetryTime: 300, // Initial time to wait before the first retry (in ms)
-        maxRetryTime: 10000, // Maximum time to wait before giving up (in ms)
-      }
+
 });
 
 export { kafkaClient };
diff --git a/profile/src/config/kafka.connection.ts b/profile/src/config/kafka.connection.ts
@@ -3,11 +3,7 @@ import { Kafka } from 'kafkajs';
 const kafkaClient = new Kafka({
     clientId: 'profile-client',
     brokers: ['devhive-kafka:9092'],
-    retry: {
-        retries: 5, // Number of retries
-        initialRetryTime: 300, // Initial time to wait before the first retry (in ms)
-        maxRetryTime: 10000, // Maximum time to wait before giving up (in ms)
-      }
+
 });
 
 export { kafkaClient };
-Original file line number
+Diff line change
@@ Expand Up / @@ -51,7 +51,6 @@ export = { @@
         },
         updateVerification: async (email: string): Promise<IUserDocument | null> => {
             const user = await UserModel.findOneAndUpdate({ email }, { isVerified: true }, { new: true });
             return user;
         },
@@ Expand Down @@