add taker order status in oneof for stream update

dydxprotocol · Aug 5, 2024 · 9dd97a5 · 9dd97a5
1 parent 9608e19
commit 9dd97a5
Show file tree

Hide file tree

Showing 3 changed files with 217 additions and 122 deletions.
diff --git a/indexer/packages/v4-protos/src/codegen/dydxprotocol/clob/query.ts b/indexer/packages/v4-protos/src/codegen/dydxprotocol/clob/query.ts
@@ -287,6 +287,7 @@ export interface StreamOrderbookUpdatesResponseSDKType {
 export interface StreamUpdate {
   orderbookUpdate?: StreamOrderbookUpdate;
   orderFill?: StreamOrderbookFill;
+  takerOrderStatus?: StreamTakerOrderStatus;
   /** Block height of the update. */
 
   blockHeight: number;
@@ -302,6 +303,7 @@ export interface StreamUpdate {
 export interface StreamUpdateSDKType {
   orderbook_update?: StreamOrderbookUpdateSDKType;
   order_fill?: StreamOrderbookFillSDKType;
+  taker_order_status?: StreamTakerOrderStatusSDKType;
   /** Block height of the update. */
 
   block_height: number;
@@ -1284,6 +1286,7 @@ function createBaseStreamUpdate(): StreamUpdate {
   return {
     orderbookUpdate: undefined,
     orderFill: undefined,
+    takerOrderStatus: undefined,
     blockHeight: 0,
     execMode: 0
   };
@@ -1299,12 +1302,16 @@ export const StreamUpdate = {
       StreamOrderbookFill.encode(message.orderFill, writer.uint32(18).fork()).ldelim();
     }
 
+    if (message.takerOrderStatus !== undefined) {
+      StreamTakerOrderStatus.encode(message.takerOrderStatus, writer.uint32(26).fork()).ldelim();
+    }
+
     if (message.blockHeight !== 0) {
-      writer.uint32(24).uint32(message.blockHeight);
+      writer.uint32(32).uint32(message.blockHeight);
     }
 
     if (message.execMode !== 0) {
-      writer.uint32(32).uint32(message.execMode);
+      writer.uint32(40).uint32(message.execMode);
     }
 
     return writer;
@@ -1328,10 +1335,14 @@ export const StreamUpdate = {
           break;
 
         case 3:
-          message.blockHeight = reader.uint32();
+          message.takerOrderStatus = StreamTakerOrderStatus.decode(reader, reader.uint32());
           break;
 
         case 4:
+          message.blockHeight = reader.uint32();
+          break;
+
+        case 5:
           message.execMode = reader.uint32();
           break;
 
@@ -1348,6 +1359,7 @@ export const StreamUpdate = {
     const message = createBaseStreamUpdate();
     message.orderbookUpdate = object.orderbookUpdate !== undefined && object.orderbookUpdate !== null ? StreamOrderbookUpdate.fromPartial(object.orderbookUpdate) : undefined;
     message.orderFill = object.orderFill !== undefined && object.orderFill !== null ? StreamOrderbookFill.fromPartial(object.orderFill) : undefined;
+    message.takerOrderStatus = object.takerOrderStatus !== undefined && object.takerOrderStatus !== null ? StreamTakerOrderStatus.fromPartial(object.takerOrderStatus) : undefined;
     message.blockHeight = object.blockHeight ?? 0;
     message.execMode = object.execMode ?? 0;
     return message;

diff --git a/proto/dydxprotocol/clob/query.proto b/proto/dydxprotocol/clob/query.proto
@@ -178,17 +178,18 @@ message StreamOrderbookUpdatesResponse {
 // GRPC stream.
 message StreamUpdate {
   // Contains one of an StreamOrderbookUpdate,
-  // StreamOrderbookFill.
+  // StreamOrderbookFill, StreamTakerOrderStatus.
   oneof update_message {
     StreamOrderbookUpdate orderbook_update = 1;
     StreamOrderbookFill order_fill = 2;
+    StreamTakerOrderStatus taker_order_status = 3;
   }
 
   // Block height of the update.
-  uint32 block_height = 3;
+  uint32 block_height = 4;
 
   // Exec mode of the update.
-  uint32 exec_mode = 4;
+  uint32 exec_mode = 5;
 }
 
 // StreamOrderbookUpdate provides information on an orderbook update. Used in