final deployment fix

lum-network · Feb 14, 2024 · a9e64a9 · a9e64a9
1 parent a7bad10
commit a9e64a9
Show file tree

Hide file tree

Showing 7 changed files with 63 additions and 34 deletions.
diff --git a/src/api.ts b/src/api.ts
@@ -28,9 +28,12 @@ async function bootstrap() {
                 host: redisUrl[0].host,
                 port: redisUrl[0].port,
                 password: redisUrl[0].password,
-                tls: {
-                    rejectUnauthorized: false,
-                },
+                tls:
+                    process.env.ENV === 'production'
+                        ? {
+                              rejectUnauthorized: false,
+                          }
+                        : null,
             },
         },
         { inheritAppConfig: true },

diff --git a/src/async/consumers/beam.consumer.ts b/src/async/consumers/beam.consumer.ts
@@ -77,5 +77,7 @@ export class BeamConsumer {
 
             this._logger.debug(`Updated beam event ${job.data.url}`);
         }
+
+        return beam;
     }
 }
diff --git a/src/async/consumers/block.consumer.ts b/src/async/consumers/block.consumer.ts
@@ -227,6 +227,8 @@ export class BlockConsumer {
                     data: blockDoc,
                 });
             }
+
+            return blockDoc;
         } catch (error) {
             this._logger.error(`Failed to ingest block ${job.data.blockHeight}: ${error}`, error.stack);
             throw error;

diff --git a/src/async/consumers/millions-deposit.consumer.ts b/src/async/consumers/millions-deposit.consumer.ts
@@ -57,6 +57,7 @@ export class MillionsDepositConsumer {
 
         try {
             await this._millionsDepositService.update(formattedMillionsDeposit);
+            return formattedMillionsDeposit;
         } catch {
             this._logger.error(`MillionsDepositEntity with id ${job.data.id} does not exist`);
             return;

diff --git a/src/async/queues.ts b/src/async/queues.ts
@@ -10,11 +10,14 @@ export const AsyncQueues: BullModuleAsyncOptions[] = [
         inject: [ConfigService],
         useFactory: (configService: ConfigService) => ({
             url: configService.get<string>('REDIS_URL'),
-            redis: {
-                tls: {
-                    rejectUnauthorized: false,
-                },
-            },
+            redis:
+                configService.get<string>('ENV') === 'production'
+                    ? {
+                          tls: {
+                              rejectUnauthorized: false,
+                          },
+                      }
+                    : {},
             limiter: {
                 max: 1,
                 duration: 30,
@@ -31,11 +34,14 @@ export const AsyncQueues: BullModuleAsyncOptions[] = [
         inject: [ConfigService],
         useFactory: (configService: ConfigService) => ({
             url: configService.get<string>('REDIS_URL'),
-            redis: {
-                tls: {
-                    rejectUnauthorized: false,
-                },
-            },
+            redis:
+                configService.get<string>('ENV') === 'production'
+                    ? {
+                          tls: {
+                              rejectUnauthorized: false,
+                          },
+                      }
+                    : {},
             defaultJobOptions: {
                 removeOnComplete: false,
                 removeOnFail: false,
@@ -48,11 +54,14 @@ export const AsyncQueues: BullModuleAsyncOptions[] = [
         inject: [ConfigService],
         useFactory: (configService: ConfigService) => ({
             url: configService.get<string>('REDIS_URL'),
-            redis: {
-                tls: {
-                    rejectUnauthorized: false,
-                },
-            },
+            redis:
+                configService.get<string>('ENV') === 'production'
+                    ? {
+                          tls: {
+                              rejectUnauthorized: false,
+                          },
+                      }
+                    : {},
             defaultJobOptions: {
                 removeOnComplete: false,
                 removeOnFail: false,
@@ -65,11 +74,14 @@ export const AsyncQueues: BullModuleAsyncOptions[] = [
         inject: [ConfigService],
         useFactory: (configService: ConfigService) => ({
             url: configService.get<string>('REDIS_URL'),
-            redis: {
-                tls: {
-                    rejectUnauthorized: false,
-                },
-            },
+            redis:
+                configService.get<string>('ENV') === 'production'
+                    ? {
+                          tls: {
+                              rejectUnauthorized: false,
+                          },
+                      }
+                    : {},
             defaultJobOptions: {
                 removeOnComplete: false,
                 removeOnFail: false,
@@ -82,11 +94,14 @@ export const AsyncQueues: BullModuleAsyncOptions[] = [
         inject: [ConfigService],
         useFactory: (configService: ConfigService) => ({
             url: configService.get<string>('REDIS_URL'),
-            redis: {
-                tls: {
-                    rejectUnauthorized: false,
-                },
-            },
+            redis:
+                configService.get<string>('ENV') === 'production'
+                    ? {
+                          tls: {
+                              rejectUnauthorized: false,
+                          },
+                      }
+                    : {},
             limiter: {
                 max: 1,
                 duration: 30,

diff --git a/src/sync_consumer.ts b/src/sync_consumer.ts
@@ -13,9 +13,12 @@ async function bootstrap() {
             host: redisUrl[0].host,
             port: redisUrl[0].port,
             password: redisUrl[0].password,
-            tls: {
-                rejectUnauthorized: false,
-            },
+            tls:
+                process.env.ENV === 'production'
+                    ? {
+                          rejectUnauthorized: false,
+                      }
+                    : null,
         },
     });
 

diff --git a/src/sync_scheduler.ts b/src/sync_scheduler.ts
@@ -13,9 +13,12 @@ async function bootstrap() {
             host: redisUrl[0].host,
             port: redisUrl[0].port,
             password: redisUrl[0].password,
-            tls: {
-                rejectUnauthorized: false,
-            },
+            tls:
+                process.env.ENV === 'production'
+                    ? {
+                          rejectUnauthorized: false,
+                      }
+                    : null,
         },
     });
-Original file line number
+Diff line change
@@ Expand Up / @@ -77,5 +77,7 @@ export class BeamConsumer { @@
                 this._logger.debug(`Updated beam event ${job.data.url}`);
             }
+            return beam;
         }
     }