From 5dacd8954fd3e0d1cbd85ced8c8da1663a77d629 Mon Sep 17 00:00:00 2001
From: Dennis Collaris <d.a.c.collaris@uu.nl>
Date: Fri, 28 Feb 2025 10:37:17 +0000
Subject: [PATCH] fix: await async methods
---
src/index.ts | 9 +++------
src/readers/insightProcessor.ts | 2 +-
2 files changed, 4 insertions(+), 7 deletions(-)
diff --git a/src/index.ts b/src/index.ts
index 40397da..15b50d0 100644
--- a/src/index.ts
+++ b/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();
diff --git a/src/readers/insightProcessor.ts b/src/readers/insightProcessor.ts
index 50bd7be..71014ea 100644
--- a/src/readers/insightProcessor.ts
+++ b/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;
--
GitLab