feat(cron): support template params

Author: MatthewPattell

microservices/cron/__tests__/services/task-manager-test.ts

@@ -16,7 +16,11 @@ describe('services/task-manager', () => {
     nodeId: 'node1',
     method: 'method',
     rule: '1 * * * *',
-    payload: {},
+    payload: {
+      params: {
+        world: "<%= 'hello' %>",
+      },
+    },
   });
   const tasks = [task];
 
@@ -141,9 +145,13 @@ describe('services/task-manager', () => {
     await callback();
 
     const [, { response, status, taskId }] = TypeormMock.entityManager.save.lastCall.args;
+    const [, params] = sendStub.firstCall.args;
 
     expect(TypeormMock.entityManager.save).to.calledTwice;
     expect(sendStub).to.calledOnce;
+    expect(params).to.deep.equal({
+      world: 'hello',
+    });
     expect(response).to.deep.equal(responseMock);
     expect(status).to.equal(TaskStatus.success);
     expect(taskId).to.equal(task.id);

microservices/cron/package-lock.json

@@ -44,10 +44,12 @@
 		"class-transformer": "0.4.1",
 		"class-validator": "^0.14.0",
 		"class-validator-jsonschema": "^5.0.0",
+		"lodash": "^4.17.21",
 		"node-schedule": "^2.1.1",
 		"typeorm": "0.2.41"
 	},
 	"devDependencies": {
+		"@types/lodash": "^4.14.191",
 		"@types/node-schedule": "^2.1.0"
 	}
 }

microservices/cron/package.json

@@ -1,6 +1,7 @@
 import { performance } from 'perf_hooks';
 import { Log } from '@lomray/microservice-helpers';
 import type { AbstractMicroservice } from '@lomray/microservice-nodejs-lib';
+import _ from 'lodash';
 import schedule from 'node-schedule';
 import { getCustomRepository, getRepository, Repository } from 'typeorm';
 import CONST from '@constants/index';
@@ -148,11 +149,12 @@ class TaskManager {
           taskId: id,
           status: TaskStatus.running,
         });
+        const templatedParams = JSON.parse(_.template(JSON.stringify(params || {}))() as string);
 
         await this.historyRepository.save(historyRecord);
 
         try {
-          const response = await this.ms.sendRequest(method, params, options);
+          const response = await this.ms.sendRequest(method, templatedParams, options);
 
           if (response.getError()) {
             throw response.getError();