diff --git a/node/modules/chain.go b/node/modules/chain.go index 9cf259438..ed4dd8ac7 100644 --- a/node/modules/chain.go +++ b/node/modules/chain.go @@ -35,7 +35,8 @@ func ChainExchange(mctx helpers.MetricsCtx, lc fx.Lifecycle, host host.Host, rt // prefix protocol for chain bitswap // (so bitswap uses /chain/ipfs/bitswap/1.0.0 internally for chain sync stuff) bitswapNetwork := network.NewFromIpfsHost(host, rt, network.Prefix("/chain")) - exch := bitswap.New(helpers.LifecycleCtx(mctx, lc), bitswapNetwork, bs) + bitswapOptions := []bitswap.Option{bitswap.ProvideEnabled(false)} + exch := bitswap.New(helpers.LifecycleCtx(mctx, lc), bitswapNetwork, bs, bitswapOptions...) lc.Append(fx.Hook{ OnStop: func(ctx context.Context) error { return exch.Close() diff --git a/node/modules/client.go b/node/modules/client.go index 006a94c14..5b2368f19 100644 --- a/node/modules/client.go +++ b/node/modules/client.go @@ -85,7 +85,8 @@ func NewClientDatastore(ds dtypes.MetadataDS) dtypes.ClientDatastore { // ClientDAG is a DAGService for the ClientBlockstore func ClientDAG(mctx helpers.MetricsCtx, lc fx.Lifecycle, ibs dtypes.ClientBlockstore, rt routing.Routing, h host.Host) dtypes.ClientDAG { bitswapNetwork := network.NewFromIpfsHost(h, rt) - exch := bitswap.New(helpers.LifecycleCtx(mctx, lc), bitswapNetwork, ibs) + bitswapOptions := []bitswap.Option{bitswap.ProvideEnabled(false)} + exch := bitswap.New(helpers.LifecycleCtx(mctx, lc), bitswapNetwork, ibs, bitswapOptions...) bsvc := blockservice.New(ibs, exch) dag := merkledag.NewDAGService(bsvc) diff --git a/node/modules/storageminer.go b/node/modules/storageminer.go index 261bbb108..a6c52840f 100644 --- a/node/modules/storageminer.go +++ b/node/modules/storageminer.go @@ -232,7 +232,8 @@ func StagingBlockstore(r repo.LockedRepo) (dtypes.StagingBlockstore, error) { func StagingDAG(mctx helpers.MetricsCtx, lc fx.Lifecycle, ibs dtypes.StagingBlockstore, rt routing.Routing, h host.Host) (dtypes.StagingDAG, error) { bitswapNetwork := network.NewFromIpfsHost(h, rt) - exch := bitswap.New(helpers.LifecycleCtx(mctx, lc), bitswapNetwork, ibs) + bitswapOptions := []bitswap.Option{bitswap.ProvideEnabled(false)} + exch := bitswap.New(helpers.LifecycleCtx(mctx, lc), bitswapNetwork, ibs, bitswapOptions...) bsvc := blockservice.New(ibs, exch) dag := merkledag.NewDAGService(bsvc)