Fix spec tests

Author: schmidt-sebastian

packages/firestore/test/unit/specs/spec_test_components.ts

@@ -121,14 +121,16 @@ function failTransactionIfNeeded(
 }
 
 export class MockOnlineComponentProvider extends OnlineComponentProvider {
-  connection!: MockConnection;
+  constructor(private readonly connection: MockConnection) {
+    super();
+  }
 
   createDatastore(cfg: ComponentConfiguration): Datastore {
     const serializer = new JsonProtoSerializer(
       cfg.databaseInfo.databaseId,
       /* useProto3Json= */ true
     );
-    return newDatastore(cfg.credentials, new MockConnection(cfg.asyncQueue), serializer);
+    return newDatastore(cfg.credentials, this.connection, serializer);
   }
 }
 

packages/firestore/test/unit/specs/spec_test_runner.ts

@@ -257,7 +257,9 @@ abstract class TestRunner {
       persistenceSettings: this.persistenceSettings
     };
 
-    const onlineComponentProvider = new MockOnlineComponentProvider();
+    this.connection = new MockConnection(this.queue);
+    
+    const onlineComponentProvider = new MockOnlineComponentProvider(this.connection);
     const offlineComponentProvider = await this.initializeOfflineComponentProvider(
       onlineComponentProvider,
       configuration,
@@ -271,7 +273,6 @@ abstract class TestRunner {
     this.sharedClientState = offlineComponentProvider.sharedClientState;
     this.persistence = offlineComponentProvider.persistence;
     this.localStore = offlineComponentProvider.localStore;
-    this.connection = onlineComponentProvider.connection;
     this.remoteStore = onlineComponentProvider.remoteStore;
     this.syncEngine = onlineComponentProvider.syncEngine;
     this.eventManager = onlineComponentProvider.eventManager;