test_utils

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

func CreateChainSupervisor() upstreams.ChainSupervisor

func CreateEvent(id string, status protocol.AvailabilityStatus, head protocol.Block, methods methods.Methods) protocol.UpstreamEvent

func CreateEventWithBlockData(
	id string,
	status protocol.AvailabilityStatus,
	head protocol.Block,
	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 NewEvmChainSpecific(connector connectors.ApiConnector) *specific.EvmChainSpecificObject

func NewSolanaChainSpecific(ctx context.Context, connector connectors.ApiConnector) *specific.SolanaChainSpecificObject

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(
	connector connectors.ApiConnector,
	upConfig *config.Upstream,
	upstreamMethods methods.Methods,
	processorAggregator *event_processors.UpstreamProcessorAggregator,
) *upstreams.BaseUpstream

func UpstreamJsonRpcRequestMatcher(request protocol.RequestHolder) func(protocol.RequestHolder) bool