NDNts-aux snapshot v1.1 (#10)

* Configurable "snapshot topic" specified
* Expose snapshot config to workspace.create()
* Default snapshot interval changed from 10 to 100.

src/adaptors/yjs-ndn-adaptor.ts

@@ -34,9 +34,9 @@ export class NdnSvsAdaptor {
     public syncAgent: SyncAgent,
     public readonly doc: Y.Doc,
     public readonly topic: string,
-    public readonly snapshotTopic: string = 'snapshot',
-    public readonly snapshotFrequency: number = 10,
     useBundler: boolean = false,
+    public readonly snapshotInterval: number = 100,
+    public readonly snapshotTopic: string = 'snapshot',
   ) {
     syncAgent.register('update', topic, (content) => this.handleSyncUpdate(content));
     syncAgent.register('blob', snapshotTopic, (content) => this.handleSnapshotUpdate(content));
@@ -116,7 +116,7 @@ export class NdnSvsAdaptor {
       count += seq;
     }
 
-    if (count % this.snapshotFrequency == 0) {
+    if (count % this.snapshotInterval == 0) {
       const encodedSV = Encoder.encode(stateVector);
 
       // NOTE: The following code depend on snapshot naming convention to work.
@@ -130,7 +130,7 @@ export class NdnSvsAdaptor {
       const content = Y.encodeStateAsUpdate(this.doc);
       // its already in UInt8Array (binary), transporting currently without any additional encoding.
       // use syncAgent's blob and publish mechanism
-      await this.syncAgent.publishBlob('snapshot', content, snapshotName, true);
+      await this.syncAgent.publishBlob(this.snapshotTopic, content, snapshotName, true);
 
       // NOTE: The following code depend on snapshot naming convention to work.
       // Verify this part if there's a change in naming convention.

src/workspace/workspace.ts

@@ -28,6 +28,7 @@ export class Workspace implements AsyncDisposable {
     createNewDoc?: () => Promise<void>;
     useBundler?: boolean;
     groupKeyBits?: Uint8Array;
+    snapshotInterval?: number;
   }) {
     // Always init a new one, and then load.
     if (opts.createNewDoc) {
@@ -54,6 +55,7 @@ export class Workspace implements AsyncDisposable {
       opts.rootDoc,
       'doc',
       opts.useBundler ?? false,
+      opts.snapshotInterval ?? 100,
     );
     const yjsSnapshotMgr = new YjsStateManager(
       () => encodeSyncState(syncAgent!.getUpdateSyncSV()),