Database Changes Uniswaps

sf.substreams

message

FieldOptions

sf.substreams.v1

message

Modules

message

Binary

message

Module

message

Package

message

NetworkParams

message

PackageMetadata

message

ModuleMetadata

message

Clock

message

BlockRef

sf.substreams.rpc.v2

message

Request

message

Response

message

BlockUndoSignal

message

BlockScopedData

message

SessionInit

message

InitialSnapshotComplete

message

InitialSnapshotData

message

MapModuleOutput

message

StoreModuleOutput

message

OutputDebugInfo

message

ModulesProgress

message

ProcessedBytes

message

Error

message

Job

message

Stage

message

ModuleStats

message

ExternalCallMetric

message

StoreDelta

message

BlockRange

sf.substreams.sink.service.v1

message

DeployRequest

message

Parameter

message

DeployResponse

message

UpdateRequest

message

UpdateResponse

message

InfoRequest

message

InfoResponse

message

SinkProgress

message

PackageInfo

message

ListRequest

message

ListResponse

message

DeploymentWithStatus

message

RemoveRequest

message

RemoveResponse

message

PauseRequest

message

PauseResponse

message

StopRequest

message

StopResponse

message

ResumeRequest

message

ResumeResponse

enum

DeploymentStatus

sf.substreams.sink.database.v1

message

DatabaseChanges

message

TableChange

message

CompositePrimaryKey

message

Field

sf.substreams.sink.sql.v1

message

Service

message

DBTConfig

message

HasuraFrontend

message

PostgraphileFrontend

message

PGWebFrontend

message

RESTFrontend

annotations

evm.uniswap.v3

message

Events

message

PoolCreated

message

Initialize

message

Swap

message

OwnerChanged

message

FeeAmountEnabled

message

Mint

message

Collect

message

Burn

message

Flash

message

IncreaseObservationCardinalityNext

message

SetFeeProtocol

message

CollectProtocol

message

PositionManagerApproval

message

PositionManagerApprovalForAll

message

PositionManagerCollect

message

PositionManagerDecreaseLiquidity

message

PositionManagerIncreaseLiquidity

message

PositionManagerTransfer

google.protobuf

message

FileDescriptorSet

message

FileDescriptorProto

message

DescriptorProto

message

ExtensionRangeOptions

message

FieldDescriptorProto

message

OneofDescriptorProto

message

EnumDescriptorProto

message

EnumValueDescriptorProto

message

ServiceDescriptorProto

message

MethodDescriptorProto

message

FileOptions

message

MessageOptions

message

FieldOptions

message

OneofOptions

message

EnumOptions

message

EnumValueOptions

message

ServiceOptions

message

MethodOptions

message

UninterpretedOption

message

SourceCodeInfo

message

GeneratedCodeInfo

message

Any

message

Timestamp

sf.substreams.index.v1

message

Keys

evm.transaction

message

AssociatedEvmTransaction

evm.uniswap.v2

message

Events

message

PairCreated

message

Sync

message

Swap

message

Mint

message

Burn

message

Transfer

message

Approval

evm.uniswap.v4

message

Events

message

Initialize

message

Swap

message

ModifyLiquidity

message

ModifyLiquidityWithAmounts

message

Donate

message

Approval

message

OperatorSet

message

OwnershipTransferred

message

Transfer

message

ProtocolFeeControllerUpdated

message

ProtocolFeeUpdated

message

PositionManagerApproval

message

PositionManagerApprovalForAll

message

PositionManagerSubscription

message

PositionManagerUnsubscription

message

PositionManagerTransfer

evm.store

message

V4PoolStore

message MessageOptions {

optional bool = 1;

optional bool = 2;

optional bool = 3;

optional bool = 7;

repeated = 999;

}

// BlockRef is a pointer to a block to which we don't know the timestamp

message BlockRef {

optional string = 1;

optional uint64 = 2;

}

message PackageInfo {

optional string = 1;

optional string = 2;

optional string = 3;

optional string = 4;

}

message Service {

optional string = 1;

oneof _dbt_config {

optional = 2;

}

optional = 4;

optional = 5;

optional = 7;

optional = 8;

}

message Sync {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional string = 21;

optional string = 22;

}

Back to evm.transaction

