kev/Onionr
1
0
Fork 0
Code Issues 24 Pull Requests Projects Releases 2 Wiki Activity

Removed close gossip command

Browse Source
This commit is contained in:
Kevin F 2022-05-18 23:56:25 -05:00
parent 9f25291c3a
commit 85626d6642
3 changed files with 0 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/gossip/commands.py
View File

@ -6,7 +6,6 @@ class GossipCommands(IntEnum):
PEER_EXCHANGE = auto() PEER_EXCHANGE = auto()
STREAM_BLOCKS = auto() STREAM_BLOCKS = auto()
PUT_BLOCKS = auto() PUT_BLOCKS = auto()
CLOSE = auto()
def command_to_byte(cmd: GossipCommands): def command_to_byte(cmd: GossipCommands):

2
src/gossip/server/__init__.py
View File

@ -60,8 +60,6 @@ def gossip_server():
match GossipCommands(cmd): match GossipCommands(cmd):
case GossipCommands.PING: case GossipCommands.PING:
writer.write(b'PONG') writer.write(b'PONG')
case GossipCommands.CLOSE:
pass
case GossipCommands.ANNOUNCE: case GossipCommands.ANNOUNCE:
async def _read_announce(): async def _read_announce():
address = await reader.readuntil(b'\n') address = await reader.readuntil(b'\n')

2
tests/gossip-unittests/test_client_announce.py
View File

@ -81,7 +81,6 @@ Thread(target=_announce_server, daemon=True).start()
class OnionrClientAnnounce(unittest.TestCase): class OnionrClientAnnounce(unittest.TestCase):
def test_client_announce_too_long(self): def test_client_announce_too_long(self):
sleep(1)
import onionrplugins import onionrplugins
our_address = "testtransport" * 100 our_address = "testtransport" * 100
@ -100,7 +99,6 @@ class OnionrClientAnnounce(unittest.TestCase):
self.assertNotEqual(our_address, reced_address[0]) self.assertNotEqual(our_address, reced_address[0])
def test_client_announce(self): def test_client_announce(self):
sleep(1)
import onionrplugins import onionrplugins
our_address = "testtransport" our_address = "testtransport"