loader

type Call3InputType struct {
	Target       common.Address
	AllowFailure bool
	CallData     []byte
}

type Call3OutputType struct {
	Success    bool
	ReturnData []uint8
}

type CallJob struct {
	Contract types.EthAddress
	CallData []byte
	Result   chan []byte
}

type ChainConfig struct {
	NetworkName         string
	ChainID             int    `json:"chain_id"`
	RPCEndpoint         string `json:"rpc"`
	Subgraph            string `json:"subgraph"`
	QueryContract       string `json:"query_contract"`
	QueryContractABI    string `json:"query_contract_abi"`
	KnockoutTickWidth   int    `json:"knockout_tick_width"`
	MulticallDisabled   bool   `json:"multicall_disabled"`
	MulticallContract   string `json:"multicall_contract"`
	MulticallMaxBatch   int    `json:"multicall_max_batch"`
	MulticallIntervalMs int    `json:"multicall_interval_ms"`
}

type CombinedData struct {
	Meta  combinedEntry   `json:"_meta"`
	Swaps json.RawMessage `json:"swaps"`
	Aggs  json.RawMessage `json:"aggEvents"`
	Liqs  json.RawMessage `json:"liquidityChanges"`
	Kos   json.RawMessage `json:"knockoutCrosses"`
	Fees  json.RawMessage `json:"feeChanges"`
	Bals  json.RawMessage `json:"userBalances"`
}

type CombinedGraphReqVars struct {
	Order             string `json:"orderDir"`
	SwapMinBlock      int    `json:"swapMinBlock"`
	SwapMaxBlock      int    `json:"swapMaxBlock"`
	LiquidityMinBlock int    `json:"liqMinBlock"`
	LiquidityMaxBlock int    `json:"liqMaxBlock"`
	AggMinBlock       int    `json:"aggMinBlock"`
	AggMaxBlock       int    `json:"aggMaxBlock"`
	BalMinBlock       int    `json:"balMinBlock"`
	BalMaxBlock       int    `json:"balMaxBlock"`
	FeeMinBlock       int    `json:"feeMinBlock"`
	FeeMaxBlock       int    `json:"feeMaxBlock"`
	KoMinBlock        int    `json:"koMinBlock"`
	KoMaxBlock        int    `json:"koMaxBlock"`
}

type CrocQuery struct {
	// contains filtered or unexported fields
}

type GraphReqVars struct {
	Order   string `json:"orderDir"`
	MinTime int    `json:"minTime"`
	MaxTime int    `json:"maxTime"`
}

type GraphRequest[V GraphReqVars | CombinedGraphReqVars] struct {
	Query     SubgraphQuery `json:"query"`
	Variables V             `json:"variables"`
}

type ICrocQuery interface {
	QueryAmbientLiq(pos types.PositionLocation) (*big.Int, error)
	QueryRangeLiquidity(pos types.PositionLocation) (*big.Int, error)
	QueryRangeRewardsLiq(pos types.PositionLocation) (*big.Int, error)
	QueryKnockoutLiq(pos types.KOClaimLocation) (KnockoutLiqResp, error)
	QueryKnockoutPivot(pos types.PositionLocation) (uint32, error)
	QueryLevel(pool types.PoolLocation, tick int) (LevelResp, error)
}

type Ingester interface {
	IngestEntries(data []byte, queryStartBlock, queryEndBlock int) (lastObs int, hasMore bool, err error)
}

type KnockoutLiqResp struct {
	Liq        *big.Int
	KnockedOut bool
}

type LevelResp struct {
	BidLots     *big.Int
	AskLots     *big.Int
	FeeOdometer uint64
}

type NetworkConfig map[types.NetworkName]ChainConfig

type NonCrocQuery struct{}

type OnChainLoader struct {
	Cfg NetworkConfig
	// contains filtered or unexported fields
}

type SubgraphError struct {
	Errors []struct {
		Message string `json:"message"`
	} `json:"errors"`
	Data json.RawMessage `json:"data"`
}

type SubgraphQuery string

type SubgraphStartBlocks struct {
	Swaps int `json:"swap"`
	Aggs  int `json:"agg"`
	Bal   int `json:"bal"`
	Fee   int `json:"fee"`
	Ko    int `json:"ko"`
	Liq   int `json:"liq"`
}

type SyncChannel[R any, S any] struct {
	RowsIngested int
	// contains filtered or unexported fields
}

type SyncChannelConfig struct {
	Chain   ChainConfig
	Network types.NetworkName
	Query   string
}