sign in oauth1 case

dist/axios.d.ts

@@ -1 +1 @@
-export default function (step: any, config: any): Promise<any>;
+export default function (step: any, config: any, signConfig?: any): Promise<any>;

dist/axios.js

@@ -28,8 +28,32 @@ export default async function(step: any, config) {
   }
 }
 */
-async function default_1(step, config) {
+// https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/encodeURI
+// see non-escaped chars
+// this handles not encoding [!'()*]
+function encodeReservedChars(str) {
+    return str.replace(/[!'()*]/g, function (c) {
+        return '%' + c.charCodeAt(0).toString(16);
+    });
+}
+async function default_1(step, config, signConfig) {
     // XXX warn about mutating config object... or clone?
+    // OAuth1 request
+    if (signConfig) {
+        const { oauthSignerUri, token } = signConfig;
+        // this handles encoding query string to make sure we match what we sign
+        const url = new URL(config.url);
+        url.search = encodeReservedChars(url.search.substr(1));
+        config.url = url.toString();
+        const payload = {
+            requestData: config,
+            token,
+        };
+        const oauthSignature = (await axios_1.default.post(oauthSignerUri, payload)).data;
+        if (!config.headers)
+            config.headers = {};
+        config.headers.Authorization = oauthSignature;
+    }
     for (const k in config.headers || {}) {
         if (typeof config.headers[k] === "undefined") {
             delete config.headers[k];

lib/axios.ts

@@ -28,8 +28,34 @@ export default async function(step: any, config) {
 }
 */
 
-export default async function(step: any, config) {
+// https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/encodeURI
+// see non-escaped chars
+// this handles not encoding [!'()*]
+function encodeReservedChars(str) {
+  return str.replace(/[!'()*]/g, function(c) {
+    return '%' + c.charCodeAt(0).toString(16)
+  })
+}
+
+export default async function(step: any, config, signConfig?) {
   // XXX warn about mutating config object... or clone?
+  // OAuth1 request
+  if (signConfig) {
+    const {oauthSignerUri, token} = signConfig
+
+    // this handles encoding query string to make sure we match what we sign
+    const url = new URL(config.url)
+    url.search = encodeReservedChars(url.search.substr(1))
+    config.url = url.toString()
+
+    const payload = {
+      requestData: config,
+      token,
+    }
+    const oauthSignature = (await axios.post(oauthSignerUri, payload)).data
+    if (!config.headers) config.headers = {}
+    config.headers.Authorization = oauthSignature
+  }
   for (const k in config.headers || {}) {
     if (typeof config.headers[k] === "undefined") {
       delete config.headers[k]

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedreamhq/platform",
-  "version": "0.2.2",
+  "version": "0.2.3",
   "description": "Pipedream platform globals (typing and runtime type checking)",
   "homepage": "https://pipedream.com",
   "main": "dist/index.js",