chore: v2 positions stream

Author: bangjelkoski

packages/sdk-ts/package.json

@@ -127,7 +127,7 @@
     "@injectivelabs/grpc-web": "^0.0.1",
     "@injectivelabs/grpc-web-node-http-transport": "^0.0.2",
     "@injectivelabs/grpc-web-react-native-transport": "^0.0.2",
-    "@injectivelabs/indexer-proto-ts": "1.13.4",
+    "@injectivelabs/indexer-proto-ts": "1.13.5",
     "@injectivelabs/mito-proto-ts": "1.13.2",
     "@injectivelabs/networks": "^1.14.34-beta.5",
     "@injectivelabs/olp-proto-ts": "1.13.1",

packages/sdk-ts/src/client/indexer/grpc_stream/IndexerGrpcDerivativesStream.ts

@@ -48,6 +48,12 @@ export type PositionsStreamCallback = (
   >,
 ) => void
 
+export type PositionsV2StreamCallback = (
+  response: ReturnType<
+    typeof IndexerDerivativeStreamTransformer.positionV2StreamCallback
+  >,
+) => void
+
 export type MarketStreamCallback = (
   response: InjectiveDerivativeExchangeRpc.StreamMarketResponse,
 ) => void
@@ -445,4 +451,55 @@ export class IndexerGrpcDerivativesStream {
 
     return subscription as unknown as Subscription
   }
+
+  streamDerivativePositionsV2({
+    marketId,
+    subaccountId,
+    callback,
+    address,
+    onEndCallback,
+    onStatusCallback,
+  }: {
+    marketId?: string
+    address?: string
+    subaccountId?: string
+    callback: PositionsV2StreamCallback
+    onEndCallback?: (status?: StreamStatusResponse) => void
+    onStatusCallback?: (status: StreamStatusResponse) => void
+  }): Subscription {
+    const request =
+      InjectiveDerivativeExchangeRpc.StreamPositionsV2Request.create()
+
+    if (marketId) {
+      request.marketId = marketId
+    }
+
+    if (address) {
+      request.accountAddress = address
+    }
+
+    if (subaccountId) {
+      request.subaccountId = subaccountId
+    }
+
+    const subscription = this.client.StreamPositionsV2(request).subscribe({
+      next(response: InjectiveDerivativeExchangeRpc.StreamPositionsV2Response) {
+        callback(
+          IndexerDerivativeStreamTransformer.positionV2StreamCallback(response),
+        )
+      },
+      error(err) {
+        if (onStatusCallback) {
+          onStatusCallback(err)
+        }
+      },
+      complete() {
+        if (onEndCallback) {
+          onEndCallback()
+        }
+      },
+    })
+
+    return subscription as unknown as Subscription
+  }
 }

packages/sdk-ts/src/client/indexer/transformers/IndexerDerivativeStreamTransformer.ts

@@ -98,4 +98,17 @@ export class IndexerDerivativeStreamTransformer {
       timestamp: response.timestamp,
     }
   }
+
+  static positionV2StreamCallback = (
+    response: InjectiveDerivativeExchangeRpc.StreamPositionsV2Response,
+  ) => {
+    const position = response.position
+
+    return {
+      position: position
+        ? IndexerGrpcDerivativeTransformer.grpcPositionV2ToPositionV2(position)
+        : undefined,
+      timestamp: response.timestamp,
+    }
+  }
 }

yarn.lock

@@ -2220,10 +2220,10 @@
   dependencies:
     browser-headers "^0.4.1"
 
-"@injectivelabs/indexer-proto-ts@1.13.4":
-  version "1.13.4"
-  resolved "https://registry.yarnpkg.com/@injectivelabs/indexer-proto-ts/-/indexer-proto-ts-1.13.4.tgz#75f7d5caa23843b862fea6199975a88c5c88290e"
-  integrity sha512-4i7jc2LQd3KRziSUCjQOt2VfhRFlJVwuWDPjKnAJRYCnbaJeZRxtZOY+2kFNthXDV2dYJkoiu+mOUHuGvWUM7Q==
+"@injectivelabs/indexer-proto-ts@1.13.5":
+  version "1.13.5"
+  resolved "https://registry.npmjs.org/@injectivelabs/indexer-proto-ts/-/indexer-proto-ts-1.13.5.tgz#1c5d43b7a274270ee919b973272b959bcf8553cd"
+  integrity sha512-Z/oSKRS2dNaMcC0zc5OYFpE2UVilDb7IzLhIisd0HBavZ9KU1UeD3WTTGUQjIT3qZv/mhOiTlCqTk+zhbdCWHQ==
   dependencies:
     "@injectivelabs/grpc-web" "^0.0.1"
     google-protobuf "^3.14.0"