refactor

src/target/mqtt.ts

@@ -3,6 +3,7 @@ import * as assert from '#assert'
 import * as check from '#check'
 import Message from '#core/message'
 import std from '#std'
+import hae from '#utils/hae'
 import * as mqtt from 'mqtt'
 
 export type MQTTTargetOptions = {
@@ -73,7 +74,9 @@ export class MQTTTarget extends Target {
 
     async stop() {
         std.log('stopping mqtt target')
-        if (check.isDefined(this.target)) await this.target.endAsync()
+        await hae.try(async () => {
+            if (check.isDefined(this.target)) await this.target.endAsync()
+        }, 'problem when stopping mqtt target')
         std.log('mqtt target stopped')
     }
 }

src/target/socketio.ts

@@ -3,6 +3,7 @@ import * as assert from '#assert'
 import * as check from '#check'
 import Message, {JSONMessage} from '#core/message'
 import std from '#std'
+import hae from '#utils/hae'
 import SocketIOClient, {Socket} from 'socket.io-client'
 
 export type SocketIOTargetOptions = {
@@ -62,7 +63,9 @@ export class SocketIOTarget extends Target {
     async stop() {
         // TODO: wait for disconnect
         std.log('stopping socketio target')
-        if (check.isDefined(this.target)) this.target.disconnect()
+        await hae.try(async () => {
+            if (check.isDefined(this.target)) this.target.disconnect()
+        }, 'problem when stopping socketio target')
         std.log('socketio target stopped')
     }
 }

src/target/ws.ts

@@ -3,6 +3,7 @@ import * as assert from '#assert'
 import * as check from '#check'
 import Message from '#core/message'
 import std from '#std'
+import hae from '#utils/hae'
 import WebSocket from 'ws'
 
 export type WSTargetOptions = {
@@ -57,7 +58,9 @@ export class WSTarget extends Target {
     async stop() {
         // TODO: wait for disconnect
         std.log('stopping websocket target')
-        if (check.isDefined(this.target)) this.target.close()
+        await hae.try(async () => {
+            if (check.isDefined(this.target)) this.target.close()
+        }, 'problem when stopping websocket target')
         std.log('websocket target stopped')
     }
 }