Mirrors/cloudcmd
1
0
Fork 0
mirror of https://github.com/coderaiser/cloudcmd.git synced 2026-01-23 18:55:26 +00:00
Code Issues Projects Releases Wiki Activity

feature(pipe) add getBody

Browse source
This commit is contained in:
coderaiser 2014-03-05 07:25:35 -05:00
parent a87618c4e5
commit 16da155f31
3 changed files with 22 additions and 34 deletions
Download patch file Download diff file Expand all files Collapse all files

19
lib/server/pipe.js
View file

@ -16,6 +16,8 @@
Util = main.util,
zlib = main.zlib;
exports.getBody = getBody;
exports.create = function(pParams) {
var lZlib, lError, lMsg, lRead, lWrite, lIsFsWrite,
p = pParams;
@ -62,4 +64,21 @@
}
};
/**
* get body of readStream
*
* @param readStream
* @param callback
*/
function getBody(readStream, callback) {
var body = '';
readStream.on('data', function(chunk) {
body += chunk;
});
readStream.on('end', function() {
Util.exec(callback, body);
});
}
})();

22
lib/server/rest.js
View file

@ -108,7 +108,7 @@
break;
case 'PUT':
getBody(p.request, function(pBody) {
pipe.getBody(p.request, function(pBody) {
p.body = pBody;
onPUT(p);
});
@ -157,7 +157,7 @@
break;
case 'DELETE':
getBody(p.request, function(body) {
pipe.getBody(p.request, function(body) {
var files = Util.parseJSON(body);
onDelete(p.name, files, query, function(error, callback) {
@ -311,24 +311,6 @@
return ret;
}
/**
* get body of url query
*
* @param req
* @param callback
*/
function getBody(req, callback) {
var body = '';
req.on('data', function(chunk) {
body += chunk.toString();
});
req.on('end', function() {
Util.exec(callback, body);
});
}
function sendMsg(pParams, pMsg, pName, pStatus) {
var msg = CloudFunc.formatMsg(pMsg, pName, pStatus);
sendResponse(pParams, msg);

15
lib/server/rest/fs/put.js
View file

@ -46,7 +46,7 @@
break;
case 'patch':
getBody(readStream, function(patch) {
pipe.getBody(readStream, function(patch) {
fs.readFile(name, 'utf8', read);
function read(error, data) {
@ -80,17 +80,4 @@
break;
}
}
function getBody(req, callback) {
var body = '';
req.on('data', function(chunk) {
body += chunk + '';
});
req.on('end', function() {
Util.exec(callback, body);
});
}
})();