Remove findingPeers() & some flush() flow from hyperswarm examples (#176)

`swarm.flush()` was kept in scenarios where replicating a hypercore
immediately was required.
This commit is contained in:
Sean Zellmer
2025-04-10 12:15:57 -05:00
committed by GitHub
parent 0d7fbfe0c3
commit 6cd081e49e
4 changed files with 4 additions and 16 deletions

View File

@@ -128,11 +128,8 @@ const mirror = debounce(mirrorDrive)
// to the Hypercore instance of the hyperdrive
drive.core.on('append', mirror)
const foundPeers = store.findingPeers()
// join a topic
swarm.join(drive.discoveryKey, { client: true, server: false })
swarm.flush().then(() => foundPeers())
// start the mirroring process (i.e copying the contents from remote drive to local dir)
mirror()
@@ -198,9 +195,8 @@ const bee = new Hyperbee(core, {
// wait till the properties of the hypercore instance are initialized
await core.ready()
const foundPeers = store.findingPeers()
swarm.join(core.discoveryKey)
swarm.flush().then(() => foundPeers())
await swarm.flush()
// execute the listBee function whenever the data is appended to the underlying hypercore
core.on('append', listBee)

View File

@@ -78,18 +78,12 @@ Pear.teardown(() => swarm.destroy())
const core = new Hypercore(path.join(Pear.config.storage, 'reader-storage'), Pear.config.args[0])
await core.ready()
const foundPeers = core.findingPeers()
swarm.join(core.discoveryKey)
swarm.on('connection', conn => core.replicate(conn))
// swarm.flush() will wait until *all* discoverable peers have been connected to
// It might take a while, so don't await it
// Instead, use core.findingPeers() to mark when the discovery process is completed
swarm.flush().then(() => foundPeers())
await swarm.flush()
// This won't resolve until either
// a) the first peer is found
// or b) no peers could be found
await core.update()
let position = core.length

View File

@@ -192,10 +192,9 @@ const core = store.get({ key: b4a.from(key, 'hex') })
// wait till the properties of the hypercore instance are initialized
await core.ready()
const foundPeers = store.findingPeers()
// join a topic
swarm.join(core.discoveryKey)
swarm.flush().then(() => foundPeers())
await swarm.flush()
// update the meta-data information of the hypercore instance
await core.update()

View File

@@ -100,9 +100,8 @@ const core = store.get({ key, valueEncoding: 'json' })
// wait till all the properties of the hypercore instance are initialized
await core.ready()
const foundPeers = core.findingPeers()
swarm.join(core.discoveryKey)
swarm.flush().then(() => foundPeers())
await swarm.flush()
// update the meta-data of the hypercore instance
await core.update()