|
@@ -18,7 +18,9 @@
|
|
|
import sys
|
|
import sys
|
|
|
import urwid
|
|
import urwid
|
|
|
import asyncio
|
|
import asyncio
|
|
|
|
|
+import logging
|
|
|
|
|
|
|
|
|
|
+import model
|
|
|
from rpc import JsonRpc
|
|
from rpc import JsonRpc
|
|
|
from view import Dnetview
|
|
from view import Dnetview
|
|
|
|
|
|
|
@@ -29,7 +31,6 @@ async def get_info(rpc):
|
|
|
break
|
|
break
|
|
|
except OSError:
|
|
except OSError:
|
|
|
pass
|
|
pass
|
|
|
-
|
|
|
|
|
response = await rpc._make_request("p2p.get_info", [])
|
|
response = await rpc._make_request("p2p.get_info", [])
|
|
|
info = response["result"]
|
|
info = response["result"]
|
|
|
channels = info["channels"]
|
|
channels = info["channels"]
|
|
@@ -38,40 +39,42 @@ async def get_info(rpc):
|
|
|
id = channel["id"]
|
|
id = channel["id"]
|
|
|
channel_lookup[id] = channel
|
|
channel_lookup[id] = channel
|
|
|
|
|
|
|
|
- #print("inbound:")
|
|
|
|
|
|
|
+ logging.debug("inbound")
|
|
|
for channel in channels:
|
|
for channel in channels:
|
|
|
if channel["session"] != "inbound":
|
|
if channel["session"] != "inbound":
|
|
|
continue
|
|
continue
|
|
|
url = channel["url"]
|
|
url = channel["url"]
|
|
|
- #print(f" {url}")
|
|
|
|
|
|
|
+ logging.debug(f" {url}")
|
|
|
|
|
|
|
|
- #print("outbound:")
|
|
|
|
|
|
|
+ logging.debug("outbound")
|
|
|
for i, id in enumerate(info["outbound_slots"]):
|
|
for i, id in enumerate(info["outbound_slots"]):
|
|
|
if id == 0:
|
|
if id == 0:
|
|
|
- #print(f" {i}: none")
|
|
|
|
|
|
|
+ logging.debug(f" {i}: none")
|
|
|
continue
|
|
continue
|
|
|
|
|
|
|
|
assert id in channel_lookup
|
|
assert id in channel_lookup
|
|
|
url = channel_lookup[id]["url"]
|
|
url = channel_lookup[id]["url"]
|
|
|
- #print(f" {i}: {url}")
|
|
|
|
|
|
|
+ logging.debug(f" {i}: {url}")
|
|
|
|
|
|
|
|
- #print("seed:")
|
|
|
|
|
|
|
+ logging.debug("seed")
|
|
|
for channel in channels:
|
|
for channel in channels:
|
|
|
if channel["session"] != "seed":
|
|
if channel["session"] != "seed":
|
|
|
continue
|
|
continue
|
|
|
url = channel["url"]
|
|
url = channel["url"]
|
|
|
- #print(f" {url}")
|
|
|
|
|
|
|
+ logging.debug(f" {i}: {url}")
|
|
|
|
|
|
|
|
- #print("manual:")
|
|
|
|
|
|
|
+ logging.debug("manual")
|
|
|
for channel in channels:
|
|
for channel in channels:
|
|
|
if channel["session"] != "manual":
|
|
if channel["session"] != "manual":
|
|
|
continue
|
|
continue
|
|
|
url = channel["url"]
|
|
url = channel["url"]
|
|
|
- #print(f" {url}")
|
|
|
|
|
|
|
+ logging.debug(f" {i}: {url}")
|
|
|
|
|
|
|
|
await rpc.stop()
|
|
await rpc.stop()
|
|
|
|
|
|
|
|
if __name__ == '__main__':
|
|
if __name__ == '__main__':
|
|
|
|
|
+ logging.basicConfig(filename='dnet.log', encoding='utf-8', level=logging.DEBUG)
|
|
|
|
|
+
|
|
|
ev = asyncio.get_event_loop()
|
|
ev = asyncio.get_event_loop()
|
|
|
|
|
|
|
|
rpc = JsonRpc()
|
|
rpc = JsonRpc()
|