fix: Fix for hypercore 10.6.0 change to update() (#8)

holepunchto/hypercore#347
digidem · Jul 6, 2023 · 0152d4b · 0152d4b
1 parent 9579359
commit 0152d4b
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/lib/core-index-stream.js b/lib/core-index-stream.js
@@ -107,7 +107,7 @@ class CoreIndexStream extends Readable {
     this.#state = 'indexing'
     this.emit('indexing')
     this.#bitfield = await Bitfield.open(this.#storage)
-    await this.#core.update()
+    await this.#core.update({ wait: true })
     this.#core.on('append', this[kHandleAppend])
     this.#core.on('download', this[kHandleDownload])
   }

diff --git a/test/multi-core-indexer.test.js b/test/multi-core-indexer.test.js
@@ -125,7 +125,7 @@ test('Appends from a replicated core are indexed', async (t) => {
   for (const [i, core] of localCores.entries()) {
     const remote = (remoteCores[i] = await create(core.key))
     replicate(core, remoteCores[i], t)
-    await remote.update()
+    await remote.update({ wait: true })
     await remote.download({ start: 0, end: remote.length }).downloaded()
   }
   /** @type {Entry[]} */

diff --git a/test/unit-tests/core-index-stream.test.js b/test/unit-tests/core-index-stream.test.js
@@ -126,7 +126,7 @@ test('Appends from a replicated core are indexed', async (t) => {
   const b = await create(a.key)
 
   replicate(a, b, t)
-  await b.update()
+  await b.update({ wait: true })
   const range1 = b.download({ start: 0, end: b.length })
   await range1.downloaded()
 

diff --git a/test/unit-tests/multi-core-index-stream.test.js b/test/unit-tests/multi-core-index-stream.test.js
@@ -157,7 +157,7 @@ test('Appends from a replicated core are indexed', async (t) => {
   for (const [i, core] of localCores.entries()) {
     const remote = (remoteCores[i] = await create(core.key))
     replicate(core, remoteCores[i], t)
-    await remote.update()
+    await remote.update({ wait: true })
     const range = remote.download({ start: 0, end: remote.length })
     await range.downloaded()
     indexStreams.push(new CoreIndexStream(core, ram()))