Merge pull request #217 from flovilmart/fix-216
Adds proper http request to match parse original implementation
This commit is contained in:
43
httpRequest.js
Normal file
43
httpRequest.js
Normal file
@@ -0,0 +1,43 @@
|
|||||||
|
var request = require("request"),
|
||||||
|
Parse = require('parse/node').Parse;
|
||||||
|
|
||||||
|
module.exports = function(options) {
|
||||||
|
var promise = new Parse.Promise();
|
||||||
|
var callbacks = {
|
||||||
|
success: options.success,
|
||||||
|
error: options.error
|
||||||
|
};
|
||||||
|
delete options.success;
|
||||||
|
delete options.error;
|
||||||
|
if (options.uri && !options.url) {
|
||||||
|
options.uri = options.url;
|
||||||
|
delete options.url;
|
||||||
|
}
|
||||||
|
if (typeof options.body === 'object') {
|
||||||
|
options.body = JSON.stringify(options.body);
|
||||||
|
}
|
||||||
|
request(options, (error, response, body) => {
|
||||||
|
var httpResponse = {};
|
||||||
|
httpResponse.status = response.statusCode;
|
||||||
|
httpResponse.headers = response.headers;
|
||||||
|
httpResponse.buffer = new Buffer(response.body);
|
||||||
|
httpResponse.cookies = response.headers["set-cookie"];
|
||||||
|
httpResponse.text = response.body;
|
||||||
|
try {
|
||||||
|
httpResponse.data = JSON.parse(response.body);
|
||||||
|
} catch (e) {}
|
||||||
|
// Consider <200 && >= 400 as errors
|
||||||
|
if (error || httpResponse.status <200 || httpResponse.status >=400) {
|
||||||
|
if (callbacks.error) {
|
||||||
|
return callbacks.error(httpResponse);
|
||||||
|
}
|
||||||
|
return promise.reject(httpResponse);
|
||||||
|
} else {
|
||||||
|
if (callbacks.success) {
|
||||||
|
return callbacks.success(httpResponse);
|
||||||
|
}
|
||||||
|
return promise.resolve(httpResponse);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
return promise;
|
||||||
|
};
|
||||||
33
index.js
33
index.js
@@ -11,7 +11,7 @@ var batch = require('./batch'),
|
|||||||
multer = require('multer'),
|
multer = require('multer'),
|
||||||
Parse = require('parse/node').Parse,
|
Parse = require('parse/node').Parse,
|
||||||
PromiseRouter = require('./PromiseRouter'),
|
PromiseRouter = require('./PromiseRouter'),
|
||||||
request = require('request');
|
httpRequest = require('./httpRequest');
|
||||||
|
|
||||||
// Mutate the Parse object to add the Cloud Code handlers
|
// Mutate the Parse object to add the Cloud Code handlers
|
||||||
addParseCloud();
|
addParseCloud();
|
||||||
@@ -148,36 +148,7 @@ function addParseCloud() {
|
|||||||
var className = getClassName(parseClass);
|
var className = getClassName(parseClass);
|
||||||
Parse.Cloud.Triggers.afterDelete[className] = handler;
|
Parse.Cloud.Triggers.afterDelete[className] = handler;
|
||||||
};
|
};
|
||||||
Parse.Cloud.httpRequest = function(options) {
|
Parse.Cloud.httpRequest = httpRequest;
|
||||||
var promise = new Parse.Promise();
|
|
||||||
var callbacks = {
|
|
||||||
success: options.success,
|
|
||||||
error: options.error
|
|
||||||
};
|
|
||||||
delete options.success;
|
|
||||||
delete options.error;
|
|
||||||
if (options.uri && !options.url) {
|
|
||||||
options.uri = options.url;
|
|
||||||
delete options.url;
|
|
||||||
}
|
|
||||||
if (typeof options.body === 'object') {
|
|
||||||
options.body = JSON.stringify(options.body);
|
|
||||||
}
|
|
||||||
request(options, (error, response, body) => {
|
|
||||||
if (error) {
|
|
||||||
if (callbacks.error) {
|
|
||||||
return callbacks.error(error);
|
|
||||||
}
|
|
||||||
return promise.reject(error);
|
|
||||||
} else {
|
|
||||||
if (callbacks.success) {
|
|
||||||
return callbacks.success(body);
|
|
||||||
}
|
|
||||||
return promise.resolve(body);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
return promise;
|
|
||||||
};
|
|
||||||
global.Parse = Parse;
|
global.Parse = Parse;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user