Firestore/lite

Author: jamesdaniels

.gitignore

@@ -25,4 +25,4 @@ publish.sh
 
 # auto-gen files
 src/compat/**/base.ts
-src/**/rxfire.ts
+src/**/rxfire.ts

package.json

@@ -63,7 +63,7 @@
     "inquirer-autocomplete-prompt": "^1.0.1",
     "lodash.isequal": "^4.5.0",
     "open": "^7.0.3",
-    "rxfire": "6.0.0-canary.cee1afe",
+    "rxfire": "6.0.0-canary.92c6c26",
     "rxjs": "~6.6.0",
     "semver": "^7.1.3",
     "tslib": "^2.1.0",

sample/package.json

@@ -24,7 +24,7 @@
     "@angular/router": "^12.0.0",
     "firebase": "9.0.0-beta.7",
     "lodash.isequal": "^4.5.0",
-    "rxfire": "6.0.0-canary.cee1afe",
+    "rxfire": "6.0.0-canary.92c6c26",
     "rxjs": "~6.6.0",
     "tslib": "^2.1.0",
     "zone.js": "~0.11.4"

sample/src/app/app.component.ts

@@ -1,7 +1,8 @@
 import { ApplicationRef, Component, NgZone, Optional } from '@angular/core';
 import { FirebaseApp, FirebaseApps } from '@angular/fire/app';
 import { Auth, AuthInstances, authState } from '@angular/fire/auth';
-import { Firestore, FirestoreInstances, firestoreInstance$ } from '@angular/fire/firestore';
+import { Firestore, FirestoreInstances } from '@angular/fire/firestore/lite';
+import { firestoreInstance$ } from '@angular/fire/firestore';
 import { debounceTime } from 'rxjs/operators';
 import { initializeFirestore$ } from './firestore';
 
