tClean up some debug methods. - obelisk - Electrum server using libbitcoin as its backend

git clone https://git.parazyd.org/obelisk

Log

Files

Refs

README

LICENSE

---

commit 1423c47cf676eec8822f6e689ae440b1a49c6733

parent 49cd87e1ba0f4f05de73c9c73d4f0eb7546aad87

Author: parazyd 

Date:   Wed,  7 Apr 2021 18:19:36 +0200

Clean up some debug methods.

Diffstat:
  M electrumobelisk/protocol.py         |      45 +++++++++++++++-----------------

1 file changed, 21 insertions(+), 24 deletions(-)
---

diff --git a/electrumobelisk/protocol.py b/electrumobelisk/protocol.py

t@@ -112,12 +112,14 @@ class ElectrumProtocol(asyncio.Protocol):  # pylint: disable=R0904
 
     async def _send_response(self, writer, result, nid):
         response = {"jsonrpc": "2.0", "result": result, "id": nid}
+        self.log.debug("<= %s", response)
         writer.write(json.dumps(response).encode("utf-8"))
         await writer.drain()
         # writer.close()
 
     async def _send_error(self, writer, error, nid):
         response = {"jsonrpc": "2.0", "error": error, "id": nid}
+        self.log.debug("<= %s", response)
         writer.write(json.dumps(response).encode("utf-8"))
         await writer.drain()
         # writer.close()
t@@ -142,13 +144,10 @@ class ElectrumProtocol(asyncio.Protocol):  # pylint: disable=R0904
         if not func:
             self.log.error("Unhandled method %s, query=%s", method, query)
             return
-
-        self.log.debug("Request method: %s", method)
         resp = await func(query)
         return await self._send_reply(writer, resp, query)
 
     async def blockchain_block_header(self, query):
-        self.log.debug("query: %s", query)
         if "params" not in query:
             return {"error": "malformed query"}
         # TODO: cp_height
t@@ -167,7 +166,6 @@ class ElectrumProtocol(asyncio.Protocol):  # pylint: disable=R0904
         return {"result": safe_hexlify(data)}
 
     async def blockchain_block_headers(self, query):
-        self.log.debug("query: %s", query)
         if "params" not in query or len(query["params"]) < 2:
             return {"error": "malformed query"}
         # Electrum doesn't allow max_chunk_size to be less than 2016
t@@ -199,63 +197,62 @@ class ElectrumProtocol(asyncio.Protocol):  # pylint: disable=R0904
         return {"result": resp}
 
     async def blockchain_estimatefee(self, query):
-        self.log.debug("query: %s", query)
         # Help wanted
         return {"result": -1}
 
     async def blockchain_headers_subscribe(self, query):
-        self.log.debug("query: %s", query)
+        return
 
     async def blockchain_relayfee(self, query):
-        self.log.debug("query: %s", query)
+        return
 
     async def blockchain_scripthash_get_balance(self, query):
-        self.log.debug("query: %s", query)
+        return
 
     async def blockchain_scripthash_get_mempool(self, query):
-        self.log.debug("query: %s", query)
+        return
 
     async def blockchain_scripthash_listunspent(self, query):
-        self.log.debug("query: %s", query)
+        return
 
     async def blockchain_scripthash_subscribe(self, query):
-        self.log.debug("query: %s", query)
+        return
 
     async def blockchain_scripthash_unsubscribe(self, query):
-        self.log.debug("query: %s", query)
+        return
 
     async def blockchain_transaction_broadcast(self, query):
-        self.log.debug("query: %s", query)
+        return
 
     async def blockchain_transaction_get(self, query):
-        self.log.debug("query: %s", query)
+        return
 
     async def blockchain_transaction_get_merkle(self, query):
-        self.log.debug("query: %s", query)
+        return
 
     async def blockchain_transaction_from_pos(self, query):
-        self.log.debug("query: %s", query)
+        return
 
     async def mempool_get_fee_histogram(self, query):
-        self.log.debug("query: %s", query)
+        return
 
     async def server_add_peer(self, query):
-        self.log.debug("query: %s", query)
+        return
 
     async def server_banner(self, query):
-        self.log.debug("query: %s", query)
+        return
 
     async def server_donation_address(self, query):
-        self.log.debug("query: %s", query)
+        return
 
     async def server_features(self, query):
-        self.log.debug("query: %s", query)
+        return
 
     async def server_peers_subscribe(self, query):
-        self.log.debug("query: %s", query)
+        return
 
     async def server_ping(self, query):
-        self.log.debug("query: %s", query)
+        return
 
     async def server_version(self, query):
-        self.log.debug("query: %s", query)
+        return