-
Notifications
You must be signed in to change notification settings - Fork 37
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Use DialOptions, custom RPC headers for RPC and Resty clients (#1032)
* try root command * use DialOptions and custom RPC headers from env vars * remove root command * fix lint * add resty env headers everywhere * goimports * use headers explicitly, debug http * bump seth * simplify GAP connection, add README
- Loading branch information
Showing
11 changed files
with
215 additions
and
23 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
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
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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,25 @@ | ||
| ### CRIB Connector | ||
|
|
||
| This is a simple CRIB connector for OCRv1 CRIB | ||
| This code is temporary and may be removed in the future if connection logic will be simplified with [ARC](https://github.com/actions/actions-runner-controller) | ||
|
|
||
| ## Example | ||
|
|
||
| Go to the [CRIB](https://github.com/smartcontractkit/crib) repository and spin up a cluster. | ||
|
|
||
| ```shell | ||
| ./scripts/cribbit.sh crib-oh-my-crib | ||
| devspace deploy --debug --profile local-dev-simulated-core-ocr1 | ||
| ``` | ||
|
|
||
| ## Run an example test | ||
|
|
||
| ```shell | ||
| export CRIB_NAMESPACE=crib-oh-my-crib | ||
| export CRIB_NETWORK=geth # only "geth" is supported for now | ||
| export CRIB_NODES=5 # min 5 nodes | ||
| #export SETH_LOG_LEVEL=debug # these two can be enabled to debug connection issues | ||
| #export RESTY_DEBUG=true | ||
| export GAP_URL=https://localhost:8080/primary # only applicable in CI, unset the var to connect locally | ||
| go test -v -run TestCRIB | ||
| ``` |
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 |
|---|---|---|
| @@ -0,0 +1,137 @@ | ||
| package crib | ||
|
|
||
| import ( | ||
| "fmt" | ||
| "net/http" | ||
| "os" | ||
| "strconv" | ||
|
|
||
| "github.com/pkg/errors" | ||
|
|
||
| "github.com/smartcontractkit/chainlink-testing-framework/logging" | ||
| ) | ||
|
|
||
| const ( | ||
| /* | ||
| These are constants for simulated CRIB that should never change | ||
| Ideally, they should be placed into CRIB repository, however, for simplicity we keep all environment connectors in CTF | ||
| CRIB: https://github.com/smartcontractkit/crib/tree/main/core | ||
| Core Chart: https://github.com/smartcontractkit/infra-charts/tree/main/chainlink-cluster | ||
| */ | ||
| MockserverCRIBTemplate = "https://%s-mockserver%s" | ||
| InternalNodeDNSTemplate = "app-node%d" | ||
| IngressNetworkWSURLTemplate = "wss://%s-geth-%d-ws%s" | ||
| IngressNetworkHTTPURLTemplate = "https://%s-geth-%d-http%s" | ||
| // DefaultSimulatedPrivateKey is a first key used for Geth/Hardhat/Anvil | ||
| DefaultSimulatedPrivateKey = "ac0974bec39a17e36ba4a6b4d238ff944bacb478cbed5efcae784d7bf4f2ff80" | ||
| // DefaultSimulatedNetworkChainID is a default chainID we use for Geth/Hardhat/Anvil | ||
| DefaultSimulatedNetworkChainID = 1337 | ||
| HostHeader = "X-Original-Host" | ||
| ) | ||
|
|
||
| // ConnectionVars common K8s connection vars | ||
| type ConnectionVars struct { | ||
| IngressSuffix string | ||
| Namespace string | ||
| Network string | ||
| Nodes int | ||
| } | ||
|
|
||
| // CoreDONConnectionConfig Chainlink DON connection config | ||
| type CoreDONConnectionConfig struct { | ||
| *ConnectionVars | ||
| PrivateKeys []string | ||
| NodeURLs []string | ||
| NodeInternalDNS []string | ||
| NodeHeaders []map[string]string | ||
| BlockchainNodeHeaders http.Header | ||
| MockserverHeaders map[string]string | ||
| ChainID int64 | ||
| NetworkWSURL string | ||
| NetworkHTTPURL string | ||
| MockserverURL string | ||
| } | ||
|
|
||
| // CoreDONSimulatedConnection returns all vars required to connect to core DON Simulated CRIB | ||
| // connects in CI via GAP if GAP_URL is provided | ||
| func CoreDONSimulatedConnection() (*CoreDONConnectionConfig, error) { | ||
| vars, err := ReadCRIBVars() | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| var conn *CoreDONConnectionConfig | ||
| clNodeURLs := make([]string, 0) | ||
| clNodesInternalDNS := make([]string, 0) | ||
| clNodesHeaders := make([]map[string]string, 0) | ||
| for i := 1; i <= vars.Nodes; i++ { | ||
| clNodesInternalDNS = append(clNodesInternalDNS, fmt.Sprintf(InternalNodeDNSTemplate, i)) | ||
| clNodesHeaders = append(clNodesHeaders, map[string]string{ | ||
| HostHeader: fmt.Sprintf("%s-node%d%s", vars.Namespace, i, vars.IngressSuffix), | ||
| }) | ||
| } | ||
| conn = &CoreDONConnectionConfig{ | ||
| ConnectionVars: vars, | ||
| PrivateKeys: []string{DefaultSimulatedPrivateKey}, | ||
| NodeURLs: clNodeURLs, | ||
| NodeInternalDNS: clNodesInternalDNS, | ||
| NodeHeaders: clNodesHeaders, | ||
| BlockchainNodeHeaders: http.Header{ | ||
| HostHeader: []string{fmt.Sprintf("%s-geth-%d-http%s", vars.Namespace, DefaultSimulatedNetworkChainID, vars.IngressSuffix)}, | ||
| }, | ||
| MockserverHeaders: map[string]string{ | ||
| HostHeader: fmt.Sprintf("%s-mockserver%s", vars.Namespace, vars.IngressSuffix), | ||
| }, | ||
| ChainID: DefaultSimulatedNetworkChainID, | ||
| } | ||
| // GAP connection | ||
| gapURL := os.Getenv("GAP_URL") | ||
| if gapURL == "" { | ||
| logging.L.Info().Msg("Connecting to CRIB locally") | ||
| for i := 1; i <= vars.Nodes; i++ { | ||
| conn.NodeURLs = append(conn.NodeURLs, fmt.Sprintf("https://%s-node%d%s", vars.Namespace, i, vars.IngressSuffix)) | ||
| } | ||
| conn.NetworkWSURL = fmt.Sprintf(IngressNetworkWSURLTemplate, vars.Namespace, DefaultSimulatedNetworkChainID, vars.IngressSuffix) | ||
| conn.NetworkHTTPURL = fmt.Sprintf(IngressNetworkHTTPURLTemplate, vars.Namespace, DefaultSimulatedNetworkChainID, vars.IngressSuffix) | ||
| conn.MockserverURL = fmt.Sprintf(MockserverCRIBTemplate, vars.Namespace, vars.IngressSuffix) | ||
| } else { | ||
| logging.L.Info().Msg("Connecting to CRIB using GAP") | ||
| for i := 1; i <= vars.Nodes; i++ { | ||
| conn.NodeURLs = append(conn.NodeURLs, gapURL) | ||
| } | ||
| conn.NetworkWSURL = gapURL | ||
| conn.NetworkHTTPURL = gapURL | ||
| conn.MockserverURL = gapURL | ||
| } | ||
| logging.L.Debug().Any("ConnectionInfo", conn).Msg("CRIB connection info") | ||
| return conn, nil | ||
| } | ||
|
|
||
| // ReadCRIBVars read CRIB environment variables | ||
| func ReadCRIBVars() (*ConnectionVars, error) { | ||
| ingressSuffix := os.Getenv("K8S_STAGING_INGRESS_SUFFIX") | ||
| if ingressSuffix == "" { | ||
| return nil, errors.New("K8S_STAGING_INGRESS_SUFFIX must be set to connect to k8s ingresses") | ||
| } | ||
| cribNamespace := os.Getenv("CRIB_NAMESPACE") | ||
| if cribNamespace == "" { | ||
| return nil, errors.New("CRIB_NAMESPACE must be set to connect") | ||
| } | ||
| cribNetwork := os.Getenv("CRIB_NETWORK") | ||
| if cribNetwork == "" { | ||
| return nil, errors.New("CRIB_NETWORK must be set to connect, only 'geth' is supported for now") | ||
| } | ||
| cribNodes := os.Getenv("CRIB_NODES") | ||
| nodes, err := strconv.Atoi(cribNodes) | ||
| if err != nil { | ||
| return nil, errors.New("CRIB_NODES must be a number, 5-19 nodes") | ||
| } | ||
| if nodes < 2 { | ||
| return nil, fmt.Errorf("not enough chainlink nodes, need at least 2") | ||
| } | ||
| return &ConnectionVars{ | ||
| IngressSuffix: ingressSuffix, | ||
| Namespace: cribNamespace, | ||
| Network: cribNetwork, | ||
| Nodes: nodes, | ||
| }, nil | ||
| } |
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