github/darkfi
1
1
Fork 0
mirror of https://github.com/darkrenaissance/darkfi.git synced 2026-01-09 14:48:08 -05:00
Code Issues Packages Projects Releases Wiki Activity

script/dnet: get async queue working

Browse Source
This commit is contained in:
lunar-mining
2023-09-08 11:18:12 +02:00
parent 8a40af693f
commit 39d27645b2
1 changed files with 22 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
script/dnet/main.py
View File

@@ -43,7 +43,11 @@ class Dnetview:
pass
data = await rpc._make_request("p2p.get_info", [])
logging.debug(f"get_info: {data}")
try:
self.queue.put_nowait(data)
except:
logging.debug("subscribe().put_nowait(): QueueFull")
await rpc.dnet_switch(True)
await rpc.dnet_subscribe_events()
@@ -51,8 +55,12 @@ class Dnetview:
while True:
data = await rpc.reader.readline()
data = json.loads(data)
# TODO: update data structures
logging.debug(f"events: {data}")
#logging.debug(f"events: {data}")
try:
self.queue.put_nowait(data)
except:
logging.debug("subscribe().putnowait(): QueueFull")
await rpc.dnet_switch(False)
await rpc.stop()
@@ -67,7 +75,17 @@ class Dnetview:
async with asyncio.TaskGroup() as tg:
for i, node in enumerate(nodes):
rpc = JsonRpc()
task = tg.create_task(self.subscribe(rpc, node['name'], node['port']))
subscribe = tg.create_task(self.subscribe(rpc, node['name'], node['port']))
update = tg.create_task(self.update_model())
async def update_model(self):
while True:
try:
item = await self.queue.get()
logging.debug(f"result: {item}")
self.queue.task_done()
except self.queue.is_empty():
logging.debug("update_model(): QueueEmpty")
def main(self):
logging.basicConfig(filename='dnet.log', encoding='utf-8', level=logging.DEBUG)