tApply some linting. - obelisk - Electrum server using libbitcoin as its backend
HTML git clone https://git.parazyd.org/obelisk
DIR Log
DIR Files
DIR Refs
DIR README
DIR LICENSE
---
DIR commit b92d6ab9e16e03747c4ac7b9f093a268b43a3c43
DIR parent 28f771b68b7cab7a304cc7d8adccf2e3b9254bea
HTML Author: parazyd <parazyd@dyne.org>
Date: Tue, 13 Apr 2021 17:42:10 +0200
Apply some linting.
Diffstat:
M obelisk/protocol.py | 10 +++++-----
M obelisk/zeromq.py | 1 -
2 files changed, 5 insertions(+), 6 deletions(-)
---
DIR diff --git a/obelisk/protocol.py b/obelisk/protocol.py
t@@ -155,28 +155,28 @@ class ElectrumProtocol(asyncio.Protocol): # pylint: disable=R0904,R0902
except (UnicodeDecodeError, json.JSONDecodeError) as err:
self.log.debug("Got error: %s", repr(err))
break
- self.log.debug("=> " + line)
+ self.log.debug("=> %s", line)
await self.handle_query(writer, query)
async def _send_notification(self, writer, method, params):
"""Send JSON-RPC notification to given writer"""
response = {"jsonrpc": "2.0", "method": method, "params": params}
self.log.debug("<= %s", response)
- writer.write(json.dumps(response).encode("utf-8") + b"\n")
+ writer.write(json.dumps(response).encode("utf-8").append("\n"))
await writer.drain()
async def _send_response(self, writer, result, nid):
"""Send successful JSON-RPC response to given writer"""
response = {"jsonrpc": "2.0", "result": result, "id": nid}
self.log.debug("<= %s", response)
- writer.write(json.dumps(response).encode("utf-8") + b"\n")
+ writer.write(json.dumps(response).encode("utf-8").append("\n"))
await writer.drain()
async def _send_error(self, writer, error, nid):
"""Send JSON-RPC error to given writer"""
response = {"jsonrpc": "2.0", "error": error, "id": nid}
self.log.debug("<= %s", response)
- writer.write(json.dumps(response).encode("utf-8") + b"\n")
+ writer.write(json.dumps(response).encode("utf-8").append("\n"))
await writer.drain()
async def _send_reply(self, writer, resp, query):
t@@ -202,7 +202,7 @@ class ElectrumProtocol(asyncio.Protocol): # pylint: disable=R0904,R0902
resp = await func(writer, query)
return await self._send_reply(writer, resp, query)
- async def blockchain_block_header(self, writer, query): # pylint: disable=W0613
+ async def blockchain_block_header(self, writer, query): # pylint: disable=W0613,R0911
"""Method: blockchain.block.header
Return the block header at the given height.
"""
DIR diff --git a/obelisk/zeromq.py b/obelisk/zeromq.py
t@@ -25,7 +25,6 @@ import zmq
import zmq.asyncio
from obelisk.libbitcoin_errors import make_error_code, ErrorCode
-from obelisk.util import bh2u
def create_random_id():