dawabit_eth_substreams

bizznezz89

v0.1.0/2 downloads/Repository

Package ref

dawabit-eth-substreams@v0.1.0

Download .spkg

Run package

CLI

Run map_wabit_transfers from the command line.

substreams run dawabit-eth-substreams@v0.1.0 map_wabit_transfers -e mainnet --start-block -1

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

README

DaWabit Ethereum Substreams

DaWabit Ethereum Substreams provides Ethereum Mainnet market and token activity for the original WABIT token and its two primary Uniswap V2 liquidity markets.

This package is the Ethereum-side companion to the existing Robinhood Chain DaWabit Substreams package.

The two packages are intentionally separate:

Ethereum Mainnet
    |
    | WABIT token activity
    | WABIT/WETH market activity
    | WABIT/USDT market activity
    v
dawabit_eth_substreams

Robinhood Chain Mainnet
    |
    | ReLaunchpad curve discovery
    | Bonding-curve activity
    | Graduation
    | Post-graduation AMM activity
    v
dawabit_substreams

The existing Robinhood Chain package remains unchanged.

Package

Name:     dawabit_eth_substreams
Version:  v0.1.0
Network:  Ethereum Mainnet
Chain ID: 1

Built package:

dawabit-eth-substreams-v0.1.0.spkg

Substreams network identifier:

mainnet

Ethereum Contracts

WABIT

Original Ethereum WABIT token:

0x5857CF3FD35D1FB4EC56151B5Dcff289e7BE8000

Decimals:

WABIT is a fee-on-transfer token with transfer-burn mechanics.

The Substream does not estimate burn activity from swap amounts.

Instead, it indexes the WABIT contract's actual Transfer events and identifies transfers sent to the configured burn address:

0xdEAD000000000000000042069420694206942069

This lets downstream consumers distinguish observed token burns from ordinary token transfers.

WETH

Ethereum Wrapped Ether:

0xC02aaA39b223FE8D0A0e5C4F27eAD9083C756Cc2

Decimals:

USDT

Ethereum Tether:

0xdAC17F958D2ee523a2206206994597C13D831ec7

Decimals:

Indexed Ethereum Markets

WABIT / WETH

Uniswap V2 pair:

0xB5C6ee9949aB5323B266a8507DC2D80285e55774

Pair ordering:

token0 = WABIT
token1 = WETH

Normalized market symbol:

WABIT/WETH

WABIT / USDT

Uniswap V2 pair:

0x2E64071209C8a3642BE74fEbD001e09f727f8EEe

Pair ordering:

token0 = WABIT
token1 = USDT

Normalized market symbol:

WABIT/USDT

Architecture

The package produces three public modules:

                     Ethereum Mainnet
                            |
             +--------------+--------------+
             |                             |
             v                             v
        WABIT token                Uniswap V2 pairs
             |                             |
             | Transfer                    | Swap
             |                             | Sync
             |                             | Mint
             |                             | Burn
             v                             v
 map_wabit_transfers            map_eth_pair_activity
             |                             |
             +--------------+--------------+
                            |
                            v
                 map_eth_market_activity
                            |
                            v
              Canonical Ethereum feed

Module: `map_wabit_transfers`

Indexes Transfer events emitted by the original Ethereum WABIT contract.

Input:

sf.ethereum.type.v2.Block

Output:

proto:contract.v1.WabitTransfers

The block filter restricts processing to logs emitted by:

0x5857cf3fd35d1fb4ec56151b5dcff289e7be8000

Each transfer record contains:

event_type
burn

token
from
to
amount

block_number
transaction_hash
ordinal
event_id

Transfer Classification

Ordinary WABIT movement:

event_type = TRANSFER
burn       = false

Transfer to the configured burn address:

event_type = BURN
burn       = true

This classification is based on the emitted destination address.

The module therefore reports observed on-chain burns instead of deriving them from a hard-coded percentage.

Module: `map_eth_pair_activity`

Indexes activity from both Ethereum WABIT Uniswap V2 pairs.

Input:

sf.ethereum.type.v2.Block

Output:

proto:contract.v1.EthereumPairActivities

Tracked pairs:

WABIT/WETH
0xB5C6ee9949aB5323B266a8507DC2D80285e55774

