src/index.ts

@@ -23,11 +23,8 @@ async function main() {
   await redis.connect();
   log.info('Connected to Redis!');
 
-  queryServiceReader(frontendPublisher, mlPublisher, 'neo4j');
-  insightProcessor();
-  // TODO: other query services for other databases
-
-  log.info('Connected to RabbitMQ!');
+  await queryServiceReader(frontendPublisher, mlPublisher, 'neo4j');
+  await insightProcessor();
 }
 
-main();
+await main();

src/readers/insightProcessor.ts

@@ -94,7 +94,7 @@ export const insightProcessor = async () => {
       const cypher = query2Cypher(convertedQuery);
       if (cypher == null) return;
       try {
-        const result = await queryService(ss.dbConnections[0], cypher);
+        const result = await queryService(ss.dbConnections[0], cypher, true);
 
         insight.status = false;