refactor(sdk) [NET-1663]: Worker-based signature validation (discardable PR)

packages/browser-test-runner/src/createKarmaConfig.ts

@@ -4,8 +4,16 @@ import type { Configuration, ExternalItem } from 'webpack'
 
 const DEBUG_MODE = process.env.BROWSER_TEST_DEBUG_MODE ?? false
 
+export interface KarmaConfigOptions {
+    // File patterns to serve but not include in the test bundle (e.g. worker files)
+    servedFiles?: string[]
+}
+
 export const createKarmaConfig = (
-    testPaths: string[], webpackConfig: () => Configuration, localDirectory?: string
+    testPaths: string[],
+    webpackConfig: () => Configuration,
+    localDirectory?: string,
+    options: KarmaConfigOptions = {}
 ): (config: any) => any => {
     const setupFiles = [fileURLToPath(new URL('./karma-setup.js', import.meta.url))]
 
@@ -57,7 +65,13 @@ export const createKarmaConfig = (
             reporters: ['spec'],
             files: [
                 ...setupFiles,
-                ...testPaths
+                ...testPaths,
+                ...(options.servedFiles ?? []).map((pattern) => ({
+                    pattern,
+                    included: false,
+                    served: true,
+                    watched: false
+                }))
             ],
             preprocessors,
             customLaunchers: {

packages/browser-test-runner/src/exports.ts

@@ -1,2 +1,3 @@
 export { createKarmaConfig } from './createKarmaConfig'
+export type { KarmaConfigOptions } from './createKarmaConfig'
 export { createWebpackConfig } from './createWebpackConfig'

packages/cli-tools/src/command.ts

@@ -53,6 +53,8 @@ export const createClientCommand = (
                         await client.destroy()
                     }
                 }
+                // Exit cleanly after command completes - worker threads may keep event loop alive
+                process.exit(0)
             } catch (e: any) {
                 console.error(e)
                 process.exit(1)

packages/cli-tools/src/resend.ts

@@ -19,16 +19,19 @@ export const resend = async (
     subscribe: boolean
 ): Promise<void> => {
     try {
-        const handler = (message: any) => {
-            console.info(JSON.stringify(message))
-        }
         if (subscribe) {
+            const handler = (message: any) => {
+                console.info(JSON.stringify(message))
+            }
             await client.subscribe({
                 stream: streamId,
                 resend: resendOpts
             }, handler)
         } else {
-            await client.resend(streamId, resendOpts, handler)
+            const messageStream = await client.resend(streamId, resendOpts)
+            for await (const message of messageStream) {
+                console.info(JSON.stringify(message.content))
+            }
         }
     } catch (err) {
         console.error(err.message ?? err)

packages/sdk/createKarmaConfig.ts

@@ -15,6 +15,7 @@ export function createKarmaConfig(testPaths: string[]): ReturnType<typeof create
                     'test/test-utils/jestGlobalsMock.ts'
                 ),
                 '@streamr/dht': resolve(__dirname, '../dht/dist/exports-browser.cjs'),
+                "@/createSignatureValidationWorker": resolve(__dirname, 'src/_karma/createSignatureValidationWorker.ts'),
                 '@': resolve(__dirname, 'src/_browser'),
             },
             fallback: {
@@ -30,6 +31,9 @@ export function createKarmaConfig(testPaths: string[]): ReturnType<typeof create
                 'node:timers/promises': 'timers/promises',
             },
         }),
-        __dirname
+        __dirname,
+        {
+            servedFiles: ['dist/*.mjs']
+        }
     )
 }

packages/sdk/jest.config.ts

@@ -11,6 +11,7 @@ const config: Config.InitialOptions = {
         '@streamr/test-utils/setupCustomMatchers',
     ],
     moduleNameMapper: {
+        "^@/createSignatureValidationWorker$": "<rootDir>/src/_jest/createSignatureValidationWorker.ts",
         "^@/(.*)$": "<rootDir>/src/_nodejs/$1",
     },
     transform: {