message AssociatedEvmTransaction {

optional string = 1;

optional string = 2;

optional uint64 = 3;

optional string = 4;

optional uint64 = 5;

optional string = 6;

optional string = 7;

optional string = 8;

optional string = 9;

optional string = 10;

optional string gas_used = 11;

optional string type = 12;

optional string max_fee_per_gas = 14;

optional string max_priority_fee_per_gas = 15;

optional uint32 index = 16;

optional string from = 17;

optional string return_data = 18;

optional string public_key = 19;

optional uint64 begin_ordinal = 20;

optional uint64 end_ordinal = 21;

optional string status = 22;

repeated string calls = 23;

optional string blob_gas = 24;

optional string blob_gas_fee_cap = 25;

repeated string blob_hashes = 26;

repeated string set_code_authorizations = 27;

}

// Describes a field within a message.

message FieldDescriptorProto {

optional string = 1;

optional int32 = 3;

optional = 4;

optional = 5;

optional string = 6;

optional string = 2;

optional string = 7;

optional int32 = 9;

optional string = 10;

optional = 8;

optional bool proto3_optional = 17;

}

// `Any` contains an arbitrary serialized protocol buffer message along with a URL that describes the type of the serialized message. Protobuf library provides support to pack/unpack Any values in the form of utility functions or additional generated methods of the Any type. Example 1: Pack and unpack a message in C++. Foo foo = ...; Any any; any.PackFrom(foo); ... if (any.UnpackTo(&foo)) { ... } Example 2: Pack and unpack a message in Java. Foo foo = ...; Any any = Any.pack(foo); ... if (any.is(Foo.class)) { foo = any.unpack(Foo.class); } Example 3: Pack and unpack a message in Python. foo = Foo(...) any = Any() any.Pack(foo) ... if any.Is(Foo.DESCRIPTOR): any.Unpack(foo) ... Example 4: Pack and unpack a message in Go foo := &pb.Foo{...} any, err := anypb.New(foo) if err != nil { ... } ... foo := &pb.Foo{} if err := any.UnmarshalTo(foo); err != nil { ... } The pack methods provided by protobuf library will by default use 'type.googleapis.com/full.type.name' as the type URL and the unpack methods only use the fully qualified type name after the last '/' in the type URL, for example "foo.bar.com/x/y.z" will yield type name "y.z". JSON The JSON representation of an `Any` value uses the regular representation of the deserialized, embedded message, with an additional field `@type` which contains the type URL. Example: package google.profile; message Person { string first_name = 1; string last_name = 2; } { "@type": "type.googleapis.com/google.profile.Person", "firstName": <string>, "lastName": <string> } If the embedded message type is well-known and has a custom JSON representation, that representation will be embedded adding a field `value` which holds the custom JSON in addition to the `@type` field. Example (for message [google.protobuf.Duration][]): { "@type": "type.googleapis.com/google.protobuf.Duration", "value": "1.212s" }

message Any {

optional string = 1;

optional bytes = 2;

}

message OutputDebugInfo {

repeated string = 1;

optional bool = 2;

optional bool = 3;

}

// / @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

message Burn {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

optional int32 = 11;

optional int32 = 12;

optional string amount = 13;

optional string amount0 = 14;

optional string amount1 = 15;

}

// Describes a complete .proto file.

message FileDescriptorProto {

optional string = 1;

optional string = 2;

repeated string = 3;

repeated int32 = 10;

repeated int32 = 11;

repeated = 4;

repeated = 5;

repeated = 6;

repeated = 7;

optional = 8;

optional source_code_info = 9;

optional string syntax = 12;

}

message KindStore {

optional = 1;

optional string = 2;

}

message ParamsEntry {

optional string key = 1;

optional string value = 2;

}

// * 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.

message Swap {

optional bytes = 1;

oneof _caller {

optional bytes = 4;

}

optional bytes = 5;

optional uint64 = 6;

optional uint32 = 7;

optional uint32 = 8;

optional uint32 = 9;

optional bytes = 10;

optional bytes = 11;

optional string = 12;

optional string amount1 = 13;

optional string sqrt_price_x96 = 14;

optional string liquidity = 15;

optional int32 tick = 16;

}

message Modules {

repeated = 1;

repeated = 2;

}

