Merge pull request #70 from ArslanKibria98/feature/node-infra

createJob modified based on v3 flow
ferrumnet · Sep 13, 2023 · ba198c9 · ba198c9
2 parents e79d79e + 9d6770d
commit ba198c9
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/src/controllers/job.controller.ts b/src/controllers/job.controller.ts
@@ -3,8 +3,8 @@ import { jobService } from '../services';
 
 export const createJob = async (req: Request, res: Response): Promise<any> => {
   try {
-    const job = await jobService.addJobs(req.body);
-    res.send({ jobId: job.id });
+    const job = await jobService.createJob(req.body.transaction);
+    res.send({ message: 'success' });
   } catch (err) {
     console.error(err);
   }

diff --git a/src/services/job.service.ts b/src/services/job.service.ts
@@ -1,5 +1,6 @@
 import { Queue, Job } from 'bullmq';
 import { JobRequestBody } from '../interfaces';
+import { addWorker } from './..//utils/crons/transactionsJob';
 import dotenv from 'dotenv';
 dotenv.config();
 
@@ -10,6 +11,13 @@ const queue = new Queue(process.env.QUEUE as string, {
   },
 });
 
+export const createJob = async (transaction: any): Promise<any> => {
+  if (transaction) {
+    addWorker(transaction);
+  }
+  return null;
+};
+
 export const addJobs = async (jobBody: JobRequestBody): Promise<Job> => {
   const job = await queue.add(jobBody.name, jobBody);
   return job;