bidirectional tests

src/target/file.ts

@@ -28,7 +28,6 @@ export class FileTarget extends Target {
 
     async send(message: Message) {
         std.log('file target sending', {message})
-        await files.createFile(this.options.file)
         await files.appendFile(this.options.file, message.toString() + '\n')
         std.log('file target sent')
     }

src/utils/files.ts

@@ -67,7 +67,7 @@ export function loadYAML<T>(file: string) {
 }
 
 export async function createFile(file: string) {
-    const handle = await fs.promises.open(path.resolve(file), 'w+')
+    const handle = await fs.promises.open(path.resolve(file), 'a+')
     await handle.close()
 }
 

src/utils/hae.ts

@@ -11,8 +11,8 @@ function exit<T>(fn: (args: T) => Promise<void>): (args: T) => Promise<void> {
     return async (options: T) => {
         try {
             await fn(options)
-        } catch (e) {
-            std.log(e)
+        } catch (error) {
+            std.log({error})
             process.exit(1)
         }
     }
@@ -22,17 +22,17 @@ function log<T>(fn: (args: T) => Promise<void>): (args: T) => Promise<void> {
     return async (args: T) => {
         try {
             await fn(args)
-        } catch (e) {
-            std.log(e)
+        } catch (error) {
+            std.log({error})
         }
     }
 }
 
 async function _try(fn: () => Promise<void>, reason?: string) {
     try {
         await fn()
-    } catch (e) {
-        std.log(reason, e)
+    } catch (error) {
+        std.log(reason, {error})
     }
 }
 

tests/bridge/can.test.ts

@@ -0,0 +1,13 @@
+import {createBidirectionalBridgeTest, createBridgeTest} from './utils'
+
+describe('bridge', () => {
+    createBidirectionalBridgeTest(
+        'can',
+        {source: 'can', sourceName: 'can2xBridge'},
+        {target: 'can', targetName: 'can2xBridge'}
+    )
+})
+
+describe('bridge', () => {
+    createBridgeTest('can', {source: 'can'}, {target: 'can'})
+})

tests/bridge/file/file.test.ts → tests/bridge/file.test.ts

@@ -5,7 +5,7 @@ import std from '#std'
 import * as utils from '#utils'
 import {expect} from 'chai'
 
-describe('file', () => {
+describe('bridge', () => {
     it('file2file', async () => {
         const message = Message.fromJSON({id: 69, data: [1, 2, 3], ext: false, rtr: false})
 

tests/bridge/http.test.ts

@@ -0,0 +1,12 @@
+import {createBridgeTest} from './utils'
+
+describe('bridge', () => {
+    createBridgeTest(
+        'http',
+        {source: 'http'},
+        {
+            target: 'http',
+            targetEndpoint: 'http://localhost:3000',
+        }
+    )
+})

tests/bridge/mqtt.test.ts

@@ -0,0 +1,28 @@
+import {createBidirectionalBridgeTest, createBridgeTest} from './utils'
+
+// TODO: mqtt returns to original sender ... (similar but not same bug as at mqtt bus)
+describe.skip('bridge', () => {
+    createBidirectionalBridgeTest(
+        'mqtt',
+        {
+            source: 'mqtt',
+        },
+        {
+            target: 'mqtt',
+            targetEndpoint: 'mqtt://localhost:3000',
+        }
+    )
+})
+
+describe('bridge', () => {
+    createBridgeTest(
+        'mqtt',
+        {
+            source: 'mqtt',
+        },
+        {
+            target: 'mqtt',
+            targetEndpoint: 'mqtt://localhost:3000',
+        }
+    )
+})