Add isConnected

features/steps/collection.js

@@ -108,10 +108,8 @@ Then(/^the collection(?: '(.*?)')? should exist$/, async function (collection) {
 Then('the mapping of {string} should be updated', async function (collection) {
   const mapping = await this.kuzzle.collection.getMapping(this.index, collection);
 
-  should(mapping[this.index].mappings[collection]).eql({
-    properties: {
-      gordon: {type: 'keyword'}
-    }
+  should(mapping[this.index].mappings[collection].properties).eql({
+    gordon: { type: 'keyword' }
   });
 });
 
@@ -129,7 +127,6 @@ Then('the specifications of {string} must not exist', async function (collection
   catch (error) {
     should(error.status).eql(404);
   }
-
 });
 
 Then('they should be validated', function () {

src/Kuzzle.js

@@ -203,6 +203,10 @@ class Kuzzle extends KuzzleEventEmitter {
     return this.protocol.sslConnection;
   }
 
+  get connected () {
+    return this.protocol.connected;
+  }
+
   /**
   * Emit an event to all registered listeners
   * An event cannot be emitted multiple times before a timeout has been reached.

src/protocols/abstract/common.js

@@ -42,6 +42,10 @@ class AbstractWrapper extends KuzzleEventEmitter {
     return _ssl;
   }
 
+  get connected () {
+    return this.state === 'online';
+  }
+
   /**
    * @abstract
    * @returns {Promise<any>}

src/protocols/http.js

@@ -6,7 +6,6 @@ const
 
 
 class HttpWrapper extends KuzzleAbstractProtocol {
-
   constructor(host, options = {}) {
     super(host, options);
 
@@ -32,6 +31,10 @@ class HttpWrapper extends KuzzleAbstractProtocol {
     return this.ssl ? 'https' : 'http';
   }
 
+  get connected () {
+    return true;
+  }
+
   /**
    * Connect to the websocket server
    */