--no commit message

--no commit message

plugins/di/di-agritronics/excute.js

+var request = require('request');
+var async = require('async');
+
+function execute_function(context,response){
+	var job_id = context.jobconfig.job_id;
+	var transaction_id = context.transaction_id;
+	var param = context.jobconfig.data_in.param;
+	var memstore = context.task.memstore;
+	var output_type = 'object/agritronics';
+
+	var data = 'hello world';
+
+	let result = {
+		"object_type": 'agritronic',
+		"station_id": param.station_id,
+		"data":[]
+	};
+
+	let idx = 0;
+		
+	//console.log(json_table.length);
+	async.whilst(function() { return idx < param.data_types.length;}, function(callback) {
+		let dtype = param.data_types[idx].type;
+		let node_id = param.data_types[idx].node_id;
+		let ts = memstore.getItem(`${param.station_id}-${dtype}`);
+		if(typeof(ts) === 'undefined') ts = `${param.init_observed_date},${param.init_observed_time}`;
+		let url = param.url + `?appkey=${param.appkey}&p=${param.station_id},${node_id},${dtype},${ts}`;
+		idx++;
+		getData(url).then((data) => {
+			if(data.search("denied") === -1){
+				result.data.push({
+					"data_types": dtype,
+					"value" : data
+				});
+				callback();			
+			}
+		}).catch((err) => {
+			callback(err);
+		});
+
+	}, function(err) {
+	    if( err ) {
+	      response.error(err);
+	    } else {
+	    	//console.log(JSON.stringify(result));
+	    	response.success(result, output_type);
+	    }
+	});
+
+
+}
+
+function getData(url) {
+	return new Promise((resolve, reject) => {
+		request(url, function (error, resp, body) {
+		    if (!error && resp.statusCode == 200) {
+		      resolve(body);
+		    }else{
+		      return reject(error);
+		    }
+	  	})
+	})
+}
+
+module.exports = execute_function;

plugins/di/di-agritronics/index.js

@@ -8,6 +8,6 @@ function DITask(context){
 }
 util.inherits(DITask,DIPlugin);
 
-DITask.prototype.execute  =  require('./execute');
+DITask.prototype.perform  =  require('./perform');
 
 module.exports = DITask;

plugins/di/di-example/index.js

@@ -8,6 +8,6 @@ function DITask(context){
 }
 util.inherits(DITask,DIPlugin);
 
-DITask.prototype.execute  =  require('./execute');
+DITask.prototype.perform  =  require('./perform');
 
 module.exports = DITask;

plugins/di/di-example/execute.js → plugins/di/di-example/perform.js

-function execute_function(context,response){
+function perform_function(context,response){
   var job_id = context.jobconfig.job_id;
   var transaction_id = context.transaction.id;
   var param = context.jobconfig.data_in.param;
@@ -23,4 +23,4 @@ function execute_function(context,response){
 
 }
 
-module.exports = execute_function;
+module.exports = perform_function;

plugins/di/di-gistda-air/index.js

@@ -8,6 +8,6 @@ function DITask(context){
 }
 util.inherits(DITask,DIPlugin);
 
-DITask.prototype.execute  =  require('./execute');
+DITask.prototype.perform  =  require('./perform');
 
 module.exports = DITask;

plugins/di/di-http-request/index.js

@@ -8,6 +8,6 @@ function DITask(context){
 }
 util.inherits(DITask,DIPlugin);
 
-DITask.prototype.execute  =  require('./execute');
+DITask.prototype.perform  =  require('./perform');
 
 module.exports = DITask;

plugins/di/di-plugin.js

@@ -15,12 +15,12 @@ DIPlugin.prototype.getname = function(){
   return this.name;
 }
 
-DIPlugin.prototype.execute = function(){}
+DIPlugin.prototype.perform = function(){}
 
 DIPlugin.prototype.run = function(){
   this.emit('start');
   var resp = new DIResponse(this);
-  this.execute(this.jobcontext,resp);
+  this.perform(this.jobcontext,resp);
 }
 
 module.exports = DIPlugin;

test/jobs/dir.json

@@ -14,7 +14,7 @@
   "data_out" : {
     "type": "dir",
 	"param": {
-		"path" : "D:/testfile"
+		"path" : "D:/testdata"
 	}
   }
 }