|
72 | 72 | testnetParticipantWalletDir string |
73 | 73 |
|
74 | 74 | alphaNodeDir = filepath.Join(homeDir, "dextest", "eth", "alpha", "node") |
75 | | - alphaIPCFile = filepath.Join(alphaNodeDir, "geth.ipc") |
76 | | - betaNodeDir = filepath.Join(homeDir, "dextest", "eth", "beta", "node") |
77 | | - betaIPCFile = filepath.Join(betaNodeDir, "geth.ipc") |
| 75 | + alphaWSEndpoint = "ws://127.0.0.1:38557" |
78 | 76 | ctx context.Context |
79 | 77 | tLogger = dex.StdOutLogger("ETHTEST", dex.LevelWarn) |
80 | 78 | simnetWalletSeed = "0812f5244004217452059e2fd11603a511b5d0870ead753df76c966ce3c71531" |
@@ -208,23 +206,23 @@ func prepareRPCClient(name, dataDir string, providers []string, net dex.Network) |
208 | 206 | return c, c.creds.acct, nil |
209 | 207 | } |
210 | 208 |
|
211 | | -func rpcEndpoints(net dex.Network) ([]string, []string) { |
| 209 | +func rpcEndpoints(net dex.Network) []string { |
212 | 210 | if net == dex.Testnet { |
213 | | - return rpcProviders, rpcProviders |
| 211 | + return rpcProviders |
214 | 212 | } |
215 | | - return []string{alphaIPCFile}, []string{betaIPCFile} |
| 213 | + return []string{alphaWSEndpoint} |
216 | 214 | } |
217 | 215 |
|
218 | 216 | func prepareTestRPCClients(initiatorDir, participantDir string, net dex.Network) (err error) { |
219 | | - initiatorEndpoints, participantEndpoints := rpcEndpoints(net) |
| 217 | + endpoints := rpcEndpoints(net) |
220 | 218 |
|
221 | | - ethClient, simnetAcct, err = prepareRPCClient("initiator", initiatorDir, initiatorEndpoints, net) |
| 219 | + ethClient, simnetAcct, err = prepareRPCClient("initiator", initiatorDir, endpoints, net) |
222 | 220 | if err != nil { |
223 | 221 | return err |
224 | 222 | } |
225 | 223 | fmt.Println("initiator address is", ethClient.address()) |
226 | 224 |
|
227 | | - participantEthClient, participantAcct, err = prepareRPCClient("participant", participantDir, participantEndpoints, net) |
| 225 | + participantEthClient, participantAcct, err = prepareRPCClient("participant", participantDir, endpoints, net) |
228 | 226 | if err != nil { |
229 | 227 | ethClient.shutdown() |
230 | 228 | return err |
@@ -258,14 +256,14 @@ func runSimnet(m *testing.M) (int, error) { |
258 | 256 |
|
259 | 257 | ethSwapContractAddr = dexeth.ContractAddresses[contractVer][dex.Simnet] |
260 | 258 |
|
261 | | - initiatorProviders, participantProviders := rpcEndpoints(dex.Simnet) |
| 259 | + providers := rpcEndpoints(dex.Simnet) |
262 | 260 |
|
263 | | - err = setupWallet(simnetWalletDir, simnetWalletSeed, "localhost:30355", initiatorProviders, dex.Simnet) |
| 261 | + err = setupWallet(simnetWalletDir, simnetWalletSeed, "localhost:30355", providers, dex.Simnet) |
264 | 262 | if err != nil { |
265 | 263 | return 1, err |
266 | 264 | } |
267 | 265 |
|
268 | | - err = setupWallet(participantWalletDir, participantWalletSeed, "localhost:30356", participantProviders, dex.Simnet) |
| 266 | + err = setupWallet(participantWalletDir, participantWalletSeed, "localhost:30356", providers, dex.Simnet) |
269 | 267 | if err != nil { |
270 | 268 | return 1, err |
271 | 269 | } |
@@ -390,13 +388,13 @@ func runTestnet(m *testing.M) (int, error) { |
390 | 388 | ethSwapContractAddr = dexeth.ContractAddresses[contractVer][dex.Testnet] |
391 | 389 | fmt.Printf("ETH swap contract address is %v\n", ethSwapContractAddr) |
392 | 390 |
|
393 | | - initiatorRPC, participantRPC := rpcEndpoints(dex.Testnet) |
| 391 | + rpc := rpcEndpoints(dex.Testnet) |
394 | 392 |
|
395 | | - err = setupWallet(testnetWalletDir, testnetWalletSeed, "localhost:30355", initiatorRPC, dex.Testnet) |
| 393 | + err = setupWallet(testnetWalletDir, testnetWalletSeed, "localhost:30355", rpc, dex.Testnet) |
396 | 394 | if err != nil { |
397 | 395 | return 1, err |
398 | 396 | } |
399 | | - err = setupWallet(testnetParticipantWalletDir, testnetParticipantWalletSeed, "localhost:30356", participantRPC, dex.Testnet) |
| 397 | + err = setupWallet(testnetParticipantWalletDir, testnetParticipantWalletSeed, "localhost:30356", rpc, dex.Testnet) |
400 | 398 | if err != nil { |
401 | 399 | return 1, err |
402 | 400 | } |
|
0 commit comments