Fix spurious triggers.

Author: yuchenshi

packages-exp/auth-exp/src/platform_browser/auth.test.ts

@@ -71,6 +71,7 @@ describe('core/auth/auth_impl', () => {
       apiHost: DefaultConfig.API_HOST,
       apiScheme: DefaultConfig.API_SCHEME,
       tokenApiHost: DefaultConfig.TOKEN_API_HOST,
+      clientPlatform: ClientPlatform.BROWSER,
       sdkClientVersion: 'v'
     });
 
@@ -137,6 +138,7 @@ describe('core/auth/initializeAuth', () => {
         apiScheme: DefaultConfig.API_SCHEME,
         tokenApiHost: DefaultConfig.TOKEN_API_HOST,
         authDomain,
+        clientPlatform: ClientPlatform.BROWSER,
         sdkClientVersion: _getClientVersion(ClientPlatform.BROWSER)
       });
 
@@ -312,6 +314,7 @@ describe('core/auth/initializeAuth', () => {
         apiHost: DefaultConfig.API_HOST,
         apiScheme: DefaultConfig.API_SCHEME,
         tokenApiHost: DefaultConfig.TOKEN_API_HOST,
+        clientPlatform: ClientPlatform.BROWSER,
         sdkClientVersion: _getClientVersion(ClientPlatform.BROWSER)
       });
     });

packages-exp/auth-exp/src/platform_browser/persistence/indexed_db.test.ts

@@ -128,6 +128,11 @@ describe('platform_browser/persistence/indexed_db', () => {
       clock.restore();
     });
 
+    it('should not trigger a listener when there are no changes', async () => {
+      await waitUntilPoll(clock);
+      expect(callback).not.to.have.been.called;
+    });
+
     it('should trigger a listener when the key changes', async () => {
       await _putObject(db, key, newValue);
 

packages-exp/auth-exp/src/platform_browser/persistence/indexed_db.ts

@@ -373,7 +373,7 @@ class IndexedDBLocalPersistence implements InternalPersistence {
       }
     }
     for (const localKey of Object.keys(this.localCache)) {
-      if (!keysInResult.has(localKey)) {
+      if (this.localCache[localKey] && !keysInResult.has(localKey)) {
         // Deleted
         this.notifyListeners(localKey, null);
         keys.push(localKey);
@@ -387,8 +387,11 @@ class IndexedDBLocalPersistence implements InternalPersistence {
     newValue: PersistenceValue | null
   ): void {
     this.localCache[key] = newValue;
-    for (const listener of Array.from(this.listeners[key])) {
-      listener(newValue);
+    const listeners = this.listeners[key];
+    if (listeners) {
+      for (const listener of Array.from(listeners)) {
+        listener(newValue);
+      }
     }
   }
 
@@ -412,7 +415,11 @@ class IndexedDBLocalPersistence implements InternalPersistence {
     if (Object.keys(this.listeners).length === 0) {
       this.startPolling();
     }
-    this.listeners[key] = this.listeners[key] || new Set();
+    if (!this.listeners[key]) {
+      this.listeners[key] = new Set();
+      // Populate the cache to avoid spuriously triggering on first poll.
+      void this._get(key); // This can happen in the background async and we can return immediately.
+    }
     this.listeners[key].add(listener);
   }
 

packages-exp/auth-exp/src/platform_browser/persistence/local_storage.ts

@@ -99,11 +99,6 @@ class BrowserLocalPersistence
 
     const key = event.key;
 
-    // Ignore keys that have no listeners.
-    if (!this.listeners[key]) {
-      return;
-    }
-
     // Check the mechanism how this event was detected.
     // The first event will dictate the mechanism to be used.
     if (poll) {
@@ -166,8 +161,11 @@ class BrowserLocalPersistence
 
   private notifyListeners(key: string, value: string | null): void {
     this.localCache[key] = value;
-    for (const listener of Array.from(this.listeners[key])) {
-      listener(value ? JSON.parse(value) : value);
+    const listeners = this.listeners[key];
+    if (listeners) {
+      for (const listener of Array.from(listeners)) {
+        listener(value ? JSON.parse(value) : value);
+      }
     }
   }
 
@@ -217,7 +215,11 @@ class BrowserLocalPersistence
         this.attachListener();
       }
     }
-    this.listeners[key] = this.listeners[key] || new Set();
+    if (!this.listeners[key]) {
+      this.listeners[key] = new Set();
+      // Populate the cache to avoid spuriously triggering on first poll.
+      this.localCache[key] = this.storage.getItem(key);
+    }
     this.listeners[key].add(listener);
   }