diff --git a/lib/Adaptor.js b/lib/Adaptor.js index a522844..2fec042 100644 --- a/lib/Adaptor.js +++ b/lib/Adaptor.js @@ -277,6 +277,16 @@ function post(url, _ref2) { function postData(params) { return function (state) { + + function assembleError(_ref3) { + var response = _ref3.response; + var error = _ref3.error; + + if (response && [200, 201, 202].indexOf(response.statusCode) > -1) return false; + if (error) return error; + return new Error('Server responded with ' + response.statusCode); + } + var _expandReferences3 = (0, _languageCommon.expandReferences)(params)(state); var url = _expandReferences3.url; @@ -292,8 +302,10 @@ function postData(params) { json: body, headers: headers }, function (error, response, body) { + error = assembleError({ error: error, response: response }); if (error) { reject(error); + console.log(response); } else { console.log("Printing response...\n"); console.log(JSON.stringify(response, null, 4) + "\n"); @@ -323,13 +335,13 @@ function postData(params) { * @param {object} params - callback and query parameters * @returns {Operation} */ -function get(path, _ref3) { - var query = _ref3.query; - var callback = _ref3.callback; +function get(path, _ref4) { + var query = _ref4.query; + var callback = _ref4.callback; - function assembleError(_ref4) { - var response = _ref4.response; - var error = _ref4.error; + function assembleError(_ref5) { + var response = _ref5.response; + var error = _ref5.error; if ([200, 201, 202].indexOf(response.statusCode) > -1) return false; if (error) return error; diff --git a/package.json b/package.json index c3e98b0..cba5691 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "language-http", - "version": "0.3.3", + "version": "0.4.0", "description": "An HTTP Language Pack for OpenFn", "main": "lib/index.js", "scripts": { diff --git a/src/Adaptor.js b/src/Adaptor.js index 443a8c1..a7fdaaf 100644 --- a/src/Adaptor.js +++ b/src/Adaptor.js @@ -175,6 +175,12 @@ export function postData(params) { return state => { + function assembleError({ response, error }) { + if (response && ([200,201,202].indexOf(response.statusCode) > -1)) return false; + if (error) return error; + return new Error(`Server responded with ${response.statusCode}`) + } + const { url, body, headers } = expandReferences(params)(state); return new Promise((resolve, reject) => { @@ -185,8 +191,10 @@ export function postData(params) { json: body, headers }, function(error, response, body){ + error = assembleError({error, response}) if(error) { reject(error); + console.log(response); } else { console.log("Printing response...\n"); console.log(JSON.stringify(response, null, 4) + "\n");