Merge branch 'main' of https://github.com/AbdulAhadArain/multiswap-node…

… into develop

.env.example

@@ -1,4 +1,6 @@
 PORT=3000
 MONGODB_URL=mongodb://127.0.0.1:27017/multiswap-node
 QUEUE=Transaction
-GATEWAY_BACKEND_URL=
+GATEWAY_BACKEND_URL=https://api-leaderboard.dev.svcs.ferrumnetwork.io
+REDIS_HOST=127.0.0.1
+REDIS_PORT=6379

README.md

@@ -6,6 +6,8 @@ Redis Version `v7.0.8`
 
 Run the Redis Server in your machine by using `redis-server` command
 
+Run this command `cp .env.example .env` to create .env file
+
 Run `yarn` OR `yarn install` at the root of the repo
 
 Run `yarn dev` to run Server

src/services/job.service.ts

@@ -3,7 +3,12 @@ import { JobRequestBody } from '../interfaces';
 import dotenv from 'dotenv';
 dotenv.config();
 
-const queue = new Queue(process.env.QUEUE as string);
+const queue = new Queue(process.env.QUEUE as string, {
+  connection: {
+    host: process.env.REDIS_HOST as string,
+    port: Number(process.env.REDIS_PORT) as number,
+  },
+});
 
 export const addJobs = async (jobBody: JobRequestBody): Promise<Job> => {
   const job = await queue.add(jobBody.name, jobBody);

src/worker.ts

@@ -5,6 +5,12 @@ const worker = new Worker(
   process.env.QUEUE as string,
   async job =>
     await web3Service.getTransactionReceipt(job.data.txId, job.data.rpcURL),
+  {
+    connection: {
+      host: process.env.REDIS_HOST as string,
+      port: Number(process.env.REDIS_PORT) as number,
+    },
+  },
 );
 worker.on('completed', async job => {
   console.info(`${job.id} has completed!`);