diff --git a/core/commands/name/ipnsps.go b/core/commands/name/ipnsps.go index 12c98ca91..4ff2e3bbd 100644 --- a/core/commands/name/ipnsps.go +++ b/core/commands/name/ipnsps.go @@ -133,7 +133,10 @@ var ipnspsCancelCmd = &cmds.Command{ return cmdkit.Errorf(cmdkit.ErrClient, err.Error()) } - ok := n.PSRouter.Cancel("/ipns/" + string(pid)) + ok, err := n.PSRouter.Cancel("/ipns/" + string(pid)) + if err != nil { + return err + } return cmds.EmitOnce(res, &ipnsPubsubCancel{ok}) }, Arguments: []cmdkit.Argument{ diff --git a/namesys/ipns_resolver_validation_test.go b/namesys/ipns_resolver_validation_test.go index 0ad2e922c..c97432c6c 100644 --- a/namesys/ipns_resolver_validation_test.go +++ b/namesys/ipns_resolver_validation_test.go @@ -174,6 +174,10 @@ func (m *mockValueStore) GetValue(ctx context.Context, k string, opts ...ropts.O return m.r.GetValue(ctx, k, opts...) } +func (m *mockValueStore) SearchValue(ctx context.Context, k string, opts ...ropts.Option) (<-chan []byte, error) { + return m.r.SearchValue(ctx, k, opts...) +} + func (m *mockValueStore) GetPublicKey(ctx context.Context, p peer.ID) (ci.PubKey, error) { pk := m.kbook.PubKey(p) if pk != nil {