{
"event": "PreToolUse",
"tool_name": "Edit",
"tool_input": {
"file_path": "\/var\/www\/scripts\/pipeline\/web_generate.py",
"old_string": "#!\/usr\/bin\/env python3\n\"\"\"\nWeb Content Generation Interface for KI-System\nCalled from PHP with command and parameters.\n\nUsage:\n python web_generate.py generate <order_id> [model] [collection] [limit]\n python web_generate.py critique <version_id> [model]\n python web_generate.py revise <version_id> [model]\n\"\"\"\n\nimport json\nimport os\nimport sys\n\nimport pymysql\n\n# Change to pipeline directory and add to path\nPIPELINE_PATH = \"\/var\/www\/scripts\/pipeline\"\nos.chdir(PIPELINE_PATH)\nsys.path.insert(0, PIPELINE_PATH)\n\nfrom generate import generate_content, revise_content, run_critique_round\n\n# Database configuration\nDB_CONFIG = {\n \"host\": \"localhost\",\n \"user\": \"root\",\n \"password\": os.environ.get(\"DB_PASSWORD\", \"\"),\n \"database\": \"ki_content\",\n \"charset\": \"utf8mb4\",\n}\n\n\ndef update_generation_status(order_id: int, status: str, error: str | None = None) -> None:\n \"\"\"Update generation_status in content_orders table.\"\"\"\n try:\n conn = pymysql.connect(**DB_CONFIG)\n with conn.cursor() as cursor:\n if status == \"generating\":\n cursor.execute(\n \"UPDATE content_orders SET generation_status = %s, generation_started_at = NOW(), updated_at = NOW() WHERE id = %s\",\n (status, order_id),\n )\n elif error:\n cursor.execute(\n \"UPDATE content_orders SET generation_status = %s, generation_error = %s, updated_at = NOW() WHERE id = %s\",\n (status, error, order_id),\n )\n else:\n cursor.execute(\n \"UPDATE content_orders SET generation_status = %s, generation_error = NULL, updated_at = NOW() WHERE id = %s\",\n (status, order_id),\n )\n conn.commit()\n except Exception as e:\n print(f\"DB update failed: {e}\", file=sys.stderr)\n finally:\n if \"conn\" in locals():\n conn.close()",
"new_string": "#!\/usr\/bin\/env python3\n\"\"\"\nWeb Content Generation Interface for KI-System\nCalled from PHP with command and parameters.\n\nUsage:\n python web_generate.py generate <order_id> [model] [collection] [limit]\n python web_generate.py critique <version_id> [model]\n python web_generate.py revise <version_id> [model]\n\"\"\"\n\nimport json\nimport os\nimport sys\nfrom datetime import datetime\n\nimport pymysql\n\n# Change to pipeline directory and add to path\nPIPELINE_PATH = \"\/var\/www\/scripts\/pipeline\"\nos.chdir(PIPELINE_PATH)\nsys.path.insert(0, PIPELINE_PATH)\n\nfrom generate import generate_content, revise_content, run_critique_round\n\n# Database configuration\nDB_CONFIG = {\n \"host\": \"localhost\",\n \"user\": \"root\",\n \"password\": os.environ.get(\"DB_PASSWORD\", \"\"),\n \"database\": \"ki_content\",\n \"charset\": \"utf8mb4\",\n}\n\n# Max log lines to keep\nMAX_LOG_LINES = 50\n\n\ndef log_step(order_id: int, message: str, step: str | None = None) -> None:\n \"\"\"Append a log line and optionally update current step.\"\"\"\n timestamp = datetime.now().strftime(\"%H:%M:%S\")\n log_line = f\"[{timestamp}] {message}\"\n\n try:\n conn = pymysql.connect(**DB_CONFIG)\n with conn.cursor() as cursor:\n # Get current log\n cursor.execute(\"SELECT generation_log FROM content_orders WHERE id = %s\", (order_id,))\n row = cursor.fetchone()\n current_log = row[0] if row and row[0] else \"\"\n\n # Append new line, keep last N lines\n lines = current_log.split(\"\\n\") if current_log else []\n lines.append(log_line)\n if len(lines) > MAX_LOG_LINES:\n lines = lines[-MAX_LOG_LINES:]\n new_log = \"\\n\".join(lines)\n\n # Update DB\n if step:\n cursor.execute(\n \"UPDATE content_orders SET generation_log = %s, generation_step = %s, updated_at = NOW() WHERE id = %s\",\n (new_log, step, order_id),\n )\n else:\n cursor.execute(\n \"UPDATE content_orders SET generation_log = %s, updated_at = NOW() WHERE id = %s\",\n (new_log, order_id),\n )\n conn.commit()\n except Exception as e:\n print(f\"Log update failed: {e}\", file=sys.stderr)\n finally:\n if \"conn\" in locals():\n conn.close()\n\n\ndef update_generation_status(order_id: int, status: str, error: str | None = None) -> None:\n \"\"\"Update generation_status in content_orders table.\"\"\"\n try:\n conn = pymysql.connect(**DB_CONFIG)\n with conn.cursor() as cursor:\n if status == \"generating\":\n cursor.execute(\n \"UPDATE content_orders SET generation_status = %s, generation_started_at = NOW(), generation_log = NULL, updated_at = NOW() WHERE id = %s\",\n (status, order_id),\n )\n elif error:\n cursor.execute(\n \"UPDATE content_orders SET generation_status = %s, generation_error = %s, updated_at = NOW() WHERE id = %s\",\n (status, error, order_id),\n )\n else:\n cursor.execute(\n \"UPDATE content_orders SET generation_status = %s, generation_error = NULL, updated_at = NOW() WHERE id = %s\",\n (status, order_id),\n )\n conn.commit()\n except Exception as e:\n print(f\"DB update failed: {e}\", file=sys.stderr)\n finally:\n if \"conn\" in locals():\n conn.close()"
}
}
{
"tool_response": {
"filePath": "\/var\/www\/scripts\/pipeline\/web_generate.py",
"oldString": "#!\/usr\/bin\/env python3\n\"\"\"\nWeb Content Generation Interface for KI-System\nCalled from PHP with command and parameters.\n\nUsage:\n python web_generate.py generate <order_id> [model] [collection] [limit]\n python web_generate.py critique <version_id> [model]\n python web_generate.py revise <version_id> [model]\n\"\"\"\n\nimport json\nimport os\nimport sys\n\nimport pymysql\n\n# Change to pipeline directory and add to path\nPIPELINE_PATH = \"\/var\/www\/scripts\/pipeline\"\nos.chdir(PIPELINE_PATH)\nsys.path.insert(0, PIPELINE_PATH)\n\nfrom generate import generate_content, revise_content, run_critique_round\n\n# Database configuration\nDB_CONFIG = {\n \"host\": \"localhost\",\n \"user\": \"root\",\n \"password\": os.environ.get(\"DB_PASSWORD\", \"\"),\n \"database\": \"ki_content\",\n \"charset\": \"utf8mb4\",\n}\n\n\ndef update_generation_status(order_id: int, status: str, error: str | None = None) -> None:\n \"\"\"Update generation_status in content_orders table.\"\"\"\n try:\n conn = pymysql.connect(**DB_CONFIG)\n with conn.cursor() as cursor:\n if status == \"generating\":\n cursor.execute(\n \"UPDATE content_orders SET generation_status = %s, generation_started_at = NOW(), updated_at = NOW() WHERE id = %s\",\n (status, order_id),\n )\n elif error:\n cursor.execute(\n \"UPDATE content_orders SET generation_status = %s, generation_error = %s, updated_at = NOW() WHERE id = %s\",\n (status, error, order_id),\n )\n else:\n cursor.execute(\n \"UPDATE content_orders SET generation_status = %s, generation_error = NULL, updated_at = NOW() WHERE id = %s\",\n (status, order_id),\n )\n conn.commit()\n except Exception as e:\n print(f\"DB update failed: {e}\", file=sys.stderr)\n finally:\n if \"conn\" in locals():\n conn.close()",
"newString": "#!\/usr\/bin\/env python3\n\"\"\"\nWeb Content Generation Interface for KI-System\nCalled from PHP with command and parameters.\n\nUsage:\n python web_generate.py generate <order_id> [model] [collection] [limit]\n python web_generate.py critique <version_id> [model]\n python web_generate.py revise <version_id> [model]\n\"\"\"\n\nimport json\nimport os\nimport sys\nfrom datetime import datetime\n\nimport pymysql\n\n# Change to pipeline directory and add to path\nPIPELINE_PATH = \"\/var\/www\/scripts\/pipeline\"\nos.chdir(PIPELINE_PATH)\nsys.path.insert(0, PIPELINE_PATH)\n\nfrom generate import generate_content, revise_content, run_critique_round\n\n# Database configuration\nDB_CONFIG = {\n \"host\": \"localhost\",\n \"user\": \"root\",\n \"password\": os.environ.get(\"DB_PASSWORD\", \"\"),\n \"database\": \"ki_content\",\n \"charset\": \"utf8mb4\",\n}\n\n# Max log lines to keep\nMAX_LOG_LINES = 50\n\n\ndef log_step(order_id: int, message: str, step: str | None = None) -> None:\n \"\"\"Append a log line and optionally update current step.\"\"\"\n timestamp = datetime.now().strftime(\"%H:%M:%S\")\n log_line = f\"[{timestamp}] {message}\"\n\n try:\n conn = pymysql.connect(**DB_CONFIG)\n with conn.cursor() as cursor:\n # Get current log\n cursor.execute(\"SELECT generation_log FROM content_orders WHERE id = %s\", (order_id,))\n row = cursor.fetchone()\n current_log = row[0] if row and row[0] else \"\"\n\n # Append new line, keep last N lines\n lines = current_log.split(\"\\n\") if current_log else []\n lines.append(log_line)\n if len(lines) > MAX_LOG_LINES:\n lines = lines[-MAX_LOG_LINES:]\n new_log = \"\\n\".join(lines)\n\n # Update DB\n if step:\n cursor.execute(\n \"UPDATE content_orders SET generation_log = %s, generation_step = %s, updated_at = NOW() WHERE id = %s\",\n (new_log, step, order_id),\n )\n else:\n cursor.execute(\n \"UPDATE content_orders SET generation_log = %s, updated_at = NOW() WHERE id = %s\",\n (new_log, order_id),\n )\n conn.commit()\n except Exception as e:\n print(f\"Log update failed: {e}\", file=sys.stderr)\n finally:\n if \"conn\" in locals():\n conn.close()\n\n\ndef update_generation_status(order_id: int, status: str, error: str | None = None) -> None:\n \"\"\"Update generation_status in content_orders table.\"\"\"\n try:\n conn = pymysql.connect(**DB_CONFIG)\n with conn.cursor() as cursor:\n if status == \"generating\":\n cursor.execute(\n \"UPDATE content_orders SET generation_status = %s, generation_started_at = NOW(), generation_log = NULL, updated_at = NOW() WHERE id = %s\",\n (status, order_id),\n )\n elif error:\n cursor.execute(\n \"UPDATE content_orders SET generation_status = %s, generation_error = %s, updated_at = NOW() WHERE id = %s\",\n (status, error, order_id),\n )\n else:\n cursor.execute(\n \"UPDATE content_orders SET generation_status = %s, generation_error = NULL, updated_at = NOW() WHERE id = %s\",\n (status, order_id),\n )\n conn.commit()\n except Exception as e:\n print(f\"DB update failed: {e}\", file=sys.stderr)\n finally:\n if \"conn\" in locals():\n conn.close()",
"originalFile": "#!\/usr\/bin\/env python3\n\"\"\"\nWeb Content Generation Interface for KI-System\nCalled from PHP with command and parameters.\n\nUsage:\n python web_generate.py generate <order_id> [model] [collection] [limit]\n python web_generate.py critique <version_id> [model]\n python web_generate.py revise <version_id> [model]\n\"\"\"\n\nimport json\nimport os\nimport sys\n\nimport pymysql\n\n# Change to pipeline directory and add to path\nPIPELINE_PATH = \"\/var\/www\/scripts\/pipeline\"\nos.chdir(PIPELINE_PATH)\nsys.path.insert(0, PIPELINE_PATH)\n\nfrom generate import generate_content, revise_content, run_critique_round\n\n# Database configuration\nDB_CONFIG = {\n \"host\": \"localhost\",\n \"user\": \"root\",\n \"password\": os.environ.get(\"DB_PASSWORD\", \"\"),\n \"database\": \"ki_content\",\n \"charset\": \"utf8mb4\",\n}\n\n\ndef update_generation_status(order_id: int, status: str, error: str | None = None) -> None:\n \"\"\"Update generation_status in content_orders table.\"\"\"\n try:\n conn = pymysql.connect(**DB_CONFIG)\n with conn.cursor() as cursor:\n if status == \"generating\":\n cursor.execute(\n \"UPDATE content_orders SET generation_status = %s, generation_started_at = NOW(), updated_at = NOW() WHERE id = %s\",\n (status, order_id),\n )\n elif error:\n cursor.execute(\n \"UPDATE content_orders SET generation_status = %s, generation_error = %s, updated_at = NOW() WHERE id = %s\",\n (status, error, order_id),\n )\n else:\n cursor.execute(\n \"UPDATE content_orders SET generation_status = %s, generation_error = NULL, updated_at = NOW() WHERE id = %s\",\n (status, order_id),\n )\n conn.commit()\n except Exception as e:\n print(f\"DB update failed: {e}\", file=sys.stderr)\n finally:\n if \"conn\" in locals():\n conn.close()\n\n\ndef main():\n \"\"\"Route CLI commands to content generation functions.\"\"\"\n if len(sys.argv) < 3:\n print(json.dumps({\"error\": \"Usage: web_generate.py <command> <id> [options]\"}))\n return\n\n command = sys.argv[1]\n entity_id = int(sys.argv[2])\n\n try:\n if command == \"generate\":\n model = sys.argv[3] if len(sys.argv) > 3 else \"anthropic\"\n collection = sys.argv[4] if len(sys.argv) > 4 else \"documents\"\n limit = int(sys.argv[5]) if len(sys.argv) > 5 else 5\n\n # Update status to generating (may already be set by PHP, but ensure it)\n update_generation_status(entity_id, \"generating\")\n\n result = generate_content(order_id=entity_id, model=model, collection=collection, context_limit=limit)\n\n # Update status based on result\n if result.get(\"error\"):\n update_generation_status(entity_id, \"failed\", result[\"error\"])\n else:\n update_generation_status(entity_id, \"completed\")\n\n elif command == \"critique\":\n model = sys.argv[3] if len(sys.argv) > 3 else \"anthropic\"\n result = run_critique_round(version_id=entity_id, model=model)\n\n elif command == \"revise\":\n model = sys.argv[3] if len(sys.argv) > 3 else \"anthropic\"\n result = revise_content(version_id=entity_id, model=model)\n\n else:\n result = {\"error\": f\"Unknown command: {command}\"}\n\n print(json.dumps(result, ensure_ascii=False))\n\n except Exception as e:\n # On exception, mark as failed\n if command == \"generate\":\n update_generation_status(entity_id, \"failed\", str(e))\n print(json.dumps({\"error\": str(e)}))\n\n\nif __name__ == \"__main__\":\n main()\n",
"structuredPatch": [
{
"oldStart": 12,
"oldLines": 6,
"newStart": 12,
"newLines": 7,
"lines": [
" import json",
" import os",
" import sys",
"+from datetime import datetime",
" ",
" import pymysql",
" "
]
},
{
"oldStart": 31,
"oldLines": 7,
"newStart": 32,
"newLines": 49,
"lines": [
" \"charset\": \"utf8mb4\",",
" }",
" ",
"+# Max log lines to keep",
"+MAX_LOG_LINES = 50",
" ",
"+",
"+def log_step(order_id: int, message: str, step: str | None = None) -> None:",
"+ \"\"\"Append a log line and optionally update current step.\"\"\"",
"+ timestamp = datetime.now().strftime(\"%H:%M:%S\")",
"+ log_line = f\"[{timestamp}] {message}\"",
"+",
"+ try:",
"+ conn = pymysql.connect(**DB_CONFIG)",
"+ with conn.cursor() as cursor:",
"+ # Get current log",
"+ cursor.execute(\"SELECT generation_log FROM content_orders WHERE id = %s\", (order_id,))",
"+ row = cursor.fetchone()",
"+ current_log = row[0] if row and row[0] else \"\"",
"+",
"+ # Append new line, keep last N lines",
"+ lines = current_log.split(\"\\n\") if current_log else []",
"+ lines.append(log_line)",
"+ if len(lines) > MAX_LOG_LINES:",
"+ lines = lines[-MAX_LOG_LINES:]",
"+ new_log = \"\\n\".join(lines)",
"+",
"+ # Update DB",
"+ if step:",
"+ cursor.execute(",
"+ \"UPDATE content_orders SET generation_log = %s, generation_step = %s, updated_at = NOW() WHERE id = %s\",",
"+ (new_log, step, order_id),",
"+ )",
"+ else:",
"+ cursor.execute(",
"+ \"UPDATE content_orders SET generation_log = %s, updated_at = NOW() WHERE id = %s\",",
"+ (new_log, order_id),",
"+ )",
"+ conn.commit()",
"+ except Exception as e:",
"+ print(f\"Log update failed: {e}\", file=sys.stderr)",
"+ finally:",
"+ if \"conn\" in locals():",
"+ conn.close()",
"+",
"+",
" def update_generation_status(order_id: int, status: str, error: str | None = None) -> None:",
" \"\"\"Update generation_status in content_orders table.\"\"\"",
" try:"
]
},
{
"oldStart": 39,
"oldLines": 7,
"newStart": 82,
"newLines": 7,
"lines": [
" with conn.cursor() as cursor:",
" if status == \"generating\":",
" cursor.execute(",
"- \"UPDATE content_orders SET generation_status = %s, generation_started_at = NOW(), updated_at = NOW() WHERE id = %s\",",
"+ \"UPDATE content_orders SET generation_status = %s, generation_started_at = NOW(), generation_log = NULL, updated_at = NOW() WHERE id = %s\",",
" (status, order_id),",
" )",
" elif error:"
]
}
],
"userModified": false,
"replaceAll": false
}
}