Merge pull request #7 from podraven/2.1.1

Updated dist files for docMapper update

dist/provider.d.ts

@@ -1,6 +1,6 @@
 /// <reference types="node" />
 import { FirebaseApp } from "@firebase/app";
-import { Firestore } from "@firebase/firestore";
+import { Firestore, Bytes } from "@firebase/firestore";
 import * as Y from "yjs";
 import { ObservableV2 } from "lib0/observable";
 import * as awarenessProtocol from "y-protocols/awareness";
@@ -9,6 +9,7 @@ export interface Parameters {
     firebaseApp: FirebaseApp;
     ydoc: Y.Doc;
     path: string;
+    docMapper?: (bytes: Bytes) => object;
     maxUpdatesThreshold?: number;
     maxWaitTime?: number;
     maxWaitFirestoreTime?: number;
@@ -43,6 +44,7 @@ export declare class FireProvider extends ObservableV2<any> {
     peersReceivers: Set<string>;
     peersSenders: Set<string>;
     peersRTC: PeersRTC;
+    documentMapper: (bytes: Bytes) => object;
     cache: Uint8Array | null;
     maxCacheUpdates: number;
     cacheUpdateCount: number;
@@ -91,7 +93,7 @@ export declare class FireProvider extends ObservableV2<any> {
     consoleHandler: (message: any, data?: any) => void;
     destroy: () => void;
     kill: (keepReadOnly?: boolean) => void;
-    constructor({ firebaseApp, ydoc, path, maxUpdatesThreshold, maxWaitTime, maxWaitFirestoreTime, }: Parameters);
+    constructor({ firebaseApp, ydoc, path, docMapper, maxUpdatesThreshold, maxWaitTime, maxWaitFirestoreTime, }: Parameters);
 }
 export {};
 //# sourceMappingURL=provider.d.ts.map

dist/provider.js

@@ -30,7 +30,7 @@ export class FireProvider extends ObservableV2 {
     get clientTimeOffset() {
         return this.timeOffset;
     }
-    constructor({ firebaseApp, ydoc, path, maxUpdatesThreshold, maxWaitTime, maxWaitFirestoreTime, }) {
+    constructor({ firebaseApp, ydoc, path, docMapper, maxUpdatesThreshold, maxWaitTime, maxWaitFirestoreTime, }) {
         super();
         this.timeOffset = 0; // offset to server time in mili seconds
         this.clients = [];
@@ -40,6 +40,7 @@ export class FireProvider extends ObservableV2 {
             receivers: {},
             senders: {},
         };
+        this.documentMapper = (bytes) => ({ content: bytes });
         this.maxCacheUpdates = 20;
         this.cacheUpdateCount = 0;
         this.maxRTCWait = 100;
@@ -237,7 +238,7 @@ export class FireProvider extends ObservableV2 {
             try {
                 // current document to firestore
                 const ref = doc(this.db, this.documentPath);
-                yield setDoc(ref, { content: Bytes.fromUint8Array(Y.encodeStateAsUpdate(this.doc)) }, { merge: true });
+                yield setDoc(ref, this.documentMapper(Bytes.fromUint8Array(Y.encodeStateAsUpdate(this.doc))), { merge: true });
                 this.deleteLocal(); // We have successfully saved to Firestore, empty indexedDb for now
             }
             catch (error) {
@@ -382,6 +383,8 @@ export class FireProvider extends ObservableV2 {
         this.db = getFirestore(this.firebaseApp);
         this.doc = ydoc;
         this.documentPath = path;
+        if (docMapper)
+            this.documentMapper = docMapper;
         if (maxUpdatesThreshold)
             this.maxCacheUpdates = maxUpdatesThreshold;
         if (maxWaitTime)

package.json

@@ -1,6 +1,6 @@
 {
   "name": "y-fire",
-  "version": "2.1.0",
+  "version": "2.1.1",
   "description": "A firebase (firestore) provider for Yjs",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",