test: get coverage work

.gitignore

@@ -8,6 +8,7 @@ pnpm-debug.log*
 lerna-debug.log*
 
 node_modules
+coverage/
 dist
 dist-ssr
 *.local

jest.config.cjs

@@ -1,6 +1,12 @@
 module.exports = {
   roots: ['<rootDir>/src'],
-  collectCoverageFrom: ['src/**/*.{js,jsx,ts,tsx}', '!src/**/*.d.ts', '!src/mocks/**'],
+  collectCoverageFrom: [
+    'src/**/*.{js,jsx,ts,tsx}',
+    '!src/**/*.d.ts',
+    '!src/mocks/**',
+    // Worker client file uses "import.meta.url" and breaks coverage collector.
+    '!src/decrypt-worker/client.ts',
+  ],
   coveragePathIgnorePatterns: [],
   setupFilesAfterEnv: ['./src/test-utils/setup-jest.ts'],
   testEnvironment: 'jsdom',

src/decrypt-worker/client.ts

@@ -1,6 +1,6 @@
-import { ConcurrentQueue } from '~/util/ConcurrentQueue';
 import { WorkerClientBus } from '~/util/WorkerEventBus';
 import { DECRYPTION_WORKER_ACTION_NAME } from './constants';
+import { DecryptionQueue } from '~/util/DecryptionQueue';
 
 // TODO: Worker pool?
 export const workerClient = new Worker(new URL('./worker', import.meta.url), { type: 'module' });
@@ -8,15 +8,5 @@ export const workerClient = new Worker(new URL('./worker', import.meta.url), { t
 // FIXME: report the error so is obvious to the user.
 workerClient.onerror = (err) => console.error(err);
 
-class DecryptionQueue extends ConcurrentQueue<{ id: string; blobURI: string }> {
-  constructor(private workerClientBus: WorkerClientBus<DECRYPTION_WORKER_ACTION_NAME>, maxQueue?: number) {
-    super(maxQueue);
-  }
-
-  async handler(item: { id: string; blobURI: string }): Promise<void> {
-    return this.workerClientBus.request(DECRYPTION_WORKER_ACTION_NAME.DECRYPT, item.blobURI);
-  }
-}
-
 export const workerClientBus = new WorkerClientBus<DECRYPTION_WORKER_ACTION_NAME>(workerClient);
 export const decryptionQueue = new DecryptionQueue(workerClientBus);

src/util/DecryptionQueue.ts

@@ -0,0 +1,13 @@
+import { DECRYPTION_WORKER_ACTION_NAME } from '~/decrypt-worker/constants';
+import { ConcurrentQueue } from './ConcurrentQueue';
+import { WorkerClientBus } from './WorkerEventBus';
+
+export class DecryptionQueue extends ConcurrentQueue<{ id: string; blobURI: string }> {
+  constructor(private workerClientBus: WorkerClientBus<DECRYPTION_WORKER_ACTION_NAME>, maxQueue?: number) {
+    super(maxQueue);
+  }
+
+  async handler(item: { id: string; blobURI: string }): Promise<void> {
+    return this.workerClientBus.request(DECRYPTION_WORKER_ACTION_NAME.DECRYPT, item.blobURI);
+  }
+}