more logs

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);
+}

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();
   }
 

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);