v0.0.8: fix SSE format — event: строка отдельно от data:
Deploy drhider / validate (push) Waiting to run

This commit is contained in:
2026-07-13 10:59:03 +04:00
parent e3405556b5
commit bf202cdfa4
2 changed files with 4 additions and 4 deletions
+1 -1
View File
@@ -20,7 +20,7 @@ if _sys_path_root not in sys.path:
sys.path.insert(0, _sys_path_root) sys.path.insert(0, _sys_path_root)
# Версия приложения (меняется при изменениях) # Версия приложения (меняется при изменениях)
VERSION = "0.0.7" VERSION = "0.0.8"
def create_app(): def create_app():
+3 -3
View File
@@ -59,7 +59,7 @@ def process_stream(sid):
all_mapping = {} all_mapping = {}
for idx, (fname, content) in enumerate(files): for idx, (fname, content) in enumerate(files):
# Отправляем: начали файл # Отправляем: начали файл
yield f"data: {json.dumps({'event': 'start', 'idx': idx, 'name': fname, 'total': total})}\n\n" yield f"event: start\ndata: {json.dumps({'idx': idx, 'name': fname, 'total': total})}\n\n"
zip_data, _csv = obfuscate_files([(fname, content, "")], llm_client=llm) zip_data, _csv = obfuscate_files([(fname, content, "")], llm_client=llm)
with zipfile.ZipFile(io.BytesIO(zip_data)) as zf: with zipfile.ZipFile(io.BytesIO(zip_data)) as zf:
for name in zf.namelist(): for name in zf.namelist():
@@ -74,14 +74,14 @@ def process_stream(sid):
elif not name.endswith("/"): elif not name.endswith("/"):
all_results.append((name, zf.read(name))) all_results.append((name, zf.read(name)))
# Отправляем: закончили файл # Отправляем: закончили файл
yield f"data: {json.dumps({'event': 'done', 'idx': idx, 'name': fname, 'total': total})}\n\n" yield f"event: done\ndata: {json.dumps({'idx': idx, 'name': fname, 'total': total})}\n\n"
csv_str = build_mapping_csv(all_mapping) if all_mapping else "" csv_str = build_mapping_csv(all_mapping) if all_mapping else ""
final_zip = build_zip(all_results) final_zip = build_zip(all_results)
store_result(sid, final_zip) store_result(sid, final_zip)
if csv_str: if csv_str:
store_csv(sid, csv_str) store_csv(sid, csv_str)
yield f"data: {json.dumps({'event': 'complete', 'total': len(all_results)})}\n\n" yield f"event: complete\ndata: {json.dumps({'total': len(all_results)})}\n\n"
return Response( return Response(
stream_with_context(generate()), stream_with_context(generate()),