Function TestHttpServer_ProviderBasedUpstreams

erpc/http_server_test.go:4527–5091

(t *testing.T)

}

func TestHttpServer_ProviderBasedUpstreams(t *testing.T) {
	t.Run("SimpleCallExistingNetwork", func(t *testing.T) {
		cfg := &common.Config{
			Server: &common.ServerConfig{
				MaxTimeout: common.Duration(5 * time.Second).Ptr(),
			},
			Projects: []*common.ProjectConfig{
				{
					Id: "test_project",
					Networks: []*common.NetworkConfig{
						{
							Architecture: common.ArchitectureEvm,
							Evm: &common.EvmNetworkConfig{
								ChainId: 123,
							},
						},
					},
					Providers: []*common.ProviderConfig{
						{
							Id:     "alchemy-prod",
							Vendor: "alchemy",
							Settings: map[string]interface{}{
								"apiKey": "test-key",
							},
							UpstreamIdTemplate: "<PROVIDER>-<NETWORK>",
						},
					},
				},
			},
		}

		util.ResetGock()
		defer util.ResetGock()
		_ = util.SetupMocksForUpstream("https://eth-mainnet.g.alchemy.com", map[string]interface{}{
			"chainId": "0x1",
		})

		gock.New("https://eth-mainnet.g.alchemy.com").
			Post("/v2/test-key").
			Filter(func(request *http.Request) bool {
				return strings.Contains(util.SafeReadBody(request), "eth_getBalance")
			}).
			Reply(200).
			JSON(map[string]interface{}{
				"jsonrpc": "2.0",
				"id":      1,
				"result":  "0x123456",
			})

		sendRequest, _, _, shutdown, _ := createServerTestFixtures(cfg, t)
		defer shutdown()

		statusCode, _, body := sendRequest(`{"jsonrpc":"2.0","method":"eth_getBalance","params":[],"id":1234}`, nil, map[string]string{
			"chainId": "1",
		})
		assert.Equal(t, http.StatusOK, statusCode)
		assert.Contains(t, body, "0x123456")
	})