LBRYFoundation/LBRY-Vault
1
0
Fork 0
mirror of https://github.com/LBRYFoundation/LBRY-Vault.git synced 2025-09-01 09:45:18 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

lnbase: typo in on_channel_reestablish

Browse source
This commit is contained in:
SomberNight 2018-10-15 21:01:33 +02:00
parent 2d0cabbc5f
commit f29a88147a
No known key found for this signature in database
GPG key ID: B33B5F232C6271E9
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
electrum/lnbase.py
View file

@ -10,7 +10,7 @@ import asyncio
import os import os
import time import time
from functools import partial from functools import partial
from typing import List from typing import List, Tuple
import aiorpcx import aiorpcx
@ -139,7 +139,7 @@ for k in structured:
assert message_types[b"\x00\x10"].__name__ == "init_handler" assert message_types[b"\x00\x10"].__name__ == "init_handler"
def decode_msg(data): def decode_msg(data: bytes) -> Tuple[str, dict]:
""" """
Decode Lightning message by reading the first Decode Lightning message by reading the first
two bytes to determine message type. two bytes to determine message type.
@ -150,7 +150,7 @@ def decode_msg(data):
k, parsed = message_types[typ](data[2:]) k, parsed = message_types[typ](data[2:])
return k, parsed return k, parsed
def gen_msg(msg_type, **kwargs): def gen_msg(msg_type: str, **kwargs) -> bytes:
""" """
Encode kwargs into a Lightning message (bytes) Encode kwargs into a Lightning message (bytes)
of the type given in the msg_type string of the type given in the msg_type string
@ -651,7 +651,7 @@ class Peer(PrintError):
# the receiving node sent, AND the receiving node # the receiving node sent, AND the receiving node
# hasn't already received a closing_signed: # hasn't already received a closing_signed:
# MUST re-send the revoke_and_ack. # MUST re-send the revoke_and_ack.
self.config[LOCAL]=self.config[LOCAL]._replace( chan.config[LOCAL]=chan.config[LOCAL]._replace(
ctn=remote_ctn, ctn=remote_ctn,
) )
self.revoke(chan) self.revoke(chan)