WABIT/USDT
0x2E64071209C8a3642BE74fEbD001e09f727f8EEe

Indexed Uniswap V2 events:

Swap
Sync
Mint
Burn

`SWAP`

SWAP represents canonical AMM trading activity.

For swap records:

canonical_trade = true

Raw Uniswap V2 fields are retained:

amount0_in
amount1_in
amount0_out
amount1_out

The package also exposes normalized WABIT / quote fields:

token_amount_in
quote_amount_in

token_amount_out
quote_amount_out

This means downstream systems do not need to independently determine which side of the pair represents WABIT.

Example semantics:

token_* = WABIT
quote_* = WETH or USDT

depending on the market.

`SYNC`

SYNC exposes the current reserve values emitted by the Uniswap V2 pair.

Raw values:

reserve0
reserve1

Normalized values:

token_reserve
quote_reserve

For both currently indexed markets:

token_reserve = WABIT reserve
quote_reserve = WETH or USDT reserve

These reserve updates provide the underlying state required for market pricing, slippage calculations, and arbitrage analysis.

`MINT`

Represents liquidity being added to a WABIT pair.

Raw amounts:

amount0
amount1

Normalized amounts:

token_amount
quote_amount

where:

token_amount = WABIT
quote_amount = WETH or USDT

`BURN`

Within map_eth_pair_activity, BURN means a Uniswap V2 liquidity-removal event.

Raw amounts:

amount0
amount1

Normalized amounts:

token_amount
quote_amount

This is distinct from a WABIT token burn.

Burn Terminology

There are two different kinds of BURN activity represented by this package.

WABIT Token Burn

Source:

WABIT Transfer event

Classification:

activity_type = TOKEN
event_type    = BURN

Meaning:

WABIT was transferred to the configured burn address.

Uniswap V2 LP Burn

Source:

Uniswap V2 Pair Burn event

Classification:

activity_type = AMM
event_type    = BURN

Meaning:

Liquidity was removed from a WABIT liquidity pool.

Consumers should use activity_type to distinguish the two.

Pair Metadata

Every AMM record identifies:

market_symbol

pair
token
quote_token

token_decimals
quote_decimals

token0
token1
token_is_token0

Current markets:

Market	WABIT Decimals	Quote Decimals
WABIT/WETH	18	18
WABIT/USDT	18	6

The package preserves the raw pair ordering while also supplying normalized WABIT-centric fields.

This makes the feed suitable for consumers that should not need to reproduce token-ordering logic.

Module: `map_eth_market_activity`

map_eth_market_activity is the canonical combined Ethereum activity feed.

Input:

sf.ethereum.type.v2.Block

Output:

proto:contract.v1.EthereumMarketActivities

It combines:

WABIT token transfers
WABIT token burns

WABIT/WETH swaps
WABIT/WETH reserve updates
WABIT/WETH liquidity additions
WABIT/WETH liquidity removals

WABIT/USDT swaps
WABIT/USDT reserve updates
WABIT/USDT liquidity additions
WABIT/USDT liquidity removals

Records are sorted by Ethereum event ordinal before being emitted.

This preserves event ordering within a block.

Canonical Ethereum Activity Envelope

Each combined-feed record contains:

activity_type
event_type
canonical_trade

market
pair
token
quote_token

block_number
transaction_hash
ordinal
event_id

It also embeds the original decoded record:

wabit_transfer

or:

pair_activity

depending on the activity type.

Activity Types

Token-layer activity:

activity_type = TOKEN

AMM-layer activity:

activity_type = AMM

Canonical Trades

Only Uniswap V2 Swap events are marked:

canonical_trade = true

Token transfers are not trades.

Reserve synchronization events are not trades.

Liquidity additions are not trades.

Liquidity removals are not trades.

This prevents downstream systems from accidentally counting non-trade activity as market volume.

Event IDs

Each decoded event receives a deterministic identifier based on:

transaction_hash + ordinal

Format:

<transaction_hash>:<ordinal>

This gives downstream consumers a stable event-level identifier for deduplication and indexing.

Arbitrage Infrastructure Role

The Ethereum Substream provides the L1 market-data side of the DaWabit cross-chain market infrastructure.

