--no commit message

--no commit message

plugins/di/di-agritronics/execute.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 = 'jsonobject'
+
+	var data = 'hello world';
+
+	let result = {
+		"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 url = param.url + `?appkey=${param.appkey}&p=${param.station_id},${node_id},${dtype},${param.init_date_observed},${param.init_time_observed}`;
+		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

+var util = require('util');
+var DIPlugin = require('../di-plugin');
+
+function DITask(context){
+  DIPlugin.call(this,context);
+  this.name = "agritronics";
+  this.output_type = "text";
+}
+util.inherits(DITask,DIPlugin);
+
+DITask.prototype.execute  =  require('./execute');
+
+module.exports = DITask;

plugins/di/di-agritronics/package.json

+{
+  "name": "di-agritronics-ibitz",
+  "version": "0.0.1",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "keywords": [
+    "bigstream"
+  ],
+  "author": "lsr.bigstream",
+  "license": "ISC",
+  "dependencies": {
+    "async": "^2.1.2",
+    "http": "0.0.0",
+    "xml2json": "^0.10.0"
+  }
+}