opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-06-22 21:21:43 +08:00
Code Issues Projects Releases Wiki Activity

update for interface changes

Browse Source 
License: MIT
Signed-off-by: Steven Allen <steven@stebalien.com>
This commit is contained in:
Steven Allen
2018-09-24 05:24:30 -07:00
parent 91833e288f
commit 074a1ab48e
2 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
core/commands/name/ipnsps.go
View File

@ -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{

4
namesys/ipns_resolver_validation_test.go
View File

@ -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 {