Current relevant market topology:

                 Ethereum Mainnet

             WABIT/WETH
                  |
                  |
                  +---------+
                            |
                            v
                      WABIT pricing
                            ^
                            |
                  +---------+
                  |
             WABIT/USDT


                Robinhood Chain

               WABIT/RHC-WETH
                      |
               Bonding Curve
                    or
               Graduated AMM

The Ethereum feed provides deterministic activity from both L1 markets.

The Robinhood Chain feed independently provides the RHC market lifecycle and trading activity.

Together, those data sources can support cross-market monitoring and arbitrage infrastructure without combining the chain-specific Substreams packages themselves.

Current Module Graph

map_wabit_transfers
    |
    | WABIT Transfer logs
    v
WabitTransfers


map_eth_pair_activity
    |
    | WABIT/WETH
    | WABIT/USDT
    |
    | Swap / Sync / Mint / Burn
    v
EthereumPairActivities


map_eth_market_activity
    |
    | TOKEN activity
    | AMM activity
    v
EthereumMarketActivities

Block Filtering

The package imports:

streamingfast/ethereum-common-v0.3.3

and uses:

ethcommon:index_events

to avoid processing irrelevant Ethereum blocks.

Token filter:

evt_addr:0x5857cf3fd35d1fb4ec56151b5dcff289e7be8000

Pair filters:

evt_addr:0xb5c6ee9949ab5323b266a8507dc2d80285e55774

and:

evt_addr:0x2e64071209c8a3642be74febd001e09f727f8eee

The combined module filters for all three addresses.

Initial Blocks

The v0.1.0 manifest uses verified per-module historical boundaries:

map_wabit_transfers:       18,430,484
map_eth_pair_activity:     20,054,765
map_eth_market_activity:   18,430,484

WABIT was deployed on Ethereum Mainnet at block 18,430,484. Historical RPC verification confirms that the contract had no runtime bytecode at block 18,430,483 and had deployed runtime bytecode at block 18,430,484.

The canonical WABIT/WETH Uniswap V2 market begins at block 20,054,765. The WABIT/USDT market follows at block 20,054,779.

map_wabit_transfers therefore begins at the WABIT deployment block.

map_eth_pair_activity begins at the earliest tracked AMM market block, avoiding unnecessary processing before either tracked pair is active.

map_eth_market_activity begins at the WABIT deployment block because the combined feed includes token-level WABIT activity as well as AMM activity.

Address-based block filters further restrict processing to WABIT and the two tracked Uniswap V2 pairs.

ABI Generation

The package uses substreams-ethereum ABI generation.

Current ABI sources:

abi/wabit.json
abi/uniswap_v2_pair.json

Generated Rust bindings:

src/abi/wabit.rs
src/abi/uniswap_v2_pair.rs

build.rs regenerates the bindings as required during compilation.

Protobuf Schema

Primary protobuf source:

proto/contract.proto

Generated Rust protobuf bindings:

src/pb/contract.v1.rs

Primary output messages:

WabitTransfer
WabitTransfers

EthereumPairActivity
EthereumPairActivities

EthereumMarketActivity
EthereumMarketActivities

Build

From the Ethereum package directory:

cd /workspace/dawabit_eth_substreams
substreams build

Expected package:

dawabit-eth-substreams-v0.1.0.spkg

Protobuf Generation

substreams protogen substreams.yaml

Package Information

substreams info substreams.yaml

or:

substreams info dawabit-eth-substreams-v0.1.0.spkg

Run on Ethereum Mainnet

StreamingFast Ethereum endpoint:

mainnet.eth.streamingfast.io:443

WABIT Transfers

substreams run \
  -e mainnet.eth.streamingfast.io:443 \
  substreams.yaml \
  map_wabit_transfers \
  --start-block <block> \
  -o json

Ethereum Pair Activity

substreams run \
  -e mainnet.eth.streamingfast.io:443 \
  substreams.yaml \
  map_eth_pair_activity \
  --start-block <block> \
  -o json

Canonical Combined Ethereum Feed

substreams run \
  -e mainnet.eth.streamingfast.io:443 \
  substreams.yaml \
  map_eth_market_activity \
  --start-block <block> \
  -o json

Single-Block Development Test

A one-block historical test can be performed with:

