Post-syncer/chain refactor, directly close peer

Author: carver

p2p/lightchain.py

@@ -267,7 +267,7 @@ async def _retry_on_bad_response(self, make_request_to_peer: Callable[[LESPeer],
                 return await make_request_to_peer(peer)
             except BadLESResponse as exc:
                 self.logger.warn("Disconnecting from peer, because: %s", exc)
-                await self.disconnect_peer(peer, DisconnectReason.subprotocol_error)
+                await peer.disconnect(DisconnectReason.subprotocol_error)
                 # reattempt after removing this peer from our pool
 
         raise TimeoutError("Could not complete peer request in %d attempts" % MAX_REQUEST_ATTEMPTS)

p2p/service.py

@@ -8,7 +8,7 @@
     Callable,
     List,
     Optional,
-    TypeVar
+    TypeVar,
     cast,
 )
 

tests/p2p/test_lightchain_integration.py

@@ -11,7 +11,6 @@
 from eth_hash.auto import keccak
 
 from evm.chains.ropsten import (
-    RopstenChain,
     ROPSTEN_NETWORK_ID,
     ROPSTEN_GENESIS_HEADER,
     ROPSTEN_VM_CONFIGURATION,