switch to http API.

This commit is contained in:
Raúl Kripalani 2021-06-21 23:10:17 +01:00
parent 502e104e6a
commit 0e2d06fc39
2 changed files with 3 additions and 3 deletions

View File

@ -439,7 +439,7 @@ func (n *Ensemble) Start() *Ensemble {
node.MockHost(n.mn),
node.Override(new(v1api.FullNode), m.FullNode),
node.Override(new(v1api.FullNode), m.FullNode.FullNode),
node.Override(new(*lotusminer.Miner), lotusminer.NewTestMiner(mineBlock, m.ActorAddr)),
// disable resource filtering so that local worker gets assigned tasks

View File

@ -30,7 +30,7 @@ func fullRpc(t *testing.T, f *TestFullNode) *TestFullNode {
srv, maddr := CreateRPCServer(t, handler)
cl, stop, err := client.NewFullNodeRPCV1(context.Background(), "ws://"+srv.Listener.Addr().String()+"/rpc/v1", nil)
cl, stop, err := client.NewFullNodeRPCV1(context.Background(), "http://"+srv.Listener.Addr().String()+"/rpc/v1", nil)
require.NoError(t, err)
t.Cleanup(stop)
f.ListenAddr, f.FullNode = maddr, cl
@ -44,7 +44,7 @@ func minerRpc(t *testing.T, m *TestMiner) *TestMiner {
srv, maddr := CreateRPCServer(t, handler)
cl, stop, err := client.NewStorageMinerRPCV0(context.Background(), "ws://"+srv.Listener.Addr().String()+"/rpc/v0", nil)
cl, stop, err := client.NewStorageMinerRPCV0(context.Background(), "http://"+srv.Listener.Addr().String()+"/rpc/v0", nil)
require.NoError(t, err)
t.Cleanup(stop)