uniswap_v3

streamingfast

This is not the latest version — go to v0.2.11

v0.2.7/638 downloads

Package ref

streamingfast/uniswap-v3@v0.2.7

Download .spkg

Run package

Start block: 12369621, the module's first block

This module reads a store, which starts empty at the module's first block: it runs from there, so its output is from then, not from the chain head. Any later block would first need the store rebuilt up to it.

Deploy it

README

These substream modules compose all the things to build up the Uniswap v3 substreams. See individual modules docs for help.

Modules

Execution graph

22 modules

mapMain

graph_out

from #12369621

Output

sf.substreams.entity.v1.EntityChanges

map

map_extract_data_types

from #12369621

Output

uniswap.types.v1.Events

Inputs

sf.ethereum.type.v2.Block store_pools_created

map

map_pools_created

Dynamic data sources pattern for Uniswap V3 pools. This module will loop over block transactions and detect pools created events. Once the pool created events have been detected, we will create `Pools` structs. Try with ``` substreams gui substreams.yaml map_pools_created -e $SUBSTREAMS_ENDPOINT -t +1000 ```

from #12369621

Output

uniswap.types.v1.Pools

Inputs

sf.ethereum.type.v2.Block

map

map_tokens_whitelist_pools

from #12369621

Output

uniswap.types.v1.ERC20Tokens

Inputs

map_pools_created

store

store_derived_factory_tvl

from #12369621

Store value

bigdecimal

Update policy

add

Inputs

sf.substreams.v1.Clockstore_derived_tvl

store

store_derived_tvl

from #12369621

Store value

bigdecimal

Update policy

set

Inputs

sf.substreams.v1.Clockmap_extract_data_types store_token_tvl store_pools_created store_eth_prices

store

store_eth_prices

from #12369621

Store value

bigdecimal

Update policy

set

Inputs

sf.substreams.v1.Clockmap_extract_data_types store_pools_created store_prices store_tokens_whitelist_pools store_native_amounts store_pool_liquidities

store

store_max_windows

from #12369621

Store value

bigdecimal

Update policy

max

Inputs

sf.substreams.v1.Clockstore_prices store_eth_prices

store

store_min_windows

from #12369621

Store value

bigdecimal

Update policy

min

Inputs

sf.substreams.v1.Clockstore_prices store_eth_prices

store

store_native_amounts

from #12369621

Store value

bigdecimal

Update policy

set

Inputs

map_extract_data_types

store

store_pool_count

from #12369621

Store value

bigint

Update policy

add

Inputs

map_pools_created

store

store_pool_liquidities

from #12369621

Store value

bigint

Update policy

set

Inputs

sf.substreams.v1.Clockmap_extract_data_types

store

store_pool_sqrt_price

from #12369621

Store value

proto:uniswap.types.v1.Events.PoolSqrtPrice

Update policy

set

Inputs

map_extract_data_types

store

store_pools_created

from #12369621

Store value

proto:uniswap.types.v1.Pool

Update policy

set

Inputs

map_pools_created

store

store_positions

from #12369621

Store value

proto:uniswap.types.v1.Events.PositionEvent

Update policy

set

Inputs

map_extract_data_types

store

store_prices

from #12369621

Store value

bigdecimal

Update policy

set

Inputs

sf.substreams.v1.Clockmap_extract_data_types store_pools_created

store

store_swaps_volume

from #12369621

Store value

bigdecimal

Update policy

add

Inputs

sf.substreams.v1.Clockmap_extract_data_types store_pools_created store_total_tx_counts store_eth_prices

store

store_ticks_liquidities

### Hello world This is how you use this: ``` substreams gui blah blah ```

from #12369621

Store value

bigint

Update policy

add

Inputs

sf.substreams.v1.Clockmap_extract_data_types

store

store_token_tvl

from #12369621

Store value

bigdecimal

Update policy

add

Inputs

map_extract_data_types

store

store_tokens

from #12369621

Store value

int64

Update policy

add

Inputs

map_pools_created

store

store_tokens_whitelist_pools

from #12369621

Store value

string

Update policy

append

Inputs

map_tokens_whitelist_pools

store

store_total_tx_counts

from #12369621

Store value

bigint

Update policy

add

Inputs

sf.substreams.v1.Clockmap_extract_data_types

Networks

mainnetdefault

The manifest declares this network only.

Protobuf

