--no commit message

--no commit message

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

@@ -6,10 +6,16 @@ function execute_function(context,response){
   var param = context.jobconfig.data_in.param;
   var memstore = context.task.memstore
 
-  var output_type = 'text'
+  var output_type = 'text';
   var url = param.url;
 
-  request(url, function (error, resp, body) {
+  var encode = 'utf8';
+  if(param.encoding == 'binary'){
+    encode = null;
+    output_type = 'binary'
+  }
+
+  request({'url':url, 'encoding':null, function (error, resp, body) {
     if (!error && resp.statusCode == 200) {
       response.success(body);
     }else{

test/test.js

@@ -219,15 +219,15 @@ var job_config = {
 // });
 
 
-var client = redis.createClient('redis://lab1.igridproject.info:6379/1');
-//var client = redis.createClient('redis://localhost:9736/1');
-
-client.hgetall('bs:regis:triggers', function (err, rep) {
-  Object.keys(rep).forEach(function(a,b){
-    console.log(b);
-  })
-  //console.log(Object.keys(rep));
-});
+// var client = redis.createClient('redis://lab1.igridproject.info:6379/1');
+// //var client = redis.createClient('redis://localhost:9736/1');
+//
+// client.hgetall('bs:regis:triggers', function (err, rep) {
+//   Object.keys(rep).forEach(function(a,b){
+//     console.log(b);
+//   })
+//   //console.log(Object.keys(rep));
+// });
 //client.hset('bs:regis:triggers','job01',JSON.stringify(job_config));
 
 // var CronList = ctx.getLib('lib/mems/cronlist');
@@ -240,3 +240,9 @@ client.hgetall('bs:regis:triggers', function (err, rep) {
 // crons.update(function(err){
 //   console.log(crons.list);
 // });
+
+var wUrl = "http://203.155.220.231/Radar/pics/zfiltered.jpg";
+var request = require('request').defa
+request.get(wUrl, function (err, res, body) {
+      console.log(body);
+});