<?php
/**
 * Hvatar SDK para PHP — un solo archivo, sin Composer. PHP 8.1+ con sodium y openssl.
 *
 *   require 'hvatar.php';
 *   $hv = new Hvatar([
 *       'url' => 'https://hvatar.com',
 *       'client_id' => 'app_xxx',
 *       'client_secret' => 'sk_xxx',          // nunca en el navegador
 *       'cache_dir' => __DIR__ . '/cache',    // opcional, para la llave pública
 *   ]);
 *
 *   $sub = $hv->user();                       // identificador del usuario en tu app o null
 *   $hv->notifyEmail($sub, 'Asunto', 'Texto');
 *   $box = $hv->encrypt('contenido');         // cifra con la llave del usuario
 *
 * Reglas del contrato: guarda solo $sub; cifra el contenido del usuario; atiende el webhook de baja.
 */
declare(strict_types=1);

final class HvatarException extends Exception {}

final class Hvatar {
    public const VERSION = '0.5.0';
    private const SESSION_KEY = '_hvatar';

    private string $url;
    private string $clientId;
    private string $secret;
    private string $cacheDir;
    private ?string $contentKey = null;

    public function __construct(array $cfg) {
        $this->url = rtrim((string) ($cfg['url'] ?? 'https://hvatar.com'), '/');
        $this->clientId = (string) ($cfg['client_id'] ?? '');
        $this->secret = (string) ($cfg['client_secret'] ?? '');
        $dir = rtrim((string) ($cfg['cache_dir'] ?? ''), '/');
        if ($dir === '' || !is_dir($dir) || !is_writable($dir)) {
            // Hosting compartido: el temporal del sistema puede no ser escribible (open_basedir)
            foreach ([sys_get_temp_dir(), (string) ini_get('upload_tmp_dir'), __DIR__] as $d) {
                if ($d !== '' && @is_dir($d) && @is_writable($d)) { $dir = rtrim($d, '/'); break; }
            }
        }
        $this->cacheDir = $dir;
        if ($this->clientId === '' || $this->secret === '') throw new HvatarException('Falta client_id o client_secret');
        if (!function_exists('sodium_crypto_sign_verify_detached')) throw new HvatarException('Se requiere la extensión sodium');
    }

    /* ======================= Login ======================= */

    /**
     * Atiende el endpoint de callback que usa c.js:
     *   GET  ?inicio=1        → {url, state}  (URL del popup con PKCE)
     *   POST {code, state}    → {ok, sub}     (intercambia el código y abre sesión)
     *
     * $alEntrar(string $sub) corre justo después de entrar, antes de responder. Sirve para migrar
     * una app existente: si ya había un usuario con sesión propia, vincúlalo a $sub y borra sus datos personales.
     * Si devuelve un string, se usa como redirección.
     */
    public function handleCallback(?string $redirect = null, ?callable $alEntrar = null): never {
        $this->startSession();
        $metodo = $_SERVER['REQUEST_METHOD'] ?? 'GET';
        $porGet = $metodo === 'GET' && isset($_GET['code'], $_GET['state']);   // la ventana regresó sin poder avisar a la página
        try {
            if ($metodo === 'GET' && isset($_GET['prueba'])) $this->json($this->diagnostico());
            if ($metodo === 'GET' && isset($_GET['estado'])) $this->json(['sesion' => $this->user() !== null, 'redirect' => $redirect]);
            if ($metodo === 'GET' && !$porGet) {
                $verifier = self::b64u(random_bytes(32));
                $state = self::b64u(random_bytes(16));
                $_SESSION[self::SESSION_KEY . '_pkce'] = ['v' => $verifier, 's' => $state, 't' => time()];
                $this->json(['url' => $this->url . '/authorize?' . http_build_query([
                    'client_id' => $this->clientId,
                    'code_challenge' => self::b64u(hash('sha256', $verifier, true)),
                    'code_challenge_method' => 'S256',
                    'state' => $state,
                    'redirect_uri' => $this->urlCallback(),
                ]), 'state' => $state]);
            }
            $in = $porGet ? $_GET : (json_decode(file_get_contents('php://input') ?: '', true) ?: $_POST);
            $pkce = $_SESSION[self::SESSION_KEY . '_pkce'] ?? null;
            if (!$pkce) throw new HvatarException('state_invalido: la sesión de PHP no se conservó entre el inicio y el regreso (revisa session_name o que la cookie de sesión se envíe en esta ruta)');
            if (time() - $pkce['t'] > 600) throw new HvatarException('state_vencido: pasaron más de 10 minutos');
            if (!hash_equals($pkce['s'], (string) ($in['state'] ?? ''))) throw new HvatarException('state_invalido: el state no coincide');
            unset($_SESSION[self::SESSION_KEY . '_pkce']);
            $tok = $this->call('/token', [
                'grant_type' => 'authorization_code',
                'code' => (string) ($in['code'] ?? ''),
                'code_verifier' => $pkce['v'],
            ]);
            $this->storeTokens($tok);
            if ($alEntrar) {
                $r = $alEntrar((string) $tok['sub']);
                if (is_string($r) && $r !== '') $redirect = $r;
            }
            session_regenerate_id(true);
            if ($porGet) $this->paginaFinal(true, $redirect);
            $this->json(['ok' => true, 'sub' => $tok['sub'], 'redirect' => $redirect]);
        } catch (Throwable $e) {
            error_log('[hvatar] callback: ' . $e->getMessage());
            if ($porGet) $this->paginaFinal(false, $redirect, $e->getMessage());
            $this->json(['error' => $e->getMessage()], 400);
        }
    }

