Full node streaming -- perp position to signed int (backport #2544) (#2562)

Co-authored-by: Jonathan Fung <121899091+jonfung-dydx@users.noreply.github.com>

Author: mergify[bot]

indexer/packages/v4-protos/src/codegen/dydxprotocol/subaccounts/streaming.ts

@@ -59,7 +59,7 @@ export interface StreamSubaccountUpdateSDKType {
 export interface SubaccountPerpetualPosition {
   /** The `Id` of the `Perpetual`. */
   perpetualId: number;
-  /** The size of the position in base quantums. */
+  /** The size of the position in base quantums. Negative means short. */
 
   quantums: Long;
 }
@@ -71,7 +71,7 @@ export interface SubaccountPerpetualPosition {
 export interface SubaccountPerpetualPositionSDKType {
   /** The `Id` of the `Perpetual`. */
   perpetual_id: number;
-  /** The size of the position in base quantums. */
+  /** The size of the position in base quantums. Negative means short. */
 
   quantums: Long;
 }
@@ -178,7 +178,7 @@ export const StreamSubaccountUpdate = {
 function createBaseSubaccountPerpetualPosition(): SubaccountPerpetualPosition {
   return {
     perpetualId: 0,
-    quantums: Long.UZERO
+    quantums: Long.ZERO
   };
 }
 
@@ -189,7 +189,7 @@ export const SubaccountPerpetualPosition = {
     }
 
     if (!message.quantums.isZero()) {
-      writer.uint32(16).uint64(message.quantums);
+      writer.uint32(16).int64(message.quantums);
     }
 
     return writer;
@@ -209,7 +209,7 @@ export const SubaccountPerpetualPosition = {
           break;
 
         case 2:
-          message.quantums = (reader.uint64() as Long);
+          message.quantums = (reader.int64() as Long);
           break;
 
         default:
@@ -224,7 +224,7 @@ export const SubaccountPerpetualPosition = {
   fromPartial(object: DeepPartial<SubaccountPerpetualPosition>): SubaccountPerpetualPosition {
     const message = createBaseSubaccountPerpetualPosition();
     message.perpetualId = object.perpetualId ?? 0;
-    message.quantums = object.quantums !== undefined && object.quantums !== null ? Long.fromValue(object.quantums) : Long.UZERO;
+    message.quantums = object.quantums !== undefined && object.quantums !== null ? Long.fromValue(object.quantums) : Long.ZERO;
     return message;
   }
 

proto/dydxprotocol/subaccounts/streaming.proto

@@ -28,8 +28,8 @@ message StreamSubaccountUpdate {
 message SubaccountPerpetualPosition {
   // The `Id` of the `Perpetual`.
   uint32 perpetual_id = 1;
-  // The size of the position in base quantums.
-  uint64 quantums = 2;
+  // The size of the position in base quantums. Negative means short.
+  int64 quantums = 2;
 }
 
 // SubaccountAssetPosition provides information on a subaccount's updated asset

protocol/x/subaccounts/keeper/subaccount.go

@@ -150,7 +150,7 @@ func (k Keeper) GetStreamSubaccountUpdate(
 	for i, pp := range subaccount.PerpetualPositions {
 		perpetualPositions[i] = &types.SubaccountPerpetualPosition{
 			PerpetualId: pp.PerpetualId,
-			Quantums:    pp.Quantums.BigInt().Uint64(),
+			Quantums:    pp.Quantums.BigInt().Int64(),
 		}
 	}
 
@@ -298,7 +298,7 @@ func GenerateStreamSubaccountUpdate(
 	for i, pp := range updatedPerpetualPositions {
 		perpetualPositions[i] = &types.SubaccountPerpetualPosition{
 			PerpetualId: pp.PerpetualId,
-			Quantums:    pp.Quantums.BigInt().Uint64(),
+			Quantums:    pp.Quantums.BigInt().Int64(),
 		}
 	}