feat: add modifications to publish event

wnfs-wg · Dec 21, 2023 · d6b654c · d6b654c
1 parent d8ec1b5
commit d6b654c
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 9 deletions.
diff --git a/packages/nest/src/class.ts b/packages/nest/src/class.ts
@@ -64,7 +64,10 @@ export interface FileSystemOptions {
 /** @group 🪺 :: START HERE */
 export class FileSystem {
   readonly #blockstore: Blockstore
-  readonly #debouncedDataRootUpdate: (...dataRoots: CID[]) => Promise<void>
+  readonly #debouncedDataRootUpdate: (
+    ...args: Array<{ dataRoot: CID; modifications: Modification[] }>
+  ) => Promise<void>
+
   readonly #eventEmitter: Emittery<Events>
   readonly #onCommit: CommitVerifier
   readonly #rng: Rng.Rng
@@ -86,10 +89,13 @@ export class FileSystem {
     this.#rootTree = rootTree
 
     this.#debouncedDataRootUpdate = debounce(
-      async (...dataRoots: CID[]): Promise<void> => {
-        const dataRoot = dataRoots.at(-1)
+      async (
+        ...args: Array<{ dataRoot: CID; modifications: Modification[] }>
+      ): Promise<void> => {
+        const modifications = args.flatMap((a) => a.modifications)
+        const dataRoot = args.at(-1)?.dataRoot
         if (dataRoot !== undefined) {
-          await this.#eventEmitter.emit('publish', { dataRoot })
+          await this.#eventEmitter.emit('publish', { dataRoot, modifications })
         }
       },
       settleTimeBeforePublish
@@ -664,13 +670,13 @@ export class FileSystem {
       mutationOptions.skipPublish === false ||
       mutationOptions.skipPublish === undefined
     ) {
-      await this.#publish(dataRoot)
+      await this.#publish(dataRoot, modifications)
     }
 
     // Fin
     return {
-      modifications,
       dataRoot,
+      modifications,
     }
   }
 
@@ -796,8 +802,8 @@ export class FileSystem {
 
   // ㊙️  ▒▒  PUBLISHING
 
-  async #publish(dataRoot: CID): Promise<void> {
+  async #publish(dataRoot: CID, modifications: Modification[]): Promise<void> {
     // eslint-disable-next-line @typescript-eslint/no-floating-promises
-    this.#debouncedDataRootUpdate(dataRoot)
+    this.#debouncedDataRootUpdate({ dataRoot, modifications })
   }
 }
diff --git a/packages/nest/src/events.ts b/packages/nest/src/events.ts
@@ -9,7 +9,10 @@ export type Events = {
     dataRoot: CID
     modifications: Modification[]
   }
-  publish: { dataRoot: CID }
+  publish: {
+    dataRoot: CID
+    modifications: Modification[]
+  }
 }
 
 export type Listener<