41 lines
978 B
Python
41 lines
978 B
Python
import sys
|
|
import asyncio
|
|
import random
|
|
import threading
|
|
import syndicate.mini.core as S
|
|
|
|
OverlayLink = S.Record.makeConstructor('OverlayLink', 'downNode upNode')
|
|
|
|
conn = S.Connection.from_url(sys.argv[1])
|
|
|
|
uplinks = {}
|
|
def add_uplink(turn, src, tgt):
|
|
uplinks[src] = tgt
|
|
summarise_uplinks()
|
|
def del_uplink(turn, src, tgt):
|
|
del uplinks[src]
|
|
summarise_uplinks()
|
|
def summarise_uplinks():
|
|
print(repr(uplinks))
|
|
|
|
with conn.turn() as t:
|
|
S.Endpoint(t, S.Observe(OverlayLink(S.CAPTURE, S.CAPTURE)),
|
|
on_add=add_uplink,
|
|
on_del=del_uplink)
|
|
|
|
async def on_connected():
|
|
print('-'*50, 'Connected')
|
|
async def on_disconnected(did_connect):
|
|
if did_connect:
|
|
print('-'*50, 'Disconnected')
|
|
else:
|
|
await asyncio.sleep(2)
|
|
return True
|
|
|
|
loop = asyncio.get_event_loop()
|
|
loop.set_debug(True)
|
|
loop.run_until_complete(conn.reconnecting_main(loop, on_connected, on_disconnected))
|
|
loop.stop()
|
|
loop.run_forever()
|
|
loop.close()
|