feat: added create to FirestoreDocumentDataAccessor

packages/firebase-server/src/lib/firestore/driver.accessor.batch.ts

@@ -13,6 +13,11 @@ export class WriteBatchFirestoreDocumentDataAccessor<T> implements FirestoreDocu
     return from(this.get()); // todo
   }
 
+  create(data: WithFieldValue<T>): Promise<void> {
+    this.batch.create(this.documentRef, data);
+    return Promise.resolve();
+  }
+
   exists(): Promise<boolean> {
     return this.get().then((x) => x.exists);
   }

packages/firebase-server/src/lib/firestore/driver.accessor.default.ts

@@ -10,6 +10,10 @@ export class DefaultFirestoreDocumentDataAccessor<T> implements FirestoreDocumen
     return streamFromOnSnapshot(({ next, error }) => this.documentRef.onSnapshot(next, error));
   }
 
+  create(data: T): Promise<GoogleCloudWriteResult> {
+    return this.documentRef.create(data);
+  }
+
   exists(): Promise<boolean> {
     return this.get().then((x) => x.exists);
   }

packages/firebase-server/src/lib/firestore/driver.accessor.transaction.ts

@@ -13,6 +13,11 @@ export class TransactionFirestoreDocumentDataAccessor<T> implements FirestoreDoc
     return from(this.get());
   }
 
+  create(data: WithFieldValue<T>): Promise<void> {
+    this.transaction.create(this.documentRef, data);
+    return Promise.resolve();
+  }
+
   exists(): Promise<boolean> {
     return this.get().then((x) => x.exists);
   }

packages/firebase/src/lib/client/firestore/driver.accessor.batch.ts

@@ -1,6 +1,7 @@
 import { DocumentReference, DocumentSnapshot, getDoc, WriteBatch as FirebaseFirestoreWriteBatch, UpdateData as FirestoreUpdateData } from '@firebase/firestore';
 import { from, Observable } from 'rxjs';
 import { FirestoreDocumentContext, UpdateData, WithFieldValue, FirestoreDocumentContextType, FirestoreDocumentDataAccessor, FirestoreDocumentDataAccessorFactory, SetOptions } from '../../common/firestore';
+import { createWithAccessor } from './driver.accessor.create';
 
 // MARK: Accessor
 /**
@@ -13,6 +14,10 @@ export class WriteBatchFirestoreDocumentDataAccessor<T> implements FirestoreDocu
     return from(this.get());
   }
 
+  create(data: WithFieldValue<T>): Promise<void> {
+    return createWithAccessor(this)(data) as Promise<void>;
+  }
+
   exists(): Promise<boolean> {
     return this.get().then((x) => x.exists());
   }

packages/firebase/src/lib/client/firestore/driver.accessor.create.ts

@@ -0,0 +1,14 @@
+import { FirestoreDocumentDataAccessor } from '../../common/firestore/accessor/accessor';
+import { WithFieldValue, WriteResult } from '../../common/firestore/types';
+
+export function createWithAccessor<T>(accessor: FirestoreDocumentDataAccessor<T>): (data: WithFieldValue<T>) => Promise<void | WriteResult> {
+  return (data: WithFieldValue<T>) => {
+    return accessor.exists().then((exists) => {
+      if (exists) {
+        throw new Error('document exists');
+      } else {
+        return accessor.set(data);
+      }
+    });
+  };
+}

packages/firebase/src/lib/client/firestore/driver.accessor.default.ts

@@ -2,6 +2,7 @@ import { DocumentReference, DocumentSnapshot, UpdateData, WithFieldValue, getDoc
 import { fromRef } from 'rxfire/firestore';
 import { Observable } from 'rxjs';
 import { FirestoreDocumentContext, FirestoreDocumentContextType, FirestoreDocumentDataAccessor, FirestoreDocumentDataAccessorFactory, SetOptions } from '../../common/firestore';
+import { createWithAccessor } from './driver.accessor.create';
 
 // MARK: Accessor
 export class DefaultFirestoreDocumentDataAccessor<T> implements FirestoreDocumentDataAccessor<T> {
@@ -11,6 +12,10 @@ export class DefaultFirestoreDocumentDataAccessor<T> implements FirestoreDocumen
     return fromRef(this.documentRef);
   }
 
+  create(data: WithFieldValue<T>): Promise<void> {
+    return createWithAccessor(this)(data) as Promise<void>;
+  }
+
   exists(): Promise<boolean> {
     return this.get().then((x) => x.exists());
   }

packages/firebase/src/lib/client/firestore/driver.accessor.transaction.ts

@@ -1,6 +1,7 @@
 import { DocumentReference, DocumentSnapshot, Transaction as FirebaseFirestoreTransaction, UpdateData, WithFieldValue } from '@firebase/firestore';
 import { from, Observable } from 'rxjs';
 import { FirestoreDocumentDataAccessor, FirestoreDocumentDataAccessorFactory, FirestoreDocumentContext, FirestoreDocumentContextType, SetOptions } from '../../common/firestore';
+import { createWithAccessor } from './driver.accessor.create';
 
 // MARK: Accessor
 /**
@@ -13,6 +14,10 @@ export class TransactionFirestoreDocumentDataAccessor<T> implements FirestoreDoc
     return from(this.get());
   }
 
+  create(data: WithFieldValue<T>): Promise<void> {
+    return createWithAccessor(this)(data) as Promise<void>;
+  }
+
   exists(): Promise<boolean> {
     return this.get().then((x) => x.exists());
   }

packages/firebase/src/lib/common/firestore/accessor/accessor.ts

@@ -20,6 +20,10 @@ export interface FirestoreDocumentDataAccessor<T, D = DocumentData> extends Docu
    * Returns a database stream of DocumentSnapshots.
    */
   stream(): Observable<DocumentSnapshot<T>>;
+  /**
+   * Creates a document if it does not exist.
+   */
+  create(data: WithFieldValue<T>): Promise<WriteResult | void>;
   /**
    * Returns the current snapshot.
    */

packages/firebase/src/lib/common/firestore/accessor/accessor.wrap.ts

@@ -19,6 +19,10 @@ export abstract class AbstractFirestoreDocumentDataAccessorWrapper<T, D = Docume
     return this.accessor.stream();
   }
 
+  create(data: WithFieldValue<T>): Promise<WriteResult | void> {
+    return this.accessor.create(data);
+  }
+
   get(): Promise<DocumentSnapshot<T>> {
     return this.accessor.get();
   }

packages/firebase/test/src/lib/common/test.driver.accessor.ts

@@ -349,6 +349,36 @@ export function describeAccessorTests<T>(init: () => DescribeAccessorTests<T>) {
     });
   });
 
+  describe('create()', () => {
+    it('should create the document if it does not exist.', async () => {
+      const data = await c.accessor.get();
+
+      await c.accessor.delete();
+
+      let exists = await c.accessor.exists();
+      expect(exists).toBe(false);
+
+      await c.accessor.create(data);
+
+      exists = await c.accessor.exists();
+      expect(exists).toBe(true);
+    });
+
+    it('should throw an exception if the document exists.', async () => {
+      const data = await c.accessor.get();
+
+      const exists = await c.accessor.exists();
+      expect(exists).toBe(true);
+
+      try {
+        await c.accessor.create(data);
+        fail();
+      } catch (e) {
+        expect(e).toBeDefined();
+      }
+    });
+  });
+
   describe('get()', () => {
     it('should return a snapshot', async () => {
       const result = await c.accessor.get();