feat: add stream event order fail

Author: achilleas-kal

examples/chain_client/38_StreamEvent.py …/chain_client/38_StreamEventOrderFail.pyexamples/chain_client/38_StreamEvent.py renamed to examples/chain_client/38_StreamEventOrderFail.py examples/chain_client/38_StreamEvent.py renamed to examples/chain_client/38_StreamEventOrderFail.py

@@ -13,22 +13,17 @@
 # limitations under the License.
 """Injective Exchange API client for Python. Example only."""
 
-import sys
-sys.path.insert(0, '/Users/nam/desktop/injective/sdk-python/')
-
 import asyncio
 import logging
 import json
 import websockets
+import base64
 
-from pyinjective.async_client import AsyncClient
 from pyinjective.constant import Network
 
 async def main() -> None:
     network = Network.mainnet()
-    client = AsyncClient(network, insecure=False)
-
-    event_filter = "tm.event='Tx' AND message.sender='inj1rwv4zn3jptsqs7l8lpa3uvzhs57y8duemete9e' AND message.action='/injective.exchange.v1beta1.MsgBatchUpdateOrders'"
+    event_filter = "tm.event='Tx' AND message.sender='inj1rwv4zn3jptsqs7l8lpa3uvzhs57y8duemete9e' AND message.action='/injective.exchange.v1beta1.MsgBatchUpdateOrders' AND injective.exchange.v1beta1.EventOrderFail.flags EXISTS"
     query = json.dumps({
         "jsonrpc": "2.0",
         "method": "subscribe",
@@ -38,12 +33,35 @@ async def main() -> None:
         },
     })
 
+    events_dict = {}
+    failed_orders = {}
+    flags = []
+    order_hashes = []
+
     async with websockets.connect(network.tm_websocket_endpoint) as ws:
         await ws.send(query)
         while True:
             events = await ws.recv()
-            print(events)
-            await asyncio.sleep(1)
+            events_json = json.loads(events)
+            resp = events_json["result"]
+            for key, value in resp.items():
+                if key == "events":
+                    events_dict = value
+            for key, value in events_dict.items():
+                if key == "injective.exchange.v1beta1.EventOrderFail.flags":
+                    k = json.loads(value[0])
+                    for i in range(len(k)):
+                        flags.append(k[i])
+                if key == "injective.exchange.v1beta1.EventOrderFail.hashes":
+                    k = json.loads(value[0])
+                    for i in range(len(k)):
+                        hash_to_bytes = k[i].encode("utf-8")
+                        bytes_to_base64 = base64.standard_b64decode(hash_to_bytes)
+                        base64_to_hex = '0x' + bytes_to_base64.hex()
+                        order_hashes.append(base64_to_hex)
+            for i in range(len(order_hashes)):
+                failed_orders[order_hashes[i]] = flags[i]
+            print(failed_orders)
 
 if __name__ == '__main__':
     logging.basicConfig(level=logging.INFO)