Adding a Gateway.connected property

gateways/js/dist/esm/fjage.js

@@ -718,6 +718,7 @@ class Gateway {
     this.listener = {};                   // set of callbacks that want to listen to incoming messages
     this.eventListeners = {};             // external listeners wanting to listen internal events
     this.queue = [];                      // incoming message queue
+    this.connected = false;               // connection status
     this.debug = false;                   // debug info to be logged to console?
     this.aid = new AgentID((isBrowser ? 'WebGW-' : 'NodeGW-')+_guid(4));         // gateway agent name
     this.connector = this._createConnector(url);
@@ -865,6 +866,7 @@ class Gateway {
     } else return null;
     conn.setReadCallback(this._onMsgRx.bind(this));
     conn.addConnectionListener(state => {
+      this.connected = !!state;
       if (state == true){
         this.flush();
         this.connector.write('{"alive": true}');

gateways/js/src/fjage.js

@@ -353,6 +353,7 @@ export class Gateway {
     this.listener = {};                   // set of callbacks that want to listen to incoming messages
     this.eventListeners = {};             // external listeners wanting to listen internal events
     this.queue = [];                      // incoming message queue
+    this.connected = false;               // connection status
     this.debug = false;                   // debug info to be logged to console?
     this.aid = new AgentID((isBrowser ? 'WebGW-' : 'NodeGW-')+_guid(4));         // gateway agent name
     this.connector = this._createConnector(url);
@@ -500,6 +501,7 @@ export class Gateway {
     } else return null;
     conn.setReadCallback(this._onMsgRx.bind(this));
     conn.addConnectionListener(state => {
+      this.connected = !!state;
       if (state == true){
         this.flush();
         this.connector.write('{"alive": true}');

gateways/js/test/spec/fjage.spec.js

@@ -252,6 +252,20 @@ describe('A Gateway', function () {
     expect(rxed.filter(r => !r).length).toBe(0);
   });
 
+  it('should update the connected property when the underlying transport is disconnected/reconnected', async function() {
+    const gw = new Gateway(gwOpts);
+    gw.connector._reconnectTime = 300;
+    await delay(700);
+    expect([1, 'open']).toContain(gw.connector.sock.readyState);
+    if (isBrowser) gw.connector.sock.close();
+    else gw.connector.sock.destroy();
+    await delay(100);
+    expect(gw.connected).toBe(false);
+    await delay(1000);
+    expect(gw.connected).toBe(true);
+    gw.connector._reconnectTime = 5000;
+  });
+
   it('should generate trigger connListener when the underlying transport is disconnected/reconnected', async function() {
     const gw = new Gateway(gwOpts);
     let spy = jasmine.createSpy('connListener');