diff --git a/core/bootstrap/bootstrap.go b/core/bootstrap/bootstrap.go
deleted file mode 100644
index 5cde5037193b04fb0b1c86bf062b1c46bc5b4007..0000000000000000000000000000000000000000
--- a/core/bootstrap/bootstrap.go
+++ /dev/null
@@ -1,371 +0,0 @@
-package bootstrap
-
-import (
- "context"
- "errors"
- "io"
- "math/rand"
- "sync"
- "sync/atomic"
- "time"
-
- logging "github.com/ipfs/go-log"
- "github.com/jbenet/goprocess"
- goprocessctx "github.com/jbenet/goprocess/context"
- periodicproc "github.com/jbenet/goprocess/periodic"
- "github.com/libp2p/go-libp2p/core/host"
- "github.com/libp2p/go-libp2p/core/network"
- "github.com/libp2p/go-libp2p/core/peer"
- "github.com/libp2p/go-libp2p/core/peerstore"
- "github.com/libp2p/go-libp2p/core/routing"
-)
-
-var log = logging.Logger("bootstrap")
-
-// ErrNotEnoughBootstrapPeers signals that we do not have enough bootstrap
-// peers to bootstrap correctly.
-var ErrNotEnoughBootstrapPeers = errors.New("not enough bootstrap peers to bootstrap")
-
-// BootstrapConfig specifies parameters used in an IpfsNode's network
-// bootstrapping process.
-type BootstrapConfig struct {
- // MinPeerThreshold governs whether to bootstrap more connections. If the
- // node has less open connections than this number, it will open connections
- // to the bootstrap nodes. From there, the routing system should be able
- // to use the connections to the bootstrap nodes to connect to even more
- // peers. Routing systems like the IpfsDHT do so in their own Bootstrap
- // process, which issues random queries to find more peers.
- MinPeerThreshold int
-
- // Period governs the periodic interval at which the node will
- // attempt to bootstrap. The bootstrap process is not very expensive, so
- // this threshold can afford to be small (<=30s).
- Period time.Duration
-
- // ConnectionTimeout determines how long to wait for a bootstrap
- // connection attempt before cancelling it.
- ConnectionTimeout time.Duration
-
- // BootstrapPeers is a function that returns a set of bootstrap peers
- // for the bootstrap process to use. This makes it possible for clients
- // to control the peers the process uses at any moment.
- BootstrapPeers func() []peer.AddrInfo
-
- // BackupBootstrapInterval governs the periodic interval at which the node will
- // attempt to save connected nodes to use as temporary bootstrap peers.
- BackupBootstrapInterval time.Duration
-
- // MaxBackupBootstrapSize controls the maximum number of peers we're saving
- // as backup bootstrap peers.
- MaxBackupBootstrapSize int
-
- saveBackupBootstrapPeers func(context.Context, []peer.AddrInfo)
- loadBackupBootstrapPeers func(context.Context) []peer.AddrInfo
-}
-
-// DefaultBootstrapConfig specifies default sane parameters for bootstrapping.
-var DefaultBootstrapConfig = BootstrapConfig{
- MinPeerThreshold: 4,
- Period: 30 * time.Second,
- ConnectionTimeout: (30 * time.Second) / 3, // Perod / 3
- BackupBootstrapInterval: 1 * time.Hour,
- MaxBackupBootstrapSize: 20,
-}
-
-// BootstrapConfigWithPeers creates a default BootstrapConfig configured with
-// the specified peers, and optional functions to load and save backup peers.
-func BootstrapConfigWithPeers(pis []peer.AddrInfo, options ...func(*BootstrapConfig)) BootstrapConfig {
- cfg := DefaultBootstrapConfig
- cfg.BootstrapPeers = func() []peer.AddrInfo {
- return pis
- }
- for _, opt := range options {
- opt(&cfg)
- }
- return cfg
-}
-
-// WithBackupPeers configures functions to load and save backup bootstrap peers.
-func WithBackupPeers(load func(context.Context) []peer.AddrInfo, save func(context.Context, []peer.AddrInfo)) func(*BootstrapConfig) {
- if save == nil && load != nil || save != nil && load == nil {
- panic("both load and save backup bootstrap peers functions must be defined")
- }
- return func(cfg *BootstrapConfig) {
- cfg.loadBackupBootstrapPeers = load
- cfg.saveBackupBootstrapPeers = save
- }
-}
-
-// BackupPeers returns the load and save backup peers functions.
-func (cfg *BootstrapConfig) BackupPeers() (func(context.Context) []peer.AddrInfo, func(context.Context, []peer.AddrInfo)) {
- return cfg.loadBackupBootstrapPeers, cfg.saveBackupBootstrapPeers
-}
-
-// SetBackupPeers sets the load and save backup peers functions.
-func (cfg *BootstrapConfig) SetBackupPeers(load func(context.Context) []peer.AddrInfo, save func(context.Context, []peer.AddrInfo)) {
- opt := WithBackupPeers(load, save)
- opt(cfg)
-}
-
-// Bootstrap kicks off IpfsNode bootstrapping. This function will periodically
-// check the number of open connections and -- if there are too few -- initiate
-// connections to well-known bootstrap peers. It also kicks off subsystem
-// bootstrapping (i.e. routing).
-func Bootstrap(id peer.ID, host host.Host, rt routing.Routing, cfg BootstrapConfig) (io.Closer, error) {
- // make a signal to wait for one bootstrap round to complete.
- doneWithRound := make(chan struct{})
-
- if len(cfg.BootstrapPeers()) == 0 {
- // We *need* to bootstrap but we have no bootstrap peers
- // configured *at all*, inform the user.
- log.Warn("no bootstrap nodes configured: go-ipfs may have difficulty connecting to the network")
- }
-
- // the periodic bootstrap function -- the connection supervisor
- periodic := func(worker goprocess.Process) {
- ctx := goprocessctx.OnClosingContext(worker)
-
- if err := bootstrapRound(ctx, host, cfg); err != nil {
- log.Debugf("%s bootstrap error: %s", id, err)
- }
-
- // Exit the first call (triggered independently by `proc.Go`, not `Tick`)
- // only after being done with the *single* Routing.Bootstrap call. Following
- // periodic calls (`Tick`) will not block on this.
- <-doneWithRound
- }
-
- // kick off the node's periodic bootstrapping
- proc := periodicproc.Tick(cfg.Period, periodic)
- proc.Go(periodic) // run one right now.
-
- // kick off Routing.Bootstrap
- if rt != nil {
- ctx := goprocessctx.OnClosingContext(proc)
- if err := rt.Bootstrap(ctx); err != nil {
- proc.Close()
- return nil, err
- }
- }
-
- doneWithRound <- struct{}{}
- close(doneWithRound) // it no longer blocks periodic
-
- // If loadBackupBootstrapPeers is not nil then saveBackupBootstrapPeers
- // must also not be nil.
- if cfg.loadBackupBootstrapPeers != nil {
- startSavePeersAsTemporaryBootstrapProc(cfg, host, proc)
- }
-
- return proc, nil
-}
-
-// Aside of the main bootstrap process we also run a secondary one that saves
-// connected peers as a backup measure if we can't connect to the official
-// bootstrap ones. These peers will serve as *temporary* bootstrap nodes.
-func startSavePeersAsTemporaryBootstrapProc(cfg BootstrapConfig, host host.Host, bootstrapProc goprocess.Process) {
- savePeersFn := func(worker goprocess.Process) {
- ctx := goprocessctx.OnClosingContext(worker)
-
- if err := saveConnectedPeersAsTemporaryBootstrap(ctx, host, cfg); err != nil {
- log.Debugf("saveConnectedPeersAsTemporaryBootstrap error: %s", err)
- }
- }
- savePeersProc := periodicproc.Tick(cfg.BackupBootstrapInterval, savePeersFn)
-
- // When the main bootstrap process ends also terminate the 'save connected
- // peers' ones. Coupling the two seems the easiest way to handle this backup
- // process without additional complexity.
- go func() {
- <-bootstrapProc.Closing()
- savePeersProc.Close()
- }()
-
- // Run the first round now (after the first bootstrap process has finished)
- // as the SavePeersPeriod can be much longer than bootstrap.
- savePeersProc.Go(savePeersFn)
-}
-
-func saveConnectedPeersAsTemporaryBootstrap(ctx context.Context, host host.Host, cfg BootstrapConfig) error {
- // Randomize the list of connected peers, we don't prioritize anyone.
- connectedPeers := randomizeList(host.Network().Peers())
-
- bootstrapPeers := cfg.BootstrapPeers()
- backupPeers := make([]peer.AddrInfo, 0, cfg.MaxBackupBootstrapSize)
- foundPeers := make(map[peer.ID]struct{}, cfg.MaxBackupBootstrapSize+len(bootstrapPeers))
-
- // Don't record bootstrap peers
- for _, b := range bootstrapPeers {
- foundPeers[b.ID] = struct{}{}
- }
-
- // Choose peers to save and filter out the ones that are already bootstrap nodes.
- for _, p := range connectedPeers {
- if _, found := foundPeers[p]; found {
- continue
- }
- foundPeers[p] = struct{}{}
-
- backupPeers = append(backupPeers, peer.AddrInfo{
- ID: p,
- Addrs: host.Network().Peerstore().Addrs(p),
- })
-
- if len(backupPeers) >= cfg.MaxBackupBootstrapSize {
- break
- }
- }
-
- // If we didn't reach the target number use previously stored connected peers.
- if len(backupPeers) < cfg.MaxBackupBootstrapSize {
- oldSavedPeers := cfg.loadBackupBootstrapPeers(ctx)
- log.Debugf("missing %d peers to reach backup bootstrap target of %d, trying from previous list of %d saved peers",
- cfg.MaxBackupBootstrapSize-len(backupPeers), cfg.MaxBackupBootstrapSize, len(oldSavedPeers))
-
- // Add some of the old saved peers. Ensure we don't duplicate them.
- for _, p := range oldSavedPeers {
- if _, found := foundPeers[p.ID]; found {
- continue
- }
- foundPeers[p.ID] = struct{}{}
-
- backupPeers = append(backupPeers, p)
-
- if len(backupPeers) >= cfg.MaxBackupBootstrapSize {
- break
- }
- }
- }
-
- cfg.saveBackupBootstrapPeers(ctx, backupPeers)
- log.Debugf("saved %d peers (of %d target) as bootstrap backup in the config", len(backupPeers), cfg.MaxBackupBootstrapSize)
- return nil
-}
-
-// Connect to as many peers needed to reach the BootstrapConfig.MinPeerThreshold.
-// Peers can be original bootstrap or temporary ones (drawn from a list of
-// persisted previously connected peers).
-func bootstrapRound(ctx context.Context, host host.Host, cfg BootstrapConfig) error {
- ctx, cancel := context.WithTimeout(ctx, cfg.ConnectionTimeout)
- defer cancel()
- id := host.ID()
-
- // get bootstrap peers from config. retrieving them here makes
- // sure we remain observant of changes to client configuration.
- peers := cfg.BootstrapPeers()
- // determine how many bootstrap connections to open
- connected := host.Network().Peers()
- if len(connected) >= cfg.MinPeerThreshold {
- log.Debugf("%s core bootstrap skipped -- connected to %d (> %d) nodes",
- id, len(connected), cfg.MinPeerThreshold)
- return nil
- }
- numToDial := cfg.MinPeerThreshold - len(connected) // numToDial > 0
-
- if len(peers) > 0 {
- numToDial -= int(peersConnect(ctx, host, peers, numToDial, true))
- if numToDial <= 0 {
- return nil
- }
- }
-
- if cfg.loadBackupBootstrapPeers == nil {
- log.Debugf("not enough bootstrap peers to fill the remaining target of %d connections", numToDial)
- return ErrNotEnoughBootstrapPeers
- }
-
- log.Debugf("not enough bootstrap peers to fill the remaining target of %d connections, trying backup list", numToDial)
-
- tempBootstrapPeers := cfg.loadBackupBootstrapPeers(ctx)
- if len(tempBootstrapPeers) > 0 {
- numToDial -= int(peersConnect(ctx, host, tempBootstrapPeers, numToDial, false))
- if numToDial <= 0 {
- return nil
- }
- }
-
- log.Debugf("tried both original bootstrap peers and temporary ones but still missing target of %d connections", numToDial)
-
- return ErrNotEnoughBootstrapPeers
-}
-
-// Attempt to make `needed` connections from the `availablePeers` list. Mark
-// peers as either `permanent` or temporary when adding them to the Peerstore.
-// Return the number of connections completed. We eagerly over-connect in parallel,
-// so we might connect to more than needed.
-// (We spawn as many routines and attempt connections as the number of availablePeers,
-// but this list comes from restricted sets of original or temporary bootstrap
-// nodes which will keep it under a sane value.)
-func peersConnect(ctx context.Context, ph host.Host, availablePeers []peer.AddrInfo, needed int, permanent bool) uint64 {
- peers := randomizeList(availablePeers)
-
- // Monitor the number of connections and stop if we reach the target.
- var connected uint64
- ctx, cancel := context.WithCancel(ctx)
- defer cancel()
- go func() {
- for {
- select {
- case <-ctx.Done():
- return
- case <-time.After(1 * time.Second):
- if int(atomic.LoadUint64(&connected)) >= needed {
- cancel()
- return
- }
- }
- }
- }()
-
- var wg sync.WaitGroup
- for _, p := range peers {
-
- // performed asynchronously because when performed synchronously, if
- // one `Connect` call hangs, subsequent calls are more likely to
- // fail/abort due to an expiring context.
- // Also, performed asynchronously for dial speed.
-
- if int(atomic.LoadUint64(&connected)) >= needed {
- cancel()
- break
- }
-
- wg.Add(1)
- go func(p peer.AddrInfo) {
- defer wg.Done()
-
- // Skip addresses belonging to a peer we're already connected to.
- // (Not a guarantee but a best-effort policy.)
- if ph.Network().Connectedness(p.ID) == network.Connected {
- return
- }
- log.Debugf("%s bootstrapping to %s", ph.ID(), p.ID)
-
- if err := ph.Connect(ctx, p); err != nil {
- if ctx.Err() != context.Canceled {
- log.Debugf("failed to bootstrap with %v: %s", p.ID, err)
- }
- return
- }
- if permanent {
- // We're connecting to an original bootstrap peer, mark it as
- // a permanent address (Connect will register it as TempAddrTTL).
- ph.Peerstore().AddAddrs(p.ID, p.Addrs, peerstore.PermanentAddrTTL)
- }
-
- log.Infof("bootstrapped with %v", p.ID)
- atomic.AddUint64(&connected, 1)
- }(p)
- }
- wg.Wait()
-
- return connected
-}
-
-func randomizeList[T any](in []T) []T {
- out := make([]T, len(in))
- for i, val := range rand.Perm(len(in)) {
- out[i] = in[val]
- }
- return out
-}
diff --git a/core/bootstrap/bootstrap_test.go b/core/bootstrap/bootstrap_test.go
deleted file mode 100644
index d933379d4e970b5c38d37c9e03c9fb94b164f798..0000000000000000000000000000000000000000
--- a/core/bootstrap/bootstrap_test.go
+++ /dev/null
@@ -1,139 +0,0 @@
-package bootstrap
-
-import (
- "context"
- "crypto/rand"
- "reflect"
- "testing"
- "time"
-
- "github.com/libp2p/go-libp2p"
- "github.com/libp2p/go-libp2p/core/crypto"
- "github.com/libp2p/go-libp2p/core/peer"
- "github.com/libp2p/go-libp2p/core/test"
-)
-
-func TestRandomizeAddressList(t *testing.T) {
- var ps []peer.AddrInfo
- sizeofSlice := 10
- for i := 0; i < sizeofSlice; i++ {
- pid, err := test.RandPeerID()
- if err != nil {
- t.Fatal(err)
- }
-
- ps = append(ps, peer.AddrInfo{ID: pid})
- }
- out := randomizeList(ps)
- if len(out) != len(ps) {
- t.Fail()
- }
-}
-
-func TestLoadAndSaveOptions(t *testing.T) {
- loadFunc := func(_ context.Context) []peer.AddrInfo { return nil }
- saveFunc := func(_ context.Context, _ []peer.AddrInfo) {}
-
- bootCfg := BootstrapConfigWithPeers(nil, WithBackupPeers(loadFunc, saveFunc))
- load, save := bootCfg.BackupPeers()
- if load == nil {
- t.Fatal("load function not assigned")
- }
- if reflect.ValueOf(load).Pointer() != reflect.ValueOf(loadFunc).Pointer() {
- t.Fatal("load not assigned correct function")
- }
- if save == nil {
- t.Fatal("save function not assigned")
- }
- if reflect.ValueOf(save).Pointer() != reflect.ValueOf(saveFunc).Pointer() {
- t.Fatal("save not assigned correct function")
- }
-
- assertPanics(t, "with only load func", func() {
- BootstrapConfigWithPeers(nil, WithBackupPeers(loadFunc, nil))
- })
-
- assertPanics(t, "with only save func", func() {
- BootstrapConfigWithPeers(nil, WithBackupPeers(nil, saveFunc))
- })
-
- bootCfg = BootstrapConfigWithPeers(nil, WithBackupPeers(nil, nil))
- load, save = bootCfg.BackupPeers()
- if load != nil || save != nil {
- t.Fatal("load and save functions should both be nil")
- }
-}
-
-func TestSetBackupPeers(t *testing.T) {
- loadFunc := func(_ context.Context) []peer.AddrInfo { return nil }
- saveFunc := func(_ context.Context, _ []peer.AddrInfo) {}
-
- bootCfg := DefaultBootstrapConfig
- bootCfg.SetBackupPeers(loadFunc, saveFunc)
- load, save := bootCfg.BackupPeers()
- if load == nil {
- t.Fatal("load function not assigned")
- }
- if reflect.ValueOf(load).Pointer() != reflect.ValueOf(loadFunc).Pointer() {
- t.Fatal("load not assigned correct function")
- }
- if save == nil {
- t.Fatal("save function not assigned")
- }
- if reflect.ValueOf(save).Pointer() != reflect.ValueOf(saveFunc).Pointer() {
- t.Fatal("save not assigned correct function")
- }
-
- assertPanics(t, "with only load func", func() {
- bootCfg.SetBackupPeers(loadFunc, nil)
- })
-
- assertPanics(t, "with only save func", func() {
- bootCfg.SetBackupPeers(nil, saveFunc)
- })
-
- bootCfg.SetBackupPeers(nil, nil)
- load, save = bootCfg.BackupPeers()
- if load != nil || save != nil {
- t.Fatal("load and save functions should both be nil")
- }
-}
-
-func TestNoTempPeersLoadAndSave(t *testing.T) {
- period := 500 * time.Millisecond
- bootCfg := BootstrapConfigWithPeers(nil)
- bootCfg.MinPeerThreshold = 2
- bootCfg.Period = period
-
- priv, pub, err := crypto.GenerateEd25519Key(rand.Reader)
- if err != nil {
- t.Fatal(err)
- }
- peerID, err := peer.IDFromPublicKey(pub)
- if err != nil {
- t.Fatal(err)
- }
- p2pHost, err := libp2p.New(libp2p.Identity(priv))
- if err != nil {
- t.Fatal(err)
- }
-
- bootstrapper, err := Bootstrap(peerID, p2pHost, nil, bootCfg)
- if err != nil {
- t.Fatal(err)
- }
-
- time.Sleep(4 * period)
- bootstrapper.Close()
-
-}
-
-func assertPanics(t *testing.T, name string, f func()) {
- defer func() {
- if r := recover(); r == nil {
- t.Errorf("%s: did not panic as expected", name)
- }
- }()
-
- f()
-}
diff --git a/core/builder.go b/core/builder.go
index 7a1d6fef22788ccc50a91960273c0e8b1bd48fea..4c54ddf8c5e75751b5aad6ce83ce8d70bd9fa4c5 100644
--- a/core/builder.go
+++ b/core/builder.go
@@ -7,7 +7,7 @@ import (
"sync"
"time"
- "github.com/ipfs/kubo/core/bootstrap"
+ "github.com/ipfs/boxo/bootstrap"
"github.com/ipfs/kubo/core/node"
"github.com/ipfs/go-metrics-interface"
diff --git a/core/core.go b/core/core.go
index 53c97c2219a6fdb438ecbc8201ec7e2683d8f674..40c6808596d1953c1d9011b4371cbf280afa9f00 100644
--- a/core/core.go
+++ b/core/core.go
@@ -47,11 +47,11 @@ import (
ma "github.com/multiformats/go-multiaddr"
madns "github.com/multiformats/go-multiaddr-dns"
+ "github.com/ipfs/boxo/bootstrap"
"github.com/ipfs/boxo/namesys"
ipnsrp "github.com/ipfs/boxo/namesys/republisher"
"github.com/ipfs/boxo/peering"
"github.com/ipfs/kubo/config"
- "github.com/ipfs/kubo/core/bootstrap"
"github.com/ipfs/kubo/core/node"
"github.com/ipfs/kubo/core/node/libp2p"
"github.com/ipfs/kubo/fuse/mount"
diff --git a/core/coreapi/test/api_test.go b/core/coreapi/test/api_test.go
index 3ae74b97e9a9a2be29facd3739ead5c9e4d87496..d9591f835220eea55cdd938f5600771babf4969b 100644
--- a/core/coreapi/test/api_test.go
+++ b/core/coreapi/test/api_test.go
@@ -8,10 +8,10 @@ import (
"path/filepath"
"testing"
+ "github.com/ipfs/boxo/bootstrap"
"github.com/ipfs/boxo/filestore"
keystore "github.com/ipfs/boxo/keystore"
"github.com/ipfs/kubo/core"
- "github.com/ipfs/kubo/core/bootstrap"
"github.com/ipfs/kubo/core/coreapi"
mock "github.com/ipfs/kubo/core/mock"
"github.com/ipfs/kubo/core/node/libp2p"
diff --git a/docs/examples/kubo-as-a-library/go.mod b/docs/examples/kubo-as-a-library/go.mod
index a2e7ec6a86163fd569bd69b871924bfdf5c08906..142f342f99a1fc7b64017d3909fb9232449152a6 100644
--- a/docs/examples/kubo-as-a-library/go.mod
+++ b/docs/examples/kubo-as-a-library/go.mod
@@ -7,7 +7,7 @@ go 1.20
replace github.com/ipfs/kubo => ./../../..
require (
- github.com/ipfs/boxo v0.13.2-0.20231031104528-b0a265b5cdcc
+ github.com/ipfs/boxo v0.13.2-0.20231031170949-08b11e5df06e
github.com/ipfs/kubo v0.0.0-00010101000000-000000000000
github.com/libp2p/go-libp2p v0.31.0
github.com/multiformats/go-multiaddr v0.11.0
diff --git a/docs/examples/kubo-as-a-library/go.sum b/docs/examples/kubo-as-a-library/go.sum
index eb14a99fd5bf45f2b0b7b497c6f87a84f0f6c140..b450881748d073428fe4657f0896caf02a97ff72 100644
--- a/docs/examples/kubo-as-a-library/go.sum
+++ b/docs/examples/kubo-as-a-library/go.sum
@@ -305,8 +305,8 @@ github.com/ipfs-shipyard/nopfs/ipfs v0.13.2-0.20231027223058-cde3b5ba964c h1:7Uy
github.com/ipfs-shipyard/nopfs/ipfs v0.13.2-0.20231027223058-cde3b5ba964c/go.mod h1:6EekK/jo+TynwSE/ZOiOJd4eEvRXoavEC3vquKtv4yI=
github.com/ipfs/bbloom v0.0.4 h1:Gi+8EGJ2y5qiD5FbsbpX/TMNcJw8gSqr7eyjHa4Fhvs=
github.com/ipfs/bbloom v0.0.4/go.mod h1:cS9YprKXpoZ9lT0n/Mw/a6/aFV6DTjTLYHeA+gyqMG0=
-github.com/ipfs/boxo v0.13.2-0.20231031104528-b0a265b5cdcc h1:jKrgzSr4RC04aG2LX8lA0emMOxSrckORZE4GKRZUt0Y=
-github.com/ipfs/boxo v0.13.2-0.20231031104528-b0a265b5cdcc/go.mod h1:pu8HsZvuyYeYJsqtLDCoYSvy8rHj6vI3dlh8P0f83Zs=
+github.com/ipfs/boxo v0.13.2-0.20231031170949-08b11e5df06e h1:+A0lJ8vc6YtiMiq3UodN0BgZJTso/VJDrECdyHpsFDY=
+github.com/ipfs/boxo v0.13.2-0.20231031170949-08b11e5df06e/go.mod h1:pu8HsZvuyYeYJsqtLDCoYSvy8rHj6vI3dlh8P0f83Zs=
github.com/ipfs/go-bitfield v1.1.0 h1:fh7FIo8bSwaJEh6DdTWbCeZ1eqOaOkKFI74SCnsWbGA=
github.com/ipfs/go-bitfield v1.1.0/go.mod h1:paqf1wjq/D2BBmzfTVFlJQ9IlFOZpg422HL0HqsGWHU=
github.com/ipfs/go-block-format v0.0.2/go.mod h1:AWR46JfpcObNfg3ok2JHDUfdiHRgWhJgCQF+KIgOPJY=
diff --git a/go.mod b/go.mod
index 8970cf2bed2b91623f8ae21a50b8a0b6f805ae9d..50555089b81e706f0a5c66a81bd248bf5d0b3d93 100644
--- a/go.mod
+++ b/go.mod
@@ -17,7 +17,7 @@ require (
github.com/hashicorp/go-multierror v1.1.1
github.com/ipfs-shipyard/nopfs v0.0.12-0.20231027223058-cde3b5ba964c
github.com/ipfs-shipyard/nopfs/ipfs v0.13.2-0.20231027223058-cde3b5ba964c
- github.com/ipfs/boxo v0.13.2-0.20231031104528-b0a265b5cdcc
+ github.com/ipfs/boxo v0.13.2-0.20231031170949-08b11e5df06e
github.com/ipfs/go-block-format v0.2.0
github.com/ipfs/go-cid v0.4.1
github.com/ipfs/go-cidutil v0.1.0
diff --git a/go.sum b/go.sum
index aad5e515012693d33256aac3b8d68aee08c450ab..e83c67de2bdc728a735219dc7f6c905fd7a7c015 100644
--- a/go.sum
+++ b/go.sum
@@ -339,8 +339,8 @@ github.com/ipfs-shipyard/nopfs/ipfs v0.13.2-0.20231027223058-cde3b5ba964c h1:7Uy
github.com/ipfs-shipyard/nopfs/ipfs v0.13.2-0.20231027223058-cde3b5ba964c/go.mod h1:6EekK/jo+TynwSE/ZOiOJd4eEvRXoavEC3vquKtv4yI=
github.com/ipfs/bbloom v0.0.4 h1:Gi+8EGJ2y5qiD5FbsbpX/TMNcJw8gSqr7eyjHa4Fhvs=
github.com/ipfs/bbloom v0.0.4/go.mod h1:cS9YprKXpoZ9lT0n/Mw/a6/aFV6DTjTLYHeA+gyqMG0=
-github.com/ipfs/boxo v0.13.2-0.20231031104528-b0a265b5cdcc h1:jKrgzSr4RC04aG2LX8lA0emMOxSrckORZE4GKRZUt0Y=
-github.com/ipfs/boxo v0.13.2-0.20231031104528-b0a265b5cdcc/go.mod h1:pu8HsZvuyYeYJsqtLDCoYSvy8rHj6vI3dlh8P0f83Zs=
+github.com/ipfs/boxo v0.13.2-0.20231031170949-08b11e5df06e h1:+A0lJ8vc6YtiMiq3UodN0BgZJTso/VJDrECdyHpsFDY=
+github.com/ipfs/boxo v0.13.2-0.20231031170949-08b11e5df06e/go.mod h1:pu8HsZvuyYeYJsqtLDCoYSvy8rHj6vI3dlh8P0f83Zs=
github.com/ipfs/go-bitfield v1.1.0 h1:fh7FIo8bSwaJEh6DdTWbCeZ1eqOaOkKFI74SCnsWbGA=
github.com/ipfs/go-bitfield v1.1.0/go.mod h1:paqf1wjq/D2BBmzfTVFlJQ9IlFOZpg422HL0HqsGWHU=
github.com/ipfs/go-bitswap v0.11.0 h1:j1WVvhDX1yhG32NTC9xfxnqycqYIlhzEzLXG/cU1HyQ=
diff --git a/test/dependencies/go.mod b/test/dependencies/go.mod
index 5d7623cf227b5b9a50e8fc7d8654319511e0d59d..30f462704bf563e754f1a8e0e4d087010f1179f4 100644
--- a/test/dependencies/go.mod
+++ b/test/dependencies/go.mod
@@ -7,7 +7,7 @@ replace github.com/ipfs/kubo => ../../
require (
github.com/Kubuxu/gocovmerge v0.0.0-20161216165753-7ecaa51963cd
github.com/golangci/golangci-lint v1.54.1
- github.com/ipfs/boxo v0.13.2-0.20231031104528-b0a265b5cdcc
+ github.com/ipfs/boxo v0.13.2-0.20231031170949-08b11e5df06e
github.com/ipfs/go-cid v0.4.1
github.com/ipfs/go-cidutil v0.1.0
github.com/ipfs/go-datastore v0.6.0
diff --git a/test/dependencies/go.sum b/test/dependencies/go.sum
index 447099e1261cbd80ab74bea7ca989323eca584a4..c9708b27b601a00b4e13ad1dc5bd9aa9c5ff4c8c 100644
--- a/test/dependencies/go.sum
+++ b/test/dependencies/go.sum
@@ -398,8 +398,8 @@ github.com/inconshreveable/mousetrap v1.1.0 h1:wN+x4NVGpMsO7ErUn/mUI3vEoE6Jt13X2
github.com/inconshreveable/mousetrap v1.1.0/go.mod h1:vpF70FUmC8bwa3OWnCshd2FqLfsEA9PFc4w1p2J65bw=
github.com/ipfs/bbloom v0.0.4 h1:Gi+8EGJ2y5qiD5FbsbpX/TMNcJw8gSqr7eyjHa4Fhvs=
github.com/ipfs/bbloom v0.0.4/go.mod h1:cS9YprKXpoZ9lT0n/Mw/a6/aFV6DTjTLYHeA+gyqMG0=
-github.com/ipfs/boxo v0.13.2-0.20231031104528-b0a265b5cdcc h1:jKrgzSr4RC04aG2LX8lA0emMOxSrckORZE4GKRZUt0Y=
-github.com/ipfs/boxo v0.13.2-0.20231031104528-b0a265b5cdcc/go.mod h1:pu8HsZvuyYeYJsqtLDCoYSvy8rHj6vI3dlh8P0f83Zs=
+github.com/ipfs/boxo v0.13.2-0.20231031170949-08b11e5df06e h1:+A0lJ8vc6YtiMiq3UodN0BgZJTso/VJDrECdyHpsFDY=
+github.com/ipfs/boxo v0.13.2-0.20231031170949-08b11e5df06e/go.mod h1:pu8HsZvuyYeYJsqtLDCoYSvy8rHj6vI3dlh8P0f83Zs=
github.com/ipfs/go-bitfield v1.1.0 h1:fh7FIo8bSwaJEh6DdTWbCeZ1eqOaOkKFI74SCnsWbGA=
github.com/ipfs/go-bitfield v1.1.0/go.mod h1:paqf1wjq/D2BBmzfTVFlJQ9IlFOZpg422HL0HqsGWHU=
github.com/ipfs/go-block-format v0.2.0 h1:ZqrkxBA2ICbDRbK8KJs/u0O3dlp6gmAuuXUJNiW1Ycs=
diff --git a/test/integration/addcat_test.go b/test/integration/addcat_test.go
index 2974f51fbbe5100d0f9435303f9ea55ee7b4264c..222326de21dcdef4b289508042e27b7f675ffe22 100644
--- a/test/integration/addcat_test.go
+++ b/test/integration/addcat_test.go
@@ -11,10 +11,10 @@ import (
"testing"
"time"
+ "github.com/ipfs/boxo/bootstrap"
"github.com/ipfs/boxo/files"
logging "github.com/ipfs/go-log"
"github.com/ipfs/kubo/core"
- "github.com/ipfs/kubo/core/bootstrap"
"github.com/ipfs/kubo/core/coreapi"
mock "github.com/ipfs/kubo/core/mock"
"github.com/ipfs/kubo/thirdparty/unit"
diff --git a/test/integration/bench_cat_test.go b/test/integration/bench_cat_test.go
index e95ff87dfce34a4cfe90777f4a0464d1b8d95c93..d0c0a4b8983d7dee4355c8593c3947bff510ec57 100644
--- a/test/integration/bench_cat_test.go
+++ b/test/integration/bench_cat_test.go
@@ -8,9 +8,9 @@ import (
"math"
"testing"
+ "github.com/ipfs/boxo/bootstrap"
"github.com/ipfs/boxo/files"
"github.com/ipfs/kubo/core"
- "github.com/ipfs/kubo/core/bootstrap"
"github.com/ipfs/kubo/core/coreapi"
mock "github.com/ipfs/kubo/core/mock"
"github.com/ipfs/kubo/thirdparty/unit"
diff --git a/test/integration/pubsub_msg_seen_cache_test.go b/test/integration/pubsub_msg_seen_cache_test.go
index 4194881a53b77d99961a7a90ad3ca64215957826..85cc8ae9f1efd9fcaea5fcc4db32be59845ced82 100644
--- a/test/integration/pubsub_msg_seen_cache_test.go
+++ b/test/integration/pubsub_msg_seen_cache_test.go
@@ -10,9 +10,9 @@ import (
"go.uber.org/fx"
+ "github.com/ipfs/boxo/bootstrap"
"github.com/ipfs/kubo/config"
"github.com/ipfs/kubo/core"
- "github.com/ipfs/kubo/core/bootstrap"
"github.com/ipfs/kubo/core/coreapi"
libp2p2 "github.com/ipfs/kubo/core/node/libp2p"
"github.com/ipfs/kubo/repo"
diff --git a/test/integration/three_legged_cat_test.go b/test/integration/three_legged_cat_test.go
index e8a838e1f47d65ec5e0917ce35ffbf7d32bc4bb2..fa594f1e5c27d8621a5e5fe54a09e586e650f106 100644
--- a/test/integration/three_legged_cat_test.go
+++ b/test/integration/three_legged_cat_test.go
@@ -9,7 +9,7 @@ import (
"testing"
"time"
- bootstrap2 "github.com/ipfs/kubo/core/bootstrap"
+ bootstrap2 "github.com/ipfs/boxo/bootstrap"
"github.com/ipfs/kubo/core/coreapi"
mock "github.com/ipfs/kubo/core/mock"
"github.com/ipfs/kubo/thirdparty/unit"