substreams.yaml

specVersion: v0.1.0
package:
  name: indexer_stake_tracker
  version: v0.0.4
  url: https://github.com/streamingfast/substreams-indexer-stake-tracker
  image: ./img/thegraph.jpeg
  doc: |
    This Substreams tracks changes in total staked tokens by indexers on The Graph.

imports:
  sql: https://github.com/streamingfast/substreams-sink-sql/releases/download/protodefs-v1.0.7/substreams-sink-sql-protodefs-v1.0.7.spkg
  entity: https://github.com/streamingfast/substreams-entity-change/releases/download/v1.1.0/substreams-entity-change-v1.1.0.spkg
  database_change: https://github.com/streamingfast/substreams-sink-database-changes/releases/download/v1.2.0/substreams-database-change-v1.2.0.spkg
  eth: https://spkg.io/v1/packages/ethereum_common/v0.3.0

protobuf:
  files:
    - allocations/v1/allocations.proto
  importPaths:
    - ./proto
  excludePaths:
    - sf/substreams
    - google

binaries:
  default:
    type: wasm/rust-v1
    file: target/wasm32-unknown-unknown/release/substreams_indexer_stake_tracker.wasm

params:
  # list of indexer addresses to track. To track all indexers, set to '*'
  map_allocation_closed: '["35917c0eb91d2e21bef40940d028940484230c06"]'
  store_stake_token_changes: '["35917c0eb91d2e21bef40940d028940484230c06"]'
  map_query_fees_collected: '["35917c0eb91d2e21bef40940d028940484230c06"]'
  map_indexing_rewards_collected: '["35917c0eb91d2e21bef40940d028940484230c06"]'
#  map_allocation_closed: '*'
#  store_stake_token_changes: '*'
#  map_query_fees_collected: '*'

modules:
  - name: map_stake_deposited
    kind: map
    blockFilter:
      module: eth:index_events
      query:
        string: evt_addr:0x00669a4cf01450b64e8a2a20e9b1fcb71e61ef03
    initialBlock: 86288639
    inputs:
      - source: sf.ethereum.type.v2.Block
    output:
      type: proto:allocations.types.v1.OwnedStakeTokenChanges

  - name: map_stake_withdrawn
    kind: map
    initialBlock: 86288639
    blockFilter:
      module: eth:index_events
      query:
        string: evt_addr:0x00669a4cf01450b64e8a2a20e9b1fcb71e61ef03
    inputs:
      - source: sf.ethereum.type.v2.Block
    output:
      type: proto:allocations.types.v1.OwnedStakeTokenChanges

  - name: store_stake_token_changes
    kind: store
    updatePolicy: add
    valueType: bigint
    inputs:
      - params: string
      - map: map_stake_deposited
      - map: map_stake_withdrawn

  - name: map_allocation_closed1
    kind: map
    initialBlock: 86288639
    blockFilter:
      module: eth:index_events
      query:
        string: evt_addr:0x00669a4cf01450b64e8a2a20e9b1fcb71e61ef03
    inputs:
      - source: sf.ethereum.type.v2.Block
    output:
      type: proto:allocations.types.v1.AllocationClosedDatas

  - name: map_allocation_closed2
    kind: map
    initialBlock: 86288639
    blockFilter:
      module: eth:index_events
      query:
        string: evt_addr:0x00669a4cf01450b64e8a2a20e9b1fcb71e61ef03
    inputs:
      - source: sf.ethereum.type.v2.Block
    output:
      type: proto:allocations.types.v1.AllocationClosedDatas

  - name: map_allocation_closed
    kind: map
    initialBlock: 86288639
    inputs:
      - params: string
      - source: sf.substreams.v1.Clock
      - map: map_allocation_closed1
      - map: map_allocation_closed2
    output:
      type: proto:allocations.types.v1.AllocationClosedDatas

  - name: map_query_fees_collected
    kind: map
    initialBlock: 86288639
    blockFilter:
      module: eth:index_events
      query:
        string: evt_addr:0x00669a4cf01450b64e8a2a20e9b1fcb71e61ef03
    inputs:
      - params: string
      - source: sf.ethereum.type.v2.Block
    output:
      type: proto:allocations.types.v1.QueryFeesCollecteds

  - name: map_indexing_rewards_collected
    kind: map
    initialBlock: 86288639
    blockFilter:
      module: eth:index_events
      query:
        string: evt_addr:0x00669a4cf01450b64e8a2a20e9b1fcb71e61ef03
    inputs:
      - params: string
      - source: sf.ethereum.type.v2.Block
    output:
      type: proto:allocations.types.v1.IndexingRewardsCollecteds

  - name: store_query_fees_collected
    kind: store
    updatePolicy: add
    valueType: bigint
    inputs:
      - map: map_query_fees_collected

  - name: store_indexing_rewards_collected
    kind: store
    updatePolicy: add
    valueType: bigint
    inputs:
      - map: map_indexing_rewards_collected

  - name: map_staked_tokens_changes
    kind: map
    initialBlock: 86288639
    inputs:
      - source: sf.substreams.v1.Clock
      - map: map_allocation_closed
      - store: store_stake_token_changes
      - store: store_query_fees_collected
      - store: store_indexing_rewards_collected
    output:
      type: proto:allocations.types.v1.StakedTokensChanges

  - name: db_out
    kind: map
    inputs:
      - source: sf.substreams.v1.Clock
      - map: map_staked_tokens_changes
    output:
      type: proto:sf.substreams.sink.database.v1.DatabaseChanges

network: arb-one

sink:
  module: db_out
  type: sf.substreams.sink.sql.v1.Service
  config:
    schema: "./schema.sql"
    engine: postgres
    postgraphile_frontend:
      enabled: true