wip: working fix need cleanup

api/src/auth/auth.service.ts

@@ -88,7 +88,16 @@ export class AuthService {
         this.getRefreshTokenOptions(),
       );
 
-      this.engineService.isUserConnected(payload.context); //check if user is connected
+      //check if user is connected
+      const isConnected = await this.engineService.isSessionValid(
+        payload.context,
+      );
+
+      console.log('isConnected', isConnected);
+      if (!isConnected) {
+        console.log('User need to reconnect');
+        throw new UnauthorizedException('User need to reconnect');
+      }
 
       const user = await this.usersService.findOne(payload.context.id);
       const isMatchingTokens =
@@ -100,6 +109,7 @@ export class AuthService {
       }
       return this.login(payload.context);
     } catch (error) {
+      console.log(error);
       throw new UnauthorizedException('Invalid refresh token');
     }
   }

api/src/engine/connectors/datashield/datashield.connector.ts

@@ -340,7 +340,7 @@ export default class DataShieldConnector implements Connector {
     return [dsDomain];
   }
 
-  async isUserConnected(user: User): Promise<boolean> {
+  async isSessionValid(user: User): Promise<boolean> {
     const sid = user && user.extraFields && user.extraFields['sid'];
 
     if (!sid) return false;

api/src/engine/engine.service.ts

@@ -80,9 +80,9 @@ export default class EngineService implements Connector {
     return this.connector.getConfiguration?.() ?? {};
   }
 
-  isUserConnected(user: User): Promise<boolean> {
-    if (!this.connector.isUserConnected) throw new NotImplementedException();
-    return this.connector.isUserConnected(user);
+  isSessionValid(user: User): Promise<boolean> {
+    if (!this.connector.isSessionValid) throw new NotImplementedException();
+    return this.connector.isSessionValid(user);
   }
 
   /**

api/src/engine/interfaces/connector.interface.ts

@@ -23,9 +23,10 @@ export default interface Connector {
   getConfiguration?(): ConnectorConfiguration;
 
   /**
-   * Tell if the user is still connected to the engine
+   * Tell if the session is still valid
+   * @param user User to check
    */
-  isUserConnected?(user: User): Promise<boolean>;
+  isSessionValid?(user: User): Promise<boolean>;
 
   /**
    * Get the list of domains along with a list of variables