substreams run \
  -e mainnet.eth.streamingfast.io:443 \
  substreams.yaml \
  map_eth_market_activity \
  --start-block <block> \
  --stop-block +1 \
  -o json

This is useful for validating known historical transactions without replaying the entire WABIT history.

Authentication

A Substreams API token can be provided through:

.substreams.env

The local auth file is not intended for source control.

Generated and Local Files

The package should not commit local build artifacts or credentials such as:

.substreams.env
target/
sink-data/
*.spkg

Generated ABI bindings may be regenerated through the Rust build process.

Source Layout

dawabit_eth_substreams/
├── abi/
│   ├── uniswap_v2_pair.json
│   └── wabit.json
│
├── proto/
│   └── contract.proto
│
├── src/
│   ├── abi/
│   │   ├── mod.rs
│   │   ├── uniswap_v2_pair.rs
│   │   └── wabit.rs
│   │
│   ├── pb/
│   └── lib.rs
│
├── build.rs
├── Cargo.toml
├── Cargo.lock
├── substreams.yaml
└── README.md

Relationship to DaWabit RHC Substreams

The Ethereum package must not replace or modify the existing Robinhood Chain package.

RHC package:

dawabit_substreams

Current completed RHC package:

dawabit_substreams@v0.2.2

Canonical RHC module:

map_market_activity

Ethereum package:

dawabit_eth_substreams

Canonical Ethereum module:

map_eth_market_activity

This separation keeps network-specific logic, contract discovery, ABIs, and lifecycle assumptions isolated while allowing higher-level DaWabit infrastructure to consume both feeds.

Repository

https://github.com/bizznezz89/dawabit-substreams

Modules

Execution graph

5 modules

mapMain

map_wabit_transfers

from #18430484

Output

contract.v1.WabitTransfers

Inputs

sf.ethereum.type.v2.Block

map

map_eth_market_activity

from #18430484

Output

contract.v1.EthereumMarketActivities

Inputs

sf.ethereum.type.v2.Block

map

map_eth_pair_activity

from #20054765

Output

contract.v1.EthereumPairActivities

Inputs

sf.ethereum.type.v2.Block

Show 2 dependencies

map

ethcommon:all_events

`all_events` gives you all the events in a block (from successful transactions), with basic block hash/number/timestamp and transaction hash

Output

sf.substreams.ethereum.v1.Events

Inputs

sf.ethereum.type.v2.Block

blockIndex

ethcommon:index_events

`index_events` sets the following keys on the block: * Event signatures evt_sig:0x0123456789abcdef0123456789abcdef0123456789abcdef0123456789abcdef (signature in hex, prefixed by 0x) * Event address evt_addr:0x0123456789abcdef0123456789abcdef01234567 (address in hex, prefixed by 0x)

Output

sf.substreams.index.v1.Keys

Inputs

ethcommon:all_events

Protobuf

contract.v1

EthereumMarketActivitiesmain

contract.v1.EthereumMarketActivities

EthereumMarketActivity[]activities = 1

EthereumPairActivitiesmain

contract.v1.EthereumPairActivities

EthereumPairActivity[]activities = 1

WabitTransfersmain

contract.v1.WabitTransfers

WabitTransfer[]transfers = 1

EthereumMarketActivity

contract.v1.EthereumMarketActivity

stringactivity_type = 1

TOKEN | AMM

stringevent_type = 2

boolcanonical_trade = 3

bytesmarket = 4

bytespair = 5

bytestoken = 6

bytesquote_token = 7

uint64block_number = 8

bytestransaction_hash = 9

uint64ordinal = 10

stringevent_id = 11

WabitTransferwabit_transfer = 12

EthereumPairActivitypair_activity = 13

EthereumPairActivity

contract.v1.EthereumPairActivity

stringevent_type = 1

SWAP | SYNC | MINT | BURN

boolcanonical_trade = 2

stringmarket_symbol = 3

WABIT/WETH | WABIT/USDT

bytespair = 4

bytestoken = 5

bytesquote_token = 6

uint32token_decimals = 7

uint32quote_decimals = 8

bytessender = 9

bytesto = 10

stringamount0 = 11

Raw Uniswap V2 values.

stringamount1 = 12

stringamount0_in = 13

stringamount1_in = 14

