Convert blockFilter to use bytes

Co-authored-by: Alex Potsides <[email protected]>
ipfs · Jul 26, 2024 · 55af4eb · 55af4eb
1 parent e5fdaf2
commit 55af4eb
Showing 1 changed file with 5 additions and 7 deletions.
diff --git a/packages/car/src/index.ts b/packages/car/src/index.ts
@@ -197,14 +197,12 @@ class DefaultCar implements Car {
     for (const root of roots) {
       void queue.add(async () => {
         await this.#walkDag(root, queue, async (cid, bytes) => {
-          // check if duplicate blocks should be skipped
-          if (options?.blockFilter != null) {
-            // skip blocks that have already been written
-            if (options.blockFilter.has(cid.toString())) {
-              return
-            }
-            options.blockFilter.add(cid.toString())
+          // if a filter has been passed, skip blocks that have already been written
+          if (options?.blockFilter?.has(cid.multihash.bytes) === true) {
+            return
           }
+
+          options?.blockFilter?.add(cid.multihash.bytes)
           await writer.put({ cid, bytes })
         }, options)
       })