From 074a1ab48e04d269343e114ed9128ca94b94e512 Mon Sep 17 00:00:00 2001 From: Steven Allen Date: Mon, 24 Sep 2018 05:24:30 -0700 Subject: [PATCH] update for interface changes License: MIT Signed-off-by: Steven Allen --- core/commands/name/ipnsps.go | 5 ++++- namesys/ipns_resolver_validation_test.go | 4 ++++ 2 files changed, 8 insertions(+), 1 deletion(-) 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 {