"wip : removed indexer"

Author: enigmarikki

pyinjective/async_client.py

@@ -2,7 +2,7 @@
 
 from grpc.aio import Channel
 
-from pyinjective.client.model.pagination import PaginationOption
+from pyinjective.client.model import PaginationOption
 from pyinjective.core.network import CookieAssistant
 from pyinjective.proto.cosmos.auth.v1beta1 import query_pb2 as auth_query_pb, query_pb2_grpc as auth_query_grpc
 from pyinjective.utils.grpc_api_request_assistant import GrpcApiRequestAssistant

pyinjective/client/chain/grpc/chain_grpc_auth_api.py

@@ -2,7 +2,7 @@
 
 from grpc.aio import Channel
 
-from pyinjective.client.model.pagination import PaginationOption
+from pyinjective.client.model import PaginationOption
 from pyinjective.core.network import CookieAssistant
 from pyinjective.proto.cosmos.authz.v1beta1 import query_pb2 as authz_query, query_pb2_grpc as authz_query_grpc
 from pyinjective.utils.grpc_api_request_assistant import GrpcApiRequestAssistant

pyinjective/client/chain/grpc/chain_grpc_authz_api.py

@@ -2,7 +2,7 @@
 
 from grpc.aio import Channel
 
-from pyinjective.client.model.pagination import PaginationOption
+from pyinjective.client.model import PaginationOption
 from pyinjective.core.network import CookieAssistant
 from pyinjective.proto.cosmos.bank.v1beta1 import query_pb2 as bank_query_pb, query_pb2_grpc as bank_query_grpc
 from pyinjective.utils.grpc_api_request_assistant import GrpcApiRequestAssistant

pyinjective/client/chain/grpc/chain_grpc_bank_api.py

@@ -2,7 +2,7 @@
 
 from grpc.aio import Channel
 
-from pyinjective.client.model.pagination import PaginationOption
+from pyinjective.client.model import PaginationOption
 from pyinjective.core.network import CookieAssistant
 from pyinjective.proto.cosmos.distribution.v1beta1 import (
     query_pb2 as distribution_query_pb,

pyinjective/client/chain/grpc/chain_grpc_distribution_api.py

@@ -2,7 +2,7 @@
 
 from grpc.aio import Channel
 
-from pyinjective.client.model.pagination import PaginationOption
+from pyinjective.client.model import PaginationOption
 from pyinjective.core.network import CookieAssistant
 from pyinjective.proto.injective.exchange.v1beta1 import (
     query_pb2 as exchange_query_pb,

pyinjective/client/chain/grpc/chain_grpc_exchange_api.py

@@ -2,7 +2,7 @@
 
 from grpc.aio import Channel
 
-from pyinjective.client.model.pagination import PaginationOption
+from pyinjective.client.model import PaginationOption
 from pyinjective.core.network import CookieAssistant
 from pyinjective.proto.cosmwasm.wasm.v1 import query_pb2 as wasm_query_pb, query_pb2_grpc as wasm_query_grpc
 from pyinjective.utils.grpc_api_request_assistant import GrpcApiRequestAssistant

pyinjective/client/chain/grpc/chain_grpc_wasm_api.py

@@ -0,0 +1,50 @@
+from typing import Callable, Optional
+
+from grpc.aio import Channel
+
+from pyinjective.core.network import CookieAssistant
+from pyinjective.proto.injective.stream.v1beta1 import query_pb2 as chain_stream_pb, query_pb2_grpc as chain_stream_grpc
+from pyinjective.utils.grpc_api_stream_assistant import GrpcApiStreamAssistant
+
+
+class ChainGrpcChainStream:
+    def __init__(self, channel: Channel, cookie_assistant: CookieAssistant):
+        self._stub = self._stub = chain_stream_grpc.StreamStub(channel)
+        self._assistant = GrpcApiStreamAssistant(cookie_assistant=cookie_assistant)
+
+    async def stream(
+        self,
+        callback: Callable,
+        on_end_callback: Optional[Callable] = None,
+        on_status_callback: Optional[Callable] = None,
+        bank_balances_filter: Optional[chain_stream_pb.BankBalancesFilter] = None,
+        subaccount_deposits_filter: Optional[chain_stream_pb.SubaccountDepositsFilter] = None,
+        spot_trades_filter: Optional[chain_stream_pb.TradesFilter] = None,
+        derivative_trades_filter: Optional[chain_stream_pb.TradesFilter] = None,
+        spot_orders_filter: Optional[chain_stream_pb.OrdersFilter] = None,
+        derivative_orders_filter: Optional[chain_stream_pb.OrdersFilter] = None,
+        spot_orderbooks_filter: Optional[chain_stream_pb.OrderbookFilter] = None,
+        derivative_orderbooks_filter: Optional[chain_stream_pb.OrderbookFilter] = None,
+        positions_filter: Optional[chain_stream_pb.PositionsFilter] = None,
+        oracle_price_filter: Optional[chain_stream_pb.OraclePriceFilter] = None,
+    ):
+        request = chain_stream_pb.StreamRequest(
+            bank_balances_filter=bank_balances_filter,
+            subaccount_deposits_filter=subaccount_deposits_filter,
+            spot_trades_filter=spot_trades_filter,
+            derivative_trades_filter=derivative_trades_filter,
+            spot_orders_filter=spot_orders_filter,
+            derivative_orders_filter=derivative_orders_filter,
+            spot_orderbooks_filter=spot_orderbooks_filter,
+            derivative_orderbooks_filter=derivative_orderbooks_filter,
+            positions_filter=positions_filter,
+            oracle_price_filter=oracle_price_filter,
+        )
+
+        await self._assistant.listen_stream(
+            call=self._stub.Stream,
+            request=request,
+            callback=callback,
+            on_end_callback=on_end_callback,
+            on_status_callback=on_status_callback,
+        )