diff --git a/lib/Adaptor.js b/lib/Adaptor.js index 4d7508a..70b6ab2 100644 --- a/lib/Adaptor.js +++ b/lib/Adaptor.js @@ -165,6 +165,7 @@ function fetch(params) { function post(url, _ref) { var body = _ref.body; var callback = _ref.callback; + var headers = _ref.headers; return function (state) { @@ -172,7 +173,8 @@ function post(url, _ref) { return new Promise(function (resolve, reject) { _request2.default.post({ url: url, - json: body + json: body, + headers: headers }, function (error, response, body) { if (error) { reject(error); diff --git a/package.json b/package.json index 933f60e..e0daf0e 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "language-http", - "version": "0.0.9", + "version": "0.1.0", "description": "An HTTP Language Pack for OpenFn", "main": "lib/index.js", "scripts": { diff --git a/src/Adaptor.js b/src/Adaptor.js index cb4d7c4..0a4f521 100644 --- a/src/Adaptor.js +++ b/src/Adaptor.js @@ -74,14 +74,15 @@ export function fetch(params) { * @param {object} params - data to make the POST * @returns {Operation} */ -export function post(url, {body, callback}) { +export function post(url, {body, callback, headers}) { return state => { return new Promise((resolve, reject) => { request.post ({ url: url, - json: body + json: body, + headers }, function(error, response, body){ if(error) { reject(error); @@ -97,7 +98,7 @@ export function post(url, {body, callback}) { }) } -} +} /** * Make a GET request