opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-07-01 02:30:39 +08:00
Code Issues Projects Releases Wiki Activity

test(bitswap)

Browse Source
This commit is contained in:
Brian Tiger Chow
2014-09-19 12:58:12 -07:00
parent 543dfeea35
commit 9f685af14f
1 changed files with 31 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
exchange/bitswap/bitswap_test.go
View File

@ -33,19 +33,45 @@ func TestProviderForKeyButNetworkCannotFind(t *testing.T) {
net := LocalNetwork()
rs := newRoutingServer()
ipfs := session(net, rs, []byte("peer id"))
// ctx := context.Background()
ctx, _ := context.WithTimeout(context.Background(), time.Nanosecond)
block := testutil.NewBlockOrFail(t, "block")
block := testutil.NewBlockOrFail(t, "block")
rs.Announce(&peer.Peer{}, block.Key()) // but not on network
_, err := ipfs.exchange.Block(ctx, block.Key())
solo := session(net, rs, []byte("peer id"))
ctx, _ := context.WithTimeout(context.Background(), time.Nanosecond)
_, err := solo.exchange.Block(ctx, block.Key())
if err != context.DeadlineExceeded {
t.Fatal("Expected DeadlineExceeded error")
}
}
// TestGetBlockAfterRequesting...
func TestGetBlockFromPeerAfterPeerAnnounces(t *testing.T) {
t.Skip("Failing. Work in progress")
net := LocalNetwork()
rs := newRoutingServer()
block := testutil.NewBlockOrFail(t, "block")
hasBlock := session(net, rs, []byte("hasBlock"))
rs.Announce(hasBlock.peer, block.Key())
hasBlock.blockstore.Put(block)
hasBlock.exchange.HasBlock(context.Background(), block)
wantsBlock := session(net, rs, []byte("wantsBlock"))
ctx, _ := context.WithTimeout(context.Background(), time.Second)
_, err := wantsBlock.exchange.Block(ctx, block.Key())
if err != nil {
t.Log(err)
t.Fatal("Expected to succeed")
}
}
type ipfs struct {
peer *peer.Peer
exchange exchange.Interface