supprt runOnce (#106)

* support runOnce

Author: oren-codefresh

agent/__tests__/index.spec.js

@@ -52,7 +52,7 @@ const buildTestConfig = () => ({
 			cronExpression: 'cron'
 		},
 		StatusReporterJob: {
-			cronExpression: 'cron'
+			cronExpression: 'cron',
 		},
 		queue: {
 
@@ -115,6 +115,7 @@ describe('Agent unit test', () => {
 				Codefresh.mockReset();
 				Codefresh.mockImplementation(() => ({
 					init: codefreshInitSpy,
+					reportStatus: jest.fn(),
 				}));
 				jest.unmock('recursive-readdir');
 				const agent = new Agent();
@@ -134,6 +135,18 @@ describe('Agent unit test', () => {
 				expect(agent._startJob).toHaveBeenNthCalledWith(2, TaskPullerJob);
 
 			});
+			it('Should call task that has runOnce when agent starts ', async () => {
+				loadActualJobs();
+				const config = buildTestConfig();
+				config.jobs.StatusReporterJob.runOnce = true;
+				const agent = new Agent();
+				agent._runOnce = jest.fn();
+				agent._startJob = jest.fn();
+				await agent.init(config);
+				expect(agent._runOnce).toHaveBeenCalledTimes(1);
+				expect(agent._runOnce).toHaveBeenNthCalledWith(1, StatusReporterJob);
+
+			});
 		});
 
 		describe('Prepare server', () => {

agent/index.js

@@ -97,7 +97,14 @@ class Agent {
 		return Promise
 			.fromCallback(cb => recursive(path.join(__dirname, './../jobs'), ignorePaths, cb))
 			.map(require)
-			.map(Job => this._startJob(Job));
+			.map(Job => {
+				const runOnce = _.get(this, `jobs.${Job.name}.runOnce`, false);
+				if (runOnce) {
+					this._runOnce(Job);
+				}
+				return Job;
+			}).map(Job => this._startJob(Job));
+			
 	}
 
 	async _readFromVenonaConfDir(dir) {
@@ -141,6 +148,16 @@ class Agent {
 		});
 	}
 
+	_runOnce(Job) {
+		const taskLogger = this.logger.child({
+			namespace: LOGGER_NAMESPACES.TASK,
+			job: Job.name,
+			uid: new Chance().guid(),
+		});
+		const job = new Job(this.codefreshAPI, this.runtimes, taskLogger);
+		job.exec();
+	}
+
 	_handleJobError(job) {
 		return (err) => {
 			if (err) {

config/index.js

@@ -36,6 +36,7 @@ function build() {
 			},
 			StatusReporterJob: {
 				cronExpression: process.env.JOB_REPORT_STATUS_CRON_EXPRESSION || CRON.EVERY_MINUTE,
+				runOnce: true,
 			},
 			DEFAULT_CRON: CRON.EVERY_MINUTE,
 			queue: {

package.json

@@ -1,6 +1,6 @@
 {
   "name": "venona",
-  "version": "1.0.6",
+  "version": "1.0.7",
   "description": "Codefresh agent to run on Codefresh's runtime environment and execute pipeline",
   "main": "index.js",
   "scripts": {

venonactl/VERSION

@@ -1 +1 @@
-1.0.6
+1.0.7