Protokoll #14291

{
    "event": "PreToolUse",
    "tool_name": "Edit",
    "tool_input": {
        "file_path": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Infrastructure\/Persistence\/TaskResultRepository.php",
        "old_string": "    public function __construct(?\\PDO $pdo = null)\n    {\n        $this->pdo = $pdo ?? DatabaseFactory::dev();\n    }",
        "new_string": "    public function __construct(\\PDO $pdo)\n    {\n        $this->pdo = $pdo;\n    }"
    }
}

{
    "tool_response": {
        "filePath": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Infrastructure\/Persistence\/TaskResultRepository.php",
        "oldString": "    public function __construct(?\\PDO $pdo = null)\n    {\n        $this->pdo = $pdo ?? DatabaseFactory::dev();\n    }",
        "newString": "    public function __construct(\\PDO $pdo)\n    {\n        $this->pdo = $pdo;\n    }",
        "originalFile": "<?php\n\ndeclare(strict_types=1);\n\nnamespace Infrastructure\\Persistence;\n\n\/\/ @responsibility: Persistenz für Task-Ergebnisse (AI-Responses, Token-Usage)\n\nuse Domain\\Entity\\TaskResult;\n\nclass TaskResultRepository\n{\n    private \\PDO $pdo;\n\n    public function __construct(?\\PDO $pdo = null)\n    {\n        $this->pdo = $pdo ?? DatabaseFactory::dev();\n    }\n\n    public function find(int $id): ?TaskResult\n    {\n        $stmt = $this->pdo->prepare('SELECT * FROM task_results WHERE id = :id');\n        $stmt->execute(['id' => $id]);\n        $row = $stmt->fetch();\n\n        return $row !== false ? TaskResult::fromArray($row) : null;\n    }\n\n    public function findByTaskId(int $taskId): array\n    {\n        $stmt = $this->pdo->prepare(\n            'SELECT * FROM task_results WHERE task_id = :task_id ORDER BY created_at DESC'\n        );\n        $stmt->execute(['task_id' => $taskId]);\n\n        $results = [];\n        while ($row = $stmt->fetch()) {\n            $results[] = TaskResult::fromArray($row);\n        }\n\n        return $results;\n    }\n\n    public function findByAssignmentId(int $assignmentId): array\n    {\n        $stmt = $this->pdo->prepare(\n            'SELECT * FROM task_results WHERE assignment_id = :assignment_id ORDER BY created_at DESC'\n        );\n        $stmt->execute(['assignment_id' => $assignmentId]);\n\n        $results = [];\n        while ($row = $stmt->fetch()) {\n            $results[] = TaskResult::fromArray($row);\n        }\n\n        return $results;\n    }\n\n    public function save(TaskResult $result): int\n    {\n        $sql = 'INSERT INTO task_results (\n            task_id, assignment_id, executor, executor_type, model_name,\n            request, response, request_timestamp, response_timestamp,\n            duration_ms, tokens_input, tokens_output, tokens_total,\n            cost_usd, status, error_message, created_at\n        ) VALUES (\n            :task_id, :assignment_id, :executor, :executor_type, :model_name,\n            :request, :response, :request_timestamp, :response_timestamp,\n            :duration_ms, :tokens_input, :tokens_output, :tokens_total,\n            :cost_usd, :status, :error_message, :created_at\n        )';\n\n        $stmt = $this->pdo->prepare($sql);\n        $data = $result->toArray();\n\n        $stmt->execute([\n            'task_id' => $data['task_id'],\n            'assignment_id' => $data['assignment_id'],\n            'executor' => $data['executor'],\n            'executor_type' => $data['executor_type'],\n            'model_name' => $data['model_name'],\n            'request' => $data['request'],\n            'response' => $data['response'],\n            'request_timestamp' => $data['request_timestamp'],\n            'response_timestamp' => $data['response_timestamp'],\n            'duration_ms' => $data['duration_ms'],\n            'tokens_input' => $data['tokens_input'],\n            'tokens_output' => $data['tokens_output'],\n            'tokens_total' => $data['tokens_total'],\n            'cost_usd' => $data['cost_usd'],\n            'status' => $data['status'],\n            'error_message' => $data['error_message'],\n            'created_at' => $data['created_at'],\n        ]);\n\n        return (int) $this->pdo->lastInsertId();\n    }\n\n    public function getTokenStatistics(?int $taskId = null): array\n    {\n        $where = $taskId !== null ? 'WHERE task_id = :task_id' : '';\n        $params = $taskId !== null ? ['task_id' => $taskId] : [];\n\n        $sql = \"SELECT\n            COUNT(*) as total_results,\n            SUM(tokens_input) as total_tokens_input,\n            SUM(tokens_output) as total_tokens_output,\n            SUM(tokens_total) as total_tokens,\n            SUM(cost_usd) as total_cost,\n            AVG(duration_ms) as avg_duration_ms,\n            SUM(CASE WHEN status = 'success' THEN 1 ELSE 0 END) as successful,\n            SUM(CASE WHEN status = 'error' THEN 1 ELSE 0 END) as failed\n        FROM task_results {$where}\";\n\n        $stmt = $this->pdo->prepare($sql);\n        $stmt->execute($params);\n\n        return $stmt->fetch();\n    }\n\n    public function getModelUsage(): array\n    {\n        $sql = 'SELECT\n            model_name,\n            executor_type,\n            COUNT(*) as usage_count,\n            SUM(tokens_total) as total_tokens,\n            SUM(cost_usd) as total_cost,\n            AVG(duration_ms) as avg_duration\n        FROM task_results\n        WHERE model_name IS NOT NULL\n        GROUP BY model_name, executor_type\n        ORDER BY usage_count DESC';\n\n        $stmt = $this->pdo->query($sql);\n\n        return $stmt->fetchAll();\n    }\n}\n",
        "structuredPatch": [
            {
                "oldStart": 12,
                "oldLines": 9,
                "newStart": 12,
                "newLines": 9,
                "lines": [
                    " {",
                    "     private \\PDO $pdo;",
                    " ",
                    "-    public function __construct(?\\PDO $pdo = null)",
                    "+    public function __construct(\\PDO $pdo)",
                    "     {",
                    "-        $this->pdo = $pdo ?? DatabaseFactory::dev();",
                    "+        $this->pdo = $pdo;",
                    "     }",
                    " ",
                    "     public function find(int $id): ?TaskResult"
                ]
            }
        ],
        "userModified": false,
        "replaceAll": false
    }
}