feat: unit test watch

Author: kalinkrustev

index.d.ts

@@ -98,6 +98,7 @@ export interface port {
         now: () => hrtime
     },
     fireEvent(event: string, data: any, mapper?: 'asyncMap' | 'reduce'),
+    config: Record<string, unknown>,
     [name: string]: any
 }
 
@@ -114,6 +115,29 @@ interface vfs {
     readFileSync: typeof readFileSync;
 }
 
+type info = () => {
+    encrypt: object,
+    sign: object,
+    uri: string,
+    port: number | string,
+    host: string,
+    address: undefined | string,
+    protocol: 'http' | 'https' | 'socket'
+}
+
+interface serviceBus {
+    config: Record<string, unknown>,
+    jsonrpc: object,
+    rpc: {
+        info: info
+    },
+    publicApi: {
+        config: Record<string, unknown>,
+        importMethod: (name: string) => (params, $meta) => any
+        info: info
+    }
+}
+
 type api<imports> = {
     joi: joi.Root,
     /**
@@ -166,20 +190,7 @@ type api<imports> = {
     version: (version: string) => boolean,
     vfs: vfs,
     callSite: () => CallSiteLike,
-    utBus: {
-        config: {
-            workDir: string
-        },
-        info: () => {
-            encrypt: object,
-            sign: object,
-            uri: string,
-            port: number | string,
-            host: string,
-            address: undefined | string,
-            protocol: 'http' | 'https' | 'socket'
-        }
-    }
+    utBus: serviceBus['publicApi']
 }
 
 interface genericExport {
@@ -345,13 +356,9 @@ export function run(params: {
     root?: string,
     resolve?: (string) => string
 }): Promise<{
-    ports: {}[],
-    portsMap: Record<string, any>,
-    serviceBus: {
-        publicApi: {
-            importMethod: (name: string) => (params, $meta) => any
-        }
-    },
+    ports: port[],
+    portsMap: Record<string, port>,
+    serviceBus: serviceBus,
     log: any,
     logger: any,
     config: {},
@@ -368,8 +375,10 @@ export function microservice(module: Partial<NodeJS.Module>, require: NodeJS.Req
 
 type Step<methods> = {
     name: string,
-    params?: () => boolean,
+    params?: any,
     steps?: () => (Step<methods> | string)[]
+    result?: (this: any, result: any, assert: Tap.Test, $meta?: meta) => void,
+    error?: (this: any, error: any, assert: Tap.Test, $meta?: meta) => void
 } | {
     [Property in keyof methods]: methods[Property] extends ((...args: any) => any) ? {
         method: Property,
@@ -407,13 +416,13 @@ type Imported<methods> = {
 
 export type test<methods> = () => Record<string, (
     test: unknown,
-    bus: unknown,
+    bus: serviceBus,
     run: (
         test: unknown,
-        bus: unknown,
+        bus: serviceBus,
         steps: (Step<methods> | string)[]
     ) => unknown,
-    ports: {}[],
+    ports: port[],
     steps: Record<string, Imported<methods>>
 ) => unknown>;
 

package.json

@@ -18,7 +18,7 @@
     "stack-utils": "2.0.5",
     "through2": "2.0.3",
     "ut-bus": "^7.62.18",
-    "ut-config": "^7.9.3",
+    "ut-config": "^7.10.0",
     "ut-function.merge": "^1.5.6",
     "ut-log": "^6.10.5",
     "ut-port": "^6.44.1",

unit.js

@@ -12,7 +12,14 @@ module.exports = function unit(serviceConfig, {params, ...envConfig}, assert, vf
         implementation: 'test',
         repl: false,
         run: {
-            logLevel: 'warn'
+            logLevel: 'warn',
+            ...params.watch && {
+                hotReload: true,
+                logLevel: 'trace',
+                test: {
+                    prompt: 1
+                }
+            }
         },
         db: {
             debug: true