Unify sender workers into one package

README.md

@@ -95,13 +95,13 @@ Make sure that your `.env` configurations exists.
 Add new section to the `docker-compose.{dev,prod}.yml` files.
 
 ```
- hawk-worker-telegram:
+ hawk-worker-sender:
     image: "codexteamuser/hawk-workers:prod"
     env_file:
       - .env
-      - workers/telegram/.env
+      - workers/sender/.env
     restart: unless-stopped
-    entrypoint: /usr/local/bin/node runner.js hawk-worker-telegram
+    entrypoint: /usr/local/bin/node runner.js hawk-worker-sender
 ```
 
 ## Error handling

docker-compose.dev.yml

@@ -121,51 +121,15 @@ services:
       - ./:/usr/src/app
       - workers-deps:/usr/src/app/node_modules
 
-  hawk-worker-email:
+  hawk-worker-sender:
     build:
       dockerfile: "dev.Dockerfile"
       context: .
     env_file:
       - .env
-      - workers/email/.env
+      - workers/sender/.env
     restart: unless-stopped
-    entrypoint: yarn run-email
-    volumes:
-      - ./:/usr/src/app
-      - workers-deps:/usr/src/app/node_modules
-
-  hawk-worker-telegram:
-    build:
-      dockerfile: "dev.Dockerfile"
-      context: .
-    env_file:
-      - .env
-    restart: unless-stopped
-    entrypoint: yarn run-telegram
-    volumes:
-      - ./:/usr/src/app
-      - workers-deps:/usr/src/app/node_modules
-
-  hawk-worker-slack:
-    build:
-      dockerfile: "dev.Dockerfile"
-      context: .
-    env_file:
-      - .env
-    restart: unless-stopped
-    entrypoint: yarn run-slack
-    volumes:
-      - ./:/usr/src/app
-      - workers-deps:/usr/src/app/node_modules
-
-  hawk-worker-webhook:
-    build:
-      dockerfile: "dev.Dockerfile"
-      context: .
-    env_file:
-      - .env
-    restart: unless-stopped
-    entrypoint: yarn run-webhook
+    entrypoint: yarn run-sender
     volumes:
       - ./:/usr/src/app
       - workers-deps:/usr/src/app/node_modules

docker-compose.prod.yml

@@ -67,20 +67,11 @@ services:
     restart: unless-stopped
     entrypoint: /usr/local/bin/node runner.js hawk-worker-notifier
 
-  hawk-worker-email:
+  hawk-worker-sender:
     image: "codexteamuser/hawk-workers:prod"
     network_mode: host
     env_file:
       - .env
-      - workers/email/.env
+      - workers/sender/.env
     restart: unless-stopped
-    entrypoint: /usr/local/bin/node runner.js hawk-worker-email
-
-  hawk-worker-telegram:
-    image: "codexteamuser/hawk-workers:prod"
-    network_mode: host
-    env_file:
-      - .env
-      - workers/telegram/.env
-    restart: unless-stopped
-    entrypoint: /usr/local/bin/node runner.js hawk-worker-telegram
+    entrypoint: /usr/local/bin/node runner.js hawk-worker-sender

lib/workerNames.js

@@ -37,4 +37,11 @@ workersDir.forEach(file => {
   workers[file.name.toUpperCase()] = pkg.workerType;
 });
 
+/**
+ * Queues of the sender worker channels (one queue per channel, see workers/sender)
+ */
+['email', 'telegram', 'slack', 'webhook', 'loop'].forEach(channel => {
+  workers[channel.toUpperCase()] = `sender/${channel}`;
+});
+
 module.exports = workers;

package.json

@@ -25,33 +25,27 @@
         "test:sentry": "jest workers/sentry --config workers/sentry/jest.config.js",
         "test:javascript": "jest workers/javascript",
         "test:release": "jest workers/release",
-        "test:slack": "jest workers/slack",
-        "test:loop": "jest workers/loop",
+        "test:sender": "jest workers/sender",
         "test:limiter": "jest workers/limiter --runInBand",
         "test:grouper": "jest workers/grouper",
         "test:diff": "jest ./workers/grouper/tests/diff.test.ts",
         "test:paymaster": "jest workers/paymaster",
         "test:notifier": "jest workers/notifier",
         "test:js": "jest workers/javascript",
         "test:task-manager": "jest workers/task-manager",
-        "test:webhook": "jest workers/webhook",
         "test:clear": "jest --clearCache",
         "run-default": "yarn worker hawk-worker-default",
         "run-sentry": "yarn worker hawk-worker-sentry",
         "run-js": "yarn worker hawk-worker-javascript",
-        "run-slack": "yarn worker hawk-worker-slack",
-        "run-loop": "yarn worker hawk-worker-loop",
+        "run-sender": "yarn worker hawk-worker-sender",
         "run-grouper": "yarn worker hawk-worker-grouper",
         "run-archiver": "yarn worker hawk-worker-archiver",
         "run-accountant": "yarn worker hawk-worker-accountant",
         "run-paymaster": "yarn worker hawk-worker-paymaster",
         "run-notifier": "yarn worker hawk-worker-notifier",
         "run-release": "yarn worker hawk-worker-release",
-        "run-email": "yarn worker hawk-worker-email",
-        "run-telegram": "yarn worker hawk-worker-telegram",
         "run-limiter": "yarn worker hawk-worker-limiter",
-        "run-task-manager": "yarn worker hawk-worker-task-manager",
-        "run-webhook": "yarn worker hawk-worker-webhook"
+        "run-task-manager": "yarn worker hawk-worker-task-manager"
     },
     "dependencies": {
         "@babel/parser": "^7.26.9",