test: wip

src/index.ts

@@ -24,7 +24,7 @@ async function main() {
   log.info('Connected to Redis!');
 
   await queryServiceReader(frontendPublisher, mlPublisher, 'neo4j');
-  await insightProcessor();
+  await insightProcessor(frontendPublisher);
 }
 
 await main();

src/readers/insightProcessor.ts

-import { rabbitMq, ums, mail, SMTP_USER, DEBUG_EMAIL } from '../variables';
+import { rabbitMq, ums, mail, SMTP_USER, DEBUG_EMAIL, ENV } from '../variables';
 import { log } from '../logger';
 import { type InsightModel } from 'ts-common';
 import { createHeadlessEditor } from '@lexical/headless';
@@ -14,6 +14,7 @@ import { populateTemplate } from '../utils/insights';
 import { RabbitMqBroker } from 'ts-common/rabbitMq';
 import { validateInsight } from '../utils/insights/validateInsight';
 import { validateTypeInsight } from '../utils/insights/validateTypeInsight';
+import { wsReturnKey, type WsMessageBackend2Frontend } from 'ts-common';
 
 const dom = new JSDOM();
 function setUpDom() {
@@ -36,7 +37,7 @@ function setUpDom() {
   };
 }
 
-export const insightProcessor = async () => {
+export const insightProcessor = async (frontendPublisher: RabbitMqBroker) => {
   if (mail == null) {
     log.warn('Mail is not configured. Insight processor will be disabled');
     //return;
@@ -101,8 +102,21 @@ export const insightProcessor = async () => {
           insight = statCheck(insight, result);
         }
 
+        log.info('Insight save: ', insight);
+
         await ums.updateInsight(insight.userId as number, insight.id, insight);
 
+        if (ENV == 'develop') {
+          const message: WsMessageBackend2Frontend = {
+            type: wsReturnKey.insightResults,
+            callID: headers.callID,
+            insight,
+            status: 'success',
+          };
+
+          frontendPublisher.publishMessageToFrontend(message, headers.routingKey, headers);
+        }
+
         if (insight.status || message.force) {
           if (insight.status) log.debug('Insight passed the check');
           if (message.force) log.debug('Forced insight processing');