GonnaHetzMe/blitz-tools
0
0 Fork 0
mirror of https://github.com/Jylpah/blitz-tools.git synced 2026-10-23 19:19:53 +02:00
Code Issues Projects Releases Wiki Activity

add _id to replays JSON read from the filesystem

Browse Source
This commit is contained in:
Jylpah committed 2020-11-26 21:29:17 +02:00
1 parent fe7292a588
commit c830955b6f
1 file changed
+8 -2
Download Patch File Download Diff File Expand all files Collapse all files
analyze_wotb_replays.py
+8 -2
View File
@@ -1960,7 +1960,7 @@ async def mk_replayQ(queue : asyncio.Queue, args : argparse.Namespace, db : moto
if not line: break if not line: break
if (p_replayfile.match(line) != None): if (p_replayfile.match(line) != None):
replay_json = await bu.open_JSON(line, wi.chk_JSON_replay) replay_json = await bu.open_JSON(line, wi.chk_JSON_replay)
await queue.put(await mk_readerQ_item(replay_json, line)) await queue.put(await mk_readerQ_item(replay_json, line))
except Exception as err: except Exception as err:
bu.error(exception=err) bu.error(exception=err)
@@ -1993,7 +1993,13 @@ async def mk_replayQ(queue : asyncio.Queue, args : argparse.Namespace, db : moto
async def mk_readerQ_item(replay_json, filename : str = None) -> list: async def mk_readerQ_item(replay_json, filename : str = None) -> list:
"""Make an item to replay queue""" """Make an item to replay queue"""
global REPLAY_N global REPLAY_N
REPLAY_N +=1 REPLAY_N +=1
try:
if not '_id' in replay_json:
id = wi.read_replay_id(replay_json)
replay_json['_id'] = id
except Exception as err:
bu.error(exception=err)
if filename == None: if filename == None:
return [replay_json, REPLAY_N, '' ] return [replay_json, REPLAY_N, '' ]
elif RE_SRC_IS_DB.match(filename) != None: elif RE_SRC_IS_DB.match(filename) != None: