[ECHOT-316] Up library patch version >> 0.1.56: Update processing of …

…broadcast_transaction_with_callback in socket client (#8)

[ECHOT-316] Up library patch version >> 0.1.56: Update processing of broadcast_transaction_with_callback in socket client

echopy/echoapi/ws/rpc.py

@@ -130,7 +130,10 @@ def method(params, *args, **kwargs):
                 'id': self.get_request_id(),
             }
             log.debug('{}{}{} {}'.format('\x1b[1;32m', '>>>', '\x1b[0m', query))
-            r = self.rpcexec(query)
+            r = self.rpcexec(
+                query,
+                name != 'broadcast_transaction_with_callback'
+            )
             message = self.parse_response(r)
             return message
 

echopy/echoapi/ws/simplewebsocket.py

@@ -49,7 +49,7 @@ def disconnect(self):
     """ RPC Calls
     """
 
-    def rpcexec(self, payload):
+    def rpcexec(self, payload, recv=True):
         """ Execute a call by sending the payload
         """
         if not self.ws:
@@ -61,13 +61,15 @@ def rpcexec(self, payload):
         # We need to lock because we need to wait for websocket
         # response but don't want to allow other threads to send
         # requests (that might take less time) to disturb
+        ret = '{"result": null}'
         self.__lock.acquire()
 
         # Send over websocket
         try:
             self.ws.send(json.dumps(payload, ensure_ascii=False).encode("utf8"))
             # Receive from websocket
-            ret = self.ws.recv()
+            if recv:
+                ret = self.ws.recv()
 
         finally:
             # Release lock

setup.py

@@ -3,7 +3,7 @@
 
 from setuptools import setup, find_packages
 
-VERSION = "0.1.55"
+VERSION = "0.1.56"
 packages = find_packages()
 packages.remove('test')