message NetworksEntry {

optional string key = 1;

optional value = 2;

}

message UpdateResponse {

optional = 1;

repeated = 2;

optional string = 3;

optional string = 4;

}

message StopResponse {

optional = 1;

optional = 2;

}

message ResumeRequest {

optional string = 1;

}

// / @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

message Donate {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

optional bytes = 11;

optional string = 12;

optional string amount1 = 13;

}

// The protocol compiler can output a FileDescriptorSet containing the .proto files it parses.

message FileDescriptorSet {

repeated = 1;

}

// Describes a message type.

message DescriptorProto {

optional string = 1;

repeated = 2;

repeated = 6;

repeated = 3;

repeated = 4;

repeated = 5;

repeated = 8;

optional = 7;

repeated = 9;

repeated string = 10;

}

message FileOptions {

optional string = 1;

optional string = 8;

optional bool = 10;

optional bool = 20;

optional bool = 27;

optional = 9;

optional string = 11;

optional bool = 16;

optional bool = 17;

optional bool = 18;

optional bool php_generic_services = 42;

optional bool deprecated = 23;

optional bool cc_enable_arenas = 31;

optional string objc_class_prefix = 36;

optional string csharp_namespace = 37;

optional string swift_prefix = 39;

optional string php_class_prefix = 40;

optional string php_namespace = 41;

optional string php_metadata_namespace = 44;

optional string ruby_package = 45;

repeated uninterpreted_option = 999;

}

message PauseResponse {

optional = 1;

optional = 2;

}

message TableChange {

optional string = 1;

oneof primary_key {

optional string = 2;

optional = 6;

}

optional uint64 = 3;

optional = 4;

repeated = 5;

}

// https://www.graphile.org/postgraphile/

message PostgraphileFrontend {

optional bool = 1;

}

// / @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

message OwnerChanged {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

optional bytes = 11;

}

// / @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

message Flash {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

optional bytes = 11;

optional string = 12;

optional string amount1 = 13;

optional string paid0 = 14;

optional string paid1 = 15;

}

// Describes the relationship between generated code and its original source file. A GeneratedCodeInfo message is associated with only one generated source file, but may contain references to different source .proto files.

message GeneratedCodeInfo {

repeated = 1;

}

message Field {

optional string = 1;

optional string = 2;

optional string = 3;

}

message ModifyLiquidityWithAmounts {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

optional bytes = 11;

optional int32 = 12;

optional int32 tick_upper = 13;

optional string liquidity_delta = 14;

optional bytes salt = 18;

optional string liquidity_math_amount0 = 19;

optional string liquidity_math_amount1 = 20;

}

// Range of reserved tag numbers. Reserved tag numbers may not be used by fields or extension ranges in the same message. Reserved ranges may not overlap.

message ReservedRange {

optional int32 = 1;

optional int32 = 2;

}

message Package {

repeated = 1;

optional uint64 = 5;

optional = 6;

repeated = 7;

repeated = 8;

optional string = 9;

optional = 10;

optional string = 11;

optional bytes = 12;

repeated = 13;

repeated block_filters = 14;

}

message InitialSnapshotData {

optional string = 1;

repeated = 2;

optional uint64 = 4;

optional uint64 = 3;

}

message Approval {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 11;

optional bytes = 12;

optional string = 13;

}

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

message PositionManagerApproval {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

optional bytes = 11;

optional string = 12;

}

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

message PositionManagerUnsubscription {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional string = 10;

optional bytes = 11;

}

Back to evm.store

message V4PoolStore {

optional string = 1;

optional int32 = 2;

}

// Describes an enum type.

message EnumDescriptorProto {

optional string = 1;

repeated = 2;

optional = 3;

repeated = 4;

repeated string = 5;

}

message InitialSnapshotComplete {

optional string = 1;

}

// https://github.com/sosedoff/pgweb

message PGWebFrontend {

optional bool = 1;

}

// / @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

message Collect {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

optional bytes = 11;

optional int32 = 12;

optional int32 tick_upper = 13;

optional string amount0 = 14;

optional string amount1 = 15;

}