stringamount0_out = 15

stringamount1_out = 16

stringreserve0 = 17

stringreserve1 = 18

bytestoken0 = 19

Known pair ordering.

bytestoken1 = 20

booltoken_is_token0 = 21

stringtoken_amount = 22

Normalized WABIT / quote semantics.

stringquote_amount = 23

stringtoken_amount_in = 24

stringquote_amount_in = 25

stringtoken_amount_out = 26

stringquote_amount_out = 27

stringtoken_reserve = 28

stringquote_reserve = 29

uint64block_number = 30

bytestransaction_hash = 31

uint64ordinal = 32

stringevent_id = 33

WabitTransfer

contract.v1.WabitTransfer

stringevent_type = 1

TRANSFER | BURN

boolburn = 2

bytestoken = 3

bytesfrom = 4

bytesto = 5

stringamount = 6

uint64block_number = 7

bytestransaction_hash = 8

uint64ordinal = 9

stringevent_id = 10

Show 48 dependencies

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.ethereum.substreams.v1

RpcCall

sf.ethereum.substreams.v1.RpcCall

bytesto_addr = 1

bytesdata = 2

RpcCalls

sf.ethereum.substreams.v1.RpcCalls

RpcCall[]calls = 1

RpcResponse

sf.ethereum.substreams.v1.RpcResponse

bytesraw = 1

boolfailed = 2

RpcResponses

sf.ethereum.substreams.v1.RpcResponses

RpcResponse[]responses = 1

sf.ethereum.transform.v1

CallToFilter

sf.ethereum.transform.v1.CallToFilter

bytes[]addresses = 1

bytes[]signatures = 2

CombinedFilter

sf.ethereum.transform.v1.CombinedFilter

LogFilter[]log_filters = 1

CallToFilter[]call_filters = 2

boolsend_all_block_headers = 3

HeaderOnly

sf.ethereum.transform.v1.HeaderOnly

No fields.

LogFilter

sf.ethereum.transform.v1.LogFilter

bytes[]addresses = 1

bytes[]event_signatures = 2

MultiCallToFilter

sf.ethereum.transform.v1.MultiCallToFilter

CallToFilter[]call_filters = 1

MultiLogFilter

sf.ethereum.transform.v1.MultiLogFilter

LogFilter[]log_filters = 1

sf.ethereum.type.v2

BlockRef

sf.ethereum.type.v2.BlockRef

byteshash = 1

uint64number = 2

BlockWithRefs

sf.ethereum.type.v2.BlockWithRefs

stringid = 1

Blockblock = 2

TransactionRefstransaction_trace_refs = 3

boolirreversible = 4

HeaderOnlyBlock

sf.ethereum.type.v2.HeaderOnlyBlock

BlockHeaderheader = 5

TransactionRefs

sf.ethereum.type.v2.TransactionRefs

bytes[]hashes = 1

TransactionTraceWithBlockRef

sf.ethereum.type.v2.TransactionTraceWithBlockRef

TransactionTracetrace = 1

BlockRefblock_ref = 2

Reasonenum

sf.ethereum.type.v2.BalanceChange.Reason

REASON_UNKNOWN = 0

REASON_REWARD_MINE_UNCLE = 1

REASON_REWARD_MINE_BLOCK = 2

REASON_DAO_REFUND_CONTRACT = 3

REASON_DAO_ADJUST_BALANCE = 4

REASON_TRANSFER = 5

REASON_GENESIS_BALANCE = 6

REASON_GAS_BUY = 7

REASON_REWARD_TRANSACTION_FEE = 8

REASON_REWARD_FEE_RESET = 14

REASON_GAS_REFUND = 9

REASON_TOUCH_ACCOUNT = 10

REASON_SUICIDE_REFUND = 11

REASON_SUICIDE_WITHDRAW = 13

REASON_CALL_BALANCE_OVERRIDE = 12

REASON_BURN = 15

REASON_WITHDRAWAL = 16

REASON_REWARD_BLOB_FEE = 17

REASON_INCREASE_MINT = 18

REASON_REVERT = 19

DetailLevelenum

sf.ethereum.type.v2.Block.DetailLevel

DETAILLEVEL_EXTENDED = 0

DETAILLEVEL_BASE = 2

