[Bug] Markdown 导入将空正文／无 choices 当成合法空提取，无告警显示 completed（main/testing 均可复现） #134

"""Run in an installed Ombre Brain checkout: PYTHONPATH=src python /tmp/repro_empty_import.py
Only the LLM and state/bucket I/O are replaced. No network or real vault is used.
"""
import asyncio
import json
from types import SimpleNamespace
from unittest.mock import AsyncMock
from import_memory import ImportEngine

async def replay(raw):
    engine = object.__new__(ImportEngine)
    engine.config = {"human": "用户"}
    engine.dehydrator = SimpleNamespace(
        api_available=True, import_max_tokens=4096,
        _chat=AsyncMock(return_value=raw),
    )
    data = {
        "status": "running", "total_chunks": 1, "processed": 0,
        "api_calls": 0, "memories_created": 0, "memories_merged": 0,
        "memories_skipped": 0, "memories_raw": 0,
        "chunks_failed": 0, "errors": [],
    }
    engine.state = SimpleNamespace(
        data=data, save=lambda: None, to_dict=lambda: dict(data),
    )
    engine._chunks = [{
        "content": "[用户] 周三我参加了北桥读书会，下周会带上蓝色封面的小说。"
    }]
    engine._paused = False
    engine._prime_exact_content_hashes = AsyncMock()
    engine._create_import_item_if_new = AsyncMock(return_value=True)
    result = await engine._process_chunks(False)
    return {
        key: result[key] for key in (
            "status", "processed", "api_calls", "memories_created",
            "chunks_failed", "errors",
        )
    }

async def main():
    cases = {
        "empty_body": "",
        "valid_empty_array": "[]",
        "invalid_json": "[",
        "valid_one_memory": json.dumps(
            [{"name": "读书会", "content": "周三参加读书会，下周带蓝色小说。"}],
            ensure_ascii=False,
        ),
    }
    for name, raw in cases.items():
        print(name, json.dumps(await replay(raw), ensure_ascii=False))

if __name__ == "__main__":
    asyncio.run(main())