[Horizon] Subgraph indexing registration implementation

config/addresses.template.ts

@@ -20,6 +20,7 @@ export class Addresses {
   l1GraphTokenGateway: string
   l2GraphTokenGateway: string
   ethereumDIDRegistry: string
+  subgraphService: string
   isL1: boolean
 }
 
@@ -45,5 +46,6 @@ export let addresses: Addresses = {
   l1GraphTokenGateway: '{{l1GraphTokenGateway}}',
   l2GraphTokenGateway: '{{l2GraphTokenGateway}}',
   ethereumDIDRegistry: '{{ethereumDIDRegistry}}',
+  subgraphService: '{{subgraphService}}',
   isL1: {{isL1}},
 }

config/arbitrumSepoliaAddressScript.ts

@@ -29,6 +29,7 @@ export let addresses: Addresses = {
   l1GraphTokenGateway: '',
   l2GraphTokenGateway: '{{arbsep.L2GraphTokenGateway.address}}',
   ethereumDIDRegistry: '{{arbsep.EthereumDIDRegistry.address}}',
+  subgraphService: '{{arbsep.SubgraphService.address}}',
   isL1: false,
 }
 

config/mainnetArbitrumAddressScript.ts

@@ -29,6 +29,7 @@ export let addresses: Addresses = {
   l1GraphTokenGateway: '',
   l2GraphTokenGateway: '{{arbitrum.L2GraphTokenGateway.address}}',
   ethereumDIDRegistry: '{{arbitrum.IEthereumDIDRegistry.address}}',
+  subgraphService: '{{arbitrum.SubgraphService.address}}',
   isL1: false,
 }
 
@@ -46,6 +47,10 @@ const main = (): void => {
     if(output.ens == '') {
       output.ens = '0x0000000000000000000000000000000000000000' // to avoid crashes due to bad config
     }
+    // remove once we have proper packages
+    if(output.subgraphService == '') {
+      output.subgraphService = '0x0000000000000000000000000000000000000000' // to avoid crashes due to bad config
+    }
     fs.writeFileSync(__dirname + '/generatedAddresses.json', JSON.stringify(output, null, 2))
   } catch (e) {
     console.log(`Error saving artifacts: ${e.message}`)

config/testAddressesL1.ts

@@ -29,6 +29,7 @@ export let addresses: Addresses = {
   l1GraphTokenGateway: '0x0000000000000000000000000000000000000000',
   l2GraphTokenGateway: '',
   ethereumDIDRegistry: '0x0000000000000000000000000000000000000000',
+  subgraphService: '0x0000000000000000000000000000000000000000',
   isL1: true,
 }
 

config/testAddressesL2.ts

@@ -29,6 +29,7 @@ export let addresses: Addresses = {
   l1GraphTokenGateway: '',
   l2GraphTokenGateway: '0x0000000000000000000000000000000000000000',
   ethereumDIDRegistry: '0x0000000000000000000000000000000000000000',
+  subgraphService: '0x0000000000000000000000000000000000000000',
   isL1: false,
 }
 

schema.graphql

@@ -898,6 +898,13 @@ type Provision @entity {
   delegatorShares: BigInt!
   "Exchange rate of of tokens received for each share"
   delegationExchangeRate: BigDecimal!
+
+  "Service registry URL for the indexer"
+  url: String
+  "Geohash of the indexer. Shows where their indexer is located in the world"
+  geoHash: String
+  "Address set as rewards destination for payments to the service provider"
+  rewardsDestination: Bytes
 }
 
 enum PaymentTypes {

src/mappings/subgraphService.ts

@@ -0,0 +1,22 @@
+import { ethereum, ValueKind, log } from "@graphprotocol/graph-ts"
+import { RewardsDestinationSet, ServiceProviderRegistered } from "../types/SubgraphService/SubgraphService"
+import { createOrLoadProvision } from "./helpers/helpers"
+
+export function handleServiceProviderRegistered(event: ServiceProviderRegistered): void {
+    let decodedCalldata = ethereum.decode('(string,string,address)', event.params.data)
+    if( decodedCalldata != null && decodedCalldata.kind == ethereum.ValueKind.TUPLE) {
+        let tupleData = decodedCalldata.toTuple()
+        let provision = createOrLoadProvision(event.params.serviceProvider, event.address, event.block.timestamp)
+        provision.url = tupleData[0].toString()
+        provision.geoHash = tupleData[1].toString()
+        provision.save()
+    } else {
+        log.warning("ServiceProviderRegistered failed to decode: {}", [event.params.data.toHexString()])
+    }
+}
+
+export function handleRewardsDestinationSet(event: RewardsDestinationSet): void {
+    let provision = createOrLoadProvision(event.params.indexer, event.address, event.block.timestamp)
+    provision.rewardsDestination = event.params.rewardsDestination
+    provision.save()
+}

subgraph.template.yaml

@@ -429,6 +429,32 @@ dataSources:
           handler: handleDelegationFeeCutSet
         - event: TokensToDelegationPoolAdded(indexed address,indexed address,uint256)
           handler: handleTokensToDelegationPoolAdded
+  - kind: ethereum/contract
+    name: SubgraphService
+    network: {{network}}
+    source:
+      address: "{{subgraphService}}"
+      abi: SubgraphService
+      startBlock: {{blockNumber}}
+    mapping:
+      kind: ethereum/events
+      apiVersion: 0.0.7
+      language: wasm/assemblyscript
+      file: ./src/mappings/subgraphService.ts
+      entities:
+        - GraphNetwork
+      abis:
+        - name: SubgraphService
+          file: ./abis/SubgraphService.json
+        - name: GraphToken
+          file: ./node_modules/@graphprotocol/contracts/dist/abis/GraphToken.json
+        - name: EpochManager
+          file: ./node_modules/@graphprotocol/contracts/dist/abis/EpochManager.json
+      eventHandlers:
+        - event: ServiceProviderRegistered(indexed address,bytes)
+          handler: handleServiceProviderRegistered
+        - event: RewardsDestinationSet(indexed address,indexed address)
+          handler: handleRewardsDestinationSet
   - kind: ethereum/contract
     name: Curation
     network: {{network}}