uniswap.types.v1

ERC20Tokensmain

uniswap.types.v1.ERC20Tokens

ERC20Token[]tokens = 1

Eventsmain

uniswap.types.v1.Events

Events.PoolSqrtPrice[]pool_sqrt_prices = 1

Events.PoolLiquidity[]pool_liquidities = 2

Events.PoolEvent[]pool_events = 3

Events.Transaction[]transactions = 4

Events.Flash[]flashes = 6

Events.FeeGrowthGlobal[]fee_growth_global_updates = 7

Events.TickCreated[]ticks_created = 8

Events.TickUpdated[]ticks_updated = 9

Events.FeeGrowthInside[]fee_growth_inside_updates = 10

Events.FeeGrowthOutside[]fee_growth_outside_updates = 11

Events.CreatedPosition[]created_positions = 20

Events.IncreaseLiquidityPosition[]increase_liquidity_positions = 21

Events.DecreaseLiquidityPosition[]decrease_liquidity_positions = 22

Events.CollectPosition[]collect_positions = 23

Events.TransferPosition[]transfer_positions = 24

Poolsmain

uniswap.types.v1.Pools

Pool[]pools = 1

ERC20Token

uniswap.types.v1.ERC20Token

stringaddress = 1

stringname = 2

stringsymbol = 3

uint64decimals = 4

stringtotal_supply = 5

string[]whitelist_pools = 6

CollectPosition

uniswap.types.v1.Events.CollectPosition

stringtoken_id = 1

stringcollected_fees_token0 = 2

BigInt

stringcollected_fees_token1 = 3

BigInt

stringfee_growth_inside0_last_x128 = 5

BigInt

stringfee_growth_inside1_last_x128 = 6

BigInt

uint64log_ordinal = 10

CreatedPosition

uniswap.types.v1.Events.CreatedPosition

stringtoken_id = 1

stringpool = 2

stringtoken0 = 3

stringtoken1 = 4

stringtick_lower = 5

stringtick_upper = 6

stringtransaction = 7

uint64log_ordinal = 8

uint64timestamp = 9

uint64block_number = 10

stringfee_growth_inside0_last_x128 = 11

BigInt

stringfee_growth_inside1_last_x128 = 12

BigInt

DecreaseLiquidityPosition

uniswap.types.v1.Events.DecreaseLiquidityPosition

stringtoken_id = 1

stringliquidity = 2

BigInt

stringwithdrawn_token0 = 3

BigDecimal

stringwithdrawn_token1 = 4

BigDecimal

stringfee_growth_inside0_last_x128 = 5

BigInt

stringfee_growth_inside1_last_x128 = 6

BigInt

uint64log_ordinal = 10

FeeGrowthGlobal

uniswap.types.v1.Events.FeeGrowthGlobal

stringpool_address = 1

uint64ordinal = 2

int32token_idx = 3

stringnew_value = 4

Integer

FeeGrowthInside

uniswap.types.v1.Events.FeeGrowthInside

stringpool_address = 1

int32tick_idx = 2

uint64ordinal = 3

stringnew_value = 4

Integer

FeeGrowthOutside

uniswap.types.v1.Events.FeeGrowthOutside

stringpool_address = 1

int32tick_lower = 2

int32tick_upper = 3

uint64ordinal = 4

stringnew_value = 5

Integer

Flash

uniswap.types.v1.Events.Flash

stringpool_address = 1

stringfee_growth_global_0X_128 = 2

Integer

stringfee_growth_global_1X_128 = 3

Integer

uint64log_ordinal = 4

IncreaseLiquidityPosition

uniswap.types.v1.Events.IncreaseLiquidityPosition

stringtoken_id = 1

stringliquidity = 2

BigInt

stringdeposited_token0 = 3

BigDecimal

stringdeposited_token1 = 4

BigDecimal

stringfee_growth_inside0_last_x128 = 5

BigInt

stringfee_growth_inside1_last_x128 = 6

BigInt

uint64log_ordinal = 10

PoolEvent

uniswap.types.v1.Events.PoolEvent

Events.PoolEvent.Swapswap = 1oneof type

Events.PoolEvent.Burnburn = 2oneof type

Events.PoolEvent.Mintmint = 3oneof type

uint64log_ordinal = 100

uint64log_index = 101

stringpool_address = 102

stringtoken0 = 103

stringtoken1 = 104

stringfee = 105

stringtransaction_id = 106

uint64timestamp = 107

uint64created_at_block_number = 108

Burn

uniswap.types.v1.Events.PoolEvent.Burn

stringowner = 1

stringorigin = 2

stringamount = 3

Integer

stringamount_0 = 4

Decimal

stringamount_1 = 5

Decimal

stringtick_lower = 6

Integer

stringtick_upper = 7

Integer

Mint

uniswap.types.v1.Events.PoolEvent.Mint

stringowner = 1

stringsender = 2

stringorigin = 3

stringamount_0 = 4

Decimal

stringamount_1 = 5

Decimal

stringtick_lower = 6

Integer

stringtick_upper = 7

Integer

stringamount = 8

Integer

Swap

uniswap.types.v1.Events.PoolEvent.Swap

stringsender = 1

stringrecipient = 2

stringorigin = 3

stringamount_0 = 4

Decimal

stringamount_1 = 5

Decimal

stringsqrt_price = 6

Integer

stringliquidity = 7

Integer

stringtick = 8

Integer

PoolLiquidity

uniswap.types.v1.Events.PoolLiquidity

stringpool_address = 1

stringliquidity = 2

Integer

stringtoken0 = 3

stringtoken1 = 4

uint64log_ordinal = 30

internals

PoolSqrtPrice

uniswap.types.v1.Events.PoolSqrtPrice

stringpool_address = 1

uint64ordinal = 2

stringsqrt_price = 3

Integer

stringtick = 4

Integer

boolinitialized = 5

PositionEvent

uniswap.types.v1.Events.PositionEvent

Events.CreatedPositioncreated_position = 1oneof type

Events.IncreaseLiquidityPositionincrease_liquidity_position = 2oneof type

Events.DecreaseLiquidityPositiondecrease_liquidity_position = 3oneof type

Events.CollectPositioncollect_position = 4oneof type

Events.TransferPositiontransfer_position = 5oneof type

TickCreated

uniswap.types.v1.Events.TickCreated

stringpool_address = 1

stringidx = 2

Integer

uint64log_ordinal = 3

uint64created_at_timestamp = 4

uint64created_at_block_number = 5

stringprice0 = 6

Decimal

stringprice1 = 7

Decimal

stringamount = 8

Integer

TickUpdated

uniswap.types.v1.Events.TickUpdated

stringpool_address = 1

stringidx = 2

Integer

uint64log_ordinal = 3

stringfee_growth_outside_0X_128 = 4

Integer

stringfee_growth_outside_1X_128 = 5

Integer

uint64timestamp = 6

Transaction

uniswap.types.v1.Events.Transaction

stringid = 1

uint64block_number = 2

uint64timestamp = 3

uint64gas_used = 4

stringgas_price = 5

Integer

uint64log_ordinal = 6

TransferPosition

uniswap.types.v1.Events.TransferPosition

stringtoken_id = 1

stringowner = 2

uint64log_ordinal = 10

Liquidity

uniswap.types.v1.Liquidity

stringpool_address = 1

stringvalue = 2

Decimal

Pool

uniswap.types.v1.Pool

stringaddress = 1

uint64created_at_timestamp = 3

uint64created_at_block_number = 4

ERC20Tokentoken0 = 5

ERC20Tokentoken1 = 6

stringfee_tier = 7

Integer

int32tick_spacing = 30

internals

uint64log_ordinal = 31

stringtransaction_id = 32

boolignore_pool = 33

SnapshotPosition

uniswap.types.v1.SnapshotPosition

stringpool = 1

stringposition = 2

the token_id of the position

uint64block_number = 3

stringowner = 4

uint64timestamp = 6

stringliquidity = 7

Decimal

stringdeposited_token0 = 8

Decimal

stringdeposited_token1 = 9

Decimal

stringwithdrawn_token0 = 10

Decimal

stringwithdrawn_token1 = 11

Decimal

stringcollected_fees_token0 = 12

Decimal

stringcollected_fees_token1 = 13

Decimal

stringtransaction = 14

stringfee_growth_inside_0_last_X_128 = 15

Integer

stringfee_growth_inside_1_last_X_128 = 16

Integer

uint64log_ordinal = 17

internal

SnapshotPositions

uniswap.types.v1.SnapshotPositions

SnapshotPosition[]snapshot_positions = 1