From 0afdf1a12e5b1135b8aa898032f925993df05c76 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Carl-Gerhard=20Lindesva=CC=88rd?= <lindesvard@gmail.com>
Date: Mon, 5 Feb 2024 21:33:43 +0100
Subject: [PATCH] add worker

---
 apps/worker/src/index.ts  | 19 +++++++++----------
 captain-definition-worker |  4 ++++
 2 files changed, 13 insertions(+), 10 deletions(-)
 create mode 100644 captain-definition-worker

diff --git a/apps/worker/src/index.ts b/apps/worker/src/index.ts
index 1f70db83..a43b4862 100644
--- a/apps/worker/src/index.ts
+++ b/apps/worker/src/index.ts
@@ -1,6 +1,7 @@
 import { createBullBoard } from '@bull-board/api';
 import { BullMQAdapter } from '@bull-board/api/bullMQAdapter';
 import { ExpressAdapter } from '@bull-board/express';
+import type { WorkerOptions } from 'bullmq';
 import { Worker } from 'bullmq';
 import express from 'express';
 
@@ -10,20 +11,21 @@ import { cronQueue } from '@mixan/queue/src/queues';
 import { cronJob } from './jobs/cron';
 import { eventsJob } from './jobs/events';
 
-const PORT = process.env.PORT || 3000;
+const PORT = parseInt(process.env.WORKER_PORT || '3000', 10);
 const serverAdapter = new ExpressAdapter();
 serverAdapter.setBasePath('/');
 const app = express();
 
-new Worker(eventsQueue.name, eventsJob, {
+const workerOptions: WorkerOptions = {
   connection,
-});
-
-new Worker(cronQueue.name, cronJob, {
-  connection,
-});
+  concurrency: parseInt(process.env.CONCURRENCY || '1', 10),
+};
 
 async function start() {
+  new Worker(eventsQueue.name, eventsJob, workerOptions);
+
+  new Worker(cronQueue.name, cronJob, workerOptions);
+
   createBullBoard({
     queues: [new BullMQAdapter(eventsQueue), new BullMQAdapter(cronQueue)],
     serverAdapter: serverAdapter,
@@ -53,9 +55,6 @@ async function start() {
       },
     }
   );
-  // if (!repeatableJobs.find((job) => job.name === 'salt')) {
-  //   console.log('Add salt job to queue');
-  // }
 }
 
 start();
diff --git a/captain-definition-worker b/captain-definition-worker
new file mode 100644
index 00000000..640e0411
--- /dev/null
+++ b/captain-definition-worker
@@ -0,0 +1,4 @@
+{
+  "schemaVersion": 2,
+  "dockerfilePath": "./apps/worker/Dockerfile"
+}