cerc-io/lotus
10
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

extract withApiEndpoint

Browse Source
This commit is contained in:
Anton Evangelatov 2020-06-30 17:50:21 +02:00
parent b62878c260
commit e3d2d2e7c1
1 changed files with 10 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
lotus-soup/node.go
View File

@ -207,13 +207,7 @@ func prepareBootstrapper(t *TestEnvironment) (*Node, error) {
node.Online(), node.Online(),
node.Repo(repo.NewMemory(nil)), node.Repo(repo.NewMemory(nil)),
node.Override(new(modules.Genesis), modtest.MakeGenesisMem(&genesisBuffer, genesisTemplate)), node.Override(new(modules.Genesis), modtest.MakeGenesisMem(&genesisBuffer, genesisTemplate)),
node.Override(node.SetApiEndpointKey, func(lr repo.LockedRepo) error { node.Override(node.SetApiEndpointKey, withApiEndpoint),
apima, err := multiaddr.NewMultiaddr("/ip4/127.0.0.1/tcp/1234")
if err != nil {
return err
}
return lr.SetAPIEndpoint(apima)
}),
withListenAddress(bootstrapperIP), withListenAddress(bootstrapperIP),
withBootstrapper(nil), withBootstrapper(nil),
withPubsubConfig(true, pubsubTracer), withPubsubConfig(true, pubsubTracer),
@ -416,13 +410,7 @@ func prepareMiner(t *TestEnvironment) (*Node, error) {
node.Online(), node.Online(),
node.Repo(minerRepo), node.Repo(minerRepo),
node.Override(new(api.FullNode), n.fullApi), node.Override(new(api.FullNode), n.fullApi),
node.Override(node.SetApiEndpointKey, func(lr repo.LockedRepo) error { node.Override(node.SetApiEndpointKey, withApiEndpoint),
apima, err := multiaddr.NewMultiaddr("/ip4/127.0.0.1/tcp/1234")
if err != nil {
return err
}
return lr.SetAPIEndpoint(apima)
}),
withMinerListenAddress(minerIP), withMinerListenAddress(minerIP),
} }
@ -856,3 +844,11 @@ func startClientAPIServer(repo *repo.MemRepo, api api.FullNode) error {
return nil return nil
} }
func withApiEndpoint(lr repo.LockedRepo) error {
apima, err := multiaddr.NewMultiaddr("/ip4/127.0.0.1/tcp/1234")
if err != nil {
return err
}
return lr.SetAPIEndpoint(apima)
}