enable sending BpMevMatches and ProposalReceiveTime to MEV indexer (#840

)
dydxprotocol · Dec 5, 2023 · 56d653a · 56d653a
1 parent 11fd8a0
commit 56d653a
Show file tree

Hide file tree

Showing 4 changed files with 169 additions and 43 deletions.
diff --git a/indexer/packages/v4-protos/src/codegen/dydxprotocol/clob/mev.ts b/indexer/packages/v4-protos/src/codegen/dydxprotocol/clob/mev.ts
@@ -94,6 +94,8 @@ export interface ValidatorMevMatchesSDKType {
 export interface MevNodeToNodeMetrics {
   validatorMevMatches?: ValidatorMevMatches;
   clobMidPrices: ClobMidPrice[];
+  bpMevMatches?: ValidatorMevMatches;
+  proposalReceiveTime: Long;
 }
 /**
  * MevNodeToNodeMetrics is a data structure for encapsulating all MEV node <>
@@ -103,6 +105,8 @@ export interface MevNodeToNodeMetrics {
 export interface MevNodeToNodeMetricsSDKType {
   validator_mev_matches?: ValidatorMevMatchesSDKType;
   clob_mid_prices: ClobMidPriceSDKType[];
+  bp_mev_matches?: ValidatorMevMatchesSDKType;
+  proposal_receive_time: Long;
 }
 
 function createBaseMEVMatch(): MEVMatch {
@@ -448,7 +452,9 @@ export const ValidatorMevMatches = {
 function createBaseMevNodeToNodeMetrics(): MevNodeToNodeMetrics {
   return {
     validatorMevMatches: undefined,
-    clobMidPrices: []
+    clobMidPrices: [],
+    bpMevMatches: undefined,
+    proposalReceiveTime: Long.UZERO
   };
 }
 
@@ -462,6 +468,14 @@ export const MevNodeToNodeMetrics = {
       ClobMidPrice.encode(v!, writer.uint32(18).fork()).ldelim();
     }
 
+    if (message.bpMevMatches !== undefined) {
+      ValidatorMevMatches.encode(message.bpMevMatches, writer.uint32(26).fork()).ldelim();
+    }
+
+    if (!message.proposalReceiveTime.isZero()) {
+      writer.uint32(32).uint64(message.proposalReceiveTime);
+    }
+
     return writer;
   },
 
@@ -482,6 +496,14 @@ export const MevNodeToNodeMetrics = {
           message.clobMidPrices.push(ClobMidPrice.decode(reader, reader.uint32()));
           break;
 
+        case 3:
+          message.bpMevMatches = ValidatorMevMatches.decode(reader, reader.uint32());
+          break;
+
+        case 4:
+          message.proposalReceiveTime = (reader.uint64() as Long);
+          break;
+
         default:
           reader.skipType(tag & 7);
           break;
@@ -495,6 +517,8 @@ export const MevNodeToNodeMetrics = {
     const message = createBaseMevNodeToNodeMetrics();
     message.validatorMevMatches = object.validatorMevMatches !== undefined && object.validatorMevMatches !== null ? ValidatorMevMatches.fromPartial(object.validatorMevMatches) : undefined;
     message.clobMidPrices = object.clobMidPrices?.map(e => ClobMidPrice.fromPartial(e)) || [];
+    message.bpMevMatches = object.bpMevMatches !== undefined && object.bpMevMatches !== null ? ValidatorMevMatches.fromPartial(object.bpMevMatches) : undefined;
+    message.proposalReceiveTime = object.proposalReceiveTime !== undefined && object.proposalReceiveTime !== null ? Long.fromValue(object.proposalReceiveTime) : Long.UZERO;
     return message;
   }
 

diff --git a/proto/dydxprotocol/clob/mev.proto b/proto/dydxprotocol/clob/mev.proto
@@ -57,4 +57,6 @@ message ValidatorMevMatches {
 message MevNodeToNodeMetrics {
   ValidatorMevMatches validator_mev_matches = 1;
   repeated ClobMidPrice clob_mid_prices = 2 [ (gogoproto.nullable) = false ];
+  ValidatorMevMatches bp_mev_matches = 3;
+  uint64 proposal_receive_time = 4;
 }
diff --git a/protocol/x/clob/keeper/mev.go b/protocol/x/clob/keeper/mev.go
@@ -345,6 +345,8 @@ func (k Keeper) RecordMevMetrics(
 				MevNodeToNode: types.MevNodeToNodeMetrics{
 					ValidatorMevMatches: validatorMevMatches,
 					ClobMidPrices:       mevClobMidPrices,
+					BpMevMatches:        blockProposerMevMatches,
+					ProposalReceiveTime: uint64(time.Now().Second()),
 				},
 			},
 		)

diff --git a/protocol/x/clob/types/mev.pb.go b/protocol/x/clob/types/mev.pb.go