cascade/ipfs-cluster
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

namespace ipfs_mock datastore

Browse Source 
License: MIT
Signed-off-by: Adrian Lanzafame <adrianlanzafame92@gmail.com>
This commit is contained in:
Adrian Lanzafame 2019-05-07 12:04:50 +10:00
parent 43fb2cf857
commit 93c0adc696
No known key found for this signature in database
GPG Key ID: 87E40C5D62EAE192
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
ipfscluster_test.go
View File

@ -136,7 +136,9 @@ func randomBytes() []byte {
func createComponents(t *testing.T, host host.Host, pubsub *pubsub.PubSub, dht *dht.IpfsDHT, i int, staging bool) (*Config, ds.Datastore, Consensus, []API, IPFSConnector, PinTracker, PeerMonitor, PinAllocator, Informer, Tracer, *test.IpfsMock) {
ctx := context.Background()
mock := test.NewIpfsMock(t)
peername := fmt.Sprintf("peer_%d", i)
mock := test.NewIpfsMock(t, peername)
//apiAddr, _ := ma.NewMultiaddr(fmt.Sprintf("/ip4/127.0.0.1/tcp/%d", apiPort+i))
// Bind on port 0
@ -146,8 +148,6 @@ func createComponents(t *testing.T, host host.Host, pubsub *pubsub.PubSub, dht *
proxyAddr, _ := ma.NewMultiaddr("/ip4/127.0.0.1/tcp/0")
nodeAddr, _ := ma.NewMultiaddr(fmt.Sprintf("/ip4/%s/tcp/%d", mock.Addr, mock.Port))
peername := fmt.Sprintf("peer_%d", i)
clusterCfg, apiCfg, ipfsproxyCfg, ipfshttpCfg, badgerCfg, raftCfg, crdtCfg, maptrackerCfg, statelesstrackerCfg, psmonCfg, diskInfCfg, tracingCfg := testingConfigs()
clusterCfg.ID = host.ID()

4
test/ipfs_mock.go
View File

@ -98,9 +98,9 @@ type mockBlockPutResp struct {
}
// NewIpfsMock returns a new mock.
func NewIpfsMock(t *testing.T) *IpfsMock {
func NewIpfsMock(t *testing.T, ns string) *IpfsMock {
store := inmem.New()
st, err := dsstate.New(store, "", dsstate.DefaultHandle())
st, err := dsstate.New(store, ns, dsstate.DefaultHandle())
if err != nil {
t.Fatal(err)
}