Uniswap v3 Substreams package

This module will loop over block transactions and detect pools created events. Once the pool created events have been detected, Pools structs will be emitted out of the module.

Try with

substreams gui substreams.yaml map_pools_created -t +1000

This modules loops over the pools created and emits ERC20Tokens structs out of the module. Tokens part of the pair of a pool are checked against the WHITELIST_TOKENS constant to see if they are part of the list. If so push the address of the pool in the field whitelist_pools of the token.

Try with

substreams gui substreams.yaml map_tokens_whitelist_pools -t +1000

Chunky module which emits multiple types of Events. Looping over every transaction to filter out Events. For some events, we have to loop over StorageChanges to be able to fetch certain changes such as liquidity increases and decreases. For more information on what the Event contains, check proto/uniswap/v1/uniswap.proto.

Try with

substreams gui substreams.yaml map_extract_data_types -t +1000

EntityChanges emitted out for all the entities defined in the schema.graphql for the Uniswap v3 Subgraph.

This module stores the Pools emitted by the map_pools_created module. Dynamic data sources pattern for Uniswap v3 pools.

Int64 store accumulator for each time a token is used for any combination for a pool.

BigInt store accumulator for each time a pool is created.

String appender store which stores the whitelist_pools field of a token.

Store setter for PoolSqrtPrice emitted out of the map_extract_data_types.

BigDecimal store setter for storing the price of token0 <> token1 and vice versa. Also store the Daily and Hourly prices.

For example: Pool: TOKEN0 <> TOKEN1 - pool:{pool_address}:{token0_addr}:token0 -> 100 - pool:{pool_address}:{token1_addr}:token1 -> 1 This means that the price of TOKEN0 is 100 for 1 TOKEN1

BigInt store setter for storing pool liquidites which were extracted from map_extract_data_types.

BigInt accumulator store for the total transaction counts for pools, tokens, factory, daily factory, daily and hourly for token and pool data.

BigDecimal accumulator store for the swap volume of various entries such as amount0_abs, amount1_abs, volume_usd, volume_usd_untracked, volume_eth, fee_usd and fee_eth. The _0 and _1 entries are the value of one token for another token.

BigDecimal setter store for the native amounts out of any Event type: Mint, Swap and Burn amounts (amount0 and amount1).

BigDecimal setter store for the eth_price. This module uses a multiple stores and map_extract_data_types to find the eth_price of any given token. If a pool contains a token which has a pair with a well-known token, the eth_price is easily found. Stores the USD price of ETH.

For example: - Pool: DAI <> WBTC -> we check if there is a pool with DAI <> ETH and easily derive the price - Pool: ANYTOKEN0 <> DAI -> we can derive the price by finding the pool DAI <> ETH - Pool: ANYTOKEN0 <> ANYTOKEN1 -> more complicated case where we have to check on either side of the pool and try to find a path to reach a whitelisted_token which has a pool with ETH to be able to derive the price

BigDecimal accumulator store for the total_value_locked for tokens.

BigDecimal accumulator store for the derived total_value_locked in USD, ETH, USDUntracked and ETHUntracked for pools and tokens.

BigDecimal accumulator store for the derived total_value_locked in USD, ETH, USDUntracked and ETHUntracked for the factory.

BigInt accumulator store for the liquidities of the pools. Tracking liquidityGross and liquidityNet for pool values at all times, daily and hourly for Mint and Burn events.

PositionEvent setter store for Position Events emitted out of map_extract_data_types. CreatedPosition, IncreaseLiquidityPosition, DecreaseLiquidityPosition, CollectPosition and TransferPosition are stored.

BigDecimal minimum store for the price of eth and token prices for open and low for daily and hourly.

BigDecimal maximum store for the price of eth and token prices for open and low for daily and hourly.