feat: added mulitple reporters feature

BREAKING CHANGE: `reporter` option is now `reporters` and can handle multiple reporters

Author: shanejonas

bin/cli.js

@@ -3,7 +3,7 @@ const program = require('commander');
 const orpcCoverage = require('../build').default;
 const { parseOpenRPCDocument } = require('@open-rpc/schema-utils-js');
 
-const getMethodsArray = (input) => {
+const getArrayFromCommaSeparated = (input) => {
   if (input && input.split(',').length > 0) {
     return input.split(',');
   } else {
@@ -15,10 +15,10 @@ program
   .version(require('./get-version'))
   .usage('[options]')
   .option('-s, --schema [schema]', 'JSON string or a Path/Url pointing to an open rpc schema')
-  .option('-r, --reporter <reporter>', 'Use the specified reporter [console] [json] [empty]')
+  .option('-r, --reporters <reporter>', 'Use the specified reporter [console] [json] [empty]. Can be a comma separated list of reporters.')
   .option('-t, --transport <transport>', 'Use the specified transport [http]')
-  .option('--skip <skip>', 'Methods to skip')
-  .option('--only <only>', 'Methods to only run')
+  .option('--skip <skip>', 'Methods to skip. Comma separated list of method names')
+  .option('--only <only>', 'Methods to only run. Comma separated list of method names')
   .action(async (options) => {
     let schema;
     try {
@@ -32,9 +32,9 @@ program
       await orpcCoverage({
         openrpcDocument: schema,
         transport: options.transport,
-        reporter: options.reporter,
-        skip: getMethodsArray(options.skip),
-        only: getMethodsArray(options.only),
+        reporters: getArrayFromCommaSeparated(options.reporters),
+        skip: getArrayFromCommaSeparated(options.skip),
+        only: getArrayFromCommaSeparated(options.only),
       });
     } catch (e) {
       console.error(e);

src/coverage.test.ts

@@ -127,7 +127,7 @@ describe("coverage", () => {
       }
       const transport = () => Promise.resolve();
       coverage({
-        reporter: new CustomReporter(),
+        reporters: [new CustomReporter()],
         transport,
         openrpcDocument: mockSchema,
         skip: [],
@@ -148,7 +148,7 @@ describe("coverage", () => {
         return { result: true };
       };
       coverage({
-        reporter: new CustomReporter(),
+        reporters: [new CustomReporter()],
         transport,
         openrpcDocument: mockSchema,
         skip: [],
@@ -168,7 +168,7 @@ describe("coverage", () => {
       const transport = () => Promise.resolve({});
       const openrpcDocument = mockSchema;
       const options = {
-        reporter,
+        reporters: [reporter],
         transport,
         openrpcDocument,
         skip: ['foo', 'bar', 'baz'],
@@ -189,14 +189,14 @@ describe("coverage", () => {
       const openrpcDocument = {...mockSchema};
       openrpcDocument.servers = undefined;
       const options = {
-        reporter,
+        reporters: [reporter],
         transport,
         openrpcDocument,
         skip: [],
         only: ['baz'],
       };
 
-      await expect(coverage(options)).resolves.toBeUndefined();
+      await expect(coverage(options)).resolves.toBeDefined();
     });
   });
   describe("transport", () => {
@@ -206,7 +206,7 @@ describe("coverage", () => {
         return Promise.resolve({});
       };
       coverage({
-        reporter: new EmptyReporter(),
+        reporters: [new EmptyReporter()],
         transport,
         openrpcDocument: mockSchema,
         skip: [],
@@ -222,7 +222,7 @@ describe("coverage", () => {
       const transport = () => Promise.resolve({});
       const openrpcDocument = mockSchema;
       const options = {
-        reporter,
+        reporters: [reporter],
         transport,
         openrpcDocument,
         skip: [],
@@ -244,7 +244,7 @@ describe("coverage", () => {
       const transport = () => Promise.resolve({});
       const openrpcDocument = mockSchema;
       const options = {
-        reporter,
+        reporters: [reporter],
         transport,
         openrpcDocument,
         skip: [],

src/coverage.ts

@@ -22,7 +22,7 @@ export interface IOptions {
   skip: string[];
   only: string[];
   transport(url: string, method: string, params: any[]): PromiseLike<any>;
-  reporter: Reporter;
+  reporters: Reporter[];
 }
 
 export interface ExampleCall {
@@ -104,10 +104,14 @@ export default async (options: IOptions) => {
     });
   });
 
-  options.reporter.onBegin(options, exampleCalls);
+  for (const reporter of options.reporters) {
+    reporter.onBegin(options, exampleCalls);
+  }
 
   for (const exampleCall of exampleCalls) {
-    options.reporter.onTestBegin(options, exampleCall);
+    for (const reporter of options.reporters) {
+      reporter.onTestBegin(options, exampleCall);
+    }
     try {
       const callResult = await options.transport(
         exampleCall.url,
@@ -135,8 +139,13 @@ export default async (options: IOptions) => {
       exampleCall.valid = false;
       exampleCall.requestError = e;
     }
-    options.reporter.onTestEnd(options, exampleCall);
+    for (const reporter of options.reporters) {
+      reporter.onTestEnd(options, exampleCall);
+    }
   }
 
-  return options.reporter.onEnd(options, exampleCalls);
+  for (const reporter of options.reporters) {
+    reporter.onEnd(options, exampleCalls);
+  }
+  return exampleCalls;
 };

src/index.ts

@@ -17,19 +17,23 @@ const reporters = {
 const transports = {
   http: HTTPTransport,
 };
-
+type ReporterString = "console" | "json" | "raw" | "empty";
 interface IOptions {
   openrpcDocument: OpenrpcDocument;
   skip?: string[];
   only?: string[];
-  reporter: "console" | "json" | "raw" | "empty";
+  reporters: ReporterString[];
   transport: "http" | ITransport;
 }
 
 export default async (options: IOptions) => {
   const transport = typeof options.transport === "function" ? options.transport : transports[options.transport || "http"];
+  let reporterInstances = options.reporters.map((reporter) => new reporters[reporter]);
+  if (reporterInstances.length === 0) {
+    reporterInstances = [new reporters["console"]()];
+  }
   return coverage({
-    reporter: new reporters[options.reporter || "console"],
+    reporters: reporterInstances,
     openrpcDocument: options.openrpcDocument,
     skip: options.skip || [],
     only: options.only || [],