feat: index RewardCallerSet reward caller delegation

abis/BondingManager.json

@@ -820,6 +820,25 @@
     "name": "Reward",
     "type": "event"
   },
+  {
+    "anonymous": false,
+    "inputs": [
+      {
+        "indexed": true,
+        "internalType": "address",
+        "name": "transcoder",
+        "type": "address"
+      },
+      {
+        "indexed": true,
+        "internalType": "address",
+        "name": "rewardCaller",
+        "type": "address"
+      }
+    ],
+    "name": "RewardCallerSet",
+    "type": "event"
+  },
   {
     "anonymous": false,
     "inputs": [

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@livepeer/subgraph",
-  "version": "1.3.3",
+  "version": "1.4.0",
   "license": "MIT",
   "scripts": {
     "prepare": "yarn prepare:arbitrum-one && yarn codegen && yarn codegen:typechain",

schema.graphql

@@ -106,6 +106,8 @@ type Transcoder @entity {
   delegator: Delegator
   "Service URI endpoint that can be used to send off-chain requests"
   serviceURI: String
+  "Address delegated to call reward on the transcoder's behalf - null if unset"
+  rewardCaller: String
   "Days which the transcoder earned fees"
   transcoderDays: [TranscoderDay!]!
 }
@@ -586,6 +588,24 @@ type RewardEvent implements Event @entity {
   delegate: Transcoder!
 }
 
+"""
+RewardCallerSetEvent entities are created for every emitted RewardCallerSet event.
+"""
+type RewardCallerSetEvent implements Event @entity {
+  "Ethereum transaction hash + event log index"
+  id: ID!
+  "Reference to the transaction the event was included in"
+  transaction: Transaction!
+  "Timestamp of the transaction the event was included in"
+  timestamp: Int!
+  "Reference to the round the event occured in"
+  round: Round!
+  "Reference to the transcoder that set the reward caller"
+  delegate: Transcoder!
+  "Address authorized to call reward - the zero address when unset"
+  rewardCaller: String!
+}
+
 """
 TranscoderActivatedEvent entities are created for every emitted TranscoderActivated event.
 """

src/mappings/bondingManager.ts

@@ -23,6 +23,7 @@ import {
   ParameterUpdate,
   Rebond,
   Reward,
+  RewardCallerSet,
   TranscoderActivated,
   TranscoderDeactivated,
   TranscoderSlashed,
@@ -37,6 +38,7 @@ import {
   EarningsClaimedEvent,
   ParameterUpdateEvent,
   RebondEvent,
+  RewardCallerSetEvent,
   RewardEvent,
   TranscoderActivatedEvent,
   TranscoderDeactivatedEvent,
@@ -574,6 +576,34 @@ export function transcoderUpdate(event: TranscoderUpdate): void {
   transcoderUpdateEvent.save();
 }
 
+export function rewardCallerSet(event: RewardCallerSet): void {
+  let round = createOrLoadRound(getBlockNum());
+  let transcoder = createOrLoadTranscoder(
+    event.params.transcoder.toHex(),
+    event.block.timestamp.toI32()
+  );
+
+  // The zero address unsets the reward caller
+  if (event.params.rewardCaller.toHex() == EMPTY_ADDRESS.toHex()) {
+    transcoder.rewardCaller = null;
+  } else {
+    transcoder.rewardCaller = event.params.rewardCaller.toHex();
+  }
+  transcoder.save();
+
+  createOrLoadTransactionFromEvent(event);
+
+  let rewardCallerSetEvent = new RewardCallerSetEvent(
+    makeEventId(event.transaction.hash, event.logIndex)
+  );
+  rewardCallerSetEvent.transaction = event.transaction.hash.toHex();
+  rewardCallerSetEvent.timestamp = event.block.timestamp.toI32();
+  rewardCallerSetEvent.round = round.id;
+  rewardCallerSetEvent.delegate = event.params.transcoder.toHex();
+  rewardCallerSetEvent.rewardCaller = event.params.rewardCaller.toHex();
+  rewardCallerSetEvent.save();
+}
+
 export function transcoderActivated(event: TranscoderActivated): void {
   let round = createOrLoadRound(getBlockNum());
   let transcoder = createOrLoadTranscoder(

subgraph.template.yaml

@@ -31,6 +31,7 @@ dataSources:
           - Pool
           - Protocol
           - RebondEvent
+          - RewardCallerSetEvent
           - RewardEvent
           - Transaction
           - Transcoder
@@ -61,6 +62,8 @@ dataSources:
           handler: withdrawStake
         - event: Reward(indexed address,uint256)
           handler: reward
+        - event: RewardCallerSet(indexed address,indexed address)
+          handler: rewardCallerSet
         - event: WithdrawFees(indexed address,address,uint256)
           handler: withdrawFees
         - event: ParameterUpdate(string)