Function TestHttpServer_EvmGetBlockByNumber

erpc/http_server_test.go:5531–7765

(t *testing.T)

}

func TestHttpServer_EvmGetBlockByNumber(t *testing.T) {
	util.ResetGock()
	defer util.ResetGock()

	t.Run("FallbackToHighestBlockIfUpstreamReturnsOlderBlock", func(t *testing.T) {
		// 1. Reset gock, set up poller mocks, etc.
		util.ResetGock()
		defer util.ResetGock()
		util.SetupMocksForEvmStatePoller()

		// 2. Create a config with 2 upstreams and enforce highest block
		cfg := &common.Config{
			Server: &common.ServerConfig{
				MaxTimeout: common.Duration(5 * time.Second).Ptr(),
			},
			Projects: []*common.ProjectConfig{
				{
					Id: "test_project",
					Networks: []*common.NetworkConfig{
						{
							Architecture: "evm",
							Evm: &common.EvmNetworkConfig{
								ChainId: 123,
								Integrity: &common.EvmIntegrityConfig{
									EnforceHighestBlock: util.BoolPtr(true),
								},
							},
						},
					},
					Upstreams: []*common.UpstreamConfig{
						{
							Id:       "rpc1",
							Endpoint: "http://rpc1.localhost",
							Type:     common.UpstreamTypeEvm,
							Evm: &common.EvmUpstreamConfig{
								ChainId:             123,
								StatePollerInterval: common.Duration(10 * time.Second),
							},
						},
						{
							Id:       "rpc2",
							Endpoint: "http://rpc2.localhost",
							Type:     common.UpstreamTypeEvm,
							Evm: &common.EvmUpstreamConfig{
								ChainId:             123,
								StatePollerInterval: common.Duration(10 * time.Second),
							},
						},
					},
				},
			},
		}

		// 3. Request: eth_getBlockByNumber("latest", true)
		requestBody := `{
			"jsonrpc": "2.0",
			"id":      1,
			"method":  "eth_getBlockByNumber",