From 90263c2fc4f70fbbb7fe3210671d4eb43efd0f15 Mon Sep 17 00:00:00 2001
From: MarcosPierasNL <pieras.marcos@gmail.com>
Date: Thu, 20 Mar 2025 09:51:40 +0100
Subject: [PATCH] test: wip
---
src/index.ts | 2 +-
src/readers/insightProcessor.ts | 18 ++++++++++++++++--
2 files changed, 17 insertions(+), 3 deletions(-)
diff --git a/src/index.ts b/src/index.ts
index 15b50d0..34c70e3 100644
--- a/src/index.ts
+++ b/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();
diff --git a/src/readers/insightProcessor.ts b/src/readers/insightProcessor.ts
index 777c620..e937452 100644
--- a/src/readers/insightProcessor.ts
+++ b/src/readers/insightProcessor.ts
@@ -1,4 +1,4 @@
-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');
--
GitLab