@@ -39,8 +40,8 @@ export class AppComponent {
     public auth: Auth, // default Firbase Auth
     public apps: FirebaseApps, // all initialized App instances
     public authInstances: AuthInstances, // all initialized Auth instances
-    @Optional() public firestore: Firestore,
-    @Optional() public firestoreInstances: FirestoreInstances,
+    public firestore: Firestore,
+    public firestoreInstances: FirestoreInstances,
     appRef: ApplicationRef,
     zone: NgZone,
   ) {
@@ -49,7 +50,7 @@ export class AppComponent {
     // onAuthStateChanged(auth, it => console.log('onAuthStateChanged', it));
     authState(auth).subscribe(it => console.log('authState', it));
     appRef.isStable.pipe(debounceTime(200)).subscribe(it => console.log('isStable', it));
-    console.log((app as any).container.providers.keys());
+    console.log((app as any).container.providers);
     firestoreInstance$.subscribe(it => console.log('$', it));
     initializeFirestore$.subscribe(it => console.log('init', it));
   }

sample/src/app/app.module.ts

@@ -7,6 +7,8 @@ import { initializeAuth } from 'firebase/auth';
 import { AppRoutingModule } from './app-routing.module';
 import { AppComponent } from './app.component';
 import { environment } from '../environments/environment';
+import { provideFirestore } from '@angular/fire/firestore/lite';
+import { getFirestore } from 'firebase/firestore/lite';
 
 @NgModule({
   declarations: [
@@ -22,6 +24,7 @@ import { environment } from '../environments/environment';
       return app;
     }),
     provideAuth(() => initializeAuth(getApp())),
+    provideFirestore(() => getFirestore()),
   ],
   providers: [ ],
   bootstrap: [AppComponent]

sample/yarn.lock

@@ -9162,10 +9162,10 @@ run-parallel@^1.1.9:
   dependencies:
     queue-microtask "^1.2.2"
 
-[email protected].cee1afe:
-  version "6.0.0-canary.cee1afe"
-  resolved "https://registry.yarnpkg.com/rxfire/-/rxfire-6.0.0-canary.cee1afe.tgz#212318f2ccc034c25581f079c51f0d952164b4db"
-  integrity sha512-PySJryeUfnuMuYlC8U+X83PIe53G1s+OpQuzjjaMUQ3gc1z6aD4ZEWc/O3LzVQ3ywwO/X4AAO9hv4F0Q3+y79A==
+[email protected].92c6c26:
+  version "6.0.0-canary.92c6c26"
+  resolved "https://registry.yarnpkg.com/rxfire/-/rxfire-6.0.0-canary.92c6c26.tgz#de888ac0ec975eb7860b4cee54aa15df90b9fec0"
+  integrity sha512-zqZZFTCFXqGNRIN/zciPVzylSw3drlkM3mojTZj4GALeUBtMI59/hmAEevbAxBQjNk4eiWj/4vFsPFJtzgT5qA==
   dependencies:
     tslib "^1.9.0 || ~2.1.0"
 

src/firestore/lite/lite.module.ts

@@ -0,0 +1,63 @@
+import { NgModule, Optional, NgZone, InjectionToken, ModuleWithProviders } from '@angular/core';
+import { FirebaseFirestore } from 'firebase/firestore/lite';
+import { AuthInstances  } from '@angular/fire/auth';
+import { ɵmemoizeInstance, ɵgetDefaultInstanceOf, ɵAngularFireSchedulers } from '@angular/fire';
+import { Firestore, FirestoreInstances, FIRESTORE_PROVIDER_NAME } from './lite';
+import { FirebaseApps } from '@angular/fire/app';
+
+export const PROVIDED_FIRESTORE_INSTANCES = new InjectionToken<Firestore[]>('angularfire2.firestore-lite-instances');
+
+export function defaultFirestoreInstanceFactory(_: Firestore[]) {
+  const defaultFirestore = ɵgetDefaultInstanceOf<FirebaseFirestore>(FIRESTORE_PROVIDER_NAME);
+  return new Firestore(defaultFirestore);
+}
+
+export function firestoreInstanceFactory(fn: () => FirebaseFirestore) {
+  return (zone: NgZone) => {
+    const firestore = ɵmemoizeInstance<FirebaseFirestore>(fn, zone);
+    return new Firestore(firestore);
+  };
+}
+
+const FIRESTORE_INSTANCES_PROVIDER = {
+  provide: FirestoreInstances,
+  deps: [
+    [new Optional(), PROVIDED_FIRESTORE_INSTANCES ],
+  ]
+};
+
+const DEFAULT_FIRESTORE_INSTANCE_PROVIDER = {
+  provide: Firestore,
+  useFactory: defaultFirestoreInstanceFactory,
+  deps: [
+    NgZone,
+    [new Optional(), PROVIDED_FIRESTORE_INSTANCES ],
+  ]
+};
+
+@NgModule({
+  providers: [
+    DEFAULT_FIRESTORE_INSTANCE_PROVIDER,
+    FIRESTORE_INSTANCES_PROVIDER,
+  ]
+})
+export class FirestoreModule {
+}
+
+export function provideFirestore(fn: () => FirebaseFirestore): ModuleWithProviders<FirestoreModule> {
+  return {
+    ngModule: FirestoreModule,
+    providers: [{
+      provide: PROVIDED_FIRESTORE_INSTANCES,
+      useFactory: firestoreInstanceFactory(fn),
+      multi: true,
+      deps: [
+        NgZone,
+        ɵAngularFireSchedulers,
+        FirebaseApps,
+        // Firestore+Auth work better if Auth is loaded first
+        [new Optional(), AuthInstances ],
+      ]
+    }]
+  };
+}

src/firestore/lite/lite.ts

@@ -0,0 +1,30 @@
+import { FirebaseFirestore } from 'firebase/firestore/lite';
+import { ɵgetAllInstancesOf } from '@angular/fire';
+import { from, timer } from 'rxjs';
+import { concatMap, distinct } from 'rxjs/operators';
+
+// see notes in core/firebase.app.module.ts for why we're building the class like this
+// tslint:disable-next-line:no-empty-interface
+export interface Firestore extends FirebaseFirestore {}
+
+export class Firestore {
+  constructor(firestore: FirebaseFirestore) {
+    return firestore;
+  }
+}
+
+export const FIRESTORE_PROVIDER_NAME = 'firestore/lite';
+
+// tslint:disable-next-line:no-empty-interface
+export interface FirestoreInstances extends Array<FirebaseFirestore> {}
+
+export class FirestoreInstances {
+  constructor() {
+    return ɵgetAllInstancesOf<FirebaseFirestore>(FIRESTORE_PROVIDER_NAME);
+  }
+}
+
+export const firestoreInstance$ = timer(0, 300).pipe(
+  concatMap(() => from(ɵgetAllInstancesOf<FirebaseFirestore>(FIRESTORE_PROVIDER_NAME))),
+  distinct(),
+);

src/firestore/lite/package.json

@@ -0,0 +1,11 @@
+{
+  "$schema": "../../../node_modules/ng-packagr/package.schema.json",
+  "ngPackage": {
+    "lib": {
+      "umdModuleIds": {
+        "rxfire/firestore-lite": "rxfire-firestore-lite"
+      },
+      "entryFile": "public_api.ts"
+    }
+  }
+}

src/firestore/lite/public_api.ts

@@ -0,0 +1,3 @@
+export { Firestore, FirestoreInstances, firestoreInstance$ } from './lite';
+export { FirestoreModule, provideFirestore } from './lite.module';
+export * from './rxfire';