Database Changes Uniswaps

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

evm.store

message

V4PoolStore

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.index.v1

message

Keys

annotations

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

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

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

message ServicesEntry {

optional string key = 1;

optional string value = 2;

}

// Describes a oneof.

message OneofDescriptorProto {

optional string = 1;

optional = 2;

}

// Describes an enum type.

message EnumDescriptorProto {

optional string = 1;

repeated = 2;

optional = 3;

repeated = 4;

repeated string = 5;

}

message BlockFiltersEntry {

optional string key = 1;

optional string value = 2;

}

message UpdateResponse {

optional = 1;

repeated = 2;

optional string = 3;

optional string = 4;

}

message PauseResponse {

optional = 1;

optional = 2;

}

// / @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 bytes = 10;

optional bytes = 11;

optional string = 12;

}

Back to evm.store

message V4PoolStore {

optional string = 1;

optional int32 = 2;

}

message StopRequest {

optional string = 1;

}

// / @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 bytes = 10;

optional bytes = 11;

optional string = 12;

optional string = 13;

optional string paid0 = 14;

optional string paid1 = 15;

}

// `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 BlockScopedData {

optional = 1;

optional = 2;

optional string = 3;

optional uint64 = 4;

repeated = 10;

repeated = 11;

}

message StopResponse {

optional = 1;

optional = 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 string = 10;

optional bytes = 11;

}

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

}

message ServicesEntry {

optional string key = 1;

optional string value = 2;

}

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;

}

// / @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 bytes = 10;

optional bytes = 11;

optional string = 13;

optional string = 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 PositionManagerApproval {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional bytes = 10;

optional bytes = 11;

optional string = 12;

}

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

message FileDescriptorSet {

repeated = 1;

}

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

message RESTFrontend {

optional bool = 1;

}

// / @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 bytes = 10;

optional bytes = 11;

optional bool = 12;

}

message StoreDelta {

optional = 1;

optional uint64 = 2;

optional string = 3;

optional bytes = 4;

optional bytes = 5;

}

message Store {

optional string = 1;

optional = 2;

}

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

}

// Describes a value within an enum.

message EnumValueDescriptorProto {

optional string = 1;

optional int32 = 2;

optional = 3;

}

message MethodOptions {

optional bool = 33;

optional = 34;

repeated = 999;

}

message MapModuleOutput {

optional string = 1;

optional = 2;

optional = 10;

}

message InitialBlocksEntry {

optional string key = 1;

optional uint64 value = 2;

}

message InitialSnapshotComplete {

optional string = 1;

}

message InitialSnapshotData {

optional string = 1;

repeated = 2;

optional uint64 = 4;

optional uint64 = 3;

}

message Transfer {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional bytes = 11;

optional bytes = 12;

optional string = 13;

}

// / @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 bytes = 10;

optional bytes = 11;

optional int32 = 12;

optional int32 = 13;

optional string amount0 = 14;

optional string amount1 = 15;

}

// Describes a service.

message ServiceDescriptorProto {

optional string = 1;

repeated = 2;

optional = 3;

}

message ListResponse {

repeated = 1;

}

// / @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 string = 10;

optional string = 11;

optional string = 12;

optional string = 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 bytes = 10;

optional bytes = 11;

optional int32 = 12;

optional int32 = 13;

optional string liquidity_delta = 14;

optional bytes salt = 18;

}

// / @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 bytes = 10;

optional bytes = 11;

optional string = 12;

optional string = 13;

}

// / @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 bytes = 10;

optional bytes = 11;

optional bytes = 12;

optional string = 13;

optional string amount = 14;

}

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

}

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

}

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

}

message MessageOptions {

optional bool = 1;

optional bool = 2;

optional bool = 3;

optional bool = 7;

repeated = 999;

}

// / @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 string = 10;

optional string = 11;

optional string = 12;

optional string = 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 bytes = 10;

optional bytes = 11;

optional bool = 12;

}

message KindMap {

optional string = 1;

}

message Sync {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional string = 21;

optional string = 22;

}

message Burn {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional bytes = 10;

optional string = 11;

optional string = 12;

optional bytes = 13;

}

// / @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 bytes = 10;

optional bytes = 11;

}

message Params {

optional string = 1;

}

message Parameter {

optional string = 1;

optional string = 2;

}

message KeysEntry {

optional string key = 1;

optional string value = 2;

}

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

message PostgraphileFrontend {

optional bool = 1;

}

// / @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 uint64 = 10;

optional uint64 = 11;

optional uint64 = 12;

optional uint64 = 13;

}

// / @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 bytes = 10;

optional bytes = 11;

optional string = 12;

optional string = 13;

}

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

message SourceCodeInfo {

repeated = 1;

}

message Mint {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional bytes = 10;

optional string = 11;

optional string = 12;

}

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;

}

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

repeated int32 = 1;

repeated int32 = 2;

optional string = 3;

optional string = 4;

repeated string = 6;

}

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

optional string = 1;

}

message Swap {

optional bytes = 1;

oneof _caller {

optional bytes = 4;

}

optional bytes = 5;

optional uint64 = 6;

optional uint32 = 7;

optional uint32 = 8;

optional bytes = 10;

optional string = 11;

optional string = 12;

optional string = 13;

optional string amount1_out = 14;

optional bytes to = 15;

}

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

message Clock {

optional string = 1;

optional uint64 = 2;

optional = 3;

}

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

repeated = 999;

}

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

repeated = 1;

repeated = 2;

repeated = 3;

repeated = 4;

repeated = 5;

repeated = 6;

repeated = 7;

repeated = 8;

}

// / @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 string = 10;

optional bytes = 11;

optional string = 12;

optional string = 13;

}

// / @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 string = 10;

optional bytes = 11;

}

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

message ModulesProgress {

repeated = 2;

repeated = 3;

repeated = 4;

optional = 5;

}

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

}

// * 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 string = 21;

optional int32 = 22;

}

// / @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 bytes = 10;

optional bytes = 11;

optional bytes = 12;

optional uint64 = 13;

optional int32 tick_spacing = 14;

optional string sqrt_price_x96 = 17;

optional int32 tick = 18;

optional string hooks = 19;

}

message Output {

optional string = 1;

}

message ParamsEntry {

optional string key = 1;

optional string value = 2;

}

message ProcessedBytes {

optional uint64 = 1;

optional uint64 = 2;

}

message UpdateRequest {

optional = 1;

optional string = 2;

optional bool = 3;

}

message PackageInfo {

optional string = 1;

optional string = 2;

optional string = 3;

optional string = 4;

}

message EnumOptions {

optional bool = 2;

optional bool = 3;

repeated = 999;

}

message Source {

optional string = 1;

}

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

message BlockRef {

optional string = 1;

optional uint64 = 2;

}

message SessionInit {

optional string = 1;

optional uint64 = 2;

optional uint64 = 3;

optional uint64 = 4;

}

message DeploymentWithStatus {

optional string = 1;

optional = 2;

optional string = 3;

optional = 4;

optional = 5;

optional string = 6;

}

message Service {

optional string = 1;

oneof _dbt_config {

optional = 2;

}

optional = 4;

optional = 5;

optional = 7;

optional = 8;

}

message PairCreated {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional bytes = 10;

optional bytes = 11;

optional bytes = 12;

optional uint64 = 13;

}

// / @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 bytes = 10;

optional bytes = 11;

}

message Map {

optional string = 1;

}

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

message HasuraFrontend {

optional bool = 1;

}

// / @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 bytes = 10;

optional bytes = 11;

optional bool = 12;

}

message PackageMetadata {

optional string = 1;

optional string = 2;

optional string = 3;

optional string = 4;

}

message BlockRange {

optional uint64 = 2;

optional uint64 = 3;

}

message DatabaseChanges {

repeated = 1;

}

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

message PGWebFrontend {

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 uint64 = 10;

optional int32 = 11;

}

message ModifyLiquidityWithAmounts {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional bytes = 10;

optional bytes = 11;

optional int32 = 12;

optional int32 = 13;

optional string liquidity_delta = 14;

optional bytes salt = 18;

optional string liquidity_math_amount0 = 19;

optional string liquidity_math_amount1 = 20;

}

message ExtensionRange {

optional int32 = 1;

optional int32 = 2;

optional = 3;

}

message BlockFilter {

optional string = 1;

oneof query {

optional string = 2;

optional = 3;

}

message DeployResponse {

optional = 1;

optional string = 2;

repeated = 3;

optional string = 4;

optional string = 5;

}

message ListRequest {

}

message PauseRequest {

optional string = 1;

}

message RemoveResponse {

optional = 1;

}

message Input {

oneof input {

optional = 1;

optional = 2;

optional = 3;

optional = 4;

}

Back to sf.substreams

message FieldOptions {

optional bool = 1;

optional bool = 2;

}

message Modules {

repeated = 1;

repeated = 2;

}

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

message Binary {

optional string = 1;

optional bytes = 2;

}

// / @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 bytes = 10;

optional int32 = 11;

optional int32 = 12;

optional string = 13;

optional string amount0 = 14;

optional string amount1 = 15;

}

message ProtocolFeeUpdated {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional bytes = 10;

optional uint64 = 11;

}

message OutputDebugInfo {

repeated string = 1;

optional bool = 2;

optional bool = 3;

}

message Stage {

repeated string = 1;

repeated = 2;

}

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 Annotation {

repeated int32 = 1;

optional string = 2;

optional int32 = 3;

optional int32 = 4;

}

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

optional bool = 33;

repeated = 999;

}

