fix notification service max payload

Signed-off-by: simvalery <[email protected]>
InternetOfPeers · Dec 4, 2024 · d6b6234 · d6b6234
1 parent 346ebff
commit d6b6234
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/notification-service/src/app.ts b/notification-service/src/app.ts
@@ -1,4 +1,4 @@
-import { ApplicationState, COMMON_CONNECTION_CONFIG, DatabaseServer, GenerateTLSOptionsNats, MessageBrokerChannel, Migration, mongoForLoggingInitialization, PinoLogger, pinoLoggerInitialization } from '@guardian/common';
+import { ApplicationState, COMMON_CONNECTION_CONFIG, DatabaseServer, GenerateTLSOptionsNats, LargePayloadContainer, MessageBrokerChannel, Migration, mongoForLoggingInitialization, PinoLogger, pinoLoggerInitialization } from '@guardian/common';
 import { ApplicationStates } from '@guardian/interfaces';
 import { MikroORM } from '@mikro-orm/core';
 import { MongoDriver } from '@mikro-orm/mongodb';
@@ -54,6 +54,12 @@ Promise.all([
         state.updateState(ApplicationStates.STARTED);
         state.updateState(ApplicationStates.INITIALIZING);
         state.updateState(ApplicationStates.READY);
+
+        const maxPayload = parseInt(process.env.MQ_MAX_PAYLOAD, 10);
+        if (Number.isInteger(maxPayload)) {
+            new LargePayloadContainer().runServer();
+        }
+
         await logger.info('notification service started', ['NOTIFICATION_SERVICE']);
     },
     (reason) => {