test_utils

func BuildLocalKeyConfig(id, key string, allowedIps []string, methods *config.AuthMethods, contracts *config.AuthContracts) *config.KeyConfig

func CreateChainSupervisor() *upstreams.ChainSupervisor

func CreateEvent(id string, status protocol.AvailabilityStatus, height uint64, methods methods.Methods) protocol.UpstreamEvent

func CreateEventWithBlockData(
	id string,
	status protocol.AvailabilityStatus,
	height uint64,
	methods methods.Methods,
	blockInfo *protocol.BlockInfo,
) protocol.UpstreamEvent

func CreateExecutor() failsafe.Executor[*protocol.ResponseHolderWrapper]

func CreateRemoveEvent(id string) protocol.UpstreamEvent

func CtxWithRemoteAddr(remote string) context.Context

func CtxWithXFF(xff string) context.Context

func GetMethodMockAndUpSupervisor() (*mocks.MethodsMock, *mocks.UpstreamSupervisorMock)

func GetResultAsBytes(json []byte) []byte

func NewUpstreamRequest(t *testing.T, method string, params any) protocol.RequestHolder

func PolicyConfig(chain, method, connector, maxSize, ttl string, cacheEmpty bool) *config.CachePolicyConfig

func PolicyConfigFinalized(chain, method, connector, maxSize, ttl string, cacheEmpty bool) *config.CachePolicyConfig

func PublishEvent(chainSupervisor *upstreams.ChainSupervisor, upId string, status protocol.AvailabilityStatus, caps mapset.Set[protocol.Cap])

func TestEvmUpstream(
	ctx context.Context,
	connector connectors.ApiConnector,
	upConfig *config.Upstream,
	blockProcessor blocks.BlockProcessor,
	settingValidationProcessor *validations.SettingsValidationProcessor,
	upstreamMethods methods.Methods,
) *upstreams.Upstream