    /** Dirección absoluta de este callback (sin parámetros), para el regreso directo. */
    private function urlCallback(): string {
        $https = ($_SERVER['HTTPS'] ?? '') === 'on' || ($_SERVER['HTTP_X_FORWARDED_PROTO'] ?? '') === 'https' || ($_SERVER['SERVER_PORT'] ?? '') === '443';
        $host = (string) ($_SERVER['HTTP_HOST'] ?? 'localhost');
        $ruta = strtok((string) ($_SERVER['REQUEST_URI'] ?? '/'), '?');
        return ($https ? 'https' : 'http') . '://' . $host . $ruta;
    }

    /** Página que ve la ventana cuando regresa directo al callback (sin poder avisar a la página que la abrió). */
    private function paginaFinal(bool $ok, ?string $redirect, string $error = ''): never {
        http_response_code($ok ? 200 : 400);
        header('Content-Type: text/html; charset=utf-8');
        header('Cache-Control: no-store');
        $dest = json_encode($redirect ?: '/', JSON_HEX_TAG | JSON_HEX_AMP | JSON_HEX_APOS | JSON_HEX_QUOT);
        $msg = $ok ? 'Listo, ya entraste. Puedes cerrar esta ventana.' : 'No se pudo entrar: ' . htmlspecialchars($error);
        echo '<!doctype html><meta charset="utf-8"><meta name="viewport" content="width=device-width,initial-scale=1"><title>Hvatar</title>'
            . '<body style="font:16px system-ui,sans-serif;display:grid;place-items:center;min-height:90vh;color:#141a33;text-align:center;padding:20px">'
            . '<p>' . $msg . '</p><script>'
            . ($ok ? "try{if(window.opener&&!window.opener.closed){window.opener.location.reload();window.close();}else if(window.name==='hvatar-login'){window.close();setTimeout(function(){location.href=$dest},400);}else{location.href=$dest;}}catch(e){location.href=$dest;}" : '')
            . '</script></body>';
        exit;
    }

    /** Revisión de la instalación: ábrela en el navegador como hvatar-callback.php?prueba=1 */
    private function diagnostico(): array {
        $r = ['sdk' => self::VERSION, 'php' => PHP_VERSION];
        $r['sodium'] = function_exists('sodium_crypto_sign_verify_detached');
        $r['openssl'] = function_exists('openssl_encrypt');
        $r['conexion'] = function_exists('curl_init') ? 'curl' : (ini_get('allow_url_fopen') ? 'allow_url_fopen' : 'ninguna');
        $r['cache_dir_escribible'] = $this->cacheDir !== '' && is_writable($this->cacheDir);
        $r['sesion_php'] = session_status() === PHP_SESSION_ACTIVE ? session_name() : 'sin sesión';
        try { $this->http('GET', $this->url . '/.well-known/keys.json'); $r['alcanza_hvatar'] = true; }
        catch (Throwable $e) { $r['alcanza_hvatar'] = $e->getMessage(); }
        try { $this->call('/token', ['grant_type' => 'prueba']); $r['credenciales'] = '?'; }
        catch (Throwable $e) {
            $m = $e->getMessage();
            $r['credenciales'] = $m === 'grant_no_soportado' ? true : $m;   // grant_no_soportado = la app se autenticó bien
        }
        $r['todo_bien'] = $r['sodium'] && $r['openssl'] && $r['conexion'] !== 'ninguna' && $r['alcanza_hvatar'] === true && $r['credenciales'] === true;
        return $r;
    }

    /** Identificador del usuario con sesión, o null. Renueva el pase si venció. */
    public function user(): ?string {
        $s = $this->session();
        if (!$s) return null;
        if (isset($this->revoked()[$s['sub']])) {   // baja recibida por webhook: cortar ya, sin esperar a que venza el pase
            $this->logout();
            return null;
        }
        return $this->pase() !== null ? $s['sub'] : null;
    }

    /** Datos del pase vigente (sub, plan, vence, caps), o null. */
    public function claims(): ?array {
        $pase = $this->pase();
        return $pase ? $this->verifyPass($pase) : null;
    }

    /** Pase vigente; lo renueva con el refresh si faltan menos de 60 s. */
    public function pase(): ?string {
        $s = $this->session();
        if (!$s) return null;
        if ($s['exp'] - 60 > time()) return $s['pase'];
        try {
            $this->storeTokens($this->call('/token', ['grant_type' => 'refresh_token', 'refresh' => $s['refresh']]));
            return $this->session()['pase'];
        } catch (HvatarException) {
            $this->logout();   // baja o revocación: la sesión local termina
            return null;
        }
    }

    /**
     * Avatar y nombre a mostrar del usuario, para el compañero animado de c.js.
     * Se guarda en la sesión hasta que se renueve el pase. Devuelve null sin sesión.
     */
    public function companero(): ?array {
        $pase = $this->pase();
        if (!$pase) return null;
        $s = $_SESSION[self::SESSION_KEY];
        if (($s['comp_pase'] ?? '') !== $pase) {
            try {
                $c = $this->call('/v1/companero', ['pase' => $pase]);
            } catch (HvatarException) {
                return null;
            }
            $_SESSION[self::SESSION_KEY]['comp'] = ['avatar' => $c['avatar'] ?? null, 'nombre' => $c['nombre'] ?? null, 'imagen' => $c['imagen'] ?? null, 'cuadros' => $c['cuadros'] ?? null];
            $_SESSION[self::SESSION_KEY]['comp_pase'] = $pase;
        }
        return $_SESSION[self::SESSION_KEY]['comp'];
    }

    /** Atributo listo para <script src=".../c.js" data-companero="..."> (vacío sin sesión). */
    public function companeroAttr(): string {
        $c = $this->companero();
        return $c ? htmlspecialchars(json_encode($c, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES), ENT_QUOTES, 'UTF-8') : '';
    }

    public function logout(): void {
        $this->startSession();
        unset($_SESSION[self::SESSION_KEY]);
        $this->contentKey = null;
    }

    /** Verifica un pase con la llave pública de Hvatar. Nunca aceptes un pase sin pasar por aquí. */
    public function verifyPass(string $pase): array {
        $parts = explode('.', $pase);
        if (count($parts) !== 3) throw new HvatarException('pase_invalido');
        [$h, $b, $sig] = $parts;
        $hdr = json_decode(self::b64d($h), true);
        if (($hdr['alg'] ?? '') !== 'EdDSA' || ($hdr['typ'] ?? '') !== 'hvatar-pase') throw new HvatarException('pase_invalido');
        $key = $this->publicKey((string) ($hdr['kid'] ?? ''));
        if (!sodium_crypto_sign_verify_detached(self::b64d($sig), "$h.$b", $key)) throw new HvatarException('pase_firma');
        $p = json_decode(self::b64d($b), true);
        if (!is_array($p)) throw new HvatarException('pase_invalido');
        if (($p['iss'] ?? '') !== $this->url) throw new HvatarException('pase_emisor');
        if (($p['aud'] ?? '') !== $this->clientId) throw new HvatarException('pase_audiencia');
        if (($p['exp'] ?? 0) < time()) throw new HvatarException('pase_vencido');
        return $p;
    }

    /* ===================== Capacidades ===================== */

    /** Envía un correo al usuario sin conocer su correo. */
    public function notifyEmail(string $sub, string $asunto, string $texto): array {
        return $this->call('/v1/notify/email', ['sub' => $sub, 'asunto' => $asunto, 'texto' => $texto]);
    }

    /** Hace una pregunta: 'edad.mayor_18' → ['respuesta' => true|false|null, ...]. */
    /** SMS o WhatsApp al usuario, sin conocer su teléfono. Requiere la capacidad notify.sms. */
    public function notifySms(string $sub, string $texto, string $canal = 'sms'): array {
        return $this->call('/v1/notify/sms', ['sub' => $sub, 'texto' => $texto, 'canal' => $canal]);
    }

    /** Correo alias de este usuario para tu app (reenvía a su correo real). Requiere correo.alias. */
    public function alias(string $sub): string {
        return (string) ($this->call('/v1/correo/alias', ['sub' => $sub])['alias'] ?? '');
    }

    /** URL de la imagen del avatar del usuario (SVG), para <img src>. Null sin sesión. */
    public function avatarUrl(): ?string {
        return $this->companero()['imagen'] ?? null;
    }

    public function verify(string $sub, string $pregunta): array {
        return $this->call('/v1/verify', ['sub' => $sub, 'pregunta' => $pregunta]);
    }

    /* ===================== Cifrado del contenido ===================== */

    /** Cifra contenido del usuario con su llave. Guarda solo el resultado. */
    public function encrypt(string $plain): string {
        $sub = $this->user() ?? throw new HvatarException('sin_sesion');
        $nonce = random_bytes(12);
        $tag = '';
        $ct = openssl_encrypt($plain, 'aes-256-gcm', $this->contentKey(), OPENSSL_RAW_DATA, $nonce, $tag, $sub, 16);
        return 'hv1.' . self::b64u($nonce . $tag . $ct);
    }

    /** Descifra contenido del usuario con sesión. Tras su baja, nadie puede hacerlo. */
    public function decrypt(string $box): string {
        $sub = $this->user() ?? throw new HvatarException('sin_sesion');
        if (!str_starts_with($box, 'hv1.')) throw new HvatarException('formato');
        $raw = self::b64d(substr($box, 4));
        $plain = openssl_decrypt(substr($raw, 28), 'aes-256-gcm', $this->contentKey(), OPENSSL_RAW_DATA, substr($raw, 0, 12), substr($raw, 12, 16), $sub);
        if ($plain === false) throw new HvatarException('descifrado');
        return $plain;
    }

    private function contentKey(): string {
        if ($this->contentKey !== null) return $this->contentKey;
        $pase = $this->pase() ?? throw new HvatarException('sin_sesion');
        $r = $this->call('/v1/keys/content', ['pase' => $pase]);
        return $this->contentKey = self::b64d((string) $r['llave']);   // solo en memoria, nunca en disco
    }

    /* ======================= Webhooks ======================= */

    /**
     * Atiende el webhook de Hvatar. $handlers = ['usuario.baja' => fn(string $sub, array $evento) => ...].
     * Verifica firma y frescura, ejecuta el manejador y responde con el acuse firmado.
     */
    public function handleWebhook(array $handlers): never {
        try {
            $body = file_get_contents('php://input') ?: '';
            $ts = (string) ($_SERVER['HTTP_X_HVATAR_TIMESTAMP'] ?? '');
            $sig = (string) ($_SERVER['HTTP_X_HVATAR_SIGNATURE'] ?? '');
            $kid = (string) ($_SERVER['HTTP_X_HVATAR_KID'] ?? '');
            if (!ctype_digit($ts) || abs(time() - (int) $ts) > 300) throw new HvatarException('webhook_hora');
            if (!sodium_crypto_sign_verify_detached(self::b64d($sig), "$ts.$body", $this->publicKey($kid))) {
                throw new HvatarException('webhook_firma');
            }
            $ev = json_decode($body, true);
            if (!is_array($ev) || !isset($ev['evento'], $ev['event_id'])) throw new HvatarException('webhook_cuerpo');
            if ($ev['evento'] === 'usuario.baja' && !empty($ev['sub'])) $this->markRevoked((string) $ev['sub']);
            if (isset($handlers[$ev['evento']])) ($handlers[$ev['evento']])((string) ($ev['sub'] ?? ''), $ev);
            $this->json(['acuse' => self::b64u(hash_hmac('sha256', (string) $ev['event_id'], hash('sha256', $this->secret), true))]);
        } catch (HvatarException $e) {
            $this->json(['error' => $e->getMessage()], 400);
        }
    }

    /* ======================= Interno ======================= */

    private function startSession(): void {
        if (session_status() !== PHP_SESSION_ACTIVE) {
            session_start(['cookie_httponly' => true, 'cookie_samesite' => 'Lax', 'use_strict_mode' => true]);
        }
    }

    private function session(): ?array {
        $this->startSession();
        $s = $_SESSION[self::SESSION_KEY] ?? null;
        return is_array($s) ? $s : null;
    }

    private function revokedFile(): string {
        return $this->cacheDir . '/hvatar-bajas-' . md5($this->url . $this->clientId) . '.json';
    }

    /** Identificadores dados de baja en las últimas 24 h (lo que dura como máximo una sesión con refresh). */
    private function revoked(): array {
        $file = $this->revokedFile();
        if (!is_file($file)) return [];
        $list = json_decode((string) file_get_contents($file), true);
        return is_array($list) ? $list : [];
    }

