async def cb(reader, writer):
    transport = LNResponderTransport(self.node_keypair.privkey, reader, writer)
    try:
        node_id = (await transport.handshake())
    except Exception as e:
        self.logger.info(f'handshake failure from incoming connection: {e!r}')
        return
    (await self._add_peer_from_transport(node_id=node_id, transport=transport))
async def cb(reader, writer):
    transport = LNResponderTransport(self.node_keypair.privkey, reader, writer)
    try:
        node_id = (await transport.handshake())
    except Exception as e:
        self.logger.info(f'handshake failure from incoming connection: {e!r}')
        return
    (await self._add_peer_from_transport(node_id=node_id, transport=transport))