ServerSerial types and usage (#550)

* ServerSerial types and emit initialized

* file

* better

* open callback

* openCallback on SerialPort open

* open on SerialPort

---------

Co-authored-by: cplepage <[email protected]>

Author: cplepage

ServerSerial.d.ts

@@ -0,0 +1,21 @@
+import * as events from 'events';
+import { SerialPortOpenOptions } from "serialport"
+import { FCallback, IServiceVector } from './ServerTCP';
+import { ErrorCallback } from '@serialport/stream';
+
+export class ServerSerial extends events.EventEmitter {
+    constructor(vector: IServiceVector, options: IServerSerialOptions);
+    close(cb: FCallback): void;
+}
+
+type IServerSerialOptions = SerialPortOpenOptions<any> & {
+    debug?: boolean,
+    unitID?: number,
+    openCallback?: ErrorCallback
+}
+
+export declare interface ServerSerial {
+    on(event: 'socketError', listener: FCallback): this;
+    on(event: 'error', listener: FCallback): this;
+    on(event: 'initialized', listener: FCallback): this;
+}

ServerTCP.d.ts

@@ -5,7 +5,7 @@ export class ServerTCP extends events.EventEmitter {
     close(cb: FCallback): void;
 }
 
-interface IServiceVector {
+export interface IServiceVector {
     getCoil?:
         ((addr: number, unitID: number, cb: FCallbackVal<boolean>) => void) |
         ((addr: number, unitID: number) => Promise<boolean>) |
@@ -58,5 +58,5 @@ export declare interface ServerTCP {
     on(event: 'initialized', listener: FCallback): this;
 }
 
-type FCallbackVal<T> = (err: Error | null, value: T) => void;
-type FCallback = (err: Error | null) => void;
+export type FCallbackVal<T> = (err: Error | null, value: T) => void;
+export type FCallback = (err: Error | null) => void;

index.d.ts

@@ -1,4 +1,5 @@
 import {ModbusRTU} from "./ModbusRTU";
 export * from "./ServerTCP";
+export * from "./ServerSerial";
 
 export default ModbusRTU;

servers/serverserial.js

@@ -237,7 +237,7 @@ class ServerSerial extends EventEmitter {
         const optionsWithBindingandSerialport = Object.assign({}, serialportOptions, optionsWithBinding);
 
         // create a serial server
-        modbus._serverPath = new SerialPort(optionsWithBindingandSerialport);
+        modbus._serverPath = new SerialPort(optionsWithBindingandSerialport, options.openCallback);
 
         // create a serial server with a timeout parser
         modbus._server = modbus._serverPath.pipe(new ServerSerialPipeHandler(optionsWithSerialPortTimeoutParser));
@@ -253,7 +253,7 @@ class ServerSerial extends EventEmitter {
         // remember open sockets
         modbus.socks = new Map();
 
-        modbus._server.on("open", function() {
+        modbus._serverPath.on("open", function() {
             modbus.socks.set(modbus._server, 0);
 
             modbusSerialDebug({
@@ -270,6 +270,7 @@ class ServerSerial extends EventEmitter {
                 modbus.socks.delete(modbus._server);
             });
 
+            modbus.emit("initialized");
         });
 
         modbus._server.on("data", function(data) {