Revert "Try downlevelIteration"

This reverts commit b04f425.

Author: schmidt-sebastian

packages/firestore/src/core/sync_engine.ts

@@ -398,7 +398,7 @@ export class SyncEngine implements RemoteSyncer, SharedClientStateSyncer {
     try {
       const changes = await this.localStore.applyRemoteEvent(remoteEvent);
       // Update `receivedDocument` as appropriate for any limbo targets.
-      for (const [targetId, targetChange] of remoteEvent.targetChanges) {
+      remoteEvent.targetChanges.forEach((targetChange, targetId) => {
         const limboResolution = this.limboResolutionsByTarget.get(targetId);
         if (limboResolution) {
           // Since this is a limbo resolution lookup, it's for a single document
@@ -427,7 +427,7 @@ export class SyncEngine implements RemoteSyncer, SharedClientStateSyncer {
             // This was probably just a CURRENT targetChange or similar.
           }
         }
-      }
+      });
       await this.emitNewSnapsAndNotifyLocalStore(changes, remoteEvent);
     } catch (error) {
       await ignoreIfPrimaryLeaseLoss(error);
@@ -643,11 +643,11 @@ export class SyncEngine implements RemoteSyncer, SharedClientStateSyncer {
 
   /** Reject all outstanding callbacks waiting for pending writes to complete. */
   private rejectOutstandingPendingWritesCallbacks(errorMessage: string): void {
-    for (const [_, callbacks] of this.pendingWritesCallbacks) {
-      for (const callback of callbacks) {
+    this.pendingWritesCallbacks.forEach(callbacks => {
+      callbacks.forEach(callback => {
         callback.reject(new FirestoreError(Code.CANCELLED, errorMessage));
-      }
-    }
+      });
+    });
 
     this.pendingWritesCallbacks.clear();
   }
@@ -913,18 +913,22 @@ export class SyncEngine implements RemoteSyncer, SharedClientStateSyncer {
 
       const activeTargets: TargetId[] = [];
 
-      for (const [targetId] of this.queriesByTarget) {
+      let p = Promise.resolve();
+      this.queriesByTarget.forEach((_, targetId) => {
         if (this.sharedClientState.isLocalQueryTarget(targetId)) {
           activeTargets.push(targetId);
         } else {
-          await this.removeAndCleanupTarget(targetId);
-          await this.localStore.releaseTarget(
-            targetId,
-            /*keepPersistedTargetData=*/ true
-          );
+          p = p.then(() => {
+            this.removeAndCleanupTarget(targetId);
+            return this.localStore.releaseTarget(
+              targetId,
+              /*keepPersistedTargetData=*/ true
+            );
+          });
         }
         this.remoteStore.unlisten(targetId);
-      }
+      });
+      await p;
 
       await this.synchronizeQueryViewsAndRaiseSnapshots(activeTargets);
       this.resetLimboDocuments();
@@ -934,9 +938,9 @@ export class SyncEngine implements RemoteSyncer, SharedClientStateSyncer {
 
   // PORTING NOTE: Multi-tab only.
   private resetLimboDocuments(): void {
-    for (const [targetId] of this.limboResolutionsByTarget) {
+    this.limboResolutionsByTarget.forEach((_, targetId) => {
       this.remoteStore.unlisten(targetId);
-    }
+    });
     this.limboDocumentRefs.removeAllReferences();
     this.limboResolutionsByTarget = new Map<TargetId, LimboResolution>();
     this.limboTargetsByKey = new SortedMap<DocumentKey, TargetId>(

packages/firestore/src/local/local_store.ts

@@ -519,10 +519,10 @@ export class LocalStore {
         newTargetDataByTargetMap = this.targetDataByTarget;
 
         const promises = [] as Array<PersistencePromise<void>>;
-        for (const [targetId, change] of remoteEvent.targetChanges) {
+        remoteEvent.targetChanges.forEach((change, targetId) => {
           const oldTargetData = newTargetDataByTargetMap.get(targetId);
           if (!oldTargetData) {
-            continue;
+            return;
           }
 
           // Only update the remote keys if the target is still active. This
@@ -565,7 +565,7 @@ export class LocalStore {
               );
             }
           }
-        }
+        });
 
         let changedDocs = maybeDocumentMap();
         let updatedKeys = documentKeySet();

packages/firestore/src/model/field_value.ts

@@ -256,7 +256,7 @@ export class ObjectValueBuilder {
         { ...existingValue.mapValue.fields }
       : {};
 
-    for (const [pathSegment, value] of currentOverlays) {
+    currentOverlays.forEach((value, pathSegment) => {
       if (value instanceof Map) {
         const nested = this.applyOverlay(currentPath.child(pathSegment), value);
         if (nested != null) {
@@ -270,7 +270,7 @@ export class ObjectValueBuilder {
         delete resultAtPath[pathSegment];
         modified = true;
       }
-    }
+    });
 
     return modified ? { mapValue: { fields: resultAtPath } } : null;
   }

packages/firestore/src/remote/remote_store.ts

@@ -343,9 +343,9 @@ export class RemoteStore implements TargetMetadataProvider {
   }
 
   private async onWatchStreamOpen(): Promise<void> {
-    for (const [_, targetData] of this.listenTargets) {
+    this.listenTargets.forEach((targetData, targetId) => {
       this.sendWatchRequest(targetData);
-    }
+    });
   }
 
   private async onWatchStreamClose(error?: FirestoreError): Promise<void> {
@@ -428,7 +428,7 @@ export class RemoteStore implements TargetMetadataProvider {
 
     // Update in-memory resume tokens. LocalStore will update the
     // persistent view of these when applying the completed RemoteEvent.
-    for (const [targetId, change] of remoteEvent.targetChanges) {
+    remoteEvent.targetChanges.forEach((change, targetId) => {
       if (change.resumeToken.approximateByteSize() > 0) {
         const targetData = this.listenTargets.get(targetId);
         // A watched target might have been removed already.
@@ -439,7 +439,7 @@ export class RemoteStore implements TargetMetadataProvider {
           );
         }
       }
-    }
+    });
 
     // Re-establish listens for the targets that have been invalidated by
     // existence filter mismatches.

packages/firestore/src/remote/watch_change.ts

@@ -422,7 +422,7 @@ export class WatchChangeAggregator {
   createRemoteEvent(snapshotVersion: SnapshotVersion): RemoteEvent {
     const targetChanges = new Map<TargetId, TargetChange>();
 
-    for (const [targetId, targetState] of this.targetStates) {
+    this.targetStates.forEach((targetState, targetId) => {
       const targetData = this.targetDataForActiveTarget(targetId);
       if (targetData) {
         if (targetState.current && targetData.target.isDocumentQuery()) {
@@ -453,7 +453,7 @@ export class WatchChangeAggregator {
           targetState.clearPendingChanges();
         }
       }
-    }
+    });
 
     let resolvedLimboDocuments = documentKeySet();
 

packages/firestore/tsconfig.json

@@ -1,9 +1,7 @@
 {
   "extends": "../../config/tsconfig.base.json",
   "compilerOptions": {
-    "outDir": "dist",
-    "downlevelIteration": true,
-    "importHelpers": true
+    "outDir": "dist"
   },
   "exclude": [
     "dist/**/*"