All packages
my_injective_events

my_injective_events

dicksonoche
v0.1.0/19 downloads

Package ref

my-injective-events@v0.1.0
Download .spkg

Run package

CLI

Run map_event_groups from the command line.

substreams run my-injective-events@v0.1.0 map_event_groups -e injective-mainnet --start-block -1
Authenticate by running substreams auth or directly on thegraph.market (see docs).

README

my_injective_events Substreams modules

This package was initialized via substreams init, using the injective-events template.

Usage

substreams build
substreams auth
substreams gui       			  # Get streaming!
substreams registry login         # Login to substreams.dev
substreams registry publish       # Publish your Substreams to substreams.dev

Modules

map_event_groups

This module uses the Injective Foundational Modules and applies filters on the chosen events and attributes.

Modules

Execution graph

10 modules
mapMain

map_event_groups

from #50000000

Output

sf.substreams.cosmos.v1.EventList

Inputs

paramsinjective:all_events
Show 9 dependencies
map

injective:all_events

`all_events` reads from the `sf.cosmos.type.v2.Block` source and outputs a list of all events in the block. Some events are at the block level, others appear inside the transactions.

Output

sf.substreams.cosmos.v1.EventList

Inputs

sf.cosmos.type.v2.Block
map

injective:all_transactions

`all_transactions` reads from the `sf.cosmos.type.v2.Block` source and outputs a list of all transactions in the block. Some known message types will be converted to the correct protobuf type, unknown ones will stay as `Any` type.

Output

sf.substreams.cosmos.v1.TransactionList

Inputs

sf.cosmos.type.v2.Block
map

injective:filtered_event_groups

`filtered_event_groups` reads from `all_events` and applies a filter on the event types and attribute keys, outputing all the events from transactions that have at least one event matching the filter. Example usage: `type:injective.peggy.v1.EventDepositClaim || (type:wasm && attr:_contract_address)`

Output

sf.substreams.cosmos.v1.EventList

Inputs

paramsinjective:all_events
map

injective:filtered_event_groups_by_attribute_value

`filtered_events_groups_by_attribute_value` reads from `all_events` and applies a filter on the event types, attribute keys and values, outputing all the events from transactions that have at least one event matching the filter. Example usage: "type:wasm && attr:_contract_address:inj1v77y5ttah96dc9qkcpc88ad7rce8n88e99t3m5" To use this module with an index, import it and override it with the `use:` parameter, setting blockFilter.Query.String to a query that matches the event type and attribute keys only (ex: `type:wasm && attr:_contract_address`)

Output

sf.substreams.cosmos.v1.EventList

Inputs

paramsinjective:all_events
map

injective:filtered_events

`filtered_events` reads from `all_events` and applies a filter on the event types and attribute keys, only outputing the events that match the filter. Example usage: `(type:message && attr:action) || (type:wasm && attr:_contract_address)`

Output

sf.substreams.cosmos.v1.EventList

Inputs

paramsinjective:all_events
map

injective:filtered_events_by_attribute_value

`filtered_events_by_attribute_value` reads from `all_events` and applies a filter on the event types, attribute keys and values, only outputing the events that match the filter. Example usage: "type:wasm && attr:_contract_address:inj1v77y5ttah96dc9qkcpc88ad7rce8n88e99t3m5" To use this module with an index, import it and override it with the `use:` parameter, setting blockFilter.Query.String to a query that matches the event type and attribute keys only (ex: `type:wasm && attr:_contract_address`)

Output

sf.substreams.cosmos.v1.EventList

Inputs

paramsinjective:all_events
map

injective:filtered_trx_by_events

`filtered_trx_by_events` reads from `all_transactions` and applies a filter on the event types and attribute keys, outputing the complete transactions that have at least one event matching the filter. Example usage: `type:injective.peggy.v1.EventDepositClaim || (type:wasm && attr:_contract_address)`

Output

sf.substreams.cosmos.v1.TransactionList

Inputs

paramsinjective:all_transactions
map

injective:filtered_trx_by_events_attribute_value

`filtered_trx_by_events_attribute_value` reads from `all_events` and applies a filter on the event types, attribute keys and values, outputing the complete transactions that have at least one event matching the filter. Example usage: "type:wasm && attr:_contract_address:inj1v77y5ttah96dc9qkcpc88ad7rce8n88e99t3m5" To use this module with an index, import it and override it with the `use:` parameter, setting blockFilter.Query.String to a query that matches the event type and attribute keys only (ex: `type:wasm && attr:_contract_address`)

Output

sf.substreams.cosmos.v1.TransactionList

Inputs

paramsinjective:all_eventsinjective:all_transactions
blockIndex

injective:index_events

`index_events` sets the keys corresponding to all event 'types' and 'attribute keys' in the block ex: `type:coin_received`, `type:injective.peggy.v1.EventDepositClaim`, `attr:action`, `attr:sender` ... The attribute values are never indexed because they have a high cardinality and would be too expensive to index.

Output

sf.substreams.index.v1.Keys

Inputs

injective:all_events