From ae3798cc51cbe348b90d7f8e8c85c469f4e7dd39 Mon Sep 17 00:00:00 2001
From: Peter Savchenko <specc.dev@gmail.com>
Date: Fri, 31 Jan 2025 19:44:17 +0300
Subject: [PATCH] more logs

---
 runner.ts                          | 18 +++++++++++++++++-
 workers/grouper/src/index.ts       |  6 +++++-
 workers/grouper/src/redisHelper.ts |  7 ++++++-
 3 files changed, 28 insertions(+), 3 deletions(-)

diff --git a/runner.ts b/runner.ts
index 4ff195d3..12f168ea 100644
--- a/runner.ts
+++ b/runner.ts
@@ -16,6 +16,8 @@ if (process.env.HAWK_CATCHER_TOKEN) {
   HawkCatcher.init(process.env.HAWK_CATCHER_TOKEN);
 }
 
+console.log('process.env', process.env);
+
 type WorkerConstructor = new () => Worker;
 
 const BEGINNING_OF_ARGS = 2;
@@ -27,6 +29,8 @@ const BEGINNING_OF_ARGS = 2;
  */
 const workerNames = process.argv.slice(BEGINNING_OF_ARGS);
 
+console.log('workerNames', workerNames);
+
 /**
  * Workers dispatcher.
  * Load, run and finish workers.
@@ -55,6 +59,8 @@ class WorkerRunner {
      */
     this.loadPackages()
       .then((workerConstructors) => {
+        console.log('packages loaded');
+        
         this.constructWorkers(workerConstructors);
       })
       // .then(() => {
@@ -165,8 +171,12 @@ class WorkerRunner {
    * @param workerConstructors - worker constructors to create new instances
    */
   private constructWorkers(workerConstructors: WorkerConstructor[]): void {
+    console.log('constructWorkers', workerConstructors);
+
     return workerConstructors.forEach((WorkerClass) => {
       try {
+        console.log('constructing worker', WorkerClass);
+
         const worker = new WorkerClass();
 
         this.workers.push(worker);
@@ -302,5 +312,11 @@ class WorkerRunner {
   }
 }
 
+console.log('Starting worker runner');
+
 // eslint-disable-next-line no-new
-new WorkerRunner();
+try {
+  new WorkerRunner();
+} catch (error) {
+  console.error('Error running worker runner', error);
+}
diff --git a/workers/grouper/src/index.ts b/workers/grouper/src/index.ts
index 4ea0950e..af67de70 100644
--- a/workers/grouper/src/index.ts
+++ b/workers/grouper/src/index.ts
@@ -49,10 +49,14 @@ export default class GrouperWorker extends Worker {
    * Start consuming messages
    */
   public async start(): Promise<void> {
+    console.log('starting grouper worker');
+
     await this.db.connect();
     this.prepareCache();
-    await this.redis.initialize();
+    console.log('redis initializing');
 
+    await this.redis.initialize();
+    console.log('redis initialized');
     await super.start();
   }
 
diff --git a/workers/grouper/src/redisHelper.ts b/workers/grouper/src/redisHelper.ts
index c29821ba..32df5876 100644
--- a/workers/grouper/src/redisHelper.ts
+++ b/workers/grouper/src/redisHelper.ts
@@ -28,9 +28,14 @@ export default class RedisHelper {
    */
   constructor() {
     try {
-      this.redisClient = createClient({ url: process.env.REDIS_URL });
+      console.log('redis constructor', process.env.REDIS_URL);
       
+
+      this.redisClient = createClient({ url: process.env.REDIS_URL });
+
       this.redisClient.on('error', (error) => {
+        console.log('redis error', error);
+        
         if (error) {
           this.logger.error('Redis error: ', error);
           HawkCatcher.send(error);