Backup #974

Dateiinhalt

<?php

declare(strict_types=1);

namespace Controller;

// @responsibility: HTTP-Endpunkte für Content Studio (Aufträge, Generierung, Kritik)

use Application\ContentCollectionService;
use Framework\Controller;
use Infrastructure\AI\ModelConfig;
use Infrastructure\Persistence\ContentRepository;
use UseCases\Command\CreateContentOrderCommand;
use UseCases\Command\GenerateContentCommand;
use UseCases\Content\GenerateContentUseCase;

class ContentController extends Controller
{
    private ContentRepository $repository;
    private ContentCollectionService $collectionService;
    private GenerateContentUseCase $generateUseCase;

    public function __construct(
        ContentRepository $repository,
        ContentCollectionService $collectionService,
        GenerateContentUseCase $generateUseCase
    ) {
        $this->repository = $repository;
        $this->collectionService = $collectionService;
        $this->generateUseCase = $generateUseCase;
    }

    /**
     * GET /content - List all content orders
     */
    public function index(): void
    {
        $status = $this->getString('status');

        $this->view('content.index', [
            'title' => 'Content Studio',
            'orders' => $this->repository->findAllOrders($status !== '' ? ['status' => $status] : []),
            'stats' => $this->repository->getStatistics(),
            'currentStatus' => $status,
        ]);
    }

    /**
     * GET /content/new - Show create form
     */
    public function contentNew(): void
    {
        $lastSettings = $this->repository->getLastOrderSettings();

        $this->view('content.new', [
            'title' => 'Neuer Content-Auftrag',
            'profiles' => $this->repository->findAllProfiles(),
            'contracts' => $this->repository->findAllContracts(),
            'structures' => $this->repository->findAllStructures(),
            'models' => ModelConfig::getAll(),
            'collections' => $this->collectionService->getAvailable(),
            'defaultModel' => $lastSettings['model'],
            'defaultCollections' => $lastSettings['collections'],
            'defaultContextLimit' => $lastSettings['context_limit'],
            'defaultProfileId' => $lastSettings['author_profile_id'],
            'defaultContractId' => $lastSettings['contract_id'],
            'defaultStructureId' => $lastSettings['structure_id'],
        ]);
    }

    /**
     * POST /content - Store new order
     */
    public function store(): void
    {
        $this->requireCsrf();

        $command = CreateContentOrderCommand::fromRequest($_POST);
        $errors = $command->validate();

        if ($errors !== []) {
            $_SESSION['error'] = implode(' ', $errors);
            $this->redirect('/content/new');
        }

        // Validate collections
        $result = $this->collectionService->validateWithCompatibility($command->collections);
        if (!$result['valid']) {
            $_SESSION['error'] = 'Collection-Fehler: ' . $result['error'];
            $this->redirect('/content/new');
        }

        $orderId = $this->repository->createOrder([
            'title' => $command->title,
            'briefing' => $command->briefing,
            'author_profile_id' => $command->authorProfileId,
            'contract_id' => $command->contractId ?? $this->getFirstContractId(),
            'structure_id' => $command->structureId,
            'model' => ModelConfig::validate($command->model),
            'collections' => json_encode($result['collections']),
            'context_limit' => $command->contextLimit,
        ]);

        if ($command->shouldGenerate()) {
            $genResult = $this->generateUseCase->generate(
                $orderId,
                ModelConfig::validate($command->model),
                $result['collections'][0] ?? 'documents',
                $command->contextLimit
            );
            $_SESSION[$genResult->hasError() ? 'error' : 'success'] =
                $genResult->hasError() ? 'Generierung fehlgeschlagen: ' . $genResult->getError() : 'Content wurde generiert.';
        }

        $this->redirect('/content/' . $orderId);
    }

    /**
     * GET /content/{id} - Show order details
     */
    public function show(int $id): void
    {
        $order = $this->repository->findOrder($id);
        if ($order === null) {
            $this->notFound('Auftrag nicht gefunden');
        }

        $versions = $this->repository->findVersionsByOrder($id);
        $latestVersion = $versions[0] ?? null;

        $this->view('content.show', [
            'title' => $order['title'],
            'order' => $order,
            'versions' => $versions,
            'latestVersion' => $latestVersion,
            'critiques' => $latestVersion ? $this->repository->findCritiquesByVersion($latestVersion['id']) : [],
            'sources' => $this->repository->findSourcesByOrder($id),
            'models' => ModelConfig::getAll(),
            'availableCollections' => $this->collectionService->getAvailable(),
        ]);
    }

