fail when code != 200,201,202

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;

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": {

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");