Merge pull request #471 from open-rpc/feat/allow-transport-passed

feat: allow transport passed + added raw json reporter

Author: shanejonas

package.json

@@ -14,7 +14,7 @@
     "bin",
     "build"
   ],
-  "main": "build/coverage.js",
+  "main": "build/index.js",
   "author": "",
   "license": "Apache-2.0",
   "dependencies": {

src/coverage.ts

@@ -109,5 +109,5 @@ export default async (options: IOptions) => {
     }
   }
 
-  options.reporter(exampleCalls, options.openrpcDocument);
+  return options.reporter(exampleCalls, options.openrpcDocument);
 };

src/index.ts

@@ -2,11 +2,14 @@ import consoleReporter from "./reporters/console";
 import coverage from "./coverage";
 import HTTPTransport from "./transports/HTTPTransport";
 import jsonReporter from "./reporters/json";
+import rawReporter from "./reporters/raw";
 import { OpenrpcDocument } from "@open-rpc/meta-schema";
+import { ITransport } from "./transports/ITransport";
 
 const reporters = {
   console: consoleReporter,
   json: jsonReporter,
+  raw: rawReporter,
 };
 
 const transports = {
@@ -17,16 +20,17 @@ interface IOptions {
   openrpcDocument: OpenrpcDocument;
   skip?: string[];
   only?: string[];
-  reporter: "console" | "json";
-  transport: "http";
+  reporter: "console" | "json" | "raw";
+  transport: "http" | ITransport;
 }
 
 export default async (options: IOptions) => {
+  const transport = typeof options.transport === "function" ? options.transport : transports[options.transport || "http"];
   return coverage({
     reporter: reporters[options.reporter || "console"],
     openrpcDocument: options.openrpcDocument,
     skip: options.skip || [],
     only: options.only || [],
-    transport: transports[options.transport || "http"],
+    transport: transport,
   });
 };

src/reporters/raw.ts

@@ -0,0 +1,5 @@
+import { OpenrpcDocument } from "@open-rpc/meta-schema";
+
+export default (callResults: any[], schema: OpenrpcDocument) => {
+  return callResults;
+};

src/transports/HTTPTransport.ts

@@ -1,7 +1,8 @@
 import fetch from "isomorphic-fetch";
+import { ITransport } from "./ITransport";
 let id = 1;
 
-export default (url: string, method: string, params: any[]) => {
+const httpTransport: ITransport = async (url: string, method: string, params: any[]) => {
   return fetch(url, {
     method: "POST",
     headers: { "Content-Type": "application/json" },
@@ -15,3 +16,5 @@ export default (url: string, method: string, params: any[]) => {
     return r.json();
   });
 };
+
+export default httpTransport;

src/transports/ITransport.ts

@@ -0,0 +1 @@
+export type ITransport = (url: string, method: string, params: any) => Promise<any>;