Maybe reduce size

Author: schmidt-sebastian

packages/firestore/src/core/component_provider.ts

@@ -121,12 +121,45 @@ export abstract class ComponentProvider {
   }
 
   protected abstract createSharedClientState(): SharedClientState;
+
   protected abstract createPersistence(): Persistence;
+
   protected abstract createGarbageCollectionScheduler(): GarbageCollectionScheduler | null;
-  protected abstract createLocalStore(): LocalStore;
-  protected abstract createRemoteStore(): RemoteStore;
-  protected abstract createSyncEngine(): SyncEngine;
-  protected abstract createEventManager(): EventManager;
+
+  protected createLocalStore(): LocalStore {
+    return new LocalStore(
+      this.persistence,
+      new IndexFreeQueryEngine(),
+      this.initialUser
+    );
+  }
+  protected createSyncEngine(): SyncEngine {
+    return new SyncEngine(
+      this.localStore,
+      this.remoteStore,
+      this.sharedClientState,
+      this.initialUser,
+      this.maxConcurrentLimboResolutions
+    );
+  }
+
+  protected createEventManager(): EventManager {
+    return new EventManager(this.syncEngine);
+  }
+
+  protected createRemoteStore(): RemoteStore {
+    return new RemoteStore(
+      this.localStore,
+      this.datastore,
+      this.asyncQueue,
+      onlineState =>
+        this.syncEngine.applyOnlineStateChange(
+          onlineState,
+          OnlineStateSource.RemoteStore
+        ),
+      this.platform.newConnectivityMonitor()
+    );
+  }
 
   abstract clearPersistence(databaseId: DatabaseInfo): Promise<void>;
 }
@@ -135,10 +168,6 @@ export abstract class ComponentProvider {
  * Provides all components needed for Firestore with IndexedDB persistence.
  */
 export class IndexedDbComponentProvider extends ComponentProvider {
-  protected createEventManager(): EventManager {
-    return new EventManager(this.syncEngine);
-  }
-
   protected createGarbageCollectionScheduler(): GarbageCollectionScheduler | null {
     debugAssert(
       this.persistence instanceof IndexedDbPersistence,
@@ -149,14 +178,6 @@ export class IndexedDbComponentProvider extends ComponentProvider {
     return new LruScheduler(garbageCollector, this.asyncQueue);
   }
 
-  protected createLocalStore(): LocalStore {
-    return new LocalStore(
-      this.persistence,
-      new IndexFreeQueryEngine(),
-      this.initialUser
-    );
-  }
-
   protected createPersistence(): Persistence {
     debugAssert(
       this.persistenceSettings.durable,
@@ -183,20 +204,6 @@ export class IndexedDbComponentProvider extends ComponentProvider {
     });
   }
 
-  protected createRemoteStore(): RemoteStore {
-    return new RemoteStore(
-      this.localStore,
-      this.datastore,
-      this.asyncQueue,
-      onlineState =>
-        this.syncEngine.applyOnlineStateChange(
-          onlineState,
-          OnlineStateSource.RemoteStore
-        ),
-      this.platform.newConnectivityMonitor()
-    );
-  }
-
   protected createSharedClientState(): SharedClientState {
     debugAssert(
       this.persistenceSettings.durable,
@@ -224,16 +231,6 @@ export class IndexedDbComponentProvider extends ComponentProvider {
     return new MemorySharedClientState();
   }
 
-  protected createSyncEngine(): SyncEngine {
-    return new SyncEngine(
-      this.localStore,
-      this.remoteStore,
-      this.sharedClientState,
-      this.initialUser,
-      this.maxConcurrentLimboResolutions
-    );
-  }
-
   clearPersistence(databaseInfo: DatabaseInfo): Promise<void> {
     const persistenceKey = IndexedDbPersistence.buildStoragePrefix(
       databaseInfo
@@ -259,22 +256,10 @@ export class MemoryComponentProvider extends ComponentProvider {
     super();
   }
 
-  protected createEventManager(): EventManager {
-    return new EventManager(this.syncEngine);
-  }
-
   protected createGarbageCollectionScheduler(): GarbageCollectionScheduler | null {
     return null;
   }
 
-  protected createLocalStore(): LocalStore {
-    return new LocalStore(
-      this.persistence,
-      new IndexFreeQueryEngine(),
-      this.initialUser
-    );
-  }
-
   protected createPersistence(): Persistence {
     debugAssert(
       !this.persistenceSettings.durable,
@@ -283,34 +268,10 @@ export class MemoryComponentProvider extends ComponentProvider {
     return new MemoryPersistence(this.clientId, this.referenceDelegateFactory);
   }
 
-  protected createRemoteStore(): RemoteStore {
-    return new RemoteStore(
-      this.localStore,
-      this.datastore,
-      this.asyncQueue,
-      onlineState =>
-        this.syncEngine.applyOnlineStateChange(
-          onlineState,
-          OnlineStateSource.RemoteStore
-        ),
-      this.platform.newConnectivityMonitor()
-    );
-  }
-
   protected createSharedClientState(): SharedClientState {
     return new MemorySharedClientState();
   }
 
-  protected createSyncEngine(): SyncEngine {
-    return new SyncEngine(
-      this.localStore,
-      this.remoteStore,
-      this.sharedClientState,
-      this.initialUser,
-      this.maxConcurrentLimboResolutions
-    );
-  }
-
   clearPersistence(): never {
     throw new FirestoreError(
       Code.FAILED_PRECONDITION,