Function TestHttpServer_HandleHealthCheck

erpc/http_server_test.go:3713–4525

(t *testing.T)

}

func TestHttpServer_HandleHealthCheck(t *testing.T) {
	testCtx, testCtxCancel := context.WithCancel(context.Background())
	defer testCtxCancel()

	logger := &log.Logger
	vr := thirdparty.NewVendorsRegistry()
	pr, err := thirdparty.NewProvidersRegistry(logger, vr, []*common.ProviderConfig{}, nil)
	require.NoError(t, err)
	ssr, err := data.NewSharedStateRegistry(testCtx, logger, &common.SharedStateConfig{
		ClusterKey: "test",
		Connector: &common.ConnectorConfig{
			Driver: common.DriverMemory,
			Memory: &common.MemoryConnectorConfig{
				MaxItems: 100_000, MaxTotalSize: "1GB",
			},
		},
	})
	require.NoError(t, err)
	mtk := health.NewTracker(logger, "test", 1*time.Second)
	up1 := &common.UpstreamConfig{
		Id:       "test-upstream",
		Type:     common.UpstreamTypeEvm,
		Endpoint: "http://rpc1.localhost",
		Evm: &common.EvmUpstreamConfig{
			ChainId: 123,
		},
	}

	tests := []struct {
		name         string
		setupServer  func(ctx context.Context) *HttpServer
		projectId    string
		architecture string
		chainId      string
		request      *http.Request
		wantStatus   int
		wantBody     string
		wantCacheHit bool
	}{
		{
			name: "Basic healthcheck",
			setupServer: func(ctx context.Context) *HttpServer {
				pp := &PreparedProject{
					Config:            &common.ProjectConfig{Id: "test", Upstreams: []*common.UpstreamConfig{up1}},
					upstreamsRegistry: upstream.NewUpstreamsRegistry(ctx, logger, "", []*common.UpstreamConfig{up1}, ssr, nil, vr, pr, nil, mtk, nil),
				}
				pp.upstreamsRegistry.Bootstrap(ctx)
				pp.networksRegistry = NewNetworksRegistry(pp, ctx, pp.upstreamsRegistry, mtk, nil, nil, nil, logger)
				return &HttpServer{
					logger: logger,
					erpc: &ERPC{
						projectsRegistry: &ProjectsRegistry{
							preparedProjects: map[string]*PreparedProject{
								"test": pp,
							},
						},
					},
					healthCheckCfg: &common.HealthCheckConfig{