eqcapital_robinhood_evidence

paulkullich

v0.1.0/1 downloads

Package ref

eqcapital-robinhood-evidence@v0.1.0

Download .spkg

Run package

CLI

Run map_evidence from the command line.

substreams run eqcapital-robinhood-evidence@v0.1.0 map_evidence -e robinhood

Authenticate by running substreams auth or directly on thegraph.market (see docs).

Modules

Execution graph

9 modules

mapMain

map_evidence

from #55234000

Output

eqcapital.evidence.v1.Evidence

Inputs

paramsdex:map_dex map_progress

map

map_progress

from #55234000

Output

sf.substreams.v1.Clock

Inputs

sf.substreams.v1.Clock

Show 7 dependencies

map

dex:map_dex

from #8928

Output

eqcapital.substreams.v1.DexTape

Inputs

dex:pools:uniswap_v2:map_events dex:pools:uniswap_v3:map_events dex:pools:uniswap_v4:map_events

map

dex:pools:uniswap_v2:map_events

from #8928

Output

evm.uniswap.v2.Events

Inputs

paramssf.ethereum.type.v2.Block dex:pools:uniswap_v2:store_pools

store

dex:pools:uniswap_v2:store_pools

from #8928

Store value

bigint

Update policy

set

Inputs

paramssf.ethereum.type.v2.Block

map

dex:pools:uniswap_v3:map_events

from #8930

Output

evm.uniswap.v3.Events

Inputs

paramssf.ethereum.type.v2.Block dex:pools:uniswap_v3:store_pools

store

dex:pools:uniswap_v3:store_pools

from #8930

Store value

bigint

Update policy

set

Inputs

paramssf.ethereum.type.v2.Block

map

dex:pools:uniswap_v4:map_events

from #9070

Output

evm.uniswap.v4.Events

Inputs

paramssf.ethereum.type.v2.Block dex:pools:uniswap_v4:store_pools

store

dex:pools:uniswap_v4:store_pools

from #9070

Store value

proto:evm.store.V4PoolStore

Update policy

set

Inputs

paramssf.ethereum.type.v2.Block

Protobuf

evm.uniswap.v2

Eventsmain

evm.uniswap.v2.Events

Swap[]swap = 1

UniswapV2Pair

Sync[]sync = 2

Mint[]mint = 3

Burn[]burn = 4

PairCreated[]pair_created = 5

UniswapV2Factory

AssociatedEvmTransaction[]associated_evm_transaction = 6

Transfer[]transfer = 7

Approval[]approval = 8

Approval

evm.uniswap.v2.Approval

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytespair_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytesowner = 11

-- event --

bytesspender = 12

address (indexed)

stringvalue = 13

uint256

Burn

evm.uniswap.v2.Burn

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytespair_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytessender = 10

-- event --

stringamount0 = 11

uint256

stringamount1 = 12

uint256

bytesto = 13

address

Mint

evm.uniswap.v2.Mint

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytespair_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytessender = 10

-- event --

stringamount0 = 11

uint256

stringamount1 = 12

uint256

PairCreated

evm.uniswap.v2.PairCreated

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytespair_factory_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytestoken0 = 10

-- event --

bytestoken1 = 11

bytespair_address = 12

uint64all_pairs_length = 13

total number of pairs created

Swap

evm.uniswap.v2.Swap

bytestx_hash = 1

-- transaction --

bytescaller = 4

-- call --

bytespair_address = 5

-- log --

uint64ordinal = 6

log.ordinal

uint32log_index = 7

log.index

uint32transaction_index = 8

log.transaction_index

uint32block_index = 9

log.block_index

bytessender = 10

-- event --

stringamount0_in = 11

uint256

stringamount0_out = 12

uint256

stringamount1_in = 13

uint256

stringamount1_out = 14

uint256

bytesto = 15

address

Sync

evm.uniswap.v2.Sync

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytespair_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

stringreserve0 = 21

-- event --

stringreserve1 = 22

uint112

Transfer

evm.uniswap.v2.Transfer

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytespair_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytesfrom = 11

-- event --

bytesto = 12

address (indexed)

stringvalue = 13

uint256

evm.uniswap.v3

Eventsmain

evm.uniswap.v3.Events

https://github.com/Uniswap/v3-core/blob/main/contracts/interfaces/IUniswapV3Factory.sol https://github.com/Uniswap/v3-core/blob/main/contracts/interfaces/IUniswapV3Pool.sol https://github.com/Uniswap/v3-core/blob/main/contracts/interfaces/pool/IUniswapV3PoolEvents.sol

Swap[]swap = 1

IUniswapV3Pool

Initialize[]initialize = 2

Mint[]mint = 3

Collect[]collect = 4

Burn[]burn = 5

Flash[]flash = 6

IncreaseObservationCardinalityNext[]increase_observation_cardinality_next = 7

SetFeeProtocol[]set_fee_protocol = 8

CollectProtocol[]collect_protocol = 9

PoolCreated[]pool_created = 10

IUniswapV3Factory

OwnerChanged[]owner_changed = 11

FeeAmountEnabled[]fee_amount_enabled = 12

AssociatedEvmTransaction[]associated_evm_transaction = 13

PositionManagerApproval[]position_manager_approval = 14

PositionManager (ERC721-like for V3)

PositionManagerApprovalForAll[]position_manager_approval_for_all = 15

PositionManagerCollect[]position_manager_collect = 16

PositionManagerDecreaseLiquidity[]position_manager_decrease_liquidity = 17

PositionManagerIncreaseLiquidity[]position_manager_increase_liquidity = 18

PositionManagerTransfer[]position_manager_transfer = 19

Burn

evm.uniswap.v3.Burn

