-
Notifications
You must be signed in to change notification settings - Fork 39
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Networktests: run local gateway against testnets (#1824)
- Loading branch information
1 parent
05eebc9
commit 057276d
Showing
4 changed files
with
109 additions
and
17 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,60 +1,138 @@ | ||
| package env | ||
|
|
||
| import ( | ||
| "fmt" | ||
|
|
||
| gethlog "github.com/ethereum/go-ethereum/log" | ||
| "github.com/ten-protocol/go-ten/go/enclave/genesis" | ||
| "github.com/ten-protocol/go-ten/integration" | ||
| "github.com/ten-protocol/go-ten/integration/common/testlog" | ||
| "github.com/ten-protocol/go-ten/integration/networktest" | ||
| gatewaycfg "github.com/ten-protocol/go-ten/tools/walletextension/config" | ||
| "github.com/ten-protocol/go-ten/tools/walletextension/container" | ||
| ) | ||
|
|
||
| const ( | ||
| // these ports were picked arbitrarily, if we want plan to use these tests on CI we need to use ports in the constants.go file | ||
| _gwHTTPPort = 11180 | ||
| _gwWSPort = 11181 | ||
| ) | ||
|
|
||
| func SepoliaTestnet() networktest.Environment { | ||
| connector := NewTestnetConnector( | ||
| func SepoliaTestnet(opts ...TestnetEnvOption) networktest.Environment { | ||
| connector := newTestnetConnector( | ||
| "http://erpc.sepolia-testnet.ten.xyz:80", // this is actually a validator... | ||
| []string{"http://erpc.sepolia-testnet.ten.xyz:80"}, | ||
| "http://sepolia-testnet-faucet.uksouth.azurecontainer.io/fund/eth", | ||
| "https://rpc.sepolia.org/", | ||
| "https://testnet.ten.xyz", // :81 for websocket | ||
| ) | ||
| return &testnetEnv{connector} | ||
| return newTestnetEnv(connector, opts...) | ||
| } | ||
|
|
||
| func UATTestnet() networktest.Environment { | ||
| connector := NewTestnetConnector( | ||
| func UATTestnet(opts ...TestnetEnvOption) networktest.Environment { | ||
| connector := newTestnetConnector( | ||
| "http://erpc.uat-testnet.ten.xyz:80", // this is actually a validator... | ||
| []string{"http://erpc.uat-testnet.ten.xyz:80"}, | ||
| "http://uat-testnet-faucet.uksouth.azurecontainer.io/fund/eth", | ||
| "ws://uat-testnet-eth2network.uksouth.cloudapp.azure.com:9000", | ||
| "https://uat-testnet.ten.xyz", | ||
| ) | ||
| return &testnetEnv{connector} | ||
| return newTestnetEnv(connector, opts...) | ||
| } | ||
|
|
||
| func DevTestnet() networktest.Environment { | ||
| connector := NewTestnetConnector( | ||
| func DevTestnet(opts ...TestnetEnvOption) networktest.Environment { | ||
| connector := newTestnetConnector( | ||
| "http://erpc.dev-testnet.ten.xyz:80", // this is actually a validator... | ||
| []string{"http://erpc.dev-testnet.ten.xyz:80"}, | ||
| "http://dev-testnet-faucet.uksouth.azurecontainer.io/fund/eth", | ||
| "ws://dev-testnet-eth2network.uksouth.cloudapp.azure.com:9000", | ||
| "https://dev-testnet.ten.xyz", | ||
| ) | ||
| return &testnetEnv{connector} | ||
| return newTestnetEnv(connector, opts...) | ||
| } | ||
|
|
||
| // LongRunningLocalNetwork is a local network, the l1WSURL is optional (can be empty string), only required if testing L1 interactions | ||
| func LongRunningLocalNetwork(l1WSURL string) networktest.Environment { | ||
| connector := NewTestnetConnectorWithFaucetAccount( | ||
| connector := newTestnetConnectorWithFaucetAccount( | ||
| "ws://127.0.0.1:26900", | ||
| []string{"ws://127.0.0.1:26901"}, | ||
| genesis.TestnetPrefundedPK, | ||
| l1WSURL, | ||
| "", | ||
| ) | ||
| return &testnetEnv{connector} | ||
| return newTestnetEnv(connector) | ||
| } | ||
|
|
||
| type TestnetEnvOption func(env *testnetEnv) | ||
|
|
||
| type testnetEnv struct { | ||
| testnetConnector networktest.NetworkConnector | ||
| testnetConnector *testnetConnector | ||
| localTenGateway bool | ||
| tenGatewayContainer *container.WalletExtensionContainer | ||
| logger gethlog.Logger | ||
| } | ||
|
|
||
| func (t *testnetEnv) Prepare() (networktest.NetworkConnector, func(), error) { | ||
| if t.logger == nil { | ||
| t.logger = testlog.Logger() | ||
| } | ||
| if t.localTenGateway { | ||
| t.startTenGateway() | ||
| } | ||
| cleanup := func() { | ||
| if t.tenGatewayContainer != nil { | ||
| go func() { | ||
| err := t.tenGatewayContainer.Stop() | ||
| if err != nil { | ||
| fmt.Println("failed to stop ten gateway", err.Error()) | ||
| } | ||
| }() | ||
| } | ||
| } | ||
| // no cleanup or setup required for the testnet connector (unlike dev network which has teardown and startup to handle) | ||
| return t.testnetConnector, func() {}, nil | ||
| return t.testnetConnector, cleanup, nil | ||
| } | ||
|
|
||
| func (t *testnetEnv) startTenGateway() { | ||
| validator := t.testnetConnector.ValidatorRPCAddress(0) | ||
| // remove http:// prefix for the gateway config | ||
| validatorHTTP := validator[len("http://"):] | ||
| // replace the last character with a 1 (expect it to be zero), this is good enough for these tests | ||
| validatorWS := validatorHTTP[:len(validatorHTTP)-1] + "1" | ||
| cfg := gatewaycfg.Config{ | ||
| WalletExtensionHost: "127.0.0.1", | ||
| WalletExtensionPortHTTP: _gwHTTPPort, | ||
| WalletExtensionPortWS: _gwWSPort, | ||
| NodeRPCHTTPAddress: validatorHTTP, | ||
| NodeRPCWebsocketAddress: validatorWS, | ||
| LogPath: "sys_out", | ||
| VerboseFlag: false, | ||
| DBType: "sqlite", | ||
| TenChainID: integration.TenChainID, | ||
| } | ||
| tenGWContainer := container.NewWalletExtensionContainerFromConfig(cfg, t.logger) | ||
| go func() { | ||
| fmt.Println("Starting Ten Gateway, HTTP Port:", _gwHTTPPort, "WS Port:", _gwWSPort) | ||
| err := tenGWContainer.Start() | ||
| if err != nil { | ||
| t.logger.Error("failed to start ten gateway", "err", err) | ||
| panic(err) | ||
| } | ||
| t.tenGatewayContainer = tenGWContainer | ||
| }() | ||
| t.testnetConnector.tenGatewayURL = fmt.Sprintf("http://localhost:%d", _gwHTTPPort) | ||
| } | ||
|
|
||
| func newTestnetEnv(testnetConnector *testnetConnector, opts ...TestnetEnvOption) networktest.Environment { | ||
| env := &testnetEnv{testnetConnector: testnetConnector} | ||
| for _, opt := range opts { | ||
| opt(env) | ||
| } | ||
| return env | ||
| } | ||
|
|
||
| func WithLocalTenGateway() TestnetEnvOption { | ||
| return func(env *testnetEnv) { | ||
| env.localTenGateway = true | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters