feat: include insight processor message reader

src/index.ts

@@ -2,6 +2,7 @@ import { RabbitMqBroker, RabbitMqConnection, RedisConnector } from 'ts-common';
 import { REDIS_PASSWORD, REDIS_HOST, REDIS_PORT, RABBIT_USER, RABBIT_PASSWORD, RABBIT_PORT, RABBIT_HOST, rabbitMq } from './variables';
 import { log } from './logger';
 import { queryServiceReader } from './readers/queryService';
+import { insightProcessor } from './readers/insightProcessor';
 
 
 async function main() {
@@ -17,7 +18,8 @@ async function main() {
     await redis.connect();
     log.info('Connected to Redis!');
 
-    await queryServiceReader(frontendPublisher, mlPublisher, redis, 'neo4j');
+    queryServiceReader(frontendPublisher, mlPublisher, redis, 'neo4j');
+    insightProcessor();
     // TODO: other query services for other databases
 
     log.info('Connected to RabbitMQ!');

src/readers/insightProcessor.ts

+import { type QueryRequest } from "ts-common";
+import {
+    Neo4jConnection,
+    type DbConnection,
+    RabbitMqBroker,
+    RedisConnector
+} from "ts-common";
+import { rabbitMq, ums, type QueryExecutionTypes } from "../variables";
+import { log } from "../logger";
+import { QueryPublisher } from "../utils/queryPublisher";
+import { query2Cypher } from "../utils/cypher/converter";
+import { parseCypherQuery } from "../utils/cypher/queryParser";
+import { formatTimeDifference } from "ts-common/src/logger/logger";
+import { graphQueryBackend2graphQuery } from "../frontend/statistics";
+import { Query2BackendQuery } from "../utils/reactflow/query2backend";
+import type { GraphQueryResultMetaFromBackend } from "ts-common/src/model/webSocket/graphResult";
+import type { InsightModel } from "ts-common/src/model/webSocket/insight";
+
+
+export const insightProcessor = async () => {
+    log.info('Starting insight processor');
+
+    const insightProcessorConsumer = await new RabbitMqBroker(rabbitMq, 'insight-processor', `insight-processor`, `insight-processor`).connect();
+    log.info('Connected to RabbitMQ ST!');
+
+    await insightProcessorConsumer.startConsuming<InsightModel>("query-service", async (message, headers) => {
+        log.info('Received insight to be processed', message);
+    });
+}
+