Protokoll #15910

{
    "event": "PreToolUse",
    "tool_name": "Edit",
    "tool_input": {
        "file_path": "\/var\/www\/dev.campus.systemische-tools.de\/src\/UseCases\/Task\/SaveTaskResultUseCase.php",
        "old_string": "    public function execute(int $taskId, array $data): TaskResult\n    {\n        $this->validate($data);\n\n        $task = $this->taskRepository->find($taskId);\n        if ($task === null) {\n            throw new \\InvalidArgumentException(\"Task {$taskId} not found\");\n        }\n\n        $executorType = AssigneeType::from($data['executor_type']);\n\n        $result = new TaskResult();\n        $result->setTaskId($taskId);\n        $result->setExecutor($data['executor']);\n        $result->setExecutorType($executorType);\n\n        if (isset($data['assignment_id'])) {\n            $result->setAssignmentId((int) $data['assignment_id']);\n        }\n\n        if (isset($data['model_name'])) {\n            $result->setModelName($data['model_name']);\n        }\n\n        if (isset($data['request'])) {\n            $result->setRequest($data['request']);\n        }\n\n        if (isset($data['response'])) {\n            $result->setResponse($data['response']);\n        }\n\n        if (isset($data['tokens_input'])) {\n            $result->setTokensInput((int) $data['tokens_input']);\n        }\n\n        if (isset($data['tokens_output'])) {\n            $result->setTokensOutput((int) $data['tokens_output']);\n        }\n\n        if (isset($data['duration_ms'])) {\n            $result->setDurationMs((int) $data['duration_ms']);\n        }\n\n        if (isset($data['cost_usd'])) {\n            $result->setCostUsd((float) $data['cost_usd']);\n        }\n\n        if (isset($data['error_message'])) {\n            $result->setErrorMessage($data['error_message']);\n        }\n\n        if (isset($data['status'])) {\n            $result->setStatus($data['status']);\n        }\n\n        if (!isset($data['tokens_input']) || !isset($data['tokens_output'])) {\n            $result->estimateTokens();\n        }\n\n        $id = $this->resultRepository->save($result);\n        $result->setId($id);\n\n        $status = $result->getStatus() === 'success' ? 'erfolgreich' : 'mit Fehler';\n        $comment = new TaskComment();\n        $comment->setTaskId($taskId);\n        $comment->setAuthor($result->getExecutor());\n        $comment->setAuthorType($executorType->isAI() ? 'ai' : 'human');\n        $comment->setCommentType('result');\n        $comment->setContent(\"Ergebnis gespeichert ({$status})\");\n        $comment->setMetadata([\n            'result_id' => $id,\n            'model' => $result->getModelName(),\n            'tokens_total' => $result->getTokensTotal(),\n        ]);\n        $this->commentRepository->save($comment);\n\n        return $result;\n    }",
        "new_string": "    public function execute(int $taskId, array $data): TaskResult\n    {\n        $this->validate($data);\n\n        $task = $this->taskRepository->find($taskId);\n        if ($task === null) {\n            throw new \\InvalidArgumentException(\"Task {$taskId} not found\");\n        }\n\n        $executorType = AssigneeType::from($data['executor_type']);\n        $builder = TaskResult::builder($taskId, $data['executor'], $executorType);\n\n        if (isset($data['assignment_id'])) {\n            $builder->withAssignment((int) $data['assignment_id']);\n        }\n\n        if (isset($data['model_name'])) {\n            $builder->withModel($data['model_name']);\n        }\n\n        if (isset($data['request'])) {\n            $builder->withRequest($data['request']);\n        }\n\n        if (isset($data['response'])) {\n            $builder->withResponse($data['response']);\n        }\n\n        if (isset($data['tokens_input'], $data['tokens_output'])) {\n            $builder->withTokens((int) $data['tokens_input'], (int) $data['tokens_output']);\n        } else {\n            $builder->estimateTokens();\n        }\n\n        if (isset($data['cost_usd'])) {\n            $builder->withCost((float) $data['cost_usd']);\n        }\n\n        if (isset($data['error_message'])) {\n            $builder->withError($data['error_message']);\n        } elseif (isset($data['status'])) {\n            $builder->withStatus(\\Domain\\ValueObject\\ResultStatus::from($data['status']));\n        }\n\n        $result = $builder->build();\n\n        $id = $this->resultRepository->save($result);\n        $result->setId($id);\n\n        $status = $result->isSuccess() ? 'erfolgreich' : 'mit Fehler';\n        $comment = new TaskComment();\n        $comment->setTaskId($taskId);\n        $comment->setAuthor($result->getExecutor());\n        $comment->setAuthorType($executorType->isAI() ? 'ai' : 'human');\n        $comment->setCommentType('result');\n        $comment->setContent(\"Ergebnis gespeichert ({$status})\");\n        $comment->setMetadata([\n            'result_id' => $id,\n            'model' => $result->getModelName(),\n            'tokens_total' => $result->getTokensTotal(),\n        ]);\n        $this->commentRepository->save($comment);\n\n        return $result;\n    }"
    }
}