CallTypeenum

sf.ethereum.type.v2.CallType

UNSPECIFIED = 0

CALL = 1

CALLCODE = 2

DELEGATE = 3

STATIC = 4

CREATE = 5

Reasonenum

sf.ethereum.type.v2.GasChange.Reason

REASON_UNKNOWN = 0

REASON_CALL = 1

REASON_CALL_CODE = 2

REASON_CALL_DATA_COPY = 3

REASON_CODE_COPY = 4

REASON_CODE_STORAGE = 5

REASON_CONTRACT_CREATION = 6

REASON_CONTRACT_CREATION2 = 7

REASON_DELEGATE_CALL = 8

REASON_EVENT_LOG = 9

REASON_EXT_CODE_COPY = 10

REASON_FAILED_EXECUTION = 11

REASON_INTRINSIC_GAS = 12

REASON_PRECOMPILED_CONTRACT = 13

REASON_REFUND_AFTER_EXECUTION = 14

REASON_RETURN = 15

REASON_RETURN_DATA_COPY = 16

REASON_REVERT = 17

REASON_SELF_DESTRUCT = 18

REASON_STATIC_CALL = 19

REASON_STATE_COLD_ACCESS = 20

REASON_TX_INITIAL_BALANCE = 21

REASON_TX_REFUNDS = 22

REASON_TX_LEFT_OVER_RETURNED = 23

REASON_CALL_INITIAL_BALANCE = 24

REASON_CALL_LEFT_OVER_RETURNED = 25

REASON_WITNESS_CONTRACT_INIT = 26

REASON_WITNESS_CONTRACT_CREATION = 27

REASON_WITNESS_CODE_CHUNK = 28

REASON_WITNESS_CONTRACT_COLLISION_CHECK = 29

REASON_TX_DATA_FLOOR = 30

Typeenum

sf.ethereum.type.v2.TransactionTrace.Type

TRX_TYPE_LEGACY = 0

TRX_TYPE_ACCESS_LIST = 1

TRX_TYPE_DYNAMIC_FEE = 2

TRX_TYPE_BLOB = 3

TRX_TYPE_SET_CODE = 4

TRX_TYPE_ARBITRUM_DEPOSIT = 100

TRX_TYPE_ARBITRUM_UNSIGNED = 101

TRX_TYPE_ARBITRUM_CONTRACT = 102

TRX_TYPE_ARBITRUM_RETRY = 104

TRX_TYPE_ARBITRUM_SUBMIT_RETRYABLE = 105

TRX_TYPE_ARBITRUM_INTERNAL = 106

TRX_TYPE_ARBITRUM_LEGACY = 120

TRX_TYPE_OPTIMISM_DEPOSIT = 126

TransactionTraceStatusenum

sf.ethereum.type.v2.TransactionTraceStatus

UNKNOWN = 0

SUCCEEDED = 1

FAILED = 2

REVERTED = 3

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

dawabit_eth_substreams

DaWabit Ethereum Substreams

Package

Ethereum Contracts

WABIT

WETH

USDT

Indexed Ethereum Markets

WABIT / WETH

WABIT / USDT

Architecture

Module: map_wabit_transfers

Transfer Classification

Module: map_eth_pair_activity

SWAP

SYNC

MINT

BURN

Burn Terminology

WABIT Token Burn

Uniswap V2 LP Burn

Pair Metadata

Module: map_eth_market_activity

Canonical Ethereum Activity Envelope

Activity Types

Canonical Trades

Event IDs

Arbitrage Infrastructure Role

Current Module Graph

Block Filtering

Initial Blocks

ABI Generation

Protobuf Schema

Build

Protobuf Generation

Package Information

Run on Ethereum Mainnet

WABIT Transfers

Ethereum Pair Activity

Canonical Combined Ethereum Feed

Single-Block Development Test

Authentication

Generated and Local Files

Source Layout

Relationship to DaWabit RHC Substreams

Repository

Execution graph

map_wabit_transfers

map_eth_market_activity

map_eth_pair_activity

ethcommon:all_events

ethcommon:index_events

Module: `map_wabit_transfers`

Module: `map_eth_pair_activity`

`SWAP`

`SYNC`

`MINT`

`BURN`

Module: `map_eth_market_activity`