message Input {

oneof input {

optional = 1;

optional = 2;

optional = 3;

optional = 4;

}

// ModuleStats gathers metrics and statistics from each module, running on tier1 or tier2 All the 'count' and 'time_ms' values may include duplicate for each stage going over that module

message ModuleStats {

optional string = 1;

optional uint64 = 2;

optional uint64 = 3;

repeated = 4;

optional uint64 = 5;

optional uint64 = 6;

optional uint64 = 10;

optional uint64 = 11;

optional uint64 = 12;

optional uint64 = 13;

optional bool store_currently_merging = 14;

optional uint64 highest_contiguous_block = 15;

}

message StopRequest {

optional string = 1;

}

message ExtensionRange {

optional int32 = 1;

optional int32 = 2;

optional = 3;

}

// Describes a oneof.

message OneofDescriptorProto {

optional string = 1;

optional = 2;

}

// Describes a service.

message ServiceDescriptorProto {

optional string = 1;

repeated = 2;

optional = 3;

}

// https://www.getdbt.com/product/what-is-dbt

message DBTConfig {

optional bytes = 1;

optional int32 = 2;

optional bool = 3;

}

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

message PositionManagerApprovalForAll {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

optional bytes = 11;

optional bool = 12;

}

message KindBlockIndex {

optional string = 1;

}

message RemoveResponse {

optional = 1;

}

// https://github.com/semiotic-ai/sql-wrapper

message RESTFrontend {

optional bool = 1;

}

// / @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

message PoolCreated {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

optional bytes = 11;

optional uint64 = 12;

optional int32 tick_spacing = 13;

optional bytes pool_address = 14;

}

// Encapsulates information about the original source file from which a FileDescriptorProto was generated.

message SourceCodeInfo {

repeated = 1;

}

message BlockFiltersEntry {

optional string key = 1;

optional string value = 2;

}

// BlockUndoSignal informs you that every bit of data with a block number above 'last_valid_block' has been reverted on-chain. Delete that data and restart from 'last_valid_cursor'

message BlockUndoSignal {

optional = 1;

optional string = 2;

}

message ListResponse {

repeated = 1;

}

// https://hasura.io/docs/latest/index/

message HasuraFrontend {

optional bool = 1;

}

// / @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

message FeeAmountEnabled {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional uint64 = 10;

optional int32 = 11;

}

message MethodOptions {

optional bool = 33;

optional = 34;

repeated = 999;

}

Back to sf.substreams

message FieldOptions {

optional bool = 1;

optional bool = 2;

}

message SessionInit {

optional string = 1;

optional uint64 = 2;

optional uint64 = 3;

optional uint64 = 4;

}

message ProcessedBytes {

optional uint64 = 1;

optional uint64 = 2;

}

message DeployResponse {

optional = 1;

optional string = 2;

repeated = 3;

optional string = 4;

optional string = 5;

}

message SinkProgress {

optional uint64 = 1;

}

message EnumValueOptions {

optional bool = 1;

repeated = 999;

}

message Module {

optional string = 1;

oneof kind {

optional = 2;

optional = 3;

optional = 10;

}

optional uint32 = 4;

optional string = 5;

repeated = 6;

optional = 7;

optional uint64 = 8;

optional = 9;

}

message ModuleMetadata {

optional uint64 = 1;

optional string = 2;

}

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

message PositionManagerCollect {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional string = 10;

optional bytes = 11;

optional string = 12;

optional string amount1 = 13;

}

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

message PositionManagerApprovalForAll {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

optional bytes = 11;

optional bool = 12;

}

// The name of the uninterpreted option. Each string represents a segment in a dot-separated name. is_extension is true iff a segment represents an extension (denoted with parentheses in options specs in .proto files). E.g.,{ ["foo", false], ["bar.baz", true], ["moo", false] } represents "foo.(bar.baz).moo".

message NamePart {

required string = 1;

required bool = 2;

}

// Binary represents some code compiled to its binary form.

message Binary {

optional string = 1;

optional bytes = 2;

}

message ExternalCallMetric {

optional string = 1;

optional uint64 = 2;

optional uint64 = 3;

}

message InfoRequest {

optional string = 1;

}

message KeysEntry {

optional string key = 1;

optional string value = 2;

}

message ServicesEntry {

optional string key = 1;

optional string value = 2;

}

message Events {

repeated = 1;

repeated = 2;

repeated = 3;

repeated = 4;

repeated = 5;

repeated = 6;

repeated = 7;

repeated = 8;

}

// * 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.

message Initialize {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional string = 21;

optional int32 = 22;

}

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

message PositionManagerIncreaseLiquidity {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional string = 10;

optional string = 11;

optional string = 12;

optional string amount1 = 13;

}

// / @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

message ModifyLiquidity {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

optional bytes = 11;

optional int32 = 12;

optional int32 tick_upper = 13;

optional string liquidity_delta = 14;

optional bytes salt = 18;

}

// / @notice Emitted when the contract ownership is transferred.

message OwnershipTransferred {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

optional bytes = 11;

}

// / @notice Emitted when balances are transferred.

message Transfer {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

optional bytes = 11;

optional bytes = 12;

optional string id = 13;

optional string amount = 14;

}

message QueryFromParams {

}

message NetworkParams {

repeated = 1;

repeated = 2;

}

message Request {

optional int64 = 1;

optional string = 2;

optional uint64 = 3;

optional bool = 4;

optional bool = 5;

optional string = 6;

optional = 7;

repeated string = 10;

}

message DeployRequest {

optional = 1;

optional bool = 2;

repeated = 3;

}

message UpdateRequest {

optional = 1;

optional string = 2;

optional bool = 3;

}

message RemoveRequest {

optional string = 1;

}

// / @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

message IncreaseObservationCardinalityNext {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional uint64 = 10;

optional uint64 = 11;

}

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

message PositionManagerTransfer {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

optional bytes = 11;

optional string = 12;

}

message ResumeResponse {

optional = 1;

optional = 2;

}

message ExtensionRangeOptions {

repeated = 999;

}

message InitialBlocksEntry {

optional string key = 1;

optional uint64 value = 2;

}

message MapModuleOutput {

optional string = 1;

optional = 2;

optional = 10;

}

message Stage {

repeated string = 1;

repeated = 2;

}

message DeploymentWithStatus {

optional string = 1;

optional = 2;

optional string = 3;

optional = 4;

optional = 5;

optional string = 6;

}

// / @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

message SetFeeProtocol {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional uint64 = 10;

optional uint64 = 11;

optional uint64 = 12;

optional uint64 fee_protocol1_new = 13;

}

// Range of reserved numeric values. Reserved values may not be used by entries in the same enum. Reserved ranges may not overlap. Note that this is distinct from DescriptorProto.ReservedRange in that it is inclusive such that it can appropriately represent the entire int32 domain.

message EnumReservedRange {

optional int32 = 1;

optional int32 = 2;

}

message EnumOptions {

optional bool = 2;

optional bool = 3;

repeated = 999;

}

message Burn {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

optional string = 11;

optional string = 12;

optional bytes to = 13;

}

message Transfer {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 11;

optional bytes = 12;

optional string = 13;

}

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

message Events {

repeated = 1;

repeated = 2;

repeated = 3;

repeated = 4;

repeated = 5;

repeated = 6;

repeated = 7;

repeated = 8;

repeated = 9;

repeated = 10;

repeated owner_changed = 11;

repeated fee_amount_enabled = 12;

repeated associated_evm_transaction = 13;

repeated position_manager_approval = 14;

repeated position_manager_approval_for_all = 15;

repeated position_manager_collect = 16;

repeated position_manager_decrease_liquidity = 17;

repeated position_manager_increase_liquidity = 18;

repeated position_manager_transfer = 19;

}

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

message PositionManagerApproval {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

optional bytes = 11;

optional string = 12;

}

// Describes a value within an enum.

message EnumValueDescriptorProto {

optional string = 1;

optional int32 = 2;

optional = 3;

}

message Annotation {

repeated int32 = 1;

optional string = 2;

optional int32 = 3;

optional int32 = 4;

}

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

message ProtocolFeeControllerUpdated {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

}

message FieldOptions {

optional = 1;

optional bool = 2;

optional = 6;

optional bool = 5;

optional bool = 15;

optional bool = 3;

optional bool = 10;

repeated = 999;

}

// A message representing a option the parser does not recognize. This only appears in options protos created by the compiler::Parser class. DescriptorPool resolves these when building Descriptor objects. Therefore, options protos in descriptor objects (e.g. returned by Descriptor::options(), or produced by Descriptor::CopyTo()) will never have UninterpretedOptions in them.

message UninterpretedOption {

repeated = 2;

optional string = 3;

optional uint64 = 4;

optional int64 = 5;

optional double = 6;

optional bytes = 7;

optional string = 8;

}

message Params {

optional string = 1;

}

message ServicesEntry {

optional string key = 1;

optional string value = 2;

}

message CompositePrimaryKey {

repeated = 1;

}

message BlockFilter {

optional string = 1;

oneof query {

optional string = 2;

optional = 3;

}

message Response {

oneof message {

optional = 1;

optional = 2;

optional = 3;

optional = 4;

optional = 5;

optional = 10;

optional = 11;

}

message BlockScopedData {

optional = 1;

optional = 2;

optional string = 3;

optional uint64 = 4;

repeated = 10;

repeated = 11;

}

message InfoResponse {

optional = 1;

repeated = 2;

optional string = 3;

optional = 4;

optional = 5;

optional string = 6;

}

Back to sf.substreams.index.v1

message Source {

optional string = 1;

}

message Keys {

repeated string = 1;

}

// ModulesProgress is a message that is sent every 500ms

message ModulesProgress {

repeated = 2;

repeated = 3;

repeated = 4;

optional = 5;

}

message ServicesEntry {

optional string key = 1;

optional string value = 2;

}

message DatabaseChanges {

repeated = 1;

}

message Swap {

optional bytes = 1;

oneof _caller {

optional bytes = 4;

}

optional bytes = 5;

optional uint64 = 6;

optional uint32 = 7;

optional uint32 = 8;

optional uint32 = 9;

optional bytes = 10;

optional string = 11;

optional string = 12;

optional string amount1_in = 13;

optional string amount1_out = 14;

optional bytes to = 15;

}

// / @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

message CollectProtocol {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

optional bytes = 11;

optional string = 12;

optional string amount1 = 13;

}

message ProtocolFeeUpdated {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

optional uint64 = 11;

}

message Store {

optional string = 1;

optional = 2;

}

message Parameter {

optional string = 1;

optional string = 2;

}

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

message PositionManagerSubscription {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional string = 10;

optional bytes = 11;

}

// Clock is a pointer to a block with added timestamp

message Clock {

optional string = 1;

optional uint64 = 2;

optional = 3;

}

message ServiceOptions {

optional bool = 33;

repeated = 999;

}

message Error {

optional string = 1;

optional string = 2;

repeated string = 3;

optional bool = 4;

}

message Job {

optional uint32 = 1;

optional uint64 = 2;

optional uint64 = 3;

optional uint64 = 4;

optional uint64 = 5;

}

// / @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

message Swap {

optional bytes = 1;

oneof _caller {

optional bytes = 4;

}

optional bytes = 5;

optional uint64 = 6;

optional uint32 = 7;

optional uint32 = 8;

optional uint32 = 9;

optional bytes = 10;

optional bytes = 11;

optional string = 13;

optional string amount1 = 14;

optional string sqrt_price_x96 = 15;

optional string liquidity = 16;

optional int32 tick = 17;

optional string fee = 18;

}

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

message Approval {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

optional bytes = 11;

optional string = 12;

optional string amount = 13;

}

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

message OperatorSet {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

optional bytes = 11;

optional bool = 12;

}

message KindMap {

optional string = 1;

}

// A Timestamp represents a point in time independent of any time zone or local calendar, encoded as a count of seconds and fractions of seconds at nanosecond resolution. The count is relative to an epoch at UTC midnight on January 1, 1970, in the proleptic Gregorian calendar which extends the Gregorian calendar backwards to year one. All minutes are 60 seconds long. Leap seconds are "smeared" so that no leap second table is needed for interpretation, using a [24-hour linear smear](https://developers.google.com/time/smear). The range is from 0001-01-01T00:00:00Z to 9999-12-31T23:59:59.999999999Z. By restricting to that range, we ensure that we can convert to and from [RFC 3339](https://www.ietf.org/rfc/rfc3339.txt) date strings. # Examples Example 1: Compute Timestamp from POSIX `time()`. Timestamp timestamp; timestamp.set_seconds(time(NULL)); timestamp.set_nanos(0); Example 2: Compute Timestamp from POSIX `gettimeofday()`. struct timeval tv; gettimeofday(&tv, NULL); Timestamp timestamp; timestamp.set_seconds(tv.tv_sec); timestamp.set_nanos(tv.tv_usec * 1000); Example 3: Compute Timestamp from Win32 `GetSystemTimeAsFileTime()`. FILETIME ft; GetSystemTimeAsFileTime(&ft); UINT64 ticks = (((UINT64)ft.dwHighDateTime) << 32) | ft.dwLowDateTime; // A Windows tick is 100 nanoseconds. Windows epoch 1601-01-01T00:00:00Z // is 11644473600 seconds before Unix epoch 1970-01-01T00:00:00Z. Timestamp timestamp; timestamp.set_seconds((INT64) ((ticks / 10000000) - 11644473600LL)); timestamp.set_nanos((INT32) ((ticks % 10000000) * 100)); Example 4: Compute Timestamp from Java `System.currentTimeMillis()`. long millis = System.currentTimeMillis(); Timestamp timestamp = Timestamp.newBuilder().setSeconds(millis / 1000) .setNanos((int) ((millis % 1000) * 1000000)).build(); Example 5: Compute Timestamp from Java `Instant.now()`. Instant now = Instant.now(); Timestamp timestamp = Timestamp.newBuilder().setSeconds(now.getEpochSecond()) .setNanos(now.getNano()).build(); Example 6: Compute Timestamp from current time in Python. timestamp = Timestamp() timestamp.GetCurrentTime() # JSON Mapping In JSON format, the Timestamp type is encoded as a string in the [RFC 3339](https://www.ietf.org/rfc/rfc3339.txt) format. That is, the format is "{year}-{month}-{day}T{hour}:{min}:{sec}[.{frac_sec}]Z" where {year} is always expressed using four digits while {month}, {day}, {hour}, {min}, and {sec} are zero-padded to two digits each. The fractional seconds, which can go up to 9 digits (i.e. up to 1 nanosecond resolution), are optional. The "Z" suffix indicates the timezone ("UTC"); the timezone is required. A proto3 JSON serializer should always use UTC (as indicated by "Z") when printing the Timestamp type and a proto3 JSON parser should be able to accept both UTC and other timezones (as indicated by an offset). For example, "2017-01-15T01:30:15.01Z" encodes 15.01 seconds past 01:30 UTC on January 15, 2017. In JavaScript, one can convert a Date object to this format using the standard [toISOString()](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Date/toISOString) method. In Python, a standard `datetime.datetime` object can be converted to this format using [`strftime`](https://docs.python.org/2/library/time.html#time.strftime) with the time format spec '%Y-%m-%dT%H:%M:%S.%fZ'. Likewise, in Java, one can use the Joda Time's [`ISODateTimeFormat.dateTime()`]( http://www.joda.org/joda-time/apidocs/org/joda/time/format/ISODateTimeFormat.html#dateTime%2D%2D ) to obtain a formatter capable of generating timestamps in this format.

message Timestamp {

optional int64 = 1;

optional int32 = 2;

}

message Map {

optional string = 1;

}

message ListRequest {

}

message PairCreated {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

optional bytes = 11;

optional bytes = 12;

optional uint64 all_pairs_length = 13;

}

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

message PositionManagerDecreaseLiquidity {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional string = 10;

optional string = 11;

optional string = 12;

optional string amount1 = 13;

}

message PauseRequest {

optional string = 1;

}

// / @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

message Mint {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

optional bytes = 11;

optional int32 = 12;

optional int32 tick_upper = 13;

optional string amount = 14;

optional string amount0 = 15;

optional string amount1 = 16;

}

// / @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

message Initialize {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

optional bytes = 11;

optional bytes = 12;

optional uint64 fee = 13;

optional int32 tick_spacing = 14;

optional string sqrt_price_x96 = 17;

optional int32 tick = 18;

optional string hooks = 19;

}

// / @notice Emitted when a position NFT is transferred.

message PositionManagerTransfer {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

optional bytes = 11;

optional string = 12;

}

// Describes a method of a service.

message MethodDescriptorProto {

optional string = 1;

optional string = 2;

optional string = 3;

optional = 4;

optional bool = 5;

optional bool = 6;

}

message StoreDelta {

optional = 1;

optional uint64 = 2;

optional string = 3;

optional bytes = 4;

optional bytes = 5;

}

message Mint {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional uint32 = 7;

optional bytes = 10;

optional string = 11;

optional string = 12;

}

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

message Events {

repeated = 1;

repeated = 2;

repeated = 3;

repeated = 4;

repeated = 5;

repeated = 6;

repeated = 7;

repeated = 8;

repeated = 9;

repeated = 10;

repeated position_manager_unsubscription = 11;

repeated position_manager_transfer = 12;

repeated modify_liquidity_with_amounts = 13;

repeated approval = 14;

repeated operator_set = 15;

repeated ownership_transferred = 16;

repeated transfer = 17;

}

message OneofOptions {

repeated = 999;

}

message Location {

repeated int32 = 1;

repeated int32 = 2;

optional string = 3;

optional string = 4;

repeated string = 6;

}

message Output {

optional string = 1;

}

message PackageMetadata {

optional string = 1;

optional string = 2;

optional string = 3;

optional string = 4;

}

// StoreModuleOutput are produced for store modules in development mode. It is not possible to retrieve store models in production, with parallelization enabled. If you need the deltas directly, write a pass through mapper module that will get them down to you.

message StoreModuleOutput {

optional string = 1;

repeated = 2;

optional = 10;

}

message BlockRange {

optional uint64 = 2;

optional uint64 = 3;

}

enum

DeploymentStatus

UNKNOWN = 0;

RUNNING = 1;

FAILING = 2;

PAUSED = 3;

STOPPED = 4;

STARTING = 5;

PAUSING = 6;

STOPPING = 7;

REMOVING = 8;

RESUMING = 9;

enum

Engine

unset = 0;

postgres = 1;

clickhouse = 2;

enum

Label

LABEL_OPTIONAL = 1;

LABEL_REQUIRED = 2;

LABEL_REPEATED = 3;

enum

OptimizeMode

Generated classes can be optimized for speed or code size.

SPEED = 1;

CODE_SIZE = 2;

LITE_RUNTIME = 3;

enum

CType

STRING = 0;

CORD = 1;

STRING_PIECE = 2;

enum

JSType

JS_NORMAL = 0;

JS_STRING = 1;

JS_NUMBER = 2;

enum

Operation

OPERATION_UNSPECIFIED = 0;

OPERATION_CREATE = 1;

OPERATION_UPDATE = 2;

OPERATION_DELETE = 3;

enum

Type

TYPE_DOUBLE = 1;

TYPE_FLOAT = 2;

TYPE_INT64 = 3;

TYPE_UINT64 = 4;

TYPE_INT32 = 5;

TYPE_FIXED64 = 6;

TYPE_FIXED32 = 7;

TYPE_BOOL = 8;

TYPE_STRING = 9;

TYPE_GROUP = 10;

TYPE_MESSAGE = 11;

TYPE_BYTES = 12;

TYPE_UINT32 = 13;

TYPE_ENUM = 14;

TYPE_SFIXED32 = 15;

TYPE_SFIXED64 = 16;

TYPE_SINT32 = 17;

TYPE_SINT64 = 18;

enum

IdempotencyLevel

Is this method side-effect-free (or safe in HTTP parlance), or idempotent, or neither? HTTP based RPC implementation may choose GET verb for safe methods, and PUT verb for idempotent methods instead of the default POST.

IDEMPOTENCY_UNKNOWN = 0;

NO_SIDE_EFFECTS = 1;

IDEMPOTENT = 2;

enum

UpdatePolicy

UPDATE_POLICY_UNSET = 0;

UPDATE_POLICY_SET = 1;

UPDATE_POLICY_SET_IF_NOT_EXISTS = 2;

UPDATE_POLICY_ADD = 3;

UPDATE_POLICY_MIN = 4;

UPDATE_POLICY_MAX = 5;

UPDATE_POLICY_APPEND = 6;

UPDATE_POLICY_SET_SUM = 7;

enum

Mode

UNSET = 0;

GET = 1;

DELTAS = 2;