update platform with axios

Author: tjk

__tests__/$send.js

@@ -1,5 +1,5 @@
 // purposefully test COMPILED platform.js! (just as lambda_maker would)
-const { $sendConfigRuntimeTypeChecker } = require("../dist/platform")
+const { $sendConfigRuntimeTypeChecker } = require("../dist")
 
 function randString() {
   return ""+Math.random()

__tests__/axios.js

@@ -0,0 +1,8 @@
+const { axios } = require("../dist")
+
+describe("axios", () => {
+  it("should fail as expected", async () => {
+    const step = {}
+    await expect(axios(step, {})).rejects.toThrow(step.error) // no url
+  })
+})

dist/axios.d.ts

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

dist/axios.js

@@ -0,0 +1,30 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+const axios_1 = require("axios");
+function observability(resp) {
+    return {
+        request: resp.config,
+        response: {
+            status: resp.status,
+            headers: resp.headers,
+            data: resp.data,
+        },
+    };
+}
+async function default_1(step, config) {
+    try {
+        const resp = await axios_1.default(config);
+        step.axios = observability(resp);
+        return resp.data;
+    }
+    catch (err) {
+        if (err.isAxiosError) {
+            step.axios = observability(err.response);
+        }
+        else {
+            step.error = err;
+        }
+        throw err;
+    }
+}
+exports.default = default_1;

dist/platform.d.ts renamed to dist/index.d.ts

@@ -1,4 +1,6 @@
 import * as t from "io-ts";
+import axios from "./axios";
+export { axios };
 export declare const SendConfigEmail: t.PartialC<{
     html: t.StringC;
     subject: t.StringC;
@@ -102,4 +104,3 @@ export declare const END_NEEDLE = "__pd_end";
 export declare function $end(message?: string): void;
 export declare let $send: SendFunctionsWrapper;
 export declare const $sendConfigRuntimeTypeChecker: {};
-export {};

dist/platform.js renamed to dist/index.js

@@ -1,6 +1,8 @@
 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 const t = require("io-ts");
+const axios_1 = require("./axios");
+exports.axios = axios_1.default;
 const SendPayload = t.union([t.string, t.object]);
 exports.SendConfigEmail = t.partial({
     html: t.string,

lib/axios.ts

@@ -0,0 +1,27 @@
+import axios from "axios"
+
+function observability(resp) {
+  return {
+    request: resp.config,
+    response: {
+      status: resp.status,
+      headers: resp.headers,
+      data: resp.data,
+    },
+  }
+}
+
+export default async function(step: any, config) {
+  try {
+    const resp = await axios(config)
+    step.axios = observability(resp)
+    return resp.data
+  } catch (err) {
+    if (err.isAxiosError) {
+      step.axios = observability(err.response)
+    } else {
+      step.error = err
+    }
+    throw err
+  }
+}

lib/platform.ts renamed to lib/index.ts

@@ -1,5 +1,9 @@
 import * as t from "io-ts"
 
+import axios from "./axios"
+
+export { axios }
+
 const SendPayload = t.union([t.string, t.object]);
 type SendPayload = t.TypeOf<typeof SendPayload>;
 

package-lock.json

@@ -3,10 +3,10 @@
   "version": "0.0.5",
   "description": "Pipedream platform globals (typing and runtime type checking)",
   "homepage": "https://pipedream.com",
-  "main": "dist/platform.js",
-  "types": "dist/platform.d.ts",
+  "main": "dist/index.js",
+  "types": "dist/index.d.ts",
   "scripts": {
-    "build": "tsc",
+    "build": "rm -rf dist/** && tsc",
     "test": "jest"
   },
   "author": "Pipedream Team",
@@ -16,6 +16,7 @@
     "url": "https://github.com/PipedreamHQ/platform.git"
   },
   "dependencies": {
+    "axios": "^0.19.0",
     "fp-ts": "^2.0.2",
     "io-ts": "^2.0.0"
   },