Merge pull request #1 from diflores/feat/dockerize

Feat/dockerize

Dockerfile

@@ -0,0 +1,5 @@
+FROM node:16.13
+COPY package.json package-lock.json ./
+RUN npm ci
+WORKDIR /usr/src/app
+COPY src ./

README.md

@@ -6,6 +6,11 @@ I made a simple POC for killing Bull jobs using [Alexander Lolis implementation]
 
 ## How to run
 
-1. Run `npm install`
-2. Start the queue in one terminal: `node queue.js`
-3. Run the main process in another terminal: `node main.js`
+### Without Docker
+
+1. Run `npm install`.
+2. Start the queue in one terminal: `node queue.js`.
+3. Run the main process in another terminal: `node main.js`.
+
+### With Docker
+1. Run `docker-compose up`.

docker-compose.yml

@@ -0,0 +1,20 @@
+version: "3.9"
+services:
+  queue:
+    build: .
+    command: [ "node", "queue.js" ]
+    environment:
+      - REDIS_URL=redis://redis:6379
+    links:
+      - redis
+  main:
+    build: .
+    command: [ "node", "main.js" ]
+    environment:
+      - REDIS_URL=redis://redis:6379
+    links:
+      - redis
+  redis:
+    image: redis
+    ports:
+      - "6379:6379"

src/consts.js

@@ -0,0 +1,2 @@
+const REDIS_URL = process.env.REDIS_URL || 'redis://localhost:6379';
+module.exports = REDIS_URL;

main.js → src/main.js

@@ -1,7 +1,8 @@
 const Queue = require('bull');
+const REDIS_URL = require('./consts');
 
 function main() {
-  const myQueue = new Queue('myQueue', 'redis://localhost:6379');
+  const myQueue = new Queue('myQueue', REDIS_URL);
   myQueue.add({ commonName: 'job_1', timeToFinish: 100000 }, { attempts: 1 });
   myQueue.add({ commonName: 'job_2', timeToFinish: 5000 }, { attempts: 1 });
   myQueue.add({ commonName: 'job_3', timeToFinish: 6000 }, { attempts: 1 });

queue.js → src/queue.js

@@ -1,5 +1,6 @@
 const Queue = require('bull');
 const kill = require('tree-kill');
+const REDIS_URL = require('./consts');
 
 const MAX_TTL = 5000;
 const CONCURRENCY = 2;
@@ -45,7 +46,7 @@ function checkIfJobsToKill(myQueue) {
 }
 
 function createQueue() {
-  const myQueue = new Queue('myQueue', 'redis://localhost:6379');
+  const myQueue = new Queue('myQueue', REDIS_URL);
   myQueue.process(CONCURRENCY, `${__dirname}/process.js`);
   myQueue.on('active', () => checkIfJobsToKill(myQueue));
   myQueue.on('failed', (job) => console.log('Job failed', job.id, job.stacktrace));