--no commit message

--no commit message

lib/bss/binarystream_v1_1.js

@@ -23,6 +23,10 @@ const STRING_TYPE = 1;
 const BINARY_TYPE = 2;
 const OBJECT_TYPE = 3;
 
+module.exports.STRING_TYPE = STRING_TYPE;
+module.exports.BINARY_TYPE = BINARY_TYPE;
+module.exports.OBJECT_TYPE = OBJECT_TYPE;
+
 module.exports.format = function(filename,opt,cb){
   var options = {};
   if(typeof opt == 'function'){

lib/ws/response.js

@@ -41,6 +41,11 @@ responseHelper.prototype.setLastModified = function(lm){
 
 responseHelper.prototype.responseOK = responseResult;
 
+responseHelper.prototype.type = function (tpy)
+{
+  this.response.type(tpy);
+}
+
 responseHelper.prototype.write = function (data)
 {
   this.response.write(data);

storage-service/main.js

@@ -25,7 +25,7 @@ var SS = function StorageService(cfg)
 SS.prototype.start = function()
 {
   console.log('Starting Storage Service ...\n');
-  this.amqp_start();
+  //this.amqp_start();
   this.http_start();
 }
 

storage-service/ws/v0.1/service-object.js

@@ -31,6 +31,8 @@ router.get('/:id/data',function (req, res) {
     var opt = {
       'field' : 'data'
     }
+    opt.filetype = (query.filetype)?query.filetype:null
+
     get_object(reqHelper,respHelper,{'oid':oid,'opt':opt});
 
 });
@@ -98,7 +100,7 @@ function get_object(reqHelper,respHelper,prm)
 
 function output(resp,obj,opt)
 {
-  if(opt.filed=='data')
+  if(opt.field=='data')
   {
     data_out(resp,obj,opt);
   }else{
@@ -117,8 +119,23 @@ function obj_out(resp,obj,opt)
 
 function data_out(resp,obj,opt)
 {
-  var objType = obj.header;
-  resp.responseOK(objType);
+  var objType = obj.header.TY;
+
+  if(objType == BinStream.BINARY_TYPE){
+    if(opt.filetype){
+      resp.response.type(opt.filetype);
+    }else{
+
+    }
+
+    resp.response.send(obj.data);
+    //resp.endOK();
+  }else if(objType == BinStream.STRING_TYPE){
+    resp.response.send(obj.data);
+  }else{
+    resp.responseOK(obj.data);
+  }
+
 }