Add authenticated property on Kuzzle object

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,14 @@ class Kuzzle extends KuzzleEventEmitter {
     return this.protocol.sslConnection;
   }
 
+  isLoggued () {
+    if (!this.jwt) {
+      return false;
+    }
+
+    return this.jwtExpiresAt > Date.now();
+  }
+
   /**
   * Emit an event to all registered listeners
   * An event cannot be emitted multiple times before a timeout has been reached.
@@ -239,6 +247,7 @@ class Kuzzle extends KuzzleEventEmitter {
 
     this.protocol.addListener('tokenExpired', () => {
       this.jwt = undefined;
+      this.jwtExpiresAt = undefined;
       this.emit('tokenExpired');
     });
 
@@ -280,10 +289,12 @@ class Kuzzle extends KuzzleEventEmitter {
             // shouldn't obtain an error but let's invalidate the token anyway
             if (!res.valid) {
               this.jwt = undefined;
+              this.jwtExpiresAt = undefined;
             }
           })
           .catch(() => {
             this.jwt = undefined;
+            this.jwtExpiresAt = undefined;
           })
           .then(() => this.emit('reconnected'));
       }

src/controllers/auth.js

@@ -144,18 +144,19 @@ class AuthController extends BaseController {
       throw new Error('Kuzzle.auth.login: strategy is required');
     }
 
-    const
-      request = {
-        strategy,
-        expiresIn,
-        body: credentials,
-        action: 'login'
-      };
+    const request = {
+      strategy,
+      expiresIn,
+      body: credentials,
+      action: 'login'
+    };
 
     return this.query(request, {queuable: false})
       .then(response => {
         try {
           this.kuzzle.jwt = response.result.jwt;
+          this.kuzzle.jwtExpiresAt = response.result.expiresAt;
+
           this.kuzzle.emit('loginAttempt', {success: true});
         }
         catch (err) {
@@ -180,6 +181,7 @@ class AuthController extends BaseController {
     }, {queuable: false})
       .then(() => {
         this.kuzzle.jwt = undefined;
+        this.kuzzle.jwtExpiresAt = undefined;
       });
   }
 
@@ -247,6 +249,7 @@ class AuthController extends BaseController {
     return this.query(query, options)
       .then(response => {
         this.kuzzle.jwt = response.result.jwt;
+        this.kuzzle.jwtExpiresAt = response.result.expiresAt;
 
         return response.result;
       });

src/controllers/realtime/index.js

@@ -112,6 +112,7 @@ class RealTimeController extends BaseController {
 
     this.subscriptions = {};
     this.kuzzle.jwt = undefined;
+    this.kuzzle.jwtExpiresAt = undefined;
 
     const now = Date.now();
     if ((now - this.lastExpirationTimestamp) > expirationThrottleDelay) {