    /**
     * GET /content/{id}/edit - Show edit form
     */
    public function edit(int $id): void
    {
        $order = $this->repository->findOrder($id);
        if ($order === null) {
            $this->notFound('Auftrag nicht gefunden');
        }

        $this->view('content.edit', [
            'title' => 'Auftrag bearbeiten',
            'order' => $order,
            'profiles' => $this->repository->findAllProfiles(),
            'contracts' => $this->repository->findAllContracts(),
            'structures' => $this->repository->findAllStructures(),
        ]);
    }

    /**
     * POST /content/{id}/generate - Generate content (HTMX)
     */
    public function generate(int $id): void
    {
        $this->requireCsrf();

        $command = GenerateContentCommand::fromRequest($id, $_POST);
        if (($errors = $command->validate()) !== []) {
            $this->htmxError(implode(' ', $errors));

            return;
        }

        $result = $this->collectionService->validateWithCompatibility([$command->collection]);
        if (!$result['valid']) {
            $this->htmxError($result['error'] ?? 'Collection-Fehler');

            return;
        }

        $genResult = $this->generateUseCase->generate($id, $command->model, $result['collections'][0], $command->contextLimit);
        if ($genResult->hasError()) {
            $this->htmxError('Fehler: ' . $genResult->getError());

            return;
        }

        $this->renderVersionPartial($genResult->toArray());
    }

    /**
     * POST /content/{id}/critique - Run critique round (HTMX)
     */
    public function critique(int $id): void
    {
        $this->requireCsrf();

        $version = $this->repository->findLatestVersion($id);
        if ($version === null) {
            $this->htmxError('Keine Version vorhanden.');

            return;
        }

        $result = $this->generateUseCase->critique($version['id'], $_POST['model'] ?? 'claude-opus-4-5-20251101');
        if ($result->hasError()) {
            $this->htmxError('Fehler: ' . $result->getError());

            return;
        }

        $this->renderCritiquePartial($result->toArray());
    }

    /**
     * POST /content/{id}/revise - Create revision (HTMX)
     */
    public function revise(int $id): void
    {
        $this->requireCsrf();

        $version = $this->repository->findLatestVersion($id);
        if ($version === null) {
            $this->htmxError('Keine Version vorhanden.');

            return;
        }

        $result = $this->generateUseCase->revise($version['id'], $_POST['model'] ?? 'claude-opus-4-5-20251101');
        if ($result->hasError()) {
            $this->htmxError('Fehler: ' . $result->getError());

            return;
        }

        $this->renderVersionPartial($result->toArray());
    }

    /**
     * POST /content/{id}/approve - Approve content
     */
    public function approve(int $id): void
    {
        $this->requireCsrf();
        $this->repository->updateOrderStatus($id, 'approve');
        $this->htmxSuccess('Content genehmigt!');
        $this->html('<script>setTimeout(() => window.location.reload(), 1000);</script>');
    }

    /**
     * POST /content/{id}/decline - Decline content
     */
    public function decline(int $id): void
    {
        $this->requireCsrf();
        $this->repository->updateOrderStatus($id, 'draft');
        $this->htmxAlert('warning', 'Content abgelehnt. Zurück zu Entwurf.');
        $this->html('<script>setTimeout(() => window.location.reload(), 1000);</script>');
    }

    private function getFirstContractId(): ?int
    {
        $contracts = $this->repository->findAllContracts();

        return $contracts !== [] ? (int) $contracts[0]['id'] : null;
    }

    private function renderVersionPartial(array $result): void
    {
        $this->view('content.partials.version', [
            'content' => $result['content'] ?? '',
            'sources' => $result['sources'] ?? [],
            'versionNumber' => $result['version_number'] ?? '?',
        ]);
    }

    private function renderCritiquePartial(array $result): void
    {
        $this->view('content.partials.critique', [
            'critiques' => $result['critiques'] ?? [],
            'allPassed' => $result['all_passed'] ?? false,
            'round' => $result['round'] ?? '?',
        ]);
    }
}

Vollständig herunterladen

Aktionen

Andere Versionen dieser Datei

← Zurück zur Übersicht