Skip to content

Commit 323e72d

Browse files
fix provider type
1 parent bb069ce commit 323e72d

File tree

2 files changed

+9
-4
lines changed

2 files changed

+9
-4
lines changed

core/node/bitswap.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -171,11 +171,11 @@ type providingExchangeIn struct {
171171
fx.In
172172

173173
BaseExch exchange.Interface
174-
Provider provider.System
174+
Provider provider.Provider
175175
}
176176

177177
// ProvidingExchange creates a providing.Exchange with the existing exchange
178-
// and the provider.System.
178+
// and the provider.Provider.
179179
// We cannot do this in OnlineExchange because it causes cycles so this is for
180180
// a decorator.
181181
func ProvidingExchange(provide bool) interface{} {

core/node/provider.go

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ import (
3030
const sampledBatchSize = 1000
3131

3232
func ProviderSys(reprovideInterval time.Duration, acceleratedDHTClient bool, provideWorkerCount int) fx.Option {
33-
return fx.Provide(func(lc fx.Lifecycle, cr irouting.ProvideManyRouter, keyProvider provider.KeyChanFunc, repo repo.Repo, bs blockstore.Blockstore) (provider.System, error) {
33+
return fx.Provide(func(lc fx.Lifecycle, cr irouting.ProvideManyRouter, keyProvider provider.KeyChanFunc, repo repo.Repo, bs blockstore.Blockstore) (provider.Provider, error) {
3434
opts := []provider.Option{
3535
provider.Online(cr),
3636
provider.ReproviderInterval(reprovideInterval),
@@ -234,7 +234,12 @@ func SweepingReprovider(provide bool, reprovideStrategy string, opts ...reprovid
234234

235235
// OfflineProviders groups units managing provider routing records offline
236236
func OfflineProviders() fx.Option {
237-
return fx.Provide(provider.NewNoopProvider)
237+
return fx.Provide(
238+
fx.Annotate(
239+
provider.NewNoopProvider,
240+
fx.As(new(provider.Provider)),
241+
),
242+
)
238243
}
239244

240245
func mfsProvider(mfsRoot *mfs.Root, fetcher fetcher.Factory) provider.KeyChanFunc {

0 commit comments

Comments
 (0)