From 5c46597c532b70ec1aee11d45199cc331272d29f Mon Sep 17 00:00:00 2001 From: Brian Tiger Chow Date: Sat, 10 Jan 2015 20:05:53 -0800 Subject: [PATCH] use the core.NewIPFSNode constructor NB: all commits (from master) pass tests up to this point. fix: squashme into use core constructor --- test/epictest/addcat_test.go | 10 ++++++---- test/epictest/three_legged_cat_test.go | 12 +++++++----- 2 files changed, 13 insertions(+), 9 deletions(-) diff --git a/test/epictest/addcat_test.go b/test/epictest/addcat_test.go index 94fb67076..fa92bb943 100644 --- a/test/epictest/addcat_test.go +++ b/test/epictest/addcat_test.go @@ -11,7 +11,9 @@ import ( context "github.com/jbenet/go-ipfs/Godeps/_workspace/src/code.google.com/p/go.net/context" random "github.com/jbenet/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-random" + "github.com/jbenet/go-ipfs/core" mocknet "github.com/jbenet/go-ipfs/p2p/net/mock" + "github.com/jbenet/go-ipfs/p2p/peer" errors "github.com/jbenet/go-ipfs/util/debugerror" testutil "github.com/jbenet/go-ipfs/util/testutil" ) @@ -100,17 +102,17 @@ func DirectAddCat(data []byte, conf testutil.LatencyConfig) error { return errors.New("test initialization error") } - adder, err := makeCore(ctx, MocknetTestRepo(peers[0], mn.Host(peers[0]), conf)) + adder, err := core.NewIPFSNode(ctx, core.ConfigOption(MocknetTestRepo(peers[0], mn.Host(peers[0]), conf))) if err != nil { return err } - catter, err := makeCore(ctx, MocknetTestRepo(peers[1], mn.Host(peers[1]), conf)) + catter, err := core.NewIPFSNode(ctx, core.ConfigOption(MocknetTestRepo(peers[1], mn.Host(peers[1]), conf))) if err != nil { return err } - adder.Bootstrap(ctx, catter.Peerstore.PeerInfo(catter.PeerHost.ID())) - catter.Bootstrap(ctx, adder.Peerstore.PeerInfo(adder.PeerHost.ID())) + catter.Bootstrap(ctx, []peer.PeerInfo{adder.Peerstore.PeerInfo(adder.Identity)}) + adder.Bootstrap(ctx, []peer.PeerInfo{catter.Peerstore.PeerInfo(catter.Identity)}) keyAdded, err := adder.Add(bytes.NewReader(data)) if err != nil { diff --git a/test/epictest/three_legged_cat_test.go b/test/epictest/three_legged_cat_test.go index 997f4b3a0..3ec6cbde3 100644 --- a/test/epictest/three_legged_cat_test.go +++ b/test/epictest/three_legged_cat_test.go @@ -7,7 +7,9 @@ import ( "testing" context "github.com/jbenet/go-ipfs/Godeps/_workspace/src/code.google.com/p/go.net/context" + "github.com/jbenet/go-ipfs/core" mocknet "github.com/jbenet/go-ipfs/p2p/net/mock" + "github.com/jbenet/go-ipfs/p2p/peer" errors "github.com/jbenet/go-ipfs/util/debugerror" testutil "github.com/jbenet/go-ipfs/util/testutil" ) @@ -43,21 +45,21 @@ func RunThreeLeggedCat(data []byte, conf testutil.LatencyConfig) error { if len(peers) < numPeers { return errors.New("test initialization error") } - adder, err := makeCore(ctx, MocknetTestRepo(peers[0], mn.Host(peers[0]), conf)) + adder, err := core.NewIPFSNode(ctx, core.ConfigOption(MocknetTestRepo(peers[0], mn.Host(peers[0]), conf))) if err != nil { return err } - catter, err := makeCore(ctx, MocknetTestRepo(peers[1], mn.Host(peers[1]), conf)) + catter, err := core.NewIPFSNode(ctx, core.ConfigOption(MocknetTestRepo(peers[1], mn.Host(peers[1]), conf))) if err != nil { return err } - bootstrap, err := makeCore(ctx, MocknetTestRepo(peers[2], mn.Host(peers[2]), conf)) + bootstrap, err := core.NewIPFSNode(ctx, core.ConfigOption(MocknetTestRepo(peers[2], mn.Host(peers[2]), conf))) if err != nil { return err } boostrapInfo := bootstrap.Peerstore.PeerInfo(bootstrap.PeerHost.ID()) - adder.Bootstrap(ctx, boostrapInfo) - catter.Bootstrap(ctx, boostrapInfo) + adder.Bootstrap(ctx, []peer.PeerInfo{boostrapInfo}) + catter.Bootstrap(ctx, []peer.PeerInfo{boostrapInfo}) keyAdded, err := adder.Add(bytes.NewReader(data)) if err != nil {