<?php

namespace Controller;

use Framework\Controller;
use Infrastructure\AI\AIConfig;
use Infrastructure\AI\ModelConfig;
use Infrastructure\AI\QdrantService;
use Infrastructure\Persistence\ContentRepository;

class ContentController extends Controller
{
    private ContentRepository $repository;
    private QdrantService $qdrantService;
    private string $pipelinePath = '/opt/scripts/pipeline';
    private string $pythonPath;

    public function __construct()
    {
        $this->repository = new ContentRepository();
        $this->pythonPath = $this->pipelinePath . '/venv/bin/python';

        $config = AIConfig::fromCredentialsFile();
        $this->qdrantService = $config->createQdrantService();
    }

    /**
     * GET /content
     * List all content orders
     */
    public function index(): void
    {
        $filters = [];
        if (isset($_GET['status']) && $_GET['status'] !== '') {
            $filters['status'] = $_GET['status'];
        }

        $orders = $this->repository->findAllOrders($filters);
        $stats = $this->repository->getStatistics();

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

    /**
     * GET /content/new
     * Show create form
     */
    public function contentNew(): void
    {
        $collections = $this->qdrantService->listCollections();
        if ($collections === []) {
            $collections = ['documents'];
        }

        $this->view('content.new', [
            'title' => 'Neuer Content-Auftrag',
            'profiles' => $this->repository->findAllProfiles(),
            'contracts' => $this->repository->findAllContracts(),
            'structures' => $this->repository->findAllStructures(),
            'models' => ModelConfig::getAll(),
            'defaultModel' => ModelConfig::DEFAULT_MODEL,
            'collections' => $collections,
        ]);
    }

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

        $title = trim($_POST['title'] ?? '');
        $briefing = trim($_POST['briefing'] ?? '');

        if ($title === '' || $briefing === '') {
            $_SESSION['error'] = 'Titel und Briefing sind erforderlich.';
            header('Location: /content/new');
            exit;
        }

        // Auto-apply first active contract if none selected
        $contractId = $_POST['contract_id'] ?? null;
        if ($contractId === null || $contractId === '') {
            $contracts = $this->repository->findAllContracts();
            if ($contracts !== []) {
                $contractId = $contracts[0]['id'];
            }
        }

        // Process collections (multi-select)
        $collections = $_POST['collections'] ?? ['documents'];
        if (!is_array($collections)) {
            $collections = [$collections];
        }

        $model = ModelConfig::validate($_POST['model'] ?? ModelConfig::DEFAULT_MODEL);
        $contextLimit = (int) ($_POST['context_limit'] ?? 5);

        $orderId = $this->repository->createOrder([
            'title' => $title,
            'briefing' => $briefing,
            'author_profile_id' => $_POST['author_profile_id'] ?? null,
            'contract_id' => $contractId,
            'structure_id' => $_POST['structure_id'] ?? null,
            'model' => $model,
            'collections' => json_encode($collections),
            'context_limit' => $contextLimit,
        ]);

        // If "generate" action: generate content immediately
        if (($_POST['action'] ?? 'save') === 'generate') {
            $collection = $collections[0] ?? 'documents';
            $result = $this->callPython('generate', $orderId, [$model, $collection, $contextLimit]);

            if (isset($result['error'])) {
                $_SESSION['error'] = 'Generierung fehlgeschlagen: ' . $result['error'];
            } else {
                $_SESSION['success'] = 'Content wurde generiert.';
            }
        }

        header('Location: /content/' . $orderId);
        exit;
    }

    /**
     * GET /content/{id}
     * Show order details
     */
    public function show(int $id): void
    {
        $order = $this->repository->findOrder($id);

        if ($order === null) {
            http_response_code(404);
            echo '404 - Auftrag nicht gefunden';

            return;
        }

        $versions = $this->repository->findVersionsByOrder($id);
        $latestVersion = $versions[0] ?? null;
        $critiques = $latestVersion ? $this->repository->findCritiquesByVersion($latestVersion['id']) : [];
        $sources = $this->repository->findSourcesByOrder($id);

        // Get available collections for the dropdown
        $availableCollections = $this->qdrantService->listCollections();
        if ($availableCollections === []) {
            $availableCollections = ['documents'];
        }

        // Check for auto-generate flag
        $autoGenerate = $_SESSION['auto_generate'] ?? false;
        unset($_SESSION['auto_generate']);

        $this->view('content.show', [
            'title' => $order['title'],
            'order' => $order,
            'versions' => $versions,
            'latestVersion' => $latestVersion,
            'critiques' => $critiques,
            'sources' => $sources,
            'models' => ModelConfig::getAll(),
            'availableCollections' => $availableCollections,
            'autoGenerate' => $autoGenerate,
        ]);
    }

    /**
     * GET /content/{id}/edit
     * Show edit form
     */
    public function edit(int $id): void
    {
        $order = $this->repository->findOrder($id);

        if ($order === null) {
            http_response_code(404);
            echo '404 - Auftrag nicht gefunden';

            return;
        }

        $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();

        $model = $_POST['model'] ?? 'claude-opus-4-5-20251101';
        $collection = $_POST['collection'] ?? 'documents';
        $limit = (int) ($_POST['context_limit'] ?? 5);

        $result = $this->callPython('generate', $id, [$model, $collection, $limit]);

        if (isset($result['error'])) {
            echo '<div class="alert error">Fehler: ' . htmlspecialchars($result['error']) . '</div>';

            return;
        }

        // Return updated content section
        $this->renderVersionPartial($result);
    }

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

        // Get latest version
        $version = $this->repository->findLatestVersion($id);

