Automatic resubscription when logged in using jwt property

src/Kuzzle.ts

@@ -429,6 +429,8 @@ export class Kuzzle extends KuzzleEventEmitter {
 
   set jwt (encodedJwt) {
     this.auth.authenticationToken = encodedJwt;
+
+    this._loggedIn = encodedJwt ? true : false;
   }
 
   get offlineQueue () {
@@ -599,7 +601,6 @@ export class Kuzzle extends KuzzleEventEmitter {
     // If an authenticator was set, check if a user was logged in and  if the token is still valid and try
     // to re-authenticate if needed. Otherwise the SDK is in disconnected state.
     if ( this._loggedIn
-      && this.authenticator 
       && ! await this.tryReAuthenticate()
     ) {
       this._loggedIn = false;
@@ -634,6 +635,14 @@ export class Kuzzle extends KuzzleEventEmitter {
         return true;
       }
 
+      /**
+       * Check if there is an authenticator after verifying if the token is still valid,
+       * like so API Keys can be used even if there is no authenticator since they will be still valid.
+       */
+      if (! this.authenticator) {
+        return false;
+      }
+
       await this.authenticate();
 
       return true;
@@ -839,7 +848,7 @@ Discarded request: ${JSON.stringify(request)}`));
       return;
     }
 
-    if (this._loggedIn && this.authenticator && await this.tryReAuthenticate()) {
+    if (this._loggedIn && await this.tryReAuthenticate()) {
       this.emit('reAuthenticated');
 
       return;
@@ -854,6 +863,7 @@ Discarded request: ${JSON.stringify(request)}`));
 
     this._lastTokenExpired = now;
 
+    this.jwt = null;
     this.emit('tokenExpired');
   }
 

test/kuzzle/authenticator.test.js

@@ -2,6 +2,7 @@ const should = require('should');
 const sinon = require('sinon');
 const ProtocolMock = require('../mocks/protocol.mock');
 const { Kuzzle } = require('../../src/Kuzzle');
+const generateJwt = require('../mocks/generateJwt.mock');
 
 describe('Kuzzle authenticator function mecanisms', () => {
   let kuzzle;
@@ -16,6 +17,20 @@ describe('Kuzzle authenticator function mecanisms', () => {
     sinon.restore();
   });
 
+  describe('jwt property', () => {
+    it('should set the SDK property _loggedIn when setting the JWT property', () => {
+      kuzzle.jwt = generateJwt();
+
+      should(kuzzle._loggedIn).be.true();
+    });
+
+    it('should set the SDK property _loggedIn when setting the JWT property to null or undefined', () => {
+      kuzzle.jwt = null;
+
+      should(kuzzle._loggedIn).be.false();
+    });
+  });
+
   describe('connected listener', () => {
     let resolve;
     let promise;
@@ -230,6 +245,17 @@ describe('Kuzzle authenticator function mecanisms', () => {
       should(reconnectionErrorSpy).not.be.called();
     });
 
+    it('should returns false if the token is not valid and there is no authenticator', async () => {
+      kuzzle.auth.checkToken.resolves({ valid: false });
+      kuzzle.authenticator = null;
+
+      const ret = await kuzzle.tryReAuthenticate();
+
+      should(ret).be.false();
+      should(kuzzle.authenticate).not.be.called();
+      should(reconnectionErrorSpy).not.be.called();
+    });
+
     it('should call "authenticate" if the token is not valid', async () => {
       const ret = await kuzzle.tryReAuthenticate();
 

test/kuzzle/protocol.test.js

@@ -52,11 +52,19 @@ describe('Kuzzle protocol methods', () => {
 
     it('should empty the jwt when a "tokenExpired" events is triggered', () => {
       kuzzle.jwt = generateJwt();
+
+      should(kuzzle._loggedIn).be.true();
+
       kuzzle.connect();
+      kuzzle.tryReAuthenticate = sinon.stub().resolves(false);
 
       kuzzle.protocol.emit('tokenExpired');
 
-      should(kuzzle.jwt).be.null();
+      setTimeout(() => {
+        should(kuzzle.tryReAuthenticate).be.calledOnce();
+        should(kuzzle._loggedIn).be.false();
+        should(kuzzle.jwt).be.null();
+      }, 1);
     });
   });
 });