{
    "tool_response": {
        "filePath": "\/var\/www\/mcp-servers\/mcp-docs\/tools\/docs_tools\/docs_writer.py",
        "oldString": "            new_id = repo.create(doc)\n            created_doc = repo.find_by_id(new_id)\n\n            logger.log(LogEntry(\n                tool_name=\"docs_create\",\n                request=json.dumps({\n                    \"title\": title,\n                    \"slug\": slug,\n                    \"parent_id\": parent_id\n                }),\n                status=\"success\",\n                duration_ms=int((time.time() - start_time) * MS_PER_SECOND)\n            ))\n\n            return {\n                \"success\": True,\n                \"doc\": created_doc.to_dict() if created_doc else None,\n                \"message\": f\"Document '{title}' created with ID {new_id}\"\n            }\n\n        except Exception as e:\n            logger.log(LogEntry(\n                tool_name=\"docs_create\",\n                request=json.dumps({\"title\": title, \"slug\": slug}),\n                status=\"error\",\n                error_message=str(e),\n                duration_ms=int((time.time() - start_time) * MS_PER_SECOND)\n            ))\n            return {\"success\": False, \"error\": str(e)}",
        "newString": "            new_id = repo.create(doc)\n            created_doc = repo.find_by_id(new_id)\n\n            _log_operation(\n                logger, \"docs_create\",\n                {\"title\": title, \"slug\": slug, \"parent_id\": parent_id},\n                start_time\n            )\n            return {\n                \"success\": True,\n                \"doc\": created_doc.to_dict() if created_doc else None,\n                \"message\": f\"Document '{title}' created with ID {new_id}\"\n            }\n\n        except Exception as e:\n            _log_operation(\n                logger, \"docs_create\", {\"title\": title, \"slug\": slug},\n                start_time, \"error\", str(e)\n            )\n            return {\"success\": False, \"error\": str(e)}",
        "originalFile": "\"\"\"Write operations for documentation management.\"\"\"\n\nimport json\nimport sys\nimport time\nfrom typing import Optional\n\nsys.path.insert(0, \"\/opt\/mcp-servers\/mcp-docs\")\nfrom domain.dokumentation import Dokumentation, DocStatus, LogEntry\nfrom infrastructure.docs_repository import get_repository\nfrom infrastructure.protokoll_logger import get_logger\n\nfrom .constants import (\n    DEFAULT_SORT_ORDER,\n    MS_PER_SECOND,\n    ROOT_DEPTH,\n    ROOT_PATH_PREFIX,\n    STATUS_DRAFT,\n    VALID_STATUSES,\n)\n\n\ndef _log_operation(\n    logger,\n    tool_name: str,\n    request_data: dict,\n    start_time: float,\n    status: str = \"success\",\n    error: Optional[str] = None\n) -> None:\n    \"\"\"Log an operation with timing information.\"\"\"\n    logger.log(LogEntry(\n        tool_name=tool_name,\n        request=json.dumps(request_data),\n        status=status,\n        error_message=error,\n        duration_ms=int((time.time() - start_time) * MS_PER_SECOND)\n    ))\n\n\ndef register_writer_tools(mcp) -> None:\n    \"\"\"Register write documentation tools with the MCP server.\"\"\"\n\n    @mcp.tool()\n    def docs_create(\n        title: str,\n        slug: str,\n        content: str = \"\",\n        description: Optional[str] = None,\n        parent_id: Optional[int] = None,\n        status: str = STATUS_DRAFT,\n        sort_order: int = DEFAULT_SORT_ORDER\n    ) -> dict:\n        \"\"\"Create a new document.\"\"\"\n        start_time = time.time()\n        logger = get_logger()\n        repo = get_repository()\n\n        try:\n            # Calculate path\n            if parent_id is not None:\n                parent = repo.find_by_id(parent_id)\n                if not parent:\n                    return {\n                        \"success\": False,\n                        \"error\": f\"Parent with ID {parent_id} not found\"\n                    }\n                path = f\"{parent.path}\/{slug}\"\n                depth = parent.depth + 1\n            else:\n                path = f\"{ROOT_PATH_PREFIX}{slug}\"\n                depth = ROOT_DEPTH\n\n            # Check if path already exists\n            existing = repo.find_by_path(path)\n            if existing:\n                return {\n                    \"success\": False,\n                    \"error\": f\"Path '{path}' already exists\"\n                }\n\n            doc = Dokumentation(\n                parent_id=parent_id,\n                slug=slug,\n                path=path,\n                title=title,\n                description=description,\n                content=content,\n                status=DocStatus(status) if status in VALID_STATUSES else DocStatus.DRAFT,\n                sort_order=sort_order,\n                depth=depth\n            )\n\n            new_id = repo.create(doc)\n            created_doc = repo.find_by_id(new_id)\n\n            logger.log(LogEntry(\n                tool_name=\"docs_create\",\n                request=json.dumps({\n                    \"title\": title,\n                    \"slug\": slug,\n                    \"parent_id\": parent_id\n                }),\n                status=\"success\",\n                duration_ms=int((time.time() - start_time) * MS_PER_SECOND)\n            ))\n\n            return {\n                \"success\": True,\n                \"doc\": created_doc.to_dict() if created_doc else None,\n                \"message\": f\"Document '{title}' created with ID {new_id}\"\n            }\n\n        except Exception as e:\n            logger.log(LogEntry(\n                tool_name=\"docs_create\",\n                request=json.dumps({\"title\": title, \"slug\": slug}),\n                status=\"error\",\n                error_message=str(e),\n                duration_ms=int((time.time() - start_time) * MS_PER_SECOND)\n            ))\n            return {\"success\": False, \"error\": str(e)}\n\n    @mcp.tool()\n    def docs_update(\n        id: int,\n        title: Optional[str] = None,\n        content: Optional[str] = None,\n        description: Optional[str] = None,\n        status: Optional[str] = None\n    ) -> dict:\n        \"\"\"\n        Update a document.\n\n        Args:\n            id: Document ID (required)\n            title: New title\n            content: New content\n            description: New description\n            status: New status (draft, published, archived)\n\n        Returns:\n            Dict containing updated document\n        \"\"\"\n        start_time = time.time()\n        logger = get_logger()\n        repo = get_repository()\n\n        try:\n            doc = repo.find_by_id(id)\n            if not doc:\n                return {\n                    \"success\": False,\n                    \"error\": f\"Document with ID {id} not found\"\n                }\n\n            updates = {}\n            if title is not None:\n                updates[\"title\"] = title\n            if content is not None:\n                updates[\"content\"] = content\n            if description is not None:\n                updates[\"description\"] = description\n            if status is not None and status in VALID_STATUSES:\n                updates[\"status\"] = status\n\n            if not updates:\n                return {\n                    \"success\": False,\n                    \"error\": \"No changes specified\"\n                }\n\n            success = repo.update(id, updates)\n            if success:\n                updated_doc = repo.find_by_id(id)\n\n                logger.log(LogEntry(\n                    tool_name=\"docs_update\",\n                    request=json.dumps({\n                        \"id\": id,\n                        \"updates\": list(updates.keys())\n                    }),\n                    status=\"success\",\n                    duration_ms=int((time.time() - start_time) * MS_PER_SECOND)\n                ))\n\n                return {\n                    \"success\": True,\n                    \"doc\": updated_doc.to_dict() if updated_doc else None,\n                    \"message\": f\"Document #{id} updated\"\n                }\n            else:\n                return {\"success\": False, \"error\": \"Update failed\"}\n\n        except Exception as e:\n            logger.log(LogEntry(\n                tool_name=\"docs_update\",\n                request=json.dumps({\"id\": id}),\n                status=\"error\",\n                error_message=str(e),\n                duration_ms=int((time.time() - start_time) * MS_PER_SECOND)\n            ))\n            return {\"success\": False, \"error\": str(e)}\n\n    @mcp.tool()\n    def docs_delete(id: int) -> dict:\n        \"\"\"\n        Delete a document.\n\n        Args:\n            id: Document ID (required)\n\n        Returns:\n            Dict containing confirmation\n        \"\"\"\n        start_time = time.time()\n        logger = get_logger()\n        repo = get_repository()\n\n        try:\n            doc = repo.find_by_id(id)\n            if not doc:\n                return {\n                    \"success\": False,\n                    \"error\": f\"Document with ID {id} not found\"\n                }\n\n            success = repo.delete(id)\n\n            logger.log(LogEntry(\n                tool_name=\"docs_delete\",\n                request=json.dumps({\"id\": id, \"title\": doc.title}),\n                status=\"success\" if success else \"error\",\n                duration_ms=int((time.time() - start_time) * MS_PER_SECOND)\n            ))\n\n            return {\n                \"success\": success,\n                \"message\": (\n                    f\"Document '{doc.title}' (ID {id}) deleted\"\n                    if success\n                    else \"Deletion failed\"\n                )\n            }\n\n        except ValueError as e:\n            # Children exist\n            logger.log(LogEntry(\n                tool_name=\"docs_delete\",\n                request=json.dumps({\"id\": id}),\n                status=\"denied\",\n                error_message=str(e),\n                duration_ms=int((time.time() - start_time) * MS_PER_SECOND)\n            ))\n            return {\"success\": False, \"error\": str(e)}\n\n        except Exception as e:\n            logger.log(LogEntry(\n                tool_name=\"docs_delete\",\n                request=json.dumps({\"id\": id}),\n                status=\"error\",\n                error_message=str(e),\n                duration_ms=int((time.time() - start_time) * MS_PER_SECOND)\n            ))\n            return {\"success\": False, \"error\": str(e)}\n",
        "structuredPatch": [
            {
                "oldStart": 94,
                "oldLines": 17,
                "newStart": 94,
                "newLines": 11,
                "lines": [
                    "             new_id = repo.create(doc)",
                    "             created_doc = repo.find_by_id(new_id)",
                    " ",
                    "-            logger.log(LogEntry(",
                    "-                tool_name=\"docs_create\",",
                    "-                request=json.dumps({",
                    "-                    \"title\": title,",
                    "-                    \"slug\": slug,",
                    "-                    \"parent_id\": parent_id",
                    "-                }),",
                    "-                status=\"success\",",
                    "-                duration_ms=int((time.time() - start_time) * MS_PER_SECOND)",
                    "-            ))",
                    "-",
                    "+            _log_operation(",
                    "+                logger, \"docs_create\",",
                    "+                {\"title\": title, \"slug\": slug, \"parent_id\": parent_id},",
                    "+                start_time",
                    "+            )",
                    "             return {",
                    "                 \"success\": True,",
                    "                 \"doc\": created_doc.to_dict() if created_doc else None,"
                ]
            },
            {
                "oldStart": 112,
                "oldLines": 13,
                "newStart": 106,
                "newLines": 10,
                "lines": [
                    "             }",
                    " ",
                    "         except Exception as e:",
                    "-            logger.log(LogEntry(",
                    "-                tool_name=\"docs_create\",",
                    "-                request=json.dumps({\"title\": title, \"slug\": slug}),",
                    "-                status=\"error\",",
                    "-                error_message=str(e),",
                    "-                duration_ms=int((time.time() - start_time) * MS_PER_SECOND)",
                    "-            ))",
                    "+            _log_operation(",
                    "+                logger, \"docs_create\", {\"title\": title, \"slug\": slug},",
                    "+                start_time, \"error\", str(e)",
                    "+            )",
                    "             return {\"success\": False, \"error\": str(e)}",
                    " ",
                    "     @mcp.tool()"
                ]
            }
        ],
        "userModified": false,
        "replaceAll": false
    }
}