MSC2918: save tokens in session on refresh

Author: sandhose

src/matrix/SessionContainer.js

@@ -192,6 +192,18 @@ export class SessionContainer {
             reconnector: this._reconnector,
         });
         if (this._tokenRefresher) {
+            this._tokenRefresher.accessToken.subscribe(token => {
+                this._platform.sessionInfoStorage.updateAccessToken(sessionInfo.id, token);
+            });
+
+            this._tokenRefresher.accessTokenExpiresAt.subscribe(expiresAt => {
+                this._platform.sessionInfoStorage.updateAccessTokenExpiresAt(sessionInfo.id, expiresAt);
+            });
+
+            this._tokenRefresher.refreshToken.subscribe(token => {
+                this._platform.sessionInfoStorage.updateRefreshToken(sessionInfo.id, token);
+            });
+
             await this._tokenRefresher.start(hsApi);
         }
         this._sessionId = sessionInfo.id;
@@ -331,6 +343,9 @@ export class SessionContainer {
             this._storage.close();
             this._storage = null;
         }
+        if (this._tokenRefresher) {
+            this._tokenRefresher.stop();
+        }
     }
 
     async deleteSession() {

src/matrix/net/TokenRefresher.js

@@ -24,6 +24,10 @@ export class TokenRefresher {
         this._renewingLoop();
     }
 
+    stop() {
+        // TODO
+    }
+
     get needsRenewing() {
         const remaining = this._accessTokenExpiresAt.get() - this._clock.now();
         const anticipated = remaining - this._anticipation;
@@ -64,6 +68,10 @@ export class TokenRefresher {
         return this._accessToken;
     }
 
+    get accessTokenExpiresAt() {
+        return this._accessTokenExpiresAt;
+    }
+
     get refreshToken() {
         return this._refreshToken;
     }

src/matrix/sessioninfo/localstorage/SessionInfoStorage.js

@@ -19,15 +19,19 @@ export class SessionInfoStorage {
         this._name = name;
     }
 
-    getAll() {
+    _getAllSync() {
         const sessionsJson = localStorage.getItem(this._name);
         if (sessionsJson) {
             const sessions = JSON.parse(sessionsJson);
             if (Array.isArray(sessions)) {
-                return Promise.resolve(sessions);
+                return sessions;
             }
         }
-        return Promise.resolve([]);
+        return [];
+    }
+
+    async getAll() {
+        return this._getAllSync();
     }
 
     async updateLastUsed(id, timestamp) {
@@ -41,6 +45,40 @@ export class SessionInfoStorage {
         }
     }
 
+    // Update to the session tokens are all done synchronousely to avoid data races
+    updateAccessToken(id, accessToken) {
+        const sessions = this._getAllSync();
+        if (sessions) {
+            const session = sessions.find(session => session.id === id);
+            if (session) {
+                session.accessToken = accessToken;
+                localStorage.setItem(this._name, JSON.stringify(sessions));
+            }
+        }
+    }
+
+    updateAccessTokenExpiresAt(id, accessTokenExpiresAt) {
+        const sessions = this._getAllSync();
+        if (sessions) {
+            const session = sessions.find(session => session.id === id);
+            if (session) {
+                session.accessTokenExpiresAt = accessTokenExpiresAt;
+                localStorage.setItem(this._name, JSON.stringify(sessions));
+            }
+        }
+    }
+
+    updateRefreshToken(id, refreshToken) {
+        const sessions = this._getAllSync();
+        if (sessions) {
+            const session = sessions.find(session => session.id === id);
+            if (session) {
+                session.refreshToken = refreshToken;
+                localStorage.setItem(this._name, JSON.stringify(sessions));
+            }
+        }
+    }
+
     async get(id) {
         const sessions = await this.getAll();
         if (sessions) {