fix: update and fix lint

D4ryl00 · D4ryl00 · commit c36f3895c04f · 2024-04-12T18:06:42.000+02:00
Signed-off-by: D4ryl00 &lt;d4ryl00@gmail.com&gt;
diff --git a/.tool-versions b/.tool-versions
@@ -1,2 +1,2 @@
 golang 1.21.8
-golangci-lint 1.50.1
+golangci-lint 1.57.2
diff --git a/accesscontroller/ipfs/accesscontroller_ipfs.go b/accesscontroller/ipfs/accesscontroller_ipfs.go
@@ -38,7 +38,7 @@ func (i *ipfsAccessController) Address() address.Address {
 	return nil
 }
 
-func (i *ipfsAccessController) CanAppend(entry logac.LogEntry, p identityprovider.Interface, additionalContext accesscontroller.CanAppendAdditionalContext) error {
+func (i *ipfsAccessController) CanAppend(entry logac.LogEntry, p identityprovider.Interface, _ accesscontroller.CanAppendAdditionalContext) error {
 	i.muWriteAccess.RLock()
 	defer i.muWriteAccess.RUnlock()
 
@@ -63,11 +63,11 @@ func (i *ipfsAccessController) GetAuthorizedByRole(role string) ([]string, error
 	return nil, nil
 }
 
-func (i *ipfsAccessController) Grant(ctx context.Context, capability string, keyID string) error {
+func (i *ipfsAccessController) Grant(ctx context.Context, capability string, keyID string) error { //nolint:all
 	return fmt.Errorf("not implemented - does not exist in JS version")
 }
 
-func (i *ipfsAccessController) Revoke(ctx context.Context, capability string, keyID string) error {
+func (i *ipfsAccessController) Revoke(ctx context.Context, capability string, keyID string) error { //nolint:all
 	return fmt.Errorf("not implemented - does not exist in JS version")
 }
 
diff --git a/accesscontroller/orbitdb/accesscontroller_orbitdb.go b/accesscontroller/orbitdb/accesscontroller_orbitdb.go
@@ -112,7 +112,7 @@ func (o *orbitDBAccessController) getAuthorizations() (map[string][]string, erro
 	return authorizationsLists, nil
 }
 
-func (o *orbitDBAccessController) CanAppend(entry logac.LogEntry, p identityprovider.Interface, additionalContext accesscontroller.CanAppendAdditionalContext) error {
+func (o *orbitDBAccessController) CanAppend(entry logac.LogEntry, p identityprovider.Interface, _ accesscontroller.CanAppendAdditionalContext) error {
 	writeAccess, err := o.GetAuthorizedByRole("write")
 	if err != nil {
 		return fmt.Errorf("unable to get keys with write access: %w", err)
@@ -249,7 +249,7 @@ func (o *orbitDBAccessController) Load(ctx context.Context, address string) erro
 	return nil
 }
 
-func (o *orbitDBAccessController) Save(ctx context.Context) (accesscontroller.ManifestParams, error) {
+func (o *orbitDBAccessController) Save(_ context.Context) (accesscontroller.ManifestParams, error) {
 	return accesscontroller.NewManifestParams(o.kvStore.Address().GetRoot(), false, "orbitdb"), nil
 }
 
@@ -261,7 +261,7 @@ func (o *orbitDBAccessController) Close() error {
 	return nil
 }
 
-func (o *orbitDBAccessController) onUpdate(ctx context.Context) {
+func (o *orbitDBAccessController) onUpdate(_ context.Context) {
 	if err := o.emitterEvtUpdated.Emit(&EventUpdated{}); err != nil {
 		o.logger.Warn("unable to emit event updated", zap.Error(err))
 	}
diff --git a/accesscontroller/simple/accesscontroller_simple.go b/accesscontroller/simple/accesscontroller_simple.go
@@ -38,19 +38,19 @@ func (o *simpleAccessController) Address() address.Address {
 	return nil
 }
 
-func (o *simpleAccessController) Grant(ctx context.Context, capability string, keyID string) error {
+func (o *simpleAccessController) Grant(ctx context.Context, capability string, keyID string) error { //nolint:all
 	return nil
 }
 
-func (o *simpleAccessController) Revoke(ctx context.Context, capability string, keyID string) error {
+func (o *simpleAccessController) Revoke(ctx context.Context, capability string, keyID string) error { //nolint:all
 	return nil
 }
 
-func (o *simpleAccessController) Load(ctx context.Context, address string) error {
+func (o *simpleAccessController) Load(ctx context.Context, address string) error { //nolint:all
 	return nil
 }
 
-func (o *simpleAccessController) Save(ctx context.Context) (accesscontroller.ManifestParams, error) {
+func (o *simpleAccessController) Save(_ context.Context) (accesscontroller.ManifestParams, error) {
 	return accesscontroller.NewManifestParams(cid.Cid{}, true, "simple"), nil
 }
 
@@ -66,7 +66,7 @@ func (o *simpleAccessController) GetAuthorizedByRole(role string) ([]string, err
 	return o.allowedKeys[role], nil
 }
 
-func (o *simpleAccessController) CanAppend(e logac.LogEntry, p identityprovider.Interface, additionalContext accesscontroller.CanAppendAdditionalContext) error {
+func (o *simpleAccessController) CanAppend(e logac.LogEntry, _ identityprovider.Interface, _ accesscontroller.CanAppendAdditionalContext) error {
 	for _, id := range o.allowedKeys["write"] {
 		if e.GetIdentity().ID == id || id == "*" {
 			return nil
diff --git a/baseorbitdb/orbitdb.go b/baseorbitdb/orbitdb.go
@@ -31,6 +31,7 @@ import (
 	peer "github.com/libp2p/go-libp2p/core/peer"
 	"github.com/libp2p/go-libp2p/p2p/host/eventbus"
 	"go.opentelemetry.io/otel/trace"
+	tracenoop "go.opentelemetry.io/otel/trace/noop"
 	"go.uber.org/zap"
 )
 
@@ -334,7 +335,7 @@ func newOrbitDB(ctx context.Context, is coreiface.CoreAPI, identity *idp.Identit
 	}
 
 	if options.Tracer == nil {
-		options.Tracer = trace.NewNoopTracerProvider().Tracer("")
+		options.Tracer = tracenoop.NewTracerProvider().Tracer("")
 	}
 
 	if options.EventBus == nil {
diff --git a/events/events.go b/events/events.go
@@ -46,7 +46,7 @@ type eventBox struct {
 
 // Deprecated: use event bus directly
 // Emit Sends an event to the subscribed listeners
-func (e *EventEmitter) Emit(ctx context.Context, evt Event) {
+func (e *EventEmitter) Emit(_ context.Context, evt Event) {
 	e.muEmitters.Lock()
 
 	bus := e.getBus()
diff --git a/pubsub/directchannel/channel.go b/pubsub/directchannel/channel.go
@@ -76,7 +76,7 @@ func (d *directChannel) handleNewPeer(s network.Stream) {
 
 // @NOTE(gfanton): we dont need this on direct channel
 // Connect Waits for the other peer to be connected
-func (d *directChannel) Connect(ctx context.Context, pid peer.ID) (err error) {
+func (d *directChannel) Connect(ctx context.Context, pid peer.ID) (err error) { //nolint:all
 	return nil
 }
 
@@ -92,7 +92,7 @@ type holderChannels struct {
 	logger *zap.Logger
 }
 
-func (c *holderChannels) NewChannel(ctx context.Context, emitter iface.DirectChannelEmitter, opts *iface.DirectChannelOptions) (iface.DirectChannel, error) {
+func (c *holderChannels) NewChannel(_ context.Context, emitter iface.DirectChannelEmitter, opts *iface.DirectChannelOptions) (iface.DirectChannel, error) {
 	if opts == nil {
 		opts = &iface.DirectChannelOptions{}
 	}
diff --git a/pubsub/pubsubcoreapi/pubsub.go b/pubsub/pubsubcoreapi/pubsub.go
@@ -9,6 +9,7 @@ import (
 	"github.com/ipfs/kubo/core/coreiface/options"
 	"github.com/libp2p/go-libp2p/core/peer"
 	"go.opentelemetry.io/otel/trace"
+	tracenoop "go.opentelemetry.io/otel/trace/noop"
 	"go.uber.org/zap"
 
 	"berty.tech/go-orbit-db/events"
@@ -172,7 +173,7 @@ func NewPubSub(api coreiface.CoreAPI, id peer.ID, pollInterval time.Duration, lo
 	}
 
 	if tracer == nil {
-		tracer = trace.NewNoopTracerProvider().Tracer("")
+		tracer = tracenoop.NewTracerProvider().Tracer("")
 	}
 
 	return &coreAPIPubSub{
diff --git a/pubsub/pubsubraw/pubsub.go b/pubsub/pubsubraw/pubsub.go
@@ -7,6 +7,7 @@ import (
 	p2ppubsub "github.com/libp2p/go-libp2p-pubsub"
 	"github.com/libp2p/go-libp2p/core/peer"
 	"go.opentelemetry.io/otel/trace"
+	tracernoop "go.opentelemetry.io/otel/trace/noop"
 	"go.uber.org/zap"
 
 	"berty.tech/go-orbit-db/events"
@@ -141,7 +142,7 @@ func NewPubSub(ps *p2ppubsub.PubSub, id peer.ID, logger *zap.Logger, tracer trac
 	}
 
 	if tracer == nil {
-		tracer = trace.NewNoopTracerProvider().Tracer("")
+		tracer = tracernoop.NewTracerProvider().Tracer("")
 	}
 
 	return &rawPubSub{
diff --git a/stores/basestore/base_index.go b/stores/basestore/base_index.go
@@ -20,7 +20,7 @@ func (b *baseIndex) Get(_ string) interface{} {
 	return b.index
 }
 
-func (b *baseIndex) UpdateIndex(log ipfslog.Log, entries []ipfslog.Entry) error {
+func (b *baseIndex) UpdateIndex(log ipfslog.Log, _ []ipfslog.Entry) error {
 	b.mu.Lock()
 	defer b.mu.Unlock()
 	b.index = log.Values().Slice()
diff --git a/stores/basestore/base_store.go b/stores/basestore/base_store.go
@@ -34,6 +34,7 @@ import (
 	"github.com/pkg/errors"
 	otkv "go.opentelemetry.io/otel/attribute"
 	"go.opentelemetry.io/otel/trace"
+	tracenoop "go.opentelemetry.io/otel/trace/noop"
 	"go.uber.org/zap"
 )
 
@@ -180,7 +181,7 @@ func (b *BaseStore) InitBaseStore(ipfs coreiface.CoreAPI, identity *identityprov
 	b.messageMarshaler = options.MessageMarshaler
 
 	if options.Tracer == nil {
-		options.Tracer = trace.NewNoopTracerProvider().Tracer("")
+		options.Tracer = tracenoop.NewTracerProvider().Tracer("")
 	}
 
 	if identity == nil {
@@ -662,7 +663,7 @@ func (b *BaseStore) Sync(ctx context.Context, heads []ipfslog.Entry) error {
 	return nil
 }
 
-func (b *BaseStore) LoadMoreFrom(ctx context.Context, amount uint, entries []ipfslog.Entry) {
+func (b *BaseStore) LoadMoreFrom(ctx context.Context, amount uint, entries []ipfslog.Entry) { //nolint:all
 	b.Replicator().Load(ctx, entries)
 	// TODO: can this return an error?
 }
diff --git a/stores/documentstore/document.go b/stores/documentstore/document.go
@@ -20,7 +20,7 @@ type orbitDBDocumentStore struct {
 	docOpts *iface.CreateDocumentDBOptions
 }
 
-func (o *orbitDBDocumentStore) Get(ctx context.Context, key string, opts *iface.DocumentStoreGetOptions) ([]interface{}, error) {
+func (o *orbitDBDocumentStore) Get(_ context.Context, key string, opts *iface.DocumentStoreGetOptions) ([]interface{}, error) {
 	if opts == nil {
 		opts = &iface.DocumentStoreGetOptions{}
 	}
@@ -179,7 +179,7 @@ func (o *orbitDBDocumentStore) PutAll(ctx context.Context, values []interface{})
 }
 
 // Query Finds documents using a filter function
-func (o *orbitDBDocumentStore) Query(ctx context.Context, filter func(doc interface{}) (bool, error)) ([]interface{}, error) {
+func (o *orbitDBDocumentStore) Query(_ context.Context, filter func(doc interface{}) (bool, error)) ([]interface{}, error) {
 	docIndex, ok := o.Index().(*documentIndex)
 	if !ok {
 		return nil, fmt.Errorf("unable to cast index to documentIndex")
diff --git a/stores/eventlogstore/index.go b/stores/eventlogstore/index.go
@@ -12,7 +12,7 @@ type eventIndex struct {
 	lock  sync.RWMutex
 }
 
-func (i *eventIndex) Get(key string) interface{} {
+func (i *eventIndex) Get(key string) interface{} { //nolint:all
 	i.lock.RLock()
 	defer i.lock.RUnlock()
 
diff --git a/stores/eventlogstore/log.go b/stores/eventlogstore/log.go
@@ -80,7 +80,7 @@ func (o *orbitDBEventLogStore) Get(ctx context.Context, cid cid.Cid) (operation.
 	}
 }
 
-func (o *orbitDBEventLogStore) Stream(ctx context.Context, resultChan chan operation.Operation, options *iface.StreamOptions) error {
+func (o *orbitDBEventLogStore) Stream(_ context.Context, resultChan chan operation.Operation, options *iface.StreamOptions) error {
 	defer close(resultChan)
 	messages, err := o.query(options)
 	if err != nil {
diff --git a/stores/kvstore/keyvalue.go b/stores/kvstore/keyvalue.go
@@ -67,7 +67,7 @@ func (o *orbitDBKeyValue) Delete(ctx context.Context, key string) (operation.Ope
 	return op, nil
 }
 
-func (o *orbitDBKeyValue) Get(ctx context.Context, key string) ([]byte, error) {
+func (o *orbitDBKeyValue) Get(_ context.Context, key string) ([]byte, error) {
 	value, ok := o.Index().(*kvIndex).Get(key).([]byte)
 	if value == nil {
 		return nil, nil
diff --git a/stores/replicator/replicator.go b/stores/replicator/replicator.go
@@ -14,6 +14,7 @@ import (
 	"github.com/libp2p/go-libp2p/p2p/host/eventbus"
 	otkv "go.opentelemetry.io/otel/attribute"
 	"go.opentelemetry.io/otel/trace"
+	tracenoop "go.opentelemetry.io/otel/trace/noop"
 	"go.uber.org/zap"
 	"golang.org/x/sync/semaphore"
 )
@@ -77,7 +78,7 @@ func NewReplicator(store storeInterface, concurrency uint, opts *Options) (Repli
 	}
 
 	if opts.Tracer == nil {
-		opts.Tracer = trace.NewNoopTracerProvider().Tracer("")
+		opts.Tracer = tracenoop.NewTracerProvider().Tracer("")
 	}
 
 	if concurrency == 0 {
@@ -178,7 +179,7 @@ func (r *replicator) Load(ctx context.Context, entries []ipfslog.Entry) {
 		wg.Add(1)
 
 		// add one process
-		go func(i int) {
+		go func(_ int) {
 			if err := r.processOne(ctx, &wg); err != nil {
 				r.logger.Warn("unable to process entry", zap.Error(err))
 			}

Original file line number	Diff line number	Diff line change
`@@ -1,2 +1,2 @@`
`1`	`1`	`golang 1.21.8`
`2`		`-golangci-lint 1.50.1`
	`2`	`+golangci-lint 1.57.2`
Original file line number	Diff line number	Diff line change
`@@ -38,7 +38,7 @@ func (i *ipfsAccessController) Address() address.Address {`
`38`	`38`	`return nil`
`39`	`39`	`}`
`40`	`40`
`41`		`-func (i *ipfsAccessController) CanAppend(entry logac.LogEntry, p identityprovider.Interface, additionalContext accesscontroller.CanAppendAdditionalContext) error {`
	`41`	`+func (i *ipfsAccessController) CanAppend(entry logac.LogEntry, p identityprovider.Interface, _ accesscontroller.CanAppendAdditionalContext) error {`
`42`	`42`	`i.muWriteAccess.RLock()`
`43`	`43`	`defer i.muWriteAccess.RUnlock()`
`44`	`44`
`@@ -63,11 +63,11 @@ func (i *ipfsAccessController) GetAuthorizedByRole(role string) ([]string, error`
`63`	`63`	`return nil, nil`
`64`	`64`	`}`
`65`	`65`
`66`		`-func (i *ipfsAccessController) Grant(ctx context.Context, capability string, keyID string) error {`
	`66`	`+func (i *ipfsAccessController) Grant(ctx context.Context, capability string, keyID string) error { //nolint:all`
`67`	`67`	`return fmt.Errorf("not implemented - does not exist in JS version")`
`68`	`68`	`}`
`69`	`69`
`70`		`-func (i *ipfsAccessController) Revoke(ctx context.Context, capability string, keyID string) error {`
	`70`	`+func (i *ipfsAccessController) Revoke(ctx context.Context, capability string, keyID string) error { //nolint:all`
`71`	`71`	`return fmt.Errorf("not implemented - does not exist in JS version")`
`72`	`72`	`}`
`73`	`73`
Original file line number	Diff line number	Diff line change
`@@ -112,7 +112,7 @@ func (o *orbitDBAccessController) getAuthorizations() (map[string][]string, erro`
`112`	`112`	`return authorizationsLists, nil`
`113`	`113`	`}`
`114`	`114`
`115`		`-func (o *orbitDBAccessController) CanAppend(entry logac.LogEntry, p identityprovider.Interface, additionalContext accesscontroller.CanAppendAdditionalContext) error {`
	`115`	`+func (o *orbitDBAccessController) CanAppend(entry logac.LogEntry, p identityprovider.Interface, _ accesscontroller.CanAppendAdditionalContext) error {`
`116`	`116`	`writeAccess, err := o.GetAuthorizedByRole("write")`
`117`	`117`	`if err != nil {`
`118`	`118`	`return fmt.Errorf("unable to get keys with write access: %w", err)`
`@@ -249,7 +249,7 @@ func (o *orbitDBAccessController) Load(ctx context.Context, address string) erro`
`249`	`249`	`return nil`
`250`	`250`	`}`
`251`	`251`
`252`		`-func (o *orbitDBAccessController) Save(ctx context.Context) (accesscontroller.ManifestParams, error) {`
	`252`	`+func (o *orbitDBAccessController) Save(_ context.Context) (accesscontroller.ManifestParams, error) {`
`253`	`253`	`return accesscontroller.NewManifestParams(o.kvStore.Address().GetRoot(), false, "orbitdb"), nil`
`254`	`254`	`}`
`255`	`255`
`@@ -261,7 +261,7 @@ func (o *orbitDBAccessController) Close() error {`
`261`	`261`	`return nil`
`262`	`262`	`}`
`263`	`263`
`264`		`-func (o *orbitDBAccessController) onUpdate(ctx context.Context) {`
	`264`	`+func (o *orbitDBAccessController) onUpdate(_ context.Context) {`
`265`	`265`	`if err := o.emitterEvtUpdated.Emit(&EventUpdated{}); err != nil {`
`266`	`266`	`o.logger.Warn("unable to emit event updated", zap.Error(err))`
`267`	`267`	`}`
Original file line number	Diff line number	Diff line change
`@@ -38,19 +38,19 @@ func (o *simpleAccessController) Address() address.Address {`
`38`	`38`	`return nil`
`39`	`39`	`}`
`40`	`40`
`41`		`-func (o *simpleAccessController) Grant(ctx context.Context, capability string, keyID string) error {`
	`41`	`+func (o *simpleAccessController) Grant(ctx context.Context, capability string, keyID string) error { //nolint:all`
`42`	`42`	`return nil`
`43`	`43`	`}`
`44`	`44`
`45`		`-func (o *simpleAccessController) Revoke(ctx context.Context, capability string, keyID string) error {`
	`45`	`+func (o *simpleAccessController) Revoke(ctx context.Context, capability string, keyID string) error { //nolint:all`
`46`	`46`	`return nil`
`47`	`47`	`}`
`48`	`48`
`49`		`-func (o *simpleAccessController) Load(ctx context.Context, address string) error {`
	`49`	`+func (o *simpleAccessController) Load(ctx context.Context, address string) error { //nolint:all`
`50`	`50`	`return nil`
`51`	`51`	`}`
`52`	`52`
`53`		`-func (o *simpleAccessController) Save(ctx context.Context) (accesscontroller.ManifestParams, error) {`
	`53`	`+func (o *simpleAccessController) Save(_ context.Context) (accesscontroller.ManifestParams, error) {`
`54`	`54`	`return accesscontroller.NewManifestParams(cid.Cid{}, true, "simple"), nil`
`55`	`55`	`}`
`56`	`56`
`@@ -66,7 +66,7 @@ func (o *simpleAccessController) GetAuthorizedByRole(role string) ([]string, err`
`66`	`66`	`return o.allowedKeys[role], nil`
`67`	`67`	`}`
`68`	`68`
`69`		`-func (o *simpleAccessController) CanAppend(e logac.LogEntry, p identityprovider.Interface, additionalContext accesscontroller.CanAppendAdditionalContext) error {`
	`69`	`+func (o *simpleAccessController) CanAppend(e logac.LogEntry, _ identityprovider.Interface, _ accesscontroller.CanAppendAdditionalContext) error {`
`70`	`70`	`for _, id := range o.allowedKeys["write"] {`
`71`	`71`	`if e.GetIdentity().ID == id \|\| id == "*" {`
`72`	`72`	`return nil`
Original file line number	Diff line number	Diff line change
`@@ -31,6 +31,7 @@ import (`
`31`	`31`	`peer "github.com/libp2p/go-libp2p/core/peer"`
`32`	`32`	`"github.com/libp2p/go-libp2p/p2p/host/eventbus"`
`33`	`33`	`"go.opentelemetry.io/otel/trace"`
	`34`	`+ tracenoop "go.opentelemetry.io/otel/trace/noop"`
`34`	`35`	`"go.uber.org/zap"`
`35`	`36`	`)`
`36`	`37`
`@@ -334,7 +335,7 @@ func newOrbitDB(ctx context.Context, is coreiface.CoreAPI, identity *idp.Identit`
`334`	`335`	`}`
`335`	`336`
`336`	`337`	`if options.Tracer == nil {`
`337`		`- options.Tracer = trace.NewNoopTracerProvider().Tracer("")`
	`338`	`+ options.Tracer = tracenoop.NewTracerProvider().Tracer("")`
`338`	`339`	`}`
`339`	`340`
`340`	`341`	`if options.EventBus == nil {`
Original file line number	Diff line number	Diff line change
`@@ -76,7 +76,7 @@ func (d *directChannel) handleNewPeer(s network.Stream) {`
`76`	`76`
`77`	`77`	`// @NOTE(gfanton): we dont need this on direct channel`
`78`	`78`	`// Connect Waits for the other peer to be connected`
`79`		`-func (d *directChannel) Connect(ctx context.Context, pid peer.ID) (err error) {`
	`79`	`+func (d *directChannel) Connect(ctx context.Context, pid peer.ID) (err error) { //nolint:all`
`80`	`80`	`return nil`
`81`	`81`	`}`
`82`	`82`
`@@ -92,7 +92,7 @@ type holderChannels struct {`
`92`	`92`	`logger *zap.Logger`
`93`	`93`	`}`
`94`	`94`
`95`		`-func (c holderChannels) NewChannel(ctx context.Context, emitter iface.DirectChannelEmitter, opts iface.DirectChannelOptions) (iface.DirectChannel, error) {`
	`95`	`+func (c holderChannels) NewChannel(_ context.Context, emitter iface.DirectChannelEmitter, opts iface.DirectChannelOptions) (iface.DirectChannel, error) {`
`96`	`96`	`if opts == nil {`
`97`	`97`	`opts = &iface.DirectChannelOptions{}`
`98`	`98`	`}`
Original file line number	Diff line number	Diff line change
`@@ -9,6 +9,7 @@ import (`
`9`	`9`	`"github.com/ipfs/kubo/core/coreiface/options"`
`10`	`10`	`"github.com/libp2p/go-libp2p/core/peer"`
`11`	`11`	`"go.opentelemetry.io/otel/trace"`
	`12`	`+ tracenoop "go.opentelemetry.io/otel/trace/noop"`
`12`	`13`	`"go.uber.org/zap"`
`13`	`14`
`14`	`15`	`"berty.tech/go-orbit-db/events"`
`@@ -172,7 +173,7 @@ func NewPubSub(api coreiface.CoreAPI, id peer.ID, pollInterval time.Duration, lo`
`172`	`173`	`}`
`173`	`174`
`174`	`175`	`if tracer == nil {`
`175`		`- tracer = trace.NewNoopTracerProvider().Tracer("")`
	`176`	`+ tracer = tracenoop.NewTracerProvider().Tracer("")`
`176`	`177`	`}`
`177`	`178`
`178`	`179`	`return &coreAPIPubSub{`
Original file line number	Diff line number	Diff line change
`@@ -7,6 +7,7 @@ import (`
`7`	`7`	`p2ppubsub "github.com/libp2p/go-libp2p-pubsub"`
`8`	`8`	`"github.com/libp2p/go-libp2p/core/peer"`
`9`	`9`	`"go.opentelemetry.io/otel/trace"`
	`10`	`+ tracernoop "go.opentelemetry.io/otel/trace/noop"`
`10`	`11`	`"go.uber.org/zap"`
`11`	`12`
`12`	`13`	`"berty.tech/go-orbit-db/events"`
`@@ -141,7 +142,7 @@ func NewPubSub(ps p2ppubsub.PubSub, id peer.ID, logger zap.Logger, tracer trac`
`141`	`142`	`}`
`142`	`143`
`143`	`144`	`if tracer == nil {`
`144`		`- tracer = trace.NewNoopTracerProvider().Tracer("")`
	`145`	`+ tracer = tracernoop.NewTracerProvider().Tracer("")`
`145`	`146`	`}`
`146`	`147`
`147`	`148`	`return &rawPubSub{`
Original file line number	Diff line number	Diff line change
`@@ -20,7 +20,7 @@ func (b *baseIndex) Get(_ string) interface{} {`
`20`	`20`	`return b.index`
`21`	`21`	`}`
`22`	`22`
`23`		`-func (b *baseIndex) UpdateIndex(log ipfslog.Log, entries []ipfslog.Entry) error {`
	`23`	`+func (b *baseIndex) UpdateIndex(log ipfslog.Log, _ []ipfslog.Entry) error {`
`24`	`24`	`b.mu.Lock()`
`25`	`25`	`defer b.mu.Unlock()`
`26`	`26`	`b.index = log.Values().Slice()`