diff --git a/protocols/registry/registry.go b/protocols/registry/registry.go index eca6276..eb5c7c6 100644 --- a/protocols/registry/registry.go +++ b/protocols/registry/registry.go @@ -12,7 +12,7 @@ const GroupName = "protocols" type Protocol interface { Name() string - Init() error + Init(ctx context.Context) error Start(ctx context.Context) error Stop(ctx context.Context) error Config() config.ProtocolConfig diff --git a/protocols/s5/s5.go b/protocols/s5/s5.go index 0698479..067f76e 100644 --- a/protocols/s5/s5.go +++ b/protocols/s5/s5.go @@ -166,10 +166,10 @@ func NewS5ProviderStore(params S5ProviderStoreParams) *S5ProviderStore { } } -func (s *S5Protocol) Init() error { +func (s *S5Protocol) Init(ctx context.Context) error { s.node.Services().Storage().SetProviderStore(s.store) - err := s.node.Init() + err := s.node.Init(ctx) if err != nil { return err }