botframework-streaming - npm Package Compare versions

Comparing version 4.7.1 to 4.7.2

lib/interfaces/IStreamingTransportServer.d.ts

@@ -18,2 +18,3 @@ /**
     send(request: StreamingRequest): Promise<IReceiveResponse>;
+    isConnected?: boolean;
 }

lib/namedPipe/namedPipeServer.d.ts

@@ -27,2 +27,6 @@ import { RequestHandler } from '../requestHandler';
     /**
+     * Returns true if currently connected.
+     */
+    readonly isConnected: boolean;
+    /**
      * Used to establish the connection used by this server and begin listening for incoming messages.
@@ -29,0 +33,0 @@ *

lib/namedPipe/namedPipeServer.js

@@ -35,2 +35,5 @@ "use strict";
     constructor(baseName, requestHandler, autoReconnect = true) {
+        if (!baseName) {
+            throw new TypeError('NamedPipeServer: Missing baseName parameter');
+        }
         this._baseName = baseName;
@@ -47,2 +50,8 @@ this._requestHandler = requestHandler;
     /**
+     * Returns true if currently connected.
+     */
+    get isConnected() {
+        return !!(this._receiver.isConnected && this._sender.isConnected);
+    }
+    /**
      * Used to establish the connection used by this server and begin listening for incoming messages.
@@ -49,0 +58,0 @@ *

lib/webSocket/webSocketServer.d.ts

@@ -17,2 +17,3 @@ import { RequestHandler } from '../requestHandler';
     private _closedSignal;
+    private _socket;
     /**
@@ -26,2 +27,6 @@ * Creates a new instance of the [WebSocketServer](xref:botframework-streaming.WebSocketServer) class.
     /**
+     * Examines the stored ISocket and returns true if the socket connection is open.
+     */
+    readonly isConnected: boolean;
+    /**
      * Used to establish the connection used by this server and begin listening for incoming messages.
@@ -28,0 +33,0 @@ *

lib/webSocket/webSocketServer.js

@@ -33,2 +33,6 @@ "use strict";
     constructor(socket, requestHandler) {
+        if (!socket) {
+            throw new TypeError('WebSocketServer: Missing socket parameter');
+        }
+        this._socket = socket;
         this._webSocketTransport = new webSocketTransport_1.WebSocketTransport(socket);
@@ -45,2 +49,8 @@ this._requestHandler = requestHandler;
     /**
+     * Examines the stored ISocket and returns true if the socket connection is open.
+     */
+    get isConnected() {
+        return this._socket.isConnected;
+    }
+    /**
      * Used to establish the connection used by this server and begin listening for incoming messages.
@@ -47,0 +57,0 @@ *

package.json

@@ -5,3 +5,3 @@ {
   "description": "Streaming library for the Microsoft Bot Framework",
-  "version": "4.7.1",
+  "version": "4.7.2",
   "license": "MIT",
@@ -49,3 +49,3 @@ "keywords": [
     "eslint-fix": "eslint  ./src/*.ts ./src/**/*.ts --fix",
-    "set-version": "npm version --allow-same-version 4.7.1",
+    "set-version": "npm version --allow-same-version 4.7.2",
     "test": "tsc && nyc mocha tests/"
@@ -52,0 +52,0 @@ },

src/interfaces/IStreamingTransportServer.ts

@@ -19,2 +19,3 @@ /**
     send(request: StreamingRequest): Promise<IReceiveResponse>;
+    isConnected?: boolean;
 }

src/namedPipe/namedPipeServer.ts

@@ -43,2 +43,6 @@ /**
     public constructor(baseName: string, requestHandler?: RequestHandler, autoReconnect: boolean = true) {
+        if (!baseName) {
+            throw new TypeError('NamedPipeServer: Missing baseName parameter');
+        }
+
         this._baseName = baseName;
@@ -56,2 +60,9 @@ this._requestHandler = requestHandler;
     /**
+     * Returns true if currently connected.
+     */
+    public get isConnected(): boolean {
+        return !!(this._receiver.isConnected && this._sender.isConnected);
+    }
+
+    /**
      * Used to establish the connection used by this server and begin listening for incoming messages.
@@ -58,0 +69,0 @@ *

src/webSocket/webSocketServer.ts

@@ -33,2 +33,3 @@ /**
     private _closedSignal;
+    private _socket: ISocket;
 
@@ -42,2 +43,7 @@ /**
     public constructor(socket: ISocket, requestHandler?: RequestHandler) {
+        if (!socket) {
+            throw new TypeError('WebSocketServer: Missing socket parameter');
+        }
+
+        this._socket = socket;
         this._webSocketTransport = new WebSocketTransport(socket);
@@ -59,2 +65,9 @@ this._requestHandler = requestHandler;
     /**
+     * Examines the stored ISocket and returns true if the socket connection is open.
+     */
+    public get isConnected(): boolean {
+        return this._socket.isConnected;
+    }
+
+    /**
      * Used to establish the connection used by this server and begin listening for incoming messages.
@@ -61,0 +74,0 @@ *

No alert changes

Improved metrics

Total package byte prevSize

314122

increased by0.63%

Lines of code

6739

increased by0.75%

No dependency changes