feat(Reporters): add mergeReporters helper

Author: Xiphe

src/reporter.spec.ts

@@ -3,6 +3,7 @@ import {
   CacheEntry,
   verboseReporter,
   createCacheEntry,
+  mergeReporters,
 } from './index';
 import { delay, prettyPrint } from './testHelpers';
 
@@ -215,6 +216,34 @@ describe('verbose reporter', () => {
   });
 });
 
+describe('mergeReporters', () => {
+  it('merges multiple reporters', async () => {
+    const cache = new Map<string, CacheEntry>();
+    const logger1 = createLogger();
+    const logger2 = createLogger();
+
+    await cachified({
+      cache,
+      key: 'test',
+      reporter: mergeReporters(
+        verboseReporter({ logger: logger1, performance: Date }),
+        undefined,
+        verboseReporter({ logger: logger2, performance: Date }),
+      ),
+      getFreshValue() {
+        return 'ONE';
+      },
+    });
+
+    expect(logger1.print()).toMatchInlineSnapshot(
+      `"LOG: 'Updated the cache value for test.' 'Getting a fresh value for this took 0ms.' 'Caching for forever in Map.'"`,
+    );
+    expect(logger2.print()).toMatchInlineSnapshot(
+      `"LOG: 'Updated the cache value for test.' 'Getting a fresh value for this took 0ms.' 'Caching for forever in Map.'"`,
+    );
+  });
+});
+
 function createLogger() {
   const log: string[] = [];
 

src/reporter.ts

@@ -242,3 +242,14 @@ export function verboseReporter<Value>({
     };
   };
 }
+
+export function mergeReporters<Value = unknown>(
+  ...reporters: (CreateReporter<Value> | undefined)[]
+): CreateReporter<Value> {
+  return (context) => {
+    const reporter = reporters.map((r) => r?.(context));
+    return (event) => {
+      reporter.forEach((r) => r?.(event));
+    };
+  };
+}