        if ($version === null) {
            echo '<div class="alert error">Keine Version vorhanden.</div>';

            return;
        }

        $model = $_POST['model'] ?? 'claude-opus-4-5-20251101';
        $result = $this->callPython('critique', $version['id'], [$model]);

        if (isset($result['error'])) {
            echo '<div class="alert error">Fehler: ' . htmlspecialchars($result['error']) . '</div>';

            return;
        }

        // Return critique results
        $this->renderCritiquePartial($result);
    }

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

        $version = $this->repository->findLatestVersion($id);

        if ($version === null) {
            echo '<div class="alert error">Keine Version vorhanden.</div>';

            return;
        }

        $model = $_POST['model'] ?? 'claude-opus-4-5-20251101';
        $result = $this->callPython('revise', $version['id'], [$model]);

        if (isset($result['error'])) {
            echo '<div class="alert error">Fehler: ' . htmlspecialchars($result['error']) . '</div>';

            return;
        }

        $this->renderVersionPartial($result);
    }

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

        $this->repository->updateOrderStatus($id, 'approve');
        echo '<div class="alert success">Content genehmigt!</div>';
        echo '<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');
        echo '<div class="alert warning">Content abgelehnt. Zurück zu Entwurf.</div>';
        echo '<script>setTimeout(() => window.location.reload(), 1000);</script>';
    }

    /**
     * Allowed Python commands (whitelist).
     */
    private const ALLOWED_COMMANDS = ['generate', 'critique', 'revise'];

    /**
     * Call Python script
     */
    private function callPython(string $command, int $entityId, array $args = []): array
    {
        // Validate command against whitelist
        if (!in_array($command, self::ALLOWED_COMMANDS, true)) {
            return ['error' => 'Ungültiger Command: ' . $command];
        }

        $scriptPath = $this->pipelinePath . '/web_generate.py';

        // Build command array for proc_open (safer than shell_exec)
        $cmdArray = [
            $this->pythonPath,
            $scriptPath,
            $command,
            (string) $entityId,
            ...$args,
        ];

        $descriptors = [
            0 => ['pipe', 'r'],
            1 => ['pipe', 'w'],
            2 => ['pipe', 'w'],
        ];

        $process = proc_open($cmdArray, $descriptors, $pipes); // nosemgrep: exec-use

        if (!is_resource($process)) {
            return ['error' => 'Script konnte nicht gestartet werden'];
        }

        fclose($pipes[0]);
        $stdout = stream_get_contents($pipes[1]);
        $stderr = stream_get_contents($pipes[2]);
        fclose($pipes[1]);
        fclose($pipes[2]);
        $exitCode = proc_close($process);

        $output = $stdout . $stderr;

        if ($exitCode !== 0 && $output === '') {
            return ['error' => 'Script fehlgeschlagen (Exit: ' . $exitCode . ')'];
        }

        if (preg_match('/\{[\s\S]*\}/', $output, $matches)) {
            $result = json_decode($matches[0], true);
            if (json_last_error() === JSON_ERROR_NONE) {
                return $result;
            }
        }

        return ['error' => 'Ungültige Antwort: ' . substr($output, 0, 500)];
    }

    /**
     * Render version partial
     */
    private function renderVersionPartial(array $result): void
    {
        $content = $result['content'] ?? '';
        $sources = $result['sources'] ?? [];

        echo '<div class="version-content">';
        echo '<div class="version-header">';
        echo '<span class="version-number">Version ' . ($result['version_number'] ?? '?') . '</span>';
        echo '<span class="badge success">Generiert</span>';
        echo '</div>';
        echo '<div class="content-text">' . nl2br(htmlspecialchars($content)) . '</div>';

        if (count($sources) > 0) {
            echo '<div class="sources">';
            echo '<strong>Quellen:</strong><ul>';
            foreach ($sources as $src) {
                $score = round(($src['score'] ?? 0) * 100);
                echo '<li>' . htmlspecialchars($src['source'] ?? '') . ' (' . $score . '%)</li>';
            }
            echo '</ul></div>';
        }

        echo '</div>';
    }

    /**
     * Render critique partial
     */
    private function renderCritiquePartial(array $result): void
    {
        $critiques = $result['critiques'] ?? [];
        $allPassed = $result['all_passed'] ?? false;

        echo '<div class="critique-results">';
        echo '<div class="critique-header">';
        echo '<span>Kritik-Runde ' . ($result['round'] ?? '?') . '</span>';
        echo $allPassed
            ? '<span class="badge success">Bestanden</span>'
            : '<span class="badge warning">Revision nötig</span>';
        echo '</div>';

        foreach ($critiques as $critique) {
            $passed = $critique['passed'] ?? false;
            $icon = $passed ? '✓' : '⚠';
            $class = $passed ? 'passed' : 'failed';

            echo '<div class="critique-item ' . $class . '">';
            echo '<div class="critique-title">' . $icon . ' ' . htmlspecialchars($critique['critic_name'] ?? '') . '</div>';
            echo '<div class="critique-rating">Bewertung: ' . ($critique['rating'] ?? 'N/A') . '/10</div>';

            if (isset($critique['issues']) && $critique['issues'] !== []) {
                echo '<div class="critique-issues"><strong>Probleme:</strong><ul>';
                foreach ($critique['issues'] as $issue) {
                    echo '<li>' . htmlspecialchars($issue) . '</li>';
                }
                echo '</ul></div>';
            }

            if (isset($critique['summary']) && $critique['summary'] !== '') {
                echo '<div class="critique-summary">' . htmlspecialchars($critique['summary']) . '</div>';
            }

            echo '</div>';
        }

        echo '</div>';
    }
}