message ExtensionRangeOptions {

repeated = 999;

}

message KindStore {

optional = 1;

optional string = 2;

}

Back to sf.substreams.index.v1

message ModuleMetadata {

optional uint64 = 1;

optional string = 2;

}

message Keys {

repeated string = 1;

}

message CompositePrimaryKey {

repeated = 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 uint64 = 10;

optional uint64 = 11;

}

message ExternalCallMetric {

optional string = 1;

optional uint64 = 2;

optional uint64 = 3;

}

// * 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 bytes = 10;

optional bytes = 11;

optional string = 12;

optional string = 13;

optional string sqrt_price_x96 = 14;

optional string liquidity = 15;

optional int32 tick = 16;

}

// / @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 bytes = 10;

optional bytes = 11;

optional string = 12;

}

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

optional string key = 1;

optional value = 2;

}

message NetworkParams {

repeated = 1;

repeated = 2;

}

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

message DBTConfig {

optional bytes = 1;

optional int32 = 2;

optional bool = 3;

}

message EnumValueOptions {

optional bool = 1;

repeated = 999;

}

message TableChange {

optional string = 1;

oneof primary_key {

optional string = 2;

optional = 6;

}

optional uint64 = 3;

optional = 4;

repeated = 5;

}

// / @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 bytes = 10;

optional bytes = 11;

optional int32 = 12;

optional int32 = 13;

optional string amount = 14;

optional string amount0 = 15;

optional string amount1 = 16;

}

// / @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 bytes = 10;

optional bytes = 11;

optional string = 12;

optional string = 13;

}

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

}

message DeployRequest {

optional = 1;

optional bool = 2;

repeated = 3;

}

message ResumeResponse {

optional = 1;

optional = 2;

}

// / @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 bytes = 10;

optional bytes = 11;

optional string = 12;

}

message FieldOptions {

optional = 1;

optional bool = 2;

optional = 6;

optional bool = 5;

optional bool = 15;

optional bool = 3;

optional bool = 10;

repeated = 999;

}

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 Field {

optional string = 1;

optional string = 2;

optional string = 3;

}

// / @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 bytes = 10;

optional bytes = 11;

optional uint64 = 12;

optional int32 = 13;

optional bytes pool_address = 14;

}

message KindBlockIndex {

optional string = 1;

}

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

optional string = 1;

}

message InfoResponse {

optional = 1;

repeated = 2;

optional string = 3;

optional = 4;

optional = 5;

optional string = 6;

}

message SinkProgress {

optional uint64 = 1;

}

message Approval {

optional bytes = 1;

oneof _caller {

optional bytes = 2;

}

optional bytes = 3;

optional uint64 = 4;

optional uint32 = 5;

optional uint32 = 6;

optional bytes = 11;

optional bytes = 12;

optional string = 13;

}

// / @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 bytes = 10;

}

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

oneof message {

optional = 1;

optional = 2;

optional = 3;

optional = 4;

optional = 5;

optional = 10;

optional = 11;

}

message ServicesEntry {

optional string key = 1;

optional string value = 2;

}

message RemoveRequest {

optional string = 1;

}

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

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

Mode

UNSET = 0;

GET = 1;

DELTAS = 2;

enum

Operation

OPERATION_UNSPECIFIED = 0;

OPERATION_CREATE = 1;

OPERATION_UPDATE = 2;

OPERATION_DELETE = 3;

enum

Engine

unset = 0;

postgres = 1;

clickhouse = 2;

enum

CType

STRING = 0;

CORD = 1;

STRING_PIECE = 2;

enum

JSType

JS_NORMAL = 0;

JS_STRING = 1;

JS_NUMBER = 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

Operation

UNSET = 0;

CREATE = 1;

UPDATE = 2;

DELETE = 3;

enum

DeploymentStatus

UNKNOWN = 0;

RUNNING = 1;

FAILING = 2;

PAUSED = 3;

STOPPED = 4;

STARTING = 5;

PAUSING = 6;

STOPPING = 7;

REMOVING = 8;

RESUMING = 9;