Merge pull request #137 from InjectiveLabs/f/add_orders_history

feat: add OrdersHistory

Author: achilleas-kal

examples/exchange_client/derivative_exchange_rpc/21_Historical_Orders.py

@@ -0,0 +1,39 @@
+# Copyright 2021 Injective Labs
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+"""Injective Exchange API client for Python. Example only."""
+
+import asyncio
+import logging
+
+from pyinjective.async_client import AsyncClient
+from pyinjective.constant import Network
+
+async def main() -> None:
+    network = Network.testnet()
+    client = AsyncClient(network, insecure=False)
+    market_id = "0x54d4505adef6a5cef26bc403a33d595620ded4e15b9e2bc3dd489b714813366a"
+    subaccount_id = "0x1b99514e320ae0087be7f87b1e3057853c43b799000000000000000000000000"
+    skip = 10
+    limit = 10
+    orders = await client.get_historical_derivative_orders(
+        market_id=market_id,
+        subaccount_id=subaccount_id,
+        skip=skip,
+        limit=limit
+    )
+    print(orders)
+
+if __name__ == '__main__':
+    logging.basicConfig(level=logging.INFO)
+    asyncio.get_event_loop().run_until_complete(main())

examples/exchange_client/spot_exchange_rpc/14_HistoricalOrders.py

@@ -0,0 +1,39 @@
+# Copyright 2021 Injective Labs
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+"""Injective Exchange API client for Python. Example only."""
+
+import asyncio
+import logging
+
+from pyinjective.async_client import AsyncClient
+from pyinjective.constant import Network
+
+async def main() -> None:
+    network = Network.testnet()
+    client = AsyncClient(network, insecure=False)
+    market_id = "0xa508cb32923323679f29a032c70342c147c17d0145625922b0ef22e955c844c0"
+    subaccount_id = "0xed8c4C43E03E24b7F12975472da771Ce2f8b857c000000000000000000000000"
+    skip = 10
+    limit = 10
+    orders = await client.get_historical_spot_orders(
+        market_id=market_id,
+        subaccount_id=subaccount_id,
+        skip=skip,
+        limit=limit
+    )
+    print(orders)
+
+if __name__ == '__main__':
+    logging.basicConfig(level=logging.INFO)
+    asyncio.get_event_loop().run_until_complete(main())

pyinjective/async_client.py

@@ -591,6 +591,19 @@ async def get_spot_orders(self, market_id: str, **kwargs):
         )
         return await self.stubSpotExchange.Orders(req)
 
+    async def get_historical_spot_orders(self, market_id: str, **kwargs):
+        req = spot_exchange_rpc_pb.OrdersHistoryRequest(
+            market_id=market_id,
+            direction=kwargs.get("direction"),
+            order_type=kwargs.get("order_type"),
+            subaccount_id=kwargs.get("subaccount_id"),
+            skip=kwargs.get("skip"),
+            limit=kwargs.get("limit"),
+            start_time=kwargs.get("start_time"),
+            end_time=kwargs.get("end_time")
+        )
+        return await self.stubSpotExchange.OrdersHistory(req)
+
     async def get_spot_trades(self, **kwargs):
         req = spot_exchange_rpc_pb.TradesRequest(
             market_id=kwargs.get("market_id"),
@@ -693,6 +706,19 @@ async def get_derivative_orders(self, market_id: str, **kwargs):
         )
         return await self.stubDerivativeExchange.Orders(req)
 
+    async def get_historical_derivative_orders(self, market_id: str, **kwargs):
+        req = derivative_exchange_rpc_pb.OrdersHistoryRequest(
+            market_id=market_id,
+            direction=kwargs.get("direction"),
+            order_type=kwargs.get("order_type"),
+            subaccount_id=kwargs.get("subaccount_id"),
+            skip=kwargs.get("skip"),
+            limit=kwargs.get("limit"),
+            start_time=kwargs.get("start_time"),
+            end_time=kwargs.get("end_time")
+        )
+        return await self.stubDerivativeExchange.OrdersHistory(req)
+
     async def get_derivative_trades(self, **kwargs):
         req = derivative_exchange_rpc_pb.TradesRequest(
             market_id=kwargs.get("market_id"),