<?php
header('Content-Type: application/json; charset=utf-8');

$dbPath = __DIR__ . '/data/domainhunter.db';
if (!file_exists($dbPath)) {
    http_response_code(500);
    echo json_encode(['ok' => false, 'error' => 'DB not found']);
    exit;
}

try {
    $db = new SQLite3($dbPath, SQLITE3_OPEN_READWRITE);
} catch (Exception $e) {
    http_response_code(500);
    echo json_encode(['ok' => false, 'error' => 'DB open failed']);
    exit;
}

$action = $_GET['action'] ?? 'domains';

if ($action === 'domains') {
    $q = trim($_GET['q'] ?? '');
    $tld = trim($_GET['tld'] ?? '');

    $runId = $db->querySingle("SELECT value FROM metadata WHERE key='latest_run_id'");
    $scannedAt = $db->querySingle("SELECT value FROM metadata WHERE key='latest_scanned_at'");

    $sql = "SELECT domain, tld, score, status, keywords_json FROM domains WHERE run_id = :run";
    if ($q !== '') $sql .= " AND domain LIKE :q";
    if ($tld !== '') $sql .= " AND tld = :tld";
    $sql .= " ORDER BY score DESC, domain ASC LIMIT 500";

    $st = $db->prepare($sql);
    $st->bindValue(':run', $runId, SQLITE3_TEXT);
    if ($q !== '') $st->bindValue(':q', '%' . $q . '%', SQLITE3_TEXT);
    if ($tld !== '') $st->bindValue(':tld', $tld, SQLITE3_TEXT);

    $res = $st->execute();
    $rows = [];
    while ($r = $res->fetchArray(SQLITE3_ASSOC)) {
        $r['keywords'] = json_decode($r['keywords_json'] ?: '[]', true) ?: [];
        unset($r['keywords_json']);
        $rows[] = $r;
    }

    echo json_encode([
        'ok' => true,
        'meta' => [
            'runId' => $runId,
            'scannedAt' => $scannedAt,
            'count' => count($rows)
        ],
        'domains' => $rows,
    ], JSON_UNESCAPED_UNICODE);
    exit;
}

if ($action === 'prices') {
    if ($_SERVER['REQUEST_METHOD'] === 'POST') {
        $raw = json_decode(file_get_contents('php://input'), true) ?: [];
        $registrar = trim($raw['registrar'] ?? '');
        $tld = trim($raw['tld'] ?? '');
        $registerPrice = $raw['register_price'] ?? null;
        $renewPrice = $raw['renew_price'] ?? null;

        if ($registrar === '' || $tld === '') {
            http_response_code(400);
            echo json_encode(['ok' => false, 'error' => 'registrar/tld required']);
            exit;
        }

        $st = $db->prepare("UPDATE registrar_prices SET register_price=:rp, renew_price=:rr, updated_at=datetime('now') WHERE registrar=:r AND tld=:t");
        if ($registerPrice === null || $registerPrice === '') $st->bindValue(':rp', null, SQLITE3_NULL);
        else $st->bindValue(':rp', floatval($registerPrice), SQLITE3_FLOAT);
        if ($renewPrice === null || $renewPrice === '') $st->bindValue(':rr', null, SQLITE3_NULL);
        else $st->bindValue(':rr', floatval($renewPrice), SQLITE3_FLOAT);
        $st->bindValue(':r', $registrar, SQLITE3_TEXT);
        $st->bindValue(':t', $tld, SQLITE3_TEXT);
        $st->execute();

        echo json_encode(['ok' => true]);
        exit;
    }

    $res = $db->query("SELECT registrar, url, tld, register_price, renew_price, updated_at FROM registrar_prices ORDER BY registrar, tld");
    $items = [];
    while ($r = $res->fetchArray(SQLITE3_ASSOC)) $items[] = $r;
    echo json_encode(['ok' => true, 'items' => $items], JSON_UNESCAPED_UNICODE);
    exit;
}

http_response_code(400);
echo json_encode(['ok' => false, 'error' => 'unknown action']);