    private function markRevoked(string $sub): void {
        $fh = fopen($this->revokedFile(), 'c+');
        if (!$fh) return;
        flock($fh, LOCK_EX);
        $list = json_decode((string) stream_get_contents($fh), true) ?: [];
        $list[$sub] = time();
        $list = array_filter($list, fn($t) => $t > time() - 86400);
        ftruncate($fh, 0);
        rewind($fh);
        fwrite($fh, json_encode($list));
        flock($fh, LOCK_UN);
        fclose($fh);
    }

    private function storeTokens(array $tok): void {
        $p = $this->verifyPass((string) ($tok['pase'] ?? ''));
        $_SESSION[self::SESSION_KEY] = [
            'sub' => $p['sub'],
            'pase' => $tok['pase'],
            'exp' => (int) $p['exp'],
            'refresh' => (string) ($tok['refresh'] ?? ''),
        ];
    }

    private function publicKey(string $kid): string {
        $file = $this->cacheDir . '/hvatar-keys-' . md5($this->url) . '.json';
        $data = is_file($file) && filemtime($file) > time() - 3600 ? json_decode((string) file_get_contents($file), true) : null;
        $find = function ($data) use ($kid) {
            foreach ($data['keys'] ?? [] as $k) {
                if (($k['kid'] ?? '') === $kid && ($k['crv'] ?? '') === 'Ed25519') return self::b64d((string) $k['x']);
            }
            return null;
        };
        $key = is_array($data) ? $find($data) : null;
        if ($key === null) {   // llave nueva o caché vencida: volver a pedir
            $raw = $this->http('GET', $this->url . '/.well-known/keys.json');
            $data = json_decode($raw, true);
            if (!is_array($data)) throw new HvatarException('llaves_no_disponibles');
            @file_put_contents($file, $raw, LOCK_EX);
            $key = $find($data);
        }
        if ($key === null || strlen($key) !== SODIUM_CRYPTO_SIGN_PUBLICKEYBYTES) throw new HvatarException('llave_desconocida');
        return $key;
    }

    private function call(string $path, array $body): array {
        $raw = $this->http('POST', $this->url . $path, json_encode($body),
            ['Authorization: Basic ' . base64_encode($this->clientId . ':' . $this->secret), 'Content-Type: application/json']);
        $data = json_decode($raw, true);
        if (!is_array($data)) throw new HvatarException('respuesta_invalida: ' . substr(trim(strip_tags($raw)), 0, 120));
        if (isset($data['error'])) throw new HvatarException((string) $data['error']);
        return $data;
    }

    private function http(string $method, string $url, ?string $body = null, array $headers = []): string {
        if (function_exists('curl_init')) {
            $ch = curl_init($url);
            curl_setopt_array($ch, [
                CURLOPT_CUSTOMREQUEST => $method,
                CURLOPT_HTTPHEADER => $headers,
                CURLOPT_RETURNTRANSFER => true,
                CURLOPT_FOLLOWLOCATION => false,
                CURLOPT_CONNECTTIMEOUT => 6,
                CURLOPT_TIMEOUT => 12,
            ]);
            if ($body !== null && $method !== 'GET') curl_setopt($ch, CURLOPT_POSTFIELDS, $body);
            $raw = curl_exec($ch);
            $err = curl_error($ch);
            curl_close($ch);
            if ($raw === false) throw new HvatarException('hvatar_no_disponible: ' . $err);
            return (string) $raw;
        }
        if (!ini_get('allow_url_fopen')) throw new HvatarException('hvatar_no_disponible: el servidor no tiene cURL ni allow_url_fopen');
        $ctx = stream_context_create(['http' => [
            'method' => $method,
            'header' => implode("\r\n", $headers),
            'content' => $body ?? '',
            'timeout' => 12,
            'ignore_errors' => true,
            'follow_location' => 0,
        ]]);
        $raw = @file_get_contents($url, false, $ctx);
        if ($raw === false) throw new HvatarException('hvatar_no_disponible: ' . (error_get_last()['message'] ?? 'sin respuesta'));
        return $raw;
    }

    private function json(array $data, int $status = 200): never {
        http_response_code($status);
        header('Content-Type: application/json; charset=utf-8');
        header('Cache-Control: no-store');
        echo json_encode($data, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
        exit;
    }

    private static function b64u(string $bin): string {
        return rtrim(strtr(base64_encode($bin), '+/', '-_'), '=');
    }

    private static function b64d(string $txt): string {
        $out = base64_decode(strtr($txt, '-_', '+/') . str_repeat('=', (4 - strlen($txt) % 4) % 4), true);
        if ($out === false) throw new HvatarException('base64');
        return $out;
    }
}