test: e2e 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';
@@ -12,6 +12,7 @@ import { diffCheck } from './diffCheck';
 import { VariableNode } from '../utils/lexical';
 import { populateTemplate } from '../utils/insights';
 import { RabbitMqBroker } from 'ts-common/rabbitMq';
+import type { WsMessageBackend2Frontend } from 'ts-common';
 
 const dom = new JSDOM();
 function setUpDom() {
@@ -34,10 +35,10 @@ 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;
+    //return;
   }
 
   log.info('Starting insight processor');
@@ -107,7 +108,20 @@ export const insightProcessor = async () => {
         }
 
         if (insight.userId == null) return; // fixes ts but never is the case
-        await ums.updateInsight(insight.userId, insight.id, insight);
+
+        //await ums.updateInsight(insight.userId, insight.id, insight);
+
+        // For testing only, not in production
+        if (ENV == 'develop') {
+          const message: WsMessageBackend2Frontend = {
+            type: 'queryStatusUpdate',
+            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');