Protokoll #15135

{
    "event": "PreToolUse",
    "tool_name": "Write",
    "tool_input": {
        "file_path": "\/var\/www\/scripts\/pipeline\/generators\/persistence.py",
        "content": "\"\"\"\nPersistence Functions - Save content versions and sources to database.\n\"\"\"\n\nimport json\nimport sys\n\nsys.path.insert(0, \"\/var\/www\/scripts\/pipeline\")\n\nfrom db import db\n\n\ndef save_version(order_id: int, content: str, version_number: int = 1, output_format: str = \"markdown\") -> int:\n    \"\"\"Save content version to database.\"\"\"\n    content_json = json.dumps({\"text\": content, \"format\": output_format})\n\n    cursor = db.execute(\n        \"\"\"INSERT INTO content_versions (order_id, version_number, content)\n           VALUES (%s, %s, %s)\"\"\",\n        (order_id, version_number, content_json),\n    )\n    db.commit()\n    version_id = cursor.lastrowid\n    cursor.close()\n    return version_id\n\n\ndef save_sources(order_id: int, context: list[dict]) -> None:\n    \"\"\"Save RAG sources to content_sources.\"\"\"\n    for ctx in context:\n        # Try to find chunk_id by content match\n        cursor = db.execute(\"SELECT id FROM chunks WHERE content LIKE %s LIMIT 1\", (ctx[\"content\"][:100] + \"%\",))\n        chunk = cursor.fetchone()\n        cursor.close()\n\n        if chunk:\n            cursor = db.execute(\n                \"\"\"INSERT IGNORE INTO content_sources (order_id, chunk_id, relevance_score)\n                   VALUES (%s, %s, %s)\"\"\",\n                (order_id, chunk[\"id\"], ctx[\"score\"]),\n            )\n            db.commit()\n            cursor.close()\n\n\ndef update_order_status(order_id: int, status: str) -> None:\n    \"\"\"Update order status.\"\"\"\n    cursor = db.execute(\"UPDATE content_orders SET status = %s, updated_at = NOW() WHERE id = %s\", (status, order_id))\n    db.commit()\n    cursor.close()\n"
    }
}

{
    "tool_response": {
        "type": "create",
        "filePath": "\/var\/www\/scripts\/pipeline\/generators\/persistence.py",
        "content": "\"\"\"\nPersistence Functions - Save content versions and sources to database.\n\"\"\"\n\nimport json\nimport sys\n\nsys.path.insert(0, \"\/var\/www\/scripts\/pipeline\")\n\nfrom db import db\n\n\ndef save_version(order_id: int, content: str, version_number: int = 1, output_format: str = \"markdown\") -> int:\n    \"\"\"Save content version to database.\"\"\"\n    content_json = json.dumps({\"text\": content, \"format\": output_format})\n\n    cursor = db.execute(\n        \"\"\"INSERT INTO content_versions (order_id, version_number, content)\n           VALUES (%s, %s, %s)\"\"\",\n        (order_id, version_number, content_json),\n    )\n    db.commit()\n    version_id = cursor.lastrowid\n    cursor.close()\n    return version_id\n\n\ndef save_sources(order_id: int, context: list[dict]) -> None:\n    \"\"\"Save RAG sources to content_sources.\"\"\"\n    for ctx in context:\n        # Try to find chunk_id by content match\n        cursor = db.execute(\"SELECT id FROM chunks WHERE content LIKE %s LIMIT 1\", (ctx[\"content\"][:100] + \"%\",))\n        chunk = cursor.fetchone()\n        cursor.close()\n\n        if chunk:\n            cursor = db.execute(\n                \"\"\"INSERT IGNORE INTO content_sources (order_id, chunk_id, relevance_score)\n                   VALUES (%s, %s, %s)\"\"\",\n                (order_id, chunk[\"id\"], ctx[\"score\"]),\n            )\n            db.commit()\n            cursor.close()\n\n\ndef update_order_status(order_id: int, status: str) -> None:\n    \"\"\"Update order status.\"\"\"\n    cursor = db.execute(\"UPDATE content_orders SET status = %s, updated_at = NOW() WHERE id = %s\", (status, order_id))\n    db.commit()\n    cursor.close()\n",
        "structuredPatch": [],
        "originalFile": null
    }
}