uniswap-database-changes-aggregator-hook-robinhood

ciyengar3

v0.0.6/584 downloads

Package ref

uniswap-database-changes-aggregator-hook-robinhood@v0.0.6

Run package

Start block: 9070, 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

Uniswap Aggregator Hook — database changes

Transforms uniswap-aggregator-hook events into database changes for the BigQuery sink (oneof indices 1500–1503, table prefix uniswap_aggregator_hook). Deploys independently of the other database changes packages.

Generated code in src/ — never edit by hand; regenerate via cd ../../autogen && yarn generate-database-changes-aggregator-hook.

See substreams-packages/CLAUDE.md for build/run/deploy conventions.

Modules

Execution graph

3 modules

mapMain

db_out

from #9070

Output

sf.substreams.sink.database.v1.DatabaseChanges

Inputs

sf.substreams.v1.Clockuniswap_aggregator_hook:map_events

Show 2 dependencies

map

uniswap_aggregator_hook:map_events

from #9070

Output

evm.uniswap.aggregator_hook.Events

Inputs

paramssf.ethereum.type.v2.Block uniswap_aggregator_hook:store_hooks

store

uniswap_aggregator_hook:store_hooks

from #9070

Store value

bigint

Update policy

set

Inputs

paramssf.ethereum.type.v2.Block

Networks

robinhooddefault

The manifest declares this network only.

Protobuf

evm.uniswap.aggregator_hook

Eventsmain

evm.uniswap.aggregator_hook.Events

Tempo AggregatorHook events: a v4 hook that routes swaps through the tempo exchange for aggregator-registered pools. Emits its own HookSwap (with the pool's swap fee rate) instead of PoolManager Swap, plus pool registration, protocol fee collection, and token-jar rotation events.

Matching is signature-wide, not address-filtered: hooks are permissionless, so every contract emitting these signatures is indexed and the emitter is captured per row in hook_address.

Swap[]swap = 1

PoolRegistered[]pool_registered = 2

ProtocolFeesCollected[]protocol_fees_collected = 3

TokenJarUpdated[]token_jar_updated = 4

AssociatedEvmTransaction[]associated_evm_transaction = 5

PoolRegistered

evm.uniswap.aggregator_hook.PoolRegistered

AggregatorPoolRegistered(bytes32 indexed poolId)

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

byteshook_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 --

ProtocolFeesCollected

evm.uniswap.aggregator_hook.ProtocolFeesCollected

ProtocolFeesCollected(address indexed recipient, address indexed currency, uint256 amount)

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

byteshook_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytesrecipient = 10

-- event --

bytescurrency = 11

address (indexed)

stringamount = 12

uint256

Swap

evm.uniswap.aggregator_hook.Swap

HookSwap(bytes32 indexed poolId, address indexed sender, int256 amount0, int256 amount1, uint24 swapFee)

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

byteshook_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 (indexed)

stringamount0 = 12

int256

stringamount1 = 13

int256

uint64swap_fee = 14

uint24 fee rate (e.g. 3000 = 0.30%)

TokenJarUpdated

evm.uniswap.aggregator_hook.TokenJarUpdated

TokenJarUpdated(address indexed tokenJar)

bytestx_hash = 1

-- transaction --

bytescaller = 2

-- call --

byteshook_address = 3

-- log --

uint64ordinal = 4

log.ordinal

uint32log_index = 5

log.index

uint32transaction_index = 6

log.transaction_index

uint32block_index = 7

log.block_index

bytestoken_jar = 10

-- event --

Show 3 dependencies

annotations

EventTopicenum

annotations.EventTopic

EVENT_TOPIC_UNSPECIFIED = 0

EVENT_TOPIC_HIGH = 1

events-{env}: the shared high-priority topic.

EVENT_TOPIC_LOW = 2

events-{env}-low-priority. Reserved; nothing internal publishes here yet.

EVENT_TOPIC_PRICES_HIGH = 3

events-{env}-prices-high: internal pricing events.

EVENT_TOPIC_STATS_HIGH = 4

events-{env}-stats-high: internal stats/TVL events.

EVENT_TOPIC_PLATFORM_HIGH = 5

events-{env}-platform-high: internal platform/api-key metrics events.

EVENT_TOPIC_TRANSACTIONS = 7

events-{env}-transactions: one wallet activity transaction per message, from data-ingestion's blocks consumer.

PayloadDeliveryenum

annotations.PayloadDelivery

PAYLOAD_DELIVERY_UNSPECIFIED = 0

PAYLOAD_DELIVERY_INLINE = 1

Published inline, the default for unannotated messages.

PAYLOAD_DELIVERY_GCS = 2

Always uploaded to GCS and published as a GcsPayloadRef.

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