feat(pob-x): fix #34

skipper-py/src/bot.py

@@ -23,6 +23,7 @@
 from src.transaction import Transaction
 from src.contract import Pool
 from src.route import Route
+from src.rest_client import FixedTxRestClient
 
 from skip_types.pob import MsgAuctionBid
 from skip_utility.tx import TransactionWithTimeout as Tx
@@ -91,6 +92,7 @@ async def init(self):
                                     staking_denomination=self.fee_denom,
                                     )
         self.client = LedgerClient(self.network_config)
+        self.client.txs = FixedTxRestClient(self.client.txs.rest_client)
         self.wallet = self.creator.create_wallet(self.chain_id, 
                                                  self.mnemonic, 
                                                  self.address_prefix) 
@@ -188,10 +190,8 @@ async def run(self):
                     # the bid transaction includes the bundle of transactions
                     # that will be executed if the bid is successful
                     tx = self.client.broadcast_tx(tx=bidTx).wait_to_complete()
-                    logging.info(f"Broadcasted bid transaction {tx_hash}")
+                    logging.info(f"Broadcasted bid transaction {tx.tx_hash}")
 
-                    # log the result of the bid transaction
-                    logging.info(f"Result of bid transaction {tx_hash}: {tx.is_successful()}")
 
     def build_most_profitable_bundle(self,
                                      transaction: Transaction,

skipper-py/src/rest_client.py

@@ -0,0 +1,35 @@
+import json
+from google.protobuf.json_format import ParseDict
+from cosmpy.tx.rest_client import TxRestClient
+from cosmpy.protos.cosmos.tx.v1beta1.service_pb2 import (
+    GetTxRequest,
+    GetTxResponse
+)
+
+class FixedTxRestClient(TxRestClient):
+    def GetTx(self, request: GetTxRequest) -> GetTxResponse:
+        """
+        GetTx fetches a tx by hash.
+
+        :param request: GetTxRequest
+        :return: GetTxResponse
+        """
+        response = self.rest_client.get(f"{self.API_URL}/txs/{request.hash}")
+
+        # JSON in case of CosmWasm messages workaround
+        dict_response = json.loads(response)
+        self._fix_messages(dict_response["tx"]["body"]["messages"])
+        self._fix_messages(dict_response["tx_response"]["tx"]["body"]["messages"])
+
+        self._fix_tip_and_events(dict_response)
+
+        return ParseDict(dict_response, GetTxResponse())
+
+    @staticmethod
+    def _fix_tip_and_events(dict_response):
+        """
+        Fix tip and events parsing error
+        """
+        del dict_response['tx']['auth_info']['tip']
+        del dict_response['tx_response']['tx']['auth_info']['tip']
+        dict_response['tx_response']['events'] = []