/ @notice Emitted when a position's liquidity is removed / @dev Does not withdraw any fees earned by the liquidity position, which must be withdrawn via #collect / @param owner The owner of the position for which liquidity is removed / @param tickLower The lower tick of the position / @param tickUpper The upper tick of the position / @param amount The amount of liquidity to remove / @param amount0 The amount of token0 withdrawn / @param amount1 The amount of token1 withdrawn

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytespool_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytesowner = 10

-- event --

int32tick_lower = 11

int24

int32tick_upper = 12

int24

stringamount = 13

uint128

stringamount0 = 14

uint256

stringamount1 = 15

uint256

Collect

evm.uniswap.v3.Collect

/ @notice Emitted when fees are collected by the owner of a position / @dev Collect events may be emitted with zero amount0 and amount1 when the caller chooses not to collect fees / @param owner The owner of the position for which fees are collected / @param tickLower The lower tick of the position / @param tickUpper The upper tick of the position / @param amount0 The amount of token0 fees collected / @param amount1 The amount of token1 fees collected

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytespool_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytesowner = 10

-- event --

bytesrecipient = 11

address

int32tick_lower = 12

int24

int32tick_upper = 13

int24

stringamount0 = 14

uint128

stringamount1 = 15

uint128

CollectProtocol

evm.uniswap.v3.CollectProtocol

/ @notice Emitted when the collected protocol fees are withdrawn by the factory owner / @param sender The address that collects the protocol fees / @param recipient The address that receives the collected protocol fees / @param amount0 The amount of token0 protocol fees that is withdrawn / @param amount0 The amount of token1 protocol fees that is withdrawn

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytespool_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytessender = 10

-- event --

bytesrecipient = 11

address

stringamount0 = 12

uint128

stringamount1 = 13

uint128

FeeAmountEnabled

evm.uniswap.v3.FeeAmountEnabled

/ @notice Emitted when a new fee amount is enabled for pool creation via the factory / @param fee The enabled fee, denominated in hundredths of a bip / @param tickSpacing The minimum number of ticks between initialized ticks for pools created with the given fee

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytespool_factory_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

uint64fee = 10

-- event --

int32tick_spacing = 11

int24

Flash

evm.uniswap.v3.Flash

/ @notice Emitted by the pool for any flashes of token0/token1 / @param sender The address that initiated the swap call, and that received the callback / @param recipient The address that received the tokens from flash / @param amount0 The amount of token0 that was flashed / @param amount1 The amount of token1 that was flashed / @param paid0 The amount of token0 paid for the flash, which can exceed the amount0 plus the fee / @param paid1 The amount of token1 paid for the flash, which can exceed the amount1 plus the fee

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytespool_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytessender = 10

-- event --

bytesrecipient = 11

address

stringamount0 = 12

uint256

stringamount1 = 13

uint256

stringpaid0 = 14

uint256

stringpaid1 = 15

uint256

IncreaseObservationCardinalityNext

evm.uniswap.v3.IncreaseObservationCardinalityNext

/ @notice Emitted by the pool for increases to the number of observations that can be stored / @dev observationCardinalityNext is not the observation cardinality until an observation is written at the index / just before a mint/swap/burn. / @param observationCardinalityNextOld The previous value of the next observation cardinality / @param observationCardinalityNextNew The updated value of the next observation cardinality

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytespool_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

uint64observation_cardinality_next_old = 10

-- event --

uint64observation_cardinality_next_new = 11

uint16

Initialize

evm.uniswap.v3.Initialize

In Uniswap v3, the initialize function is a crucial setup step that configures a newly deployed pool by setting its initial square root price (sqrtPriceX96) and corresponding tick value. After the pool is created via the PoolCreated event, calling initialize establishes the starting price and essential parameters, thereby enabling the pool to process swaps and support liquidity provisioning. Without this initialization, the pool remains unconfigured and cannot operate properly.

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytespool_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

stringsqrt_price_x96 = 21

-- event --

int32tick = 22

int24

Mint

evm.uniswap.v3.Mint

/ @notice Emitted when liquidity is minted for a given position / @param sender The address that minted the liquidity / @param owner The owner of the position and recipient of any minted liquidity / @param tickLower The lower tick of the position / @param tickUpper The upper tick of the position / @param amount The amount of liquidity minted to the position range / @param amount0 How much token0 was required for the minted liquidity / @param amount1 How much token1 was required for the minted liquidity

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytespool_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytessender = 10

-- event --

bytesowner = 11

address

int32tick_lower = 12

int24

int32tick_upper = 13

int24

stringamount = 14

uint128

stringamount0 = 15

uint256

stringamount1 = 16

uint256

OwnerChanged

evm.uniswap.v3.OwnerChanged

/ @notice Emitted when the owner of the factory is changed / @param oldOwner The owner before the owner was changed / @param newOwner The owner after the owner was changed

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytespool_factory_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytesold_owner = 10

-- event --

bytesnew_owner = 11

address

PoolCreated

evm.uniswap.v3.PoolCreated

/ @notice Emitted when a pool is created / @param token0 The first token of the pool by address sort order / @param token1 The second token of the pool by address sort order / @param fee The fee collected upon every swap in the pool, denominated in hundredths of a bip / @param tickSpacing The minimum number of ticks between initialized ticks / @param pool The address of the created pool

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytespool_factory_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytestoken0 = 10

-- event --

bytestoken1 = 11

uint64fee = 12

uint24 (e.g., 3000 represents 0.30%)

int32tick_spacing = 13

int24 (e.g., 60)

bytespool_address = 14

address

PositionManagerApproval

evm.uniswap.v3.PositionManagerApproval

/ @notice Emitted when approval is given to approved to manage tokenId.

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytesposition_manager_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytesowner = 10

-- event --

bytesapproved = 11

address

stringtoken_id = 12

uint256

PositionManagerApprovalForAll

evm.uniswap.v3.PositionManagerApprovalForAll

/ @notice Emitted when operator is enabled or disabled for owner.

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytesposition_manager_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytesowner = 10

-- event --

bytesoperator = 11

address

boolapproved = 12

bool

PositionManagerCollect

evm.uniswap.v3.PositionManagerCollect

/ @notice Emitted when fees are collected from a position via the PositionManager.

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytesposition_manager_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

stringtoken_id = 10

-- event --

bytesrecipient = 11

address

stringamount0 = 12

uint256

stringamount1 = 13

uint256

PositionManagerDecreaseLiquidity

evm.uniswap.v3.PositionManagerDecreaseLiquidity

/ @notice Emitted when a position's liquidity is decreased via the PositionManager.

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytesposition_manager_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

stringtoken_id = 10

-- event --

stringliquidity = 11

uint128

stringamount0 = 12

uint256

stringamount1 = 13

uint256

PositionManagerIncreaseLiquidity

evm.uniswap.v3.PositionManagerIncreaseLiquidity

/ @notice Emitted when a position's liquidity is increased via the PositionManager.

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytesposition_manager_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

stringtoken_id = 10

-- event --

stringliquidity = 11

uint128

stringamount0 = 12

uint256

stringamount1 = 13

uint256

PositionManagerTransfer

evm.uniswap.v3.PositionManagerTransfer

/ @notice Emitted when a position NFT is transferred via the PositionManager.

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytesposition_manager_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytesfrom = 10

-- event --

bytesto = 11

address

stringtoken_id = 12

uint256

SetFeeProtocol

evm.uniswap.v3.SetFeeProtocol

/ @notice Emitted when the protocol fee is changed by the pool / @param feeProtocol0Old The previous value of the token0 protocol fee / @param feeProtocol1Old The previous value of the token1 protocol fee / @param feeProtocol0New The updated value of the token0 protocol fee / @param feeProtocol1New The updated value of the token1 protocol fee

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytespool_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

uint64fee_protocol0_old = 10

-- event --

uint64fee_protocol1_old = 11

uint8

uint64fee_protocol0_new = 12

uint8

uint64fee_protocol1_new = 13

uint8

Swap

evm.uniswap.v3.Swap

In Uniswap v3, the Swap event is emitted when a trade occurs in a liquidity pool. It provides key details of the swap, including the address of the sender initiating the swap, the recipient of the swapped tokens, and the amounts of token0 and token1 involved in the trade. Additionally, the event logs updated state parameters such as the square root price (sqrtPriceX96), current liquidity, and the tick after the swap, thereby reflecting the pool's state changes. This event is essential for on-chain tracking of trades, liquidity dynamics, and price updates.

Price Calculation: Uniswap V3 represents the current pool price using a square root price value, sqrtPriceX96, stored as a Q64.96 fixed-point number (with 64 bits for the integer part and 96 bits for the fraction). To compute the actual price of token0 in terms of token1, the value is squared and then divided by 2^192:

Conversely, to determine the price of token1 in terms of token0, take the reciprocal of the computed price.

This calculation method provides high precision and efficient on-chain computation of price ratios.

bytestx_hash = 1

-- transaction --

bytescaller = 4

-- call --

bytespool_address = 5

-- log --

uint64ordinal = 6

log.ordinal

uint32log_index = 7

log.index

uint32transaction_index = 8

log.transaction_index

uint32block_index = 9

log.block_index

bytessender = 10

-- event --

bytesrecipient = 11

address

stringamount0 = 12

int256

stringamount1 = 13

int256

stringsqrt_price_x96 = 14

uint160

stringliquidity = 15

uint128

int32tick = 16

int24

evm.uniswap.v4

Eventsmain

evm.uniswap.v4.Events

https://github.com/Uniswap/v4-core/blob/main/src/interfaces/IPoolManager.sol https://github.com/Uniswap/v4-core/blob/59d3ecf53afa9264a16bba0e38f4c5d2231f80bc/src/interfaces/IProtocolFees.sol

Swap[]swap = 1

IPoolManager

Initialize[]initialize = 2

ModifyLiquidity[]modify_liquidity = 3

Donate[]donate = 4

ProtocolFeeControllerUpdated[]protocol_fee_controller_updated = 5

IProtocolFees

ProtocolFeeUpdated[]protocol_fee_updated = 6

AssociatedEvmTransaction[]associated_evm_transaction = 7

PositionManagerApproval[]position_manager_approval = 8

PositionManager (ERC721-like + subscription hooks)

PositionManagerApprovalForAll[]position_manager_approval_for_all = 9

PositionManagerSubscription[]position_manager_subscription = 10

PositionManagerUnsubscription[]position_manager_unsubscription = 11

PositionManagerTransfer[]position_manager_transfer = 12

ModifyLiquidityWithAmounts[]modify_liquidity_with_amounts = 13

Approval[]approval = 14

IPoolManager: Other events

OperatorSet[]operator_set = 15

OwnershipTransferred[]ownership_transferred = 16

Transfer[]transfer = 17

Approval

evm.uniswap.v4.Approval

/ @notice Emitted when approval is given to spender to manage id.

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytespool_manager_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytesowner = 10

-- event --

bytesspender = 11

address

stringid = 12

uint256

stringamount = 13

uint256

Donate

evm.uniswap.v4.Donate

/ @notice Emitted for donations / @param id The abi encoded hash of the pool key struct for the pool that was donated to / @param sender The address that initiated the donate call / @param amount0 The amount donated in currency0 / @param amount1 The amount donated in currency1

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytespool_manager_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytespool_id = 10

-- event --

bytessender = 11

address

stringamount0 = 12

uint256

stringamount1 = 13

uint256

Initialize

evm.uniswap.v4.Initialize

/ @notice Emitted when a new pool is initialized / @param id The abi encoded hash of the pool key struct for the new pool / @param currency0 The first currency of the pool by address sort order / @param currency1 The second currency of the pool by address sort order / @param fee The fee collected upon every swap in the pool, denominated in hundredths of a bip / @param tickSpacing The minimum number of ticks between initialized ticks / @param hooks The hooks contract address for the pool, or address(0) if none / @param sqrtPriceX96 The price of the pool on initialization / @param tick The initial tick of the pool corresponding to the initialized price

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytespool_manager_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytespool_id = 10

-- event --

bytescurrency0 = 11

address (token0)

bytescurrency1 = 12

address (token1)

uint64fee = 13

uint24 (e.g., 3000 represents 0.30%)

int32tick_spacing = 14

int24 (e.g., 60)

stringsqrt_price_x96 = 17

uint160

int32tick = 18

int24

stringhooks = 19

address

ModifyLiquidity

evm.uniswap.v4.ModifyLiquidity

/ @notice Emitted when a liquidity position is modified / @param id The abi encoded hash of the pool key struct for the pool that was modified / @param sender The address that modified the pool / @param tickLower The lower tick of the position / @param tickUpper The upper tick of the position / @param liquidityDelta The amount of liquidity that was added or removed / @param salt The extra data to make positions unique

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytespool_manager_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytespool_id = 10

-- event --

bytessender = 11

address

int32tick_lower = 12

int24

int32tick_upper = 13

int24

stringliquidity_delta = 14

int128

bytessalt = 18

bytes32

ModifyLiquidityWithAmounts

evm.uniswap.v4.ModifyLiquidityWithAmounts

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytespool_manager_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytespool_id = 10

-- event --

bytessender = 11

address

int32tick_lower = 12

int24

int32tick_upper = 13

int24

stringliquidity_delta = 14

int128

bytessalt = 18

bytes32

stringliquidity_math_amount0 = 19

calculated amounts from latest pool state

stringliquidity_math_amount1 = 20

uint256

OperatorSet

evm.uniswap.v4.OperatorSet

/ @notice Emitted when operator is enabled or disabled for owner.

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytespool_manager_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytesowner = 10

-- event --

bytesoperator = 11

address

boolapproved = 12

bool

OwnershipTransferred

evm.uniswap.v4.OwnershipTransferred

/ @notice Emitted when the contract ownership is transferred.

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytespool_manager_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytesuser = 10

-- event --

bytesnew_owner = 11

address

PositionManagerApproval

evm.uniswap.v4.PositionManagerApproval

/ @notice Emitted when approval is given to spender to manage id.

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytesposition_manager_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytesowner = 10

-- event --

bytesspender = 11

address

stringid = 12

uint256

PositionManagerApprovalForAll

evm.uniswap.v4.PositionManagerApprovalForAll

/ @notice Emitted when operator is enabled or disabled for owner.

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytesposition_manager_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytesowner = 10

-- event --

bytesoperator = 11

address

boolapproved = 12

bool

PositionManagerSubscription

evm.uniswap.v4.PositionManagerSubscription

/ @notice Emitted when a position subscribes to a subscriber contract.

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytesposition_manager_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

stringtoken_id = 10

-- event --

bytessubscriber = 11

address

PositionManagerTransfer

evm.uniswap.v4.PositionManagerTransfer

/ @notice Emitted when a position NFT is transferred.

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytesposition_manager_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytesfrom = 10

-- event --

bytesto = 11

address

stringid = 12

uint256

PositionManagerUnsubscription

evm.uniswap.v4.PositionManagerUnsubscription

/ @notice Emitted when a position unsubscribes from a subscriber contract.

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytesposition_manager_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

stringtoken_id = 10

-- event --

bytessubscriber = 11

address

ProtocolFeeControllerUpdated

evm.uniswap.v4.ProtocolFeeControllerUpdated

/ @notice Emitted when the protocol fee controller address is updated in setProtocolFeeController.

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytesprotocol_fee_controller_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytesprotocol_fee_controller = 10

-- event --

ProtocolFeeUpdated

evm.uniswap.v4.ProtocolFeeUpdated

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytesprotocol_fee_controller_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytespool_id = 10

-- event --

uint64protocol_fee = 11

uint24

Swap

evm.uniswap.v4.Swap

/ @notice Emitted for swaps between currency0 and currency1 / @param id The abi encoded hash of the pool key struct for the pool that was modified / @param sender The address that initiated the swap call, and that received the callback / @param amount0 The delta of the currency0 balance of the pool / @param amount1 The delta of the currency1 balance of the pool / @param sqrtPriceX96 The sqrt(price) of the pool after the swap, as a Q64.96 / @param liquidity The liquidity of the pool after the swap / @param tick The log base 1.0001 of the price of the pool after the swap / @param fee The swap fee in hundredths of a bip

bytestx_hash = 1

-- transaction --

bytescaller = 4

-- call --

bytespool_manager_address = 5

-- log --

uint64ordinal = 6

log.ordinal

uint32log_index = 7

log.index

uint32transaction_index = 8

log.transaction_index

uint32block_index = 9

log.block_index

bytespool_id = 10

-- event --

bytessender = 11

address

stringamount0 = 13

int256

stringamount1 = 14

int256

stringsqrt_price_x96 = 15

uint160

stringliquidity = 16

uint128

int32tick = 17

int24

stringfee = 18

int256

Transfer

evm.uniswap.v4.Transfer

/ @notice Emitted when balances are transferred.

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

bytespool_manager_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytescaller_address = 10

-- event --

bytesfrom = 11

address

bytesto = 12

address

stringid = 13

uint256

stringamount = 14

uint256

eqcapital.substreams.v1

DexTapemain

eqcapital.substreams.v1.DexTape

Each field contains the corresponding upstream evm.uniswap.vN.Events protobuf with selected event tags only. Decode using the pinned upstream descriptors; these are opaque event tapes, not new canonical contracts.

bytesv2 = 1

bytesv3 = 2

bytesv4 = 3

eqcapital.evidence.v1

Evidencemain

eqcapital.evidence.v1.Evidence

Chunk[]chunks = 1

Chunk

eqcapital.evidence.v1.Chunk

stringid = 1

stringbatch_id = 2

stringscope_id = 3

stringextractor_version = 4

stringselection_digest = 5

uint64chain_id = 6

uint64block_number = 7

stringblock_hash = 8

int64block_time_seconds = 9

uint32chunk_index = 10

uint32chunk_count = 11

stringpayload_sha256 = 12

stringbatch_sha256 = 13

stringpayload_hex = 14

Show 48 dependencies

eqcapital.substreams.sql.v1

SqlEvents

eqcapital.substreams.sql.v1.SqlEvents

V2Swap[]v2_swap = 1

V2Sync[]v2_sync = 2

V2Mint[]v2_mint = 3

V2Burn[]v2_burn = 4

V2PairCreated[]v2_pair_created = 5

V3Swap[]v3_swap = 6

V3Initialize[]v3_initialize = 7

V3Mint[]v3_mint = 8

V3Collect[]v3_collect = 9

V3Burn[]v3_burn = 10

V3Flash[]v3_flash = 11

V3CollectProtocol[]v3_collect_protocol = 12

V3PoolCreated[]v3_pool_created = 13

V4Swap[]v4_swap = 14

V4Initialize[]v4_initialize = 15

V4ModifyLiquidity[]v4_modify_liquidity = 16

V4Donate[]v4_donate = 17

V4ModifyLiquidityWithAmounts[]v4_modify_liquidity_with_amounts = 18

V2Burn

eqcapital.substreams.sql.v1.V2Burn

bytestx_hash = 1

bytescaller = 2

bytespair_address = 3

uint64ordinal = 4

uint32log_index = 5

uint32transaction_index = 6

uint32block_index = 7

bytessender = 10

stringamount0 = 11

stringamount1 = 12

bytesto = 13

stringrow_id = 1000

stringsource_block_hash = 1001

uint64chain_id = 1002

stringsource_package_sha256 = 1003

V2Mint

eqcapital.substreams.sql.v1.V2Mint

bytestx_hash = 1

bytescaller = 2

bytespair_address = 3

uint64ordinal = 4

uint32log_index = 5

uint32transaction_index = 6

uint32block_index = 7

bytessender = 10

stringamount0 = 11

stringamount1 = 12

stringrow_id = 1000

stringsource_block_hash = 1001

uint64chain_id = 1002

stringsource_package_sha256 = 1003

V2PairCreated

eqcapital.substreams.sql.v1.V2PairCreated

bytestx_hash = 1

bytescaller = 2

bytespair_factory_address = 3

uint64ordinal = 4

uint32log_index = 5

uint32transaction_index = 6

uint32block_index = 7

bytestoken0 = 10

bytestoken1 = 11

bytespair_address = 12

uint64all_pairs_length = 13

stringrow_id = 1000

stringsource_block_hash = 1001

uint64chain_id = 1002

stringsource_package_sha256 = 1003

V2Swap

eqcapital.substreams.sql.v1.V2Swap

bytestx_hash = 1

bytescaller = 4

bytespair_address = 5

uint64ordinal = 6

uint32log_index = 7

uint32transaction_index = 8

uint32block_index = 9

bytessender = 10

stringamount0_in = 11

stringamount0_out = 12

stringamount1_in = 13

stringamount1_out = 14

bytesto = 15

stringrow_id = 1000

stringsource_block_hash = 1001

uint64chain_id = 1002

stringsource_package_sha256 = 1003

V2Sync

eqcapital.substreams.sql.v1.V2Sync

bytestx_hash = 1

bytescaller = 2

bytespair_address = 3

uint64ordinal = 4

uint32log_index = 5

uint32transaction_index = 6

uint32block_index = 7

stringreserve0 = 21

stringreserve1 = 22

stringrow_id = 1000

stringsource_block_hash = 1001

uint64chain_id = 1002

stringsource_package_sha256 = 1003

V3Burn

eqcapital.substreams.sql.v1.V3Burn

bytestx_hash = 1

bytescaller = 2

bytespool_address = 3

uint64ordinal = 4

uint32log_index = 5

uint32transaction_index = 6

uint32block_index = 7

bytesowner = 10

int32tick_lower = 11

int32tick_upper = 12

stringamount = 13

stringamount0 = 14

stringamount1 = 15

stringrow_id = 1000

stringsource_block_hash = 1001

uint64chain_id = 1002

stringsource_package_sha256 = 1003

V3Collect

eqcapital.substreams.sql.v1.V3Collect

bytestx_hash = 1

bytescaller = 2

bytespool_address = 3

uint64ordinal = 4

uint32log_index = 5

uint32transaction_index = 6

uint32block_index = 7

bytesowner = 10

bytesrecipient = 11

int32tick_lower = 12

int32tick_upper = 13

stringamount0 = 14

stringamount1 = 15

stringrow_id = 1000

stringsource_block_hash = 1001

uint64chain_id = 1002

stringsource_package_sha256 = 1003

V3CollectProtocol

eqcapital.substreams.sql.v1.V3CollectProtocol

bytestx_hash = 1

bytescaller = 2

bytespool_address = 3

uint64ordinal = 4

uint32log_index = 5

uint32transaction_index = 6

uint32block_index = 7

bytessender = 10

bytesrecipient = 11

stringamount0 = 12

stringamount1 = 13

stringrow_id = 1000

stringsource_block_hash = 1001

uint64chain_id = 1002

stringsource_package_sha256 = 1003

V3Flash

eqcapital.substreams.sql.v1.V3Flash

bytestx_hash = 1

bytescaller = 2

bytespool_address = 3

uint64ordinal = 4

uint32log_index = 5

uint32transaction_index = 6

uint32block_index = 7

bytessender = 10

bytesrecipient = 11

stringamount0 = 12

stringamount1 = 13

stringpaid0 = 14

stringpaid1 = 15

stringrow_id = 1000

stringsource_block_hash = 1001

uint64chain_id = 1002

stringsource_package_sha256 = 1003

V3Initialize

eqcapital.substreams.sql.v1.V3Initialize

bytestx_hash = 1

bytescaller = 2

bytespool_address = 3

uint64ordinal = 4

uint32log_index = 5

uint32transaction_index = 6

uint32block_index = 7

stringsqrt_price_x96 = 21

int32tick = 22

stringrow_id = 1000

stringsource_block_hash = 1001

uint64chain_id = 1002

stringsource_package_sha256 = 1003

V3Mint

eqcapital.substreams.sql.v1.V3Mint

bytestx_hash = 1

bytescaller = 2

bytespool_address = 3

uint64ordinal = 4

uint32log_index = 5

uint32transaction_index = 6

uint32block_index = 7

bytessender = 10

bytesowner = 11

int32tick_lower = 12

int32tick_upper = 13

stringamount = 14

stringamount0 = 15

stringamount1 = 16

stringrow_id = 1000

stringsource_block_hash = 1001

uint64chain_id = 1002

stringsource_package_sha256 = 1003

V3PoolCreated

eqcapital.substreams.sql.v1.V3PoolCreated

bytestx_hash = 1

bytescaller = 2

bytespool_factory_address = 3

uint64ordinal = 4

uint32log_index = 5

uint32transaction_index = 6

uint32block_index = 7

bytestoken0 = 10

bytestoken1 = 11

uint64fee = 12

int32tick_spacing = 13

bytespool_address = 14

stringrow_id = 1000

stringsource_block_hash = 1001

uint64chain_id = 1002

stringsource_package_sha256 = 1003

V3Swap

eqcapital.substreams.sql.v1.V3Swap

bytestx_hash = 1

bytescaller = 4

bytespool_address = 5

uint64ordinal = 6

uint32log_index = 7

uint32transaction_index = 8

uint32block_index = 9

bytessender = 10

bytesrecipient = 11

stringamount0 = 12

stringamount1 = 13

stringsqrt_price_x96 = 14

stringliquidity = 15

int32tick = 16

stringrow_id = 1000

stringsource_block_hash = 1001

uint64chain_id = 1002

stringsource_package_sha256 = 1003

V4Donate

eqcapital.substreams.sql.v1.V4Donate

bytestx_hash = 1

bytescaller = 2

bytespool_manager_address = 3

uint64ordinal = 4

uint32log_index = 5

uint32transaction_index = 6

uint32block_index = 7

bytespool_id = 10

bytessender = 11

stringamount0 = 12

stringamount1 = 13

stringrow_id = 1000

stringsource_block_hash = 1001

uint64chain_id = 1002

stringsource_package_sha256 = 1003

V4Initialize

eqcapital.substreams.sql.v1.V4Initialize

bytestx_hash = 1

bytescaller = 2

bytespool_manager_address = 3

uint64ordinal = 4

uint32log_index = 5

uint32transaction_index = 6

uint32block_index = 7

bytespool_id = 10

bytescurrency0 = 11

bytescurrency1 = 12

uint64fee = 13

int32tick_spacing = 14

stringsqrt_price_x96 = 17

int32tick = 18

stringhooks = 19

stringrow_id = 1000

stringsource_block_hash = 1001

uint64chain_id = 1002

stringsource_package_sha256 = 1003

V4ModifyLiquidity

eqcapital.substreams.sql.v1.V4ModifyLiquidity

bytestx_hash = 1

bytescaller = 2

bytespool_manager_address = 3

uint64ordinal = 4

uint32log_index = 5

uint32transaction_index = 6

uint32block_index = 7

bytespool_id = 10

bytessender = 11

int32tick_lower = 12

int32tick_upper = 13

stringliquidity_delta = 14

bytessalt = 18

stringrow_id = 1000

stringsource_block_hash = 1001

uint64chain_id = 1002

stringsource_package_sha256 = 1003

V4ModifyLiquidityWithAmounts

eqcapital.substreams.sql.v1.V4ModifyLiquidityWithAmounts

bytestx_hash = 1

bytescaller = 2

bytespool_manager_address = 3

uint64ordinal = 4

uint32log_index = 5

uint32transaction_index = 6

uint32block_index = 7

bytespool_id = 10

bytessender = 11

int32tick_lower = 12

int32tick_upper = 13

stringliquidity_delta = 14

bytessalt = 18

stringliquidity_math_amount0 = 19

stringliquidity_math_amount1 = 20

stringrow_id = 1000

stringsource_block_hash = 1001

uint64chain_id = 1002

stringsource_package_sha256 = 1003

V4Swap

eqcapital.substreams.sql.v1.V4Swap

bytestx_hash = 1

bytescaller = 4

bytespool_manager_address = 5

uint64ordinal = 6

uint32log_index = 7

uint32transaction_index = 8

uint32block_index = 9

bytespool_id = 10

bytessender = 11

stringamount0 = 13

stringamount1 = 14

stringsqrt_price_x96 = 15

stringliquidity = 16

int32tick = 17

stringfee = 18

stringrow_id = 1000

stringsource_block_hash = 1001

uint64chain_id = 1002

stringsource_package_sha256 = 1003

evm.store

V4PoolStore

evm.store.V4PoolStore

stringsqrt_price_x96 = 1

int32current_tick = 2

evm.transaction

AssociatedEvmTransaction

evm.transaction.AssociatedEvmTransaction

stringtx_hash = 1

stringto = 2

uint64nonce = 3

stringgas_price = 4

uint64gas_limit = 5

stringvalue = 6

stringinput = 7

stringv = 8

stringr = 9

strings = 10

stringgas_used = 11

stringtype = 12

stringmax_fee_per_gas = 14

stringmax_priority_fee_per_gas = 15

uint32index = 16

stringfrom = 17

stringreturn_data = 18

stringpublic_key = 19

uint64begin_ordinal = 20

uint64end_ordinal = 21

stringstatus = 22

string[]calls = 23

stringblob_gas = 24

stringblob_gas_fee_cap = 25

string[]blob_hashes = 26

string[]set_code_authorizations = 27

schema

ClickhouseIndexField

schema.ClickhouseIndexField

ClickhouseIndexField defines a secondary index for improved query performance. Secondary indexes help ClickHouse skip irrelevant data blocks during query execution.

stringname = 1

The name of the index (must be unique within the table)

stringfield_name = 2

The field name on which to create the index

IndexTypetype = 3

The type of index to create (e.g., minmax, bloom_filter, set)

uint32granularity = 4

The granularity parameter that controls index density (higher = less memory, lower precision)

Functionfunction = 5

Optional function to apply to the field value before indexing

ClickhouseOrderByField

schema.ClickhouseOrderByField

ClickhouseOrderByField defines a field used in the ClickHouse table ORDER BY clause. ORDER BY determines the physical storage order of data for optimal compression and query performance.

stringname = 1

The name of the field to include in the ORDER BY clause

booldescending = 2

Whether to sort this field in descending order (default is ascending)

Functionfunction = 3

Optional function to apply to the field value before ordering (e.g., toDate for timestamps)

ClickhousePartitionByField

schema.ClickhousePartitionByField

ClickhousePartitionByField defines a field used for ClickHouse table partitioning. Partitioning splits data into separate parts based on the specified field values.

stringname = 1

The name of the field to use for partitioning

Functionfunction = 2

Optional function to apply to the field value before partitioning (e.g., toYYYYMM for dates)

ClickhouseTableOptions

schema.ClickhouseTableOptions

ClickhouseTableOptions defines ClickHouse-specific table configuration options. These options are used to configure ClickHouse table engines and optimize query performance.

ClickhouseOrderByField[]order_by_fields = 1

Fields to use for the ORDER BY clause in ClickHouse table definition. ORDER BY determines the physical ordering of data on disk for better compression and query performance.

ClickhousePartitionByField[]partition_fields = 2

Fields to use for table partitioning in ClickHouse. Partitioning helps with query performance and data management by splitting data into logical parts.

ClickhouseIndexField[]index_fields = 4

Secondary indexes to create for improved query performance on specific columns. These are data skipping indexes that help ClickHouse skip irrelevant data blocks during queries.

Column

schema.Column

Column defines metadata for mapping a protobuf field to a database column. This message is used with the (field) extension on protobuf fields.

stringname = 1

Custom column name. If not specified, the field name is used.

stringforeign_key = 2

Foreign key reference to another table's column in the format "table.column". Used to establish referential integrity constraints in relational databases.

boolunique = 3

Whether this column should have a unique constraint. Ensures no duplicate values exist for this column.

boolprimary_key = 4

Whether this column is part of the primary key. Primary key columns are automatically non-null and unique.

StringConvertionconvertTo = 5

Specifies how to convert string fields to specific numeric types. Only applies to string fields that contain numeric data. Leave unset for no conversion (store as string).

boolinline = 6

Decimal128

schema.Decimal128

Decimal128 represents a 128-bit decimal type for string conversion. Used in StringConvertion to specify that a string field should be converted to Decimal128.

int32scale = 1

The number of digits after the decimal point for this decimal type.

Decimal256

schema.Decimal256

Decimal256 represents a 256-bit decimal type for string conversion. Used in StringConvertion to specify that a string field should be converted to Decimal256.

int32scale = 1

The number of digits after the decimal point for this decimal type.

Int128

schema.Int128

Int128 represents a 128-bit signed integer type for string conversion. Used in StringConvertion to specify that a string field should be converted to Int128.

No fields.

Int256

schema.Int256

Int256 represents a 256-bit signed integer type for string conversion. Used in StringConvertion to specify that a string field should be converted to Int256.

No fields.

StringConvertion

schema.StringConvertion

StringConvertion defines how string fields should be converted to specific numeric types. This is used when protobuf string fields contain numeric data that should be stored as native numeric types in the database for better performance and storage efficiency. Usage: Set this in Column.convertTo field to specify the target numeric type.

Int128int128 = 2oneof convertion

Convert string to 128-bit signed integer

UInt128uint128 = 3oneof convertion

Convert string to 128-bit unsigned integer

Int256int256 = 4oneof convertion

Convert string to 256-bit signed integer

UInt256uint256 = 6oneof convertion

Convert string to 256-bit unsigned integer

Decimal128decimal128 = 50oneof convertion

Convert string to 128-bit decimal with specified scale

Decimal256decimal256 = 51oneof convertion

Convert string to 256-bit decimal with specified scale

Table

schema.Table

Table defines metadata for mapping a protobuf message to a database table. This message is used with the (table) extension on protobuf messages.

stringname = 1

The name of the database table. If not specified, the message name is used.

stringchild_of = 2

Optional field to specify a parent table for establishing table relationships. Used for creating foreign key relationships in relational databases.

ClickhouseTableOptionsclickhouse_table_options = 200

ClickHouse-specific table options for configuring table engine parameters. Only applicable when using ClickHouse as the target database.

UInt128

schema.UInt128

UInt128 represents a 128-bit unsigned integer type for string conversion. Used in StringConvertion to specify that a string field should be converted to UInt128.

No fields.

UInt256

schema.UInt256

UInt256 represents a 256-bit unsigned integer type for string conversion. Used in StringConvertion to specify that a string field should be converted to UInt256.

No fields.

Functionenum

schema.Function

unset = 0

No function applied (use raw field value)

toYYYYMM = 1

Convert date/timestamp to YYYYMM format (useful for monthly partitioning)

toYYYYDD = 2

Convert date/timestamp to YYYYDD format (useful for daily partitioning)

toYear = 3

Extract year from date/timestamp (useful for yearly partitioning)

toMonth = 4

Extract month from date/timestamp (useful for monthly grouping)

toDate = 5

Convert timestamp to date (removes time component)

toStartOfMonth = 6

Convert date to first day of the month (useful for monthly aggregations)

IndexTypeenum

schema.IndexType

minmax = 0

MinMax index stores minimum and maximum values for each granule (fastest, least memory)

set = 1

Set index stores unique values for each granule (good for low cardinality fields)

ngrambf_v1 = 2

N-gram Bloom filter index for substring searches (good for text search)

tokenbf_v1 = 3

Token Bloom filter index for full-word searches (good for tokenized text)

bloom_filter = 4

Bloom filter index for equality checks (good for high cardinality fields)

sf.firehose.v2

BlockMetadata

sf.firehose.v2.BlockMetadata

uint64num = 1

Num is the block number of this response's block.

stringid = 2

ID is the block ID of this response's block. The ID actual representation is chain specific.

Antelope & Ethereum uses hex.
NEAR & Solana uses base58.

Refer to the chain documentation for more details.

uint64parent_num = 3

ParentNum is the block number of the parent of this response's block

stringparent_id = 4

ParentID is the block ID of the parent of this response's block. If this response is the genesis block, this field is empty.

The ID actual representation is chain specific.

Antelope & Ethereum uses hex.
NEAR & Solana uses base58.

Refer to the chain documentation for more details.

uint64lib_num = 5

LibNum is the block number of the last irreversible block (a.k.a last finalized block) at the time of this response' block. It determines the finality of the block.

Timestamptime = 6

Time is the time at which the block was produced.

InfoRequest

sf.firehose.v2.InfoRequest

No fields.

InfoResponse

sf.firehose.v2.InfoResponse

stringchain_name = 1

Canonical chain name from https://thegraph.com/docs/en/developing/supported-networks/ (ex: matic, mainnet ...)

string[]chain_name_aliases = 2

Alternate names for the chain.

uint64first_streamable_block_num = 3

First block that is served by this endpoint. This should usually be the genesis block, but some providers may have truncated history.

stringfirst_streamable_block_id = 4

InfoResponse.BlockIdEncodingblock_id_encoding = 5

This informs the client on how to decode the block_id field inside the "Clock" message as well as the first_streamable_block_id above.

string[]block_features = 10

features describes the blocks. Popular values for EVM chains include base, extended or hybrid.

Request

sf.firehose.v2.Request

int64start_block_num = 1

Controls where the stream of blocks will start.

The stream will start inclusively at the requested block num.

When not provided, starts at first streamable block of the chain. Not all chain starts at the same block number, so you might get an higher block than requested when using default value of 0.

Can be negative, will be resolved relative to the chain head block, assuming a chain at head block #100, then using -50 as the value will start at block #50. If it resolves before first streamable block of chain, we assume start of chain.

If start_cursor is given, this value is ignored and the stream instead starts immediately after the Block pointed by the opaque start_cursor value.

stringcursor = 2

Controls where the stream of blocks will start which will be immediately after the Block pointed by this opaque cursor.

Obtain this value from a previously received Response.cursor.

This value takes precedence over start_block_num.

uint64stop_block_num = 3

When non-zero, controls where the stream of blocks will stop.

The stream will close after that block has passed so the boundary is inclusive.

boolfinal_blocks_only = 4

With final_block_only, you only receive blocks with STEP_FINAL Default behavior will send blocks as STEP_NEW, with occasional STEP_UNDO

Any[]transforms = 10

Response

sf.firehose.v2.Response

Anyblock = 1

Chain specific block payload, ex:

sf.eosio.type.v1.Block
sf.ethereum.type.v1.Block
sf.near.type.v1.Block

ForkStepstep = 6

stringcursor = 10

BlockMetadatametadata = 12

Metadata about the block, added in some Firehose version, so consumer should be ready to handle the absence of this field.

SingleBlockRequest

sf.firehose.v2.SingleBlockRequest

SingleBlockRequest.BlockNumberblock_number = 3oneof reference

SingleBlockRequest.BlockHashAndNumberblock_hash_and_number = 4oneof reference

SingleBlockRequest.Cursorcursor = 5oneof reference

Any[]transforms = 6

BlockHashAndNumber

sf.firehose.v2.SingleBlockRequest.BlockHashAndNumber

Get the current block with specific hash and number

uint64num = 1

stringhash = 2

BlockNumber

sf.firehose.v2.SingleBlockRequest.BlockNumber

Get the current known canonical version of a block at with this number

uint64num = 1

Cursor

sf.firehose.v2.SingleBlockRequest.Cursor

Get the block that generated a specific cursor

stringcursor = 1

SingleBlockResponse

sf.firehose.v2.SingleBlockResponse

Anyblock = 1

BlockMetadatametadata = 2

Metadata about the block, added in some Firehose version, so consumer should be ready to handle the absence of this field.

ForkStepenum

sf.firehose.v2.ForkStep

STEP_UNSET = 0

STEP_NEW = 1

Incoming block

STEP_UNDO = 2

A reorg caused this specific block to be excluded from the chain

STEP_FINAL = 3

Block is now final and can be committed (finality is chain specific, see chain documentation for more details)

BlockIdEncodingenum

sf.firehose.v2.InfoResponse.BlockIdEncoding

BLOCK_ID_ENCODING_UNSET = 0

BLOCK_ID_ENCODING_HEX = 1

BLOCK_ID_ENCODING_0X_HEX = 2

BLOCK_ID_ENCODING_BASE58 = 3

BLOCK_ID_ENCODING_BASE64 = 4

BLOCK_ID_ENCODING_BASE64URL = 5