<?php
/**
 * Momentum Screener — Real-time Streaming (Ultra-Optimized)
 * Sources:
 * 1. TradingView   — Most Volatile (US stocks)
 * 2. NASDAQ        — Market Cap screener (Medium/Small/Micro/Nano)
 * 3. NASDAQ Gainers — Top % Gainers list (api.nasdaq.com)
 * 4. Yahoo Trending — Trending symbols (query1.finance.yahoo.com)
 */

// ─── Yahoo Proxy (CORS bypass) ──────────────────────────────────────────────
if (isset($_GET['yahoo_proxy']) && $_GET['yahoo_proxy'] == '1') {
    header('Content-Type: application/json');
    $q = isset($_GET['q']) ? trim($_GET['q']) : '';
    if (empty($q)) {
        echo json_encode(['error' => 'Missing q parameter']);
        exit;
    }
    $url = 'https://query1.finance.yahoo.com/v1/finance/search?q=' . urlencode($q) . '&quotesCount=1&newsCount=0';
    $ch = curl_init($url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_USERAGENT, 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36');
    curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
    curl_setopt($ch, CURLOPT_TIMEOUT, 10);
    curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
    $response = curl_exec($ch);
    $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    curl_close($ch);

    if ($httpCode !== 200 || !$response) {
        echo json_encode(['error' => 'Yahoo proxy failed', 'http_code' => $httpCode]);
    } else {
        echo $response;
    }
    exit;
}

// ─── Get JSON endpoint ──────────────────────────────────────────────────────
if (isset($_GET['get_json']) && $_GET['get_json'] == '1') {
    header('Content-Type: application/json');
    $jsonFile = __DIR__ . '/stockscreener.json';
    if (file_exists($jsonFile)) {
        echo file_get_contents($jsonFile);
    } else {
        echo '[]';
    }
    exit;
}

// ─── Save to JSON endpoint ──────────────────────────────────────────────────
if (isset($_POST['save_json']) && $_POST['save_json'] === '1') {
    header('Content-Type: application/json');
    $data = isset($_POST['data']) ? json_decode($_POST['data'], true) : null;
    if (!$data || !is_array($data)) {
        echo json_encode(['error' => 'Invalid data']);
        exit;
    }

    $jsonFile = __DIR__ . '/stockscreener.json';
    $existing = [];
    if (file_exists($jsonFile)) {
        $existing = json_decode(file_get_contents($jsonFile), true);
        if (!is_array($existing)) $existing = [];
    }

    // Build a lookup of symbols already present, so we can update them
    // in place (e.g. a changed comment) instead of only appending new ones.
    $existingIndexBySymbol = [];
    foreach ($existing as $idx => $e) {
        if (!empty($e['symbol'])) {
            $existingIndexBySymbol[$e['symbol']] = $idx;
        }
    }

    $added = 0;
    $updated = 0;
    foreach ($data as $entry) {
        if (empty($entry['symbol'])) continue;
        if (isset($existingIndexBySymbol[$entry['symbol']])) {
            // Symbol already present — merge in any changed fields
            // (isin, gettex_status, comment, etc.) rather than skipping it.
            $idx = $existingIndexBySymbol[$entry['symbol']];
            $existing[$idx] = array_merge($existing[$idx], $entry);
            $updated++;
        } else {
            $existing[] = $entry;
            $existingIndexBySymbol[$entry['symbol']] = count($existing) - 1;
            $added++;
        }
    }

    if (file_put_contents($jsonFile, json_encode($existing, JSON_PRETTY_PRINT))) {
        echo json_encode(['success' => true, 'count' => count($existing), 'added' => $added, 'updated' => $updated]);
    } else {
        echo json_encode(['error' => 'Failed to write file']);
    }
    exit;
}

// ─── Config ──────────────────────────────────────────────────────────────────

$MIN_AVG_VOLUME = 70000;
$MIN_PRICE = 0.50;
$MAX_PRICE = 5.00;
$MIN_PCT_CHANGE = 3.0;

$LOOKBACK_DAYS = 20;

$BREAKOUT_THRESHOLD = 1.02;
$VOLUME_SPIKE = 1.2;
$MAX_RSI_BREAKOUT = 80;

$VOL_SURGE_MIN = 2.0;
$VOL_SURGE_PRICE_MIN = 1.02;

$REVERSAL_MAX_RSI = 35;
$REVERSAL_MIN_VOL = 1.5;
$REVERSAL_MIN_BOUNCE = 1.05;

$HIGH_MOMENTUM_THRESHOLD = 15;
$MOM_GAP_THRESHOLD = 10;

$TICKER_BASE_URL = 'https://alceawis.de/other/extra/fetchdata/2026-05-13-Finance/2026-05-13-Stocks/process.php?symbol=';

// ─── NASDAQ Cap Band Definitions ────────────────────────────────────────────

define('CAP_MEDIUM_MIN', 2_000_000_000);
define('CAP_MEDIUM_MAX', 10_000_000_000);
define('CAP_SMALL_MIN',    300_000_000);
define('CAP_SMALL_MAX',  2_000_000_000);
define('CAP_MICRO_MIN',     50_000_000);
define('CAP_MICRO_MAX',   300_000_000);
define('CAP_NANO_MAX',      50_000_000);

function capBand(float $cap): ?string {
    if ($cap >= CAP_MEDIUM_MIN && $cap < CAP_MEDIUM_MAX) return 'Medium';
    if ($cap >= CAP_SMALL_MIN  && $cap < CAP_SMALL_MAX)  return 'Small';
    if ($cap >= CAP_MICRO_MIN  && $cap < CAP_MICRO_MAX)  return 'Micro';
    if ($cap > 0 && $cap < CAP_NANO_MAX)                 return 'Nano';
    return null;
}

// ─── Check if this is a streaming request ──────────────────────────────────

$isStream = isset($_GET['stream']) && $_GET['stream'] === '1';

if ($isStream) {
    header('Content-Type: text/event-stream');
    header('Cache-Control: no-cache');
    header('X-Accel-Buffering: no');
    ob_end_flush();

    runStreamingScan();
    exit;
}

// ─── Run streaming scan ─────────────────────────────────────────────────────

function runStreamingScan() {
    global $MIN_AVG_VOLUME, $MIN_PRICE, $MAX_PRICE, $MIN_PCT_CHANGE, $LOOKBACK_DAYS;
    global $BREAKOUT_THRESHOLD, $VOLUME_SPIKE, $MAX_RSI_BREAKOUT;
    global $VOL_SURGE_MIN, $VOL_SURGE_PRICE_MIN;
    global $REVERSAL_MAX_RSI, $REVERSAL_MIN_VOL, $REVERSAL_MIN_BOUNCE;
    global $HIGH_MOMENTUM_THRESHOLD, $MOM_GAP_THRESHOLD;

    $seenSymbols = [];
    $stats = [
        'tv_checked' => 0, 'tv_signals' => 0, 'tv_total' => 0,
        'nas_checked' => 0, 'nas_signals' => 0, 'nas_total' => 0,
        'nas_skipped_price' => 0, 'nas_skipped_change' => 0, 'nas_skipped_cap' => 0,
        'nasg_checked' => 0, 'nasg_signals' => 0, 'nasg_total' => 0,
        'ytrend_checked' => 0, 'ytrend_signals' => 0, 'ytrend_total' => 0,
    ];

    // ── Run 1: TradingView ──
    sendEvent('status', ['message' => 'Fetching TradingView volatile stocks...', 'type' => 'info']);
    $tvCandidates = fetchTradingViewVolatile();
    runSimpleSourceScan('TradingView', 'tv', $tvCandidates, $seenSymbols, $stats);

    // ── Run 2: NASDAQ ──
    sendEvent('status', ['message' => 'Fetching NASDAQ screener data...', 'type' => 'info']);

    $allNasdaqStocks = fetchNasdaqScreener();

    $filteredCandidates = [];
    $skipReasons = [
        'price_too_high' => 0,
        'price_too_low' => 0,
        'cap_too_big' => 0,
        'pct_change_too_low' => 0,
        'no_data' => 0
    ];

    foreach ($allNasdaqStocks as $cand) {
        $price = (float) str_replace(['$', ','], '', $cand['lastsale'] ?? '0');
        $pctChangeRaw = str_replace('%', '', $cand['pctchange'] ?? '0');
        $pctChange = (float) $pctChangeRaw;
        $cap = $cand['marketCap'] ?? 0;

        if ($price > $MAX_PRICE) { $skipReasons['price_too_high']++; continue; }
        if ($price < $MIN_PRICE) { $skipReasons['price_too_low']++; continue; }
        if ($cap > 10_000_000_000) { $skipReasons['cap_too_big']++; continue; }
        if (abs($pctChange) < 1.0) { $skipReasons['pct_change_too_low']++; continue; }
        if ($price <= 0 || $cap <= 0) { $skipReasons['no_data']++; continue; }

        $filteredCandidates[] = $cand;
    }

    $stats['nas_total'] = count($filteredCandidates);
    $stats['nas_original'] = count($allNasdaqStocks);
    $stats['nas_skipped_price'] = $skipReasons['price_too_high'] + $skipReasons['price_too_low'];
    $stats['nas_skipped_cap'] = $skipReasons['cap_too_big'];
    $stats['nas_skipped_change'] = $skipReasons['pct_change_too_low'];
    $stats['nas_skipped_total'] = array_sum($skipReasons);

    $totalSkipped = $stats['nas_skipped_total'];
    $keptPercent = $stats['nas_total'] > 0 ? round(($stats['nas_total'] / max($stats['nas_original'], 1)) * 100, 1) : 0;

    sendEvent('status', [
        'message' => "NASDAQ: {$stats['nas_original']} → {$stats['nas_total']} candidates (price≤$".$MAX_PRICE.", skipped {$totalSkipped}) - Price too high: {$skipReasons['price_too_high']}, Change<1%: {$skipReasons['pct_change_too_low']}, Cap: {$skipReasons['cap_too_big']}",
        'type' => 'info'
    ]);

    foreach ($filteredCandidates as $idx => $cand) {
        $stats['nas_checked']++;
        $sym = $cand['symbol'];

        if ($idx % 5 === 0) {
            sendEvent('progress', [
                'source' => 'NASDAQ',
                'checked' => $stats['nas_checked'],
                'total' => $stats['nas_total'],
                'signals' => $stats['nas_signals'],
                'symbol' => $sym,
                'skipped' => $stats['nas_skipped_total'],
                'kept_pct' => $keptPercent
            ]);
        }

        if (isset($seenSymbols[$sym])) continue;

        $hist = fetchHistory($sym);
        if (!$hist) continue;

        if ($sig = screen($hist, $sym)) {
            $sig['source'] = 'NASDAQ';
            $sig['marketCap'] = $cand['marketCap'];
            $sig['sector'] = $cand['sector'];
            $sig['band'] = $cand['band'];
            $sig['companyName'] = $cand['name'] ?? $sym;
            $stats['nas_signals']++;
            $seenSymbols[$sym] = true;

            sendEvent('signal', array_merge($sig, ['stats' => $stats]));
        }

        usleep(50000);
    }

    sendEvent('status', [
        'message' => "NASDAQ done: {$stats['nas_signals']} signals found",
        'type' => 'info'
    ]);

    // ── Run 3: NASDAQ Top Gainers ──
    sendEvent('status', ['message' => 'Fetching NASDAQ top gainers...', 'type' => 'info']);
    $nasgCandidates = fetchNasdaqGainers();
    runSimpleSourceScan('NasdaqGainers', 'nasg', $nasgCandidates, $seenSymbols, $stats);

    // ── Run 4: Yahoo Trending ──
    sendEvent('status', ['message' => 'Fetching Yahoo Finance trending symbols...', 'type' => 'info']);
    $ytrendCandidates = fetchYahooTrending();
    runSimpleSourceScan('YahooTrending', 'ytrend', $ytrendCandidates, $seenSymbols, $stats);

    $totalSignals = $stats['tv_signals'] + $stats['nas_signals'] + $stats['nasg_signals']
        + $stats['ytrend_signals'];

    sendEvent('done', [
        'message' => "✅ Complete! Found {$totalSignals} signals across 4 sources.",
        'stats' => $stats
    ]);
}

// ─── Generic scan loop ──────────────────────────────────────────────────────

function runSimpleSourceScan(string $sourceLabel, string $statPrefix, array $candidates, array &$seenSymbols, array &$stats) {
    $totalKey = "{$statPrefix}_total";
    $checkedKey = "{$statPrefix}_checked";
    $signalsKey = "{$statPrefix}_signals";

    $stats[$totalKey] = count($candidates);

    sendEvent('status', [
        'message' => "Found {$stats[$totalKey]} candidates from {$sourceLabel}, screening...",
        'type' => 'info'
    ]);

    foreach ($candidates as $idx => $sym) {
        $stats[$checkedKey]++;

        if ($idx % 5 === 0) {
            sendEvent('progress', [
                'source' => $sourceLabel,
                'checked' => $stats[$checkedKey],
                'total' => $stats[$totalKey],
                'signals' => $stats[$signalsKey],
                'symbol' => $sym
            ]);
        }

        if (isset($seenSymbols[$sym])) continue;

        $hist = fetchHistory($sym);
        if (!$hist) continue;

        if ($sig = screen($hist, $sym)) {
            $sig['source'] = $sourceLabel;
            $sig['marketCap'] = null;
            $sig['sector'] = null;
            $sig['band'] = null;
            $sig['companyName'] = $sym; // Will be enriched by JS if needed
            $stats[$signalsKey]++;
            $seenSymbols[$sym] = true;

            sendEvent('signal', array_merge($sig, ['stats' => $stats]));
        }

        usleep(50000);
    }

    sendEvent('status', [
        'message' => "{$sourceLabel} done: {$stats[$signalsKey]} signals found",
        'type' => 'info'
    ]);
}

// ─── Helper to send SSE event ──────────────────────────────────────────────

function sendEvent($event, $data) {
    echo "event: {$event}\n";
    echo "data: " . json_encode($data) . "\n\n";
    flush();

    if (connection_aborted()) {
        exit;
    }
}

// ─── Discovery Functions ────────────────────────────────────────────────────

function fetchTradingViewVolatile(): array {
    $url = 'https://www.tradingview.com/markets/stocks-usa/market-movers-most-volatile/';
    $opts = [
        'http' => [
            'header' => "User-Agent: Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36\r\n",
            'timeout' => 20
        ]
    ];
    $html = @file_get_contents($url, false, stream_context_create($opts));
    if (!$html) return [];
    preg_match_all('/data-rowkey="([A-Z]+:[A-Z]+)"/', $html, $matches);
    $symbols = [];
    foreach ($matches[1] as $rowkey) {
        $parts = explode(':', $rowkey);
        $symbols[] = $parts[1] ?? $rowkey;
    }
    return array_values(array_unique($symbols));
}

function fetchNasdaqScreener(): array {
    $url = 'https://api.nasdaq.com/api/screener/stocks?' . http_build_query([
        'tableonly' => 'true',
        'limit'     => 0,
        'offset'    => 0,
        'download'  => 'true',
    ]);

    $ch = curl_init($url);
    curl_setopt_array($ch, [
        CURLOPT_RETURNTRANSFER => true,
        CURLOPT_HTTPHEADER => [
            'Accept: application/json, text/plain, */*',
            'Accept-Language: en-US,en;q=0.9',
            'User-Agent: Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 '
                . '(KHTML, like Gecko) Chrome/126.0.0.0 Safari/537.36',
            'Origin: https://www.nasdaq.com',
            'Referer: https://www.nasdaq.com/market-activity/stocks/screener',
        ],
        CURLOPT_ENCODING => '',
        CURLOPT_TIMEOUT  => 60,
    ]);

    $response = curl_exec($ch);
    if (curl_errno($ch) || curl_getinfo($ch, CURLINFO_HTTP_CODE) !== 200) {
        curl_close($ch);
        return [];
    }
    curl_close($ch);

    $data = json_decode($response, true);
    if (json_last_error() !== JSON_ERROR_NONE) {
        return [];
    }

    $allRows = $data['data']['rows']
        ?? $data['data']['table']['rows']
        ?? $data['rows']
        ?? $data['table']['rows']
        ?? [];

    if (empty($allRows)) return [];

    $wanted = ['Medium', 'Small', 'Micro', 'Nano'];
    $filtered = [];

    foreach ($allRows as $row) {
        $capRaw = str_replace(',', '', $row['marketCap'] ?? '0');
        $cap = is_numeric($capRaw) ? (float) $capRaw : 0.0;
        $band = capBand($cap);
        if ($band !== null && in_array($band, $wanted, true)) {
            $filtered[] = [
                'symbol' => $row['symbol'] ?? '',
                'name' => $row['name'] ?? '',
                'marketCap' => $cap,
                'sector' => $row['sector'] ?? '',
                'lastsale' => $row['lastsale'] ?? '0',
                'pctchange' => $row['pctchange'] ?? '0%',
                'band' => $band,
            ];
        }
    }

    return $filtered;
}

function fetchNasdaqGainers(): array {
    $url = 'https://api.nasdaq.com/api/quote/list-type-extended/gainers?' . http_build_query([
        'assetclass' => 'stocks',
    ]);

    $ch = curl_init($url);
    curl_setopt_array($ch, [
        CURLOPT_RETURNTRANSFER => true,
        CURLOPT_HTTPHEADER => [
            'Accept: application/json, text/plain, */*',
            'Accept-Language: en-US,en;q=0.9',
            'User-Agent: Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 '
                . '(KHTML, like Gecko) Chrome/126.0.0.0 Safari/537.36',
            'Origin: https://www.nasdaq.com',
            'Referer: https://www.nasdaq.com/market-activity/stocks/gainers',
        ],
        CURLOPT_ENCODING => '',
        CURLOPT_TIMEOUT => 30,
    ]);
    $resp = curl_exec($ch);
    $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    $curlErr = curl_error($ch);
    curl_close($ch);

    if ($resp === false || $httpCode !== 200) {
        error_log("NASDAQ Gainers fetch failed: HTTP {$httpCode}, curl_error: {$curlErr}");
        return [];
    }

    $data = json_decode($resp, true);
    if (json_last_error() !== JSON_ERROR_NONE) {
        error_log("NASDAQ Gainers JSON decode failed: " . json_last_error_msg());
        return [];
    }

    $rows = $data['data']['gainers']['rows']
        ?? $data['data']['rows']
        ?? $data['data']['table']['rows']
        ?? [];

    $symbols = [];
    foreach ($rows as $row) {
        if (!empty($row['symbol'])) $symbols[] = $row['symbol'];
    }
    return array_values(array_unique($symbols));
}

function fetchYahooTrending(): array {
    $url = 'https://query1.finance.yahoo.com/v1/finance/trending/US?' . http_build_query([
        'count' => 50,
    ]);

    $ch = curl_init($url);
    curl_setopt_array($ch, [
        CURLOPT_RETURNTRANSFER => true,
        CURLOPT_HTTPHEADER => [
            'Accept: application/json',
            'User-Agent: Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 '
                . '(KHTML, like Gecko) Chrome/126.0.0.0 Safari/537.36',
        ],
        CURLOPT_ENCODING => '',
        CURLOPT_TIMEOUT => 15,
    ]);
    $resp = curl_exec($ch);
    $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    $curlErr = curl_error($ch);
    curl_close($ch);

    if ($resp === false || $httpCode !== 200) {
        error_log("Yahoo Trending fetch failed: HTTP {$httpCode}, curl_error: {$curlErr}");
        return [];
    }

    $data = json_decode($resp, true);
    if (json_last_error() !== JSON_ERROR_NONE) {
        error_log("Yahoo Trending JSON decode failed: " . json_last_error_msg());
        return [];
    }

    $quotes = $data['finance']['result'][0]['quotes'] ?? [];
    $symbols = [];
    foreach ($quotes as $q) {
        if (!empty($q['symbol'])) $symbols[] = $q['symbol'];
    }
    return array_values(array_unique($symbols));
}

function fetchHistory(string $symbol): ?array {
    $p1 = strtotime("-90 days");
    $p2 = time();
    $url = "https://query1.finance.yahoo.com/v8/finance/chart/{$symbol}?period1={$p1}&period2={$p2}&interval=1d&events=history&includeAdjustedClose=true";
    $opts = ['http' => ['header' => "User-Agent: Mozilla/5.0\r\n", 'timeout' => 12]];
    $json = @file_get_contents($url, false, stream_context_create($opts));
    if (!$json) return null;
    $d = json_decode($json, true);
    if (empty($d['chart']['result'][0])) return null;
    $r = $d['chart']['result'][0];
    $ts = $r['timestamp'] ?? [];
    $q = $r['indicators']['quote'][0] ?? [];
    $adj = $r['indicators']['adjclose'][0]['adjclose'] ?? [];
    $hist = [];
    for ($i = 0; $i < count($ts); $i++) {
        if (!isset($adj[$i]) || $adj[$i] === null) continue;
        $hist[] = [
            'date' => date('Y-m-d', $ts[$i]),
            'open' => $q['open'][$i] ?? null,
            'high' => $q['high'][$i] ?? null,
            'low' => $q['low'][$i] ?? null,
            'close' => $adj[$i],
            'volume' => $q['volume'][$i] ?? 0,
        ];
    }
    return $hist;
}

// ─── Technical Helpers ───────────────────────────────────────────────────────

function calcRSI(array $closes, int $period = 14): float {
    if (count($closes) < $period + 1) return 50;
    $gains = $losses = [];
    for ($i = count($closes) - $period; $i < count($closes); $i++) {
        $change = $closes[$i] - $closes[$i - 1];
        $gains[] = max($change, 0);
        $losses[] = max(-$change, 0);
    }
    $avgGain = array_sum($gains) / $period;
    $avgLoss = array_sum($losses) / $period;
    if ($avgLoss == 0) return 100;
    return 100 - (100 / (1 + ($avgGain / $avgLoss)));
}

function screen(array $h, string $sym): ?array {
    global $LOOKBACK_DAYS, $MIN_AVG_VOLUME, $MIN_PRICE, $MAX_PRICE;
    global $BREAKOUT_THRESHOLD, $VOLUME_SPIKE, $MAX_RSI_BREAKOUT;
    global $VOL_SURGE_MIN, $VOL_SURGE_PRICE_MIN;
    global $REVERSAL_MAX_RSI, $REVERSAL_MIN_VOL, $REVERSAL_MIN_BOUNCE;
    global $HIGH_MOMENTUM_THRESHOLD, $MOM_GAP_THRESHOLD;

    if (count($h) < $LOOKBACK_DAYS + 5) return null;

    $today = end($h);
    $price = $today['close'];
    $vol = $today['volume'];

    if ($price < $MIN_PRICE) return null;
    if ($price > $MAX_PRICE) return null;

    $past = array_slice($h, -($LOOKBACK_DAYS + 1), $LOOKBACK_DAYS);
    $high20 = max(array_column($past, 'high'));
    $low20 = min(array_column($past, 'low'));
    $avgVol = array_sum(array_column($past, 'volume')) / count($past);

    if ($avgVol < 5000) return null;

    $closes = array_column($h, 'close');
    $rsi = calcRSI($closes);

    $threeAgo = $h[count($h) - 4]['close'] ?? $price;
    $mom3d = (($price - $threeAgo) / $threeAgo) * 100;

    if (count($h) >= 6) {
        $fiveDaysAgo = $h[count($h) - 6]['close'] ?? $price;
        $mom5d = (($price - $fiveDaysAgo) / $fiveDaysAgo) * 100;
        
        if ($mom5d >= $HIGH_MOMENTUM_THRESHOLD && $rsi < 85) {
            return [
                'symbol' => $sym, 
                'strategy' => 'HIGH-MOMENTUM',
                'price' => $price, 
                'trigger' => $mom5d.'% in 5d',
                'trigger_pct' => round($mom5d, 1),
                'rsi' => round($rsi,1), 
                'spike' => round($vol/max($avgVol,1),1),
                'vol' => $vol, 
                'avg_vol' => round($avgVol),
                'mom3d' => round($mom3d, 1),
            ];
        }
    }

    if ($mom3d >= $MOM_GAP_THRESHOLD && $vol < $avgVol * 0.5 && $rsi < 80) {
        return [
            'symbol' => $sym, 
            'strategy' => 'MOM-GAP',
            'price' => $price, 
            'trigger' => $mom3d.'% in 3d (low vol)',
            'trigger_pct' => round($mom3d, 1),
            'rsi' => round($rsi,1), 
            'spike' => round($vol/max($avgVol,1),1),
            'vol' => $vol, 
            'avg_vol' => round($avgVol),
            'mom3d' => round($mom3d, 1),
        ];
    }

    if ($price >= $high20 * $BREAKOUT_THRESHOLD && $vol >= $avgVol * $VOLUME_SPIKE && $rsi <= $MAX_RSI_BREAKOUT) {
        return [
            'symbol' => $sym, 'strategy' => 'BREAKOUT',
            'price' => $price, 'trigger' => '$'.number_format($high20,2).' high',
            'trigger_pct' => round((($price - $high20) / $high20) * 100, 1),
            'rsi' => round($rsi,1), 'spike' => round($vol/max($avgVol,1),1),
            'vol' => $vol, 'avg_vol' => round($avgVol),
            'mom3d' => round($mom3d, 1),
        ];
    }

    $yesterday = $h[count($h) - 2] ?? $today;
    $priceChange = (($price - $yesterday['close']) / $yesterday['close']);
    if ($vol >= $avgVol * $VOL_SURGE_MIN && $priceChange >= 0.02 && $rsi < 75) {
        return [
            'symbol' => $sym, 'strategy' => 'VOL-SURGE',
            'price' => $price, 'trigger' => '+'.round($priceChange*100,1).'% today',
            'trigger_pct' => round($priceChange*100, 1),
            'rsi' => round($rsi,1), 'spike' => round($vol/max($avgVol,1),1),
            'vol' => $vol, 'avg_vol' => round($avgVol),
            'mom3d' => round($mom3d, 1),
        ];
    }

    if ($rsi <= $REVERSAL_MAX_RSI && $vol >= $avgVol * $REVERSAL_MIN_VOL && $price >= $low20 * $REVERSAL_MIN_BOUNCE) {
        return [
            'symbol' => $sym, 'strategy' => 'REVERSAL',
            'price' => $price, 'trigger' => 'RSI '.round($rsi,1).' + bounce',
            'trigger_pct' => round((($price - $low20) / $low20) * 100, 1),
            'rsi' => round($rsi,1), 'spike' => round($vol/max($avgVol,1),1),
            'vol' => $vol, 'avg_vol' => round($avgVol),
            'mom3d' => round($mom3d, 1),
        ];
    }

    return null;
}

// ─── If not streaming, show the UI ──────────────────────────────────────────

header('Content-Type: text/html; charset=utf-8');
?>
<!DOCTYPE html>
<html>
<head>
    <title>Momentum Screener — Real-time</title>
    <style>
        * { box-sizing: border-box; }
        body { font-family: -apple-system, BlinkMacSystemFont, 'Segoe UI', Roboto, sans-serif; background: #0d1117; color: #c9d1d9; padding: 24px; margin: 0; }
        h2 { color: #58a6ff; margin: 0 0 6px 0; font-size: 22px; }
        .meta { color: #8b949e; font-size: 13px; margin-bottom: 24px; }
        .stats { display: flex; gap: 16px; margin-bottom: 20px; flex-wrap: wrap; }
        .stat-box { background: #161b22; border: 1px solid #30363d; border-radius: 8px; padding: 12px 18px; min-width: 110px; }
        .stat-label { color: #8b949e; font-size: 11px; text-transform: uppercase; letter-spacing: 0.5px; }
        .stat-value { color: #fff; font-size: 20px; font-weight: 700; margin-top: 4px; }
        .stat-value.loading { color: #d29922; animation: pulse 1s infinite; }
        @keyframes pulse { 0%, 100% { opacity: 1; } 50% { opacity: 0.5; } }
        .source-badge { display: inline-block; padding: 1px 6px; border-radius: 3px; font-size: 9px; font-weight: 700; text-transform: uppercase; letter-spacing: 0.5px; margin-left: 6px; vertical-align: middle; }
        .source-tv { background: #1f6feb; color: #fff; }
        .source-nas { background: #8957e5; color: #fff; }
        .source-nasg { background: #d29922; color: #000; }
        .source-ytrend { background: #39c5cf; color: #000; }
        .band-badge { display: inline-block; padding: 1px 6px; border-radius: 3px; font-size: 8px; font-weight: 700; background: #21262d; color: #8b949e; margin-left: 4px; }
        .band-medium { background: #238636; color: #fff; }
        .band-small { background: #d29922; color: #000; }
        .band-micro { background: #da3633; color: #fff; }
        .band-nano { background: #8957e5; color: #fff; }
        .isin-link { 
            color: #58a6ff; 
            text-decoration: none; 
            font-size: 11px;
            cursor: pointer;
            padding: 2px 8px;
            border: 1px solid #30363d;
            border-radius: 4px;
            background: #0d1117;
            display: inline-block;
            transition: all 0.2s;
        }
        .isin-link:hover { 
            background: #1c2128;
            border-color: #58a6ff;
        }
        .isin-link.loading {
            opacity: 0.5;
            cursor: wait;
        }
        .isin-result {
            font-size: 11px;
            margin-top: 4px;
            padding: 4px 8px;
            border-radius: 4px;
            background: #161b22;
            border: 1px solid #30363d;
            display: none;
        }
        .isin-result.show {
            display: block;
        }
        .isin-result .found {
            color: #3fb950;
        }
        .isin-result .not-found {
            color: #f85149;
        }
        .isin-result .multiple {
            color: #d29922;
            cursor: pointer;
            text-decoration: underline;
        }
        .comment-input {
            width: 140px;
            background: #0d1117;
            border: 1px solid #30363d;
            border-radius: 4px;
            color: #c9d1d9;
            font-size: 11px;
            padding: 4px 6px;
            text-align: left;
        }
        .comment-input:focus {
            outline: none;
            border-color: #58a6ff;
        }
        .comment-input.saved-flash {
            border-color: #3fb950;
        }
        tr.reversesplit-row td {
            text-decoration: line-through;
            text-decoration-color: #f85149;
            opacity: 0.55;
        }
        tr.reversesplit-row .comment-input {
            text-decoration: line-through;
            text-decoration-color: #f85149;
            opacity: 1;
        }
        table { border-collapse: collapse; width: 100%; font-size: 13px; background: #161b22; border: 1px solid #30363d; border-radius: 8px; overflow: hidden; }
        th { 
            background: #21262d; 
            color: #58a6ff; 
            padding: 12px 14px; 
            text-align: right; 
            font-weight: 600; 
            font-size: 11px; 
            text-transform: uppercase; 
            letter-spacing: 0.5px; 
            border-bottom: 1px solid #30363d; 
            cursor: pointer; 
            user-select: none; 
            transition: background 0.15s; 
            white-space: nowrap; 
            position: sticky; 
            top: 0; 
            z-index: 10; 
        }
        th:hover { background: #30363d; }
        th:first-child, td:first-child { text-align: left; }
        th .arrow { 
            margin-left: 6px; 
            opacity: 0.3; 
            font-size: 10px;
            display: inline-block;
            transition: opacity 0.2s;
        }
        th.sorted .arrow { opacity: 1; }
        th.sorted-asc .arrow::after { content: '▲'; }
        th.sorted-desc .arrow::after { content: '▼'; }
        td { padding: 10px 14px; border-bottom: 1px solid #21262d; text-align: right; vertical-align: middle; }
        tr:hover { background: #1c2128; }
        tr:last-child td { border-bottom: none; }
        .sym a { font-weight: 700; color: #58a6ff; font-size: 14px; text-decoration: none; }
        .sym a:hover { text-decoration: underline; color: #79c0ff; }
        .sym .company-name { color: #8b949e; font-size: 11px; font-weight: 400; display: block; }
        .strat { display: inline-block; padding: 2px 8px; border-radius: 4px; font-size: 10px; font-weight: 700; text-transform: uppercase; letter-spacing: 0.5px; }
        .strat-breakout { background: #238636; color: #fff; }
        .strat-vol { background: #8957e5; color: #fff; }
        .strat-rev { background: #d29922; color: #000; }
        .strat-high { background: #f0883e; color: #000; }
        .strat-gap { background: #da3633; color: #fff; }
        .spike { color: #f85149; font-weight: 700; }
        .results-container { max-height: 600px; overflow-y: auto; }
        .results-container::-webkit-scrollbar { width: 8px; }
        .results-container::-webkit-scrollbar-track { background: #0d1117; }
        .results-container::-webkit-scrollbar-thumb { background: #30363d; border-radius: 4px; }
        .results-container::-webkit-scrollbar-thumb:hover { background: #484f58; }
        .source-header { display: flex; gap: 10px; margin-bottom: 12px; flex-wrap: wrap; }
        .source-pill { padding: 4px 12px; border-radius: 16px; font-size: 12px; font-weight: 600; cursor: pointer; border: 1px solid #30363d; background: #161b22; color: #8b949e; }
        .source-pill.active { background: #21262d; color: #58a6ff; border-color: #58a6ff; }
        .source-pill:hover { border-color: #58a6ff; }
        .scan-btn { background: #238636; color: #fff; border: none; padding: 8px 20px; border-radius: 6px; font-weight: 600; cursor: pointer; font-size: 14px; }
        .scan-btn:hover { background: #2ea043; }
        .scan-btn:disabled { opacity: 0.5; cursor: not-allowed; }
        .scan-btn.scanning { background: #d29922; }
        .save-btn { background: #1f6feb; color: #fff; border: none; padding: 8px 20px; border-radius: 6px; font-weight: 600; cursor: pointer; font-size: 14px; margin-left: 8px; }
        .save-btn:hover { background: #388bfd; }
        .save-btn:disabled { opacity: 0.5; cursor: not-allowed; }
        .status-bar { 
            background: #161b22; 
            border: 1px solid #30363d; 
            border-radius: 8px; 
            padding: 12px 16px; 
            margin-bottom: 16px; 
            font-size: 13px; 
            color: #8b949e; 
            min-height: 44px; 
            display: flex; 
            flex-direction: column;
            gap: 8px;
        }
        .status-top {
            display: flex;
            align-items: center;
            gap: 12px;
            flex-wrap: wrap;
        }
        .status-dot { width: 8px; height: 8px; border-radius: 50%; display: inline-block; flex-shrink: 0; }
        .status-dot.idle { background: #8b949e; }
        .status-dot.scanning { background: #d29922; animation: pulse 1s infinite; }
        .status-dot.done { background: #3fb950; }
        .status-dot.error { background: #f85149; }
        .status-message { flex: 1; }
        .log-container {
            max-height: 150px;
            overflow-y: auto;
            background: #0d1117;
            border: 1px solid #30363d;
            border-radius: 4px;
            padding: 6px 8px;
            font-family: 'Courier New', monospace;
            font-size: 11px;
            line-height: 1.5;
            color: #c9d1d9;
            margin-top: 4px;
            scroll-behavior: smooth;
        }
        .log-container::-webkit-scrollbar { width: 6px; }
        .log-container::-webkit-scrollbar-track { background: #0d1117; }
        .log-container::-webkit-scrollbar-thumb { background: #30363d; border-radius: 3px; }
        .log-entry {
            border-bottom: 1px solid #21262d;
            padding: 2px 0;
            white-space: pre-wrap;
            word-break: break-all;
        }
        .log-entry:last-child { border-bottom: none; }
        .log-entry .timestamp { color: #484f58; margin-right: 8px; }
        .log-entry .level-info { color: #58a6ff; }
        .log-entry .level-debug { color: #8b949e; }
        .log-entry .level-error { color: #f85149; }
        .log-entry .level-success { color: #3fb950; }
        .signal-flash { animation: flashGreen 0.5s; }
        @keyframes flashGreen { 0% { background: rgba(63, 185, 80, 0.3); } 100% { background: transparent; } }
        .price-filter-info {
            background: #1c2128;
            border: 1px solid #30363d;
            border-radius: 6px;
            padding: 8px 14px;
            font-size: 12px;
            color: #8b949e;
            margin-bottom: 12px;
            display: inline-block;
        }
        .price-filter-info strong {
            color: #58a6ff;
        }
        .isin-modal {
            display: none;
            position: fixed;
            z-index: 1000;
            left: 0;
            top: 0;
            width: 100%;
            height: 100%;
            background-color: rgba(0,0,0,0.7);
        }
        .isin-modal-content {
            background-color: #161b22;
            margin: 10% auto;
            padding: 20px;
            border: 1px solid #30363d;
            border-radius: 8px;
            width: 80%;
            max-width: 600px;
            max-height: 500px;
            overflow-y: auto;
        }
        .isin-modal-content h3 {
            color: #58a6ff;
            margin-top: 0;
        }
        .isin-modal-item {
            padding: 10px;
            margin: 8px 0;
            background: #0d1117;
            border: 1px solid #30363d;
            border-radius: 4px;
            cursor: pointer;
            transition: background 0.2s;
        }
        .isin-modal-item:hover {
            background: #1c2128;
            border-color: #58a6ff;
        }
        .isin-modal-item .isin-code {
            font-weight: 700;
            color: #58a6ff;
        }
        .isin-modal-close {
            float: right;
            color: #8b949e;
            font-size: 28px;
            font-weight: bold;
            cursor: pointer;
        }
        .isin-modal-close:hover {
            color: #f85149;
        }
        .market-badge-wrapper {
            cursor: pointer;
            display: block;
            margin-top: 4px;
        }
        .market-badge-wrapper:hover {
            opacity: 0.8;
        }
        .market-badge-iframe {
            width: 100%;
            height: 60px;
            border: none;
            display: block;
            pointer-events: none;
        }
        .clear-log-btn {
            background: #21262d;
            border: 1px solid #30363d;
            color: #8b949e;
            padding: 2px 10px;
            border-radius: 4px;
            font-size: 11px;
            cursor: pointer;
            float: right;
        }
        .clear-log-btn:hover {
            background: #30363d;
            color: #c9d1d9;
        }
    </style>
</head>
<body>
    <div style="display: flex; justify-content: space-between; align-items: center; margin-bottom: 12px;">
        <div>
            <h2>🎯 Momentum Signals <span style="font-size:12px;color:#8b949e;font-weight:400;">(live streaming)</span></h2>
            <div class="meta" id="timestamp">Click "Scan Now" to start</div>
        </div>
        <div>
            <button class="scan-btn" id="scanBtn" onclick="startScan()">🔍 Scan Now</button>
            <button class="save-btn" id="saveBtn" onclick="saveToJSON()">💾 Save to JSON</button>
        </div>
    </div>

    <div class="price-filter-info">
        ⚡ Auto-filter: Only stocks <strong>under $x</strong> — focusing on high-momentum small caps
    </div>

    <div class="status-bar" id="statusBar">
        <div class="status-top">
            <span class="status-dot idle" id="statusDot"></span>
            <span class="status-message" id="statusMessage">Ready to scan</span>
            <button class="clear-log-btn" onclick="clearLog()">Clear Log</button>
        </div>
        <div class="log-container" id="logContainer"></div>
    </div>

    <div class="stats">
        <div class="stat-box"><div class="stat-label">Total Signals</div><div class="stat-value" id="totalCount">0</div></div>
        <div class="stat-box"><div class="stat-label">TradingView</div><div class="stat-value" id="tvCount" style="color: #58a6ff">0</div></div>
        <div class="stat-box"><div class="stat-label">NASDAQ</div><div class="stat-value" id="nasCount" style="color: #8957e5">0</div></div>
        <div class="stat-box"><div class="stat-label">NASDAQ Gainers</div><div class="stat-value" id="nasgCount" style="color: #d29922">0</div></div>
        <div class="stat-box"><div class="stat-label">Yahoo Trending</div><div class="stat-value" id="ytrendCount" style="color: #39c5cf">0</div></div>
        <div class="stat-box"><div class="stat-label">Breakouts</div><div class="stat-value" id="boCount">0</div></div>
        <div class="stat-box"><div class="stat-label">Vol Surge</div><div class="stat-value" id="vsCount">0</div></div>
        <div class="stat-box"><div class="stat-label">Reversals</div><div class="stat-value" id="rvCount">0</div></div>
        <div class="stat-box"><div class="stat-label">High Mom</div><div class="stat-value" id="hmCount" style="color: #f0883e">0</div></div>
        <div class="stat-box"><div class="stat-label">Mom Gap</div><div class="stat-value" id="mgCount" style="color: #da3633">0</div></div>
        <div class="stat-box"><div class="stat-label">Progress</div><div class="stat-value" id="progressCount" style="font-size:14px;">0%</div></div>
    </div>

    <div class="source-header">
        <div class="source-pill active" data-filter="all" onclick="filterSource('all')">All Sources</div>
        <div class="source-pill" data-filter="TradingView" onclick="filterSource('TradingView')">TradingView</div>
        <div class="source-pill" data-filter="NASDAQ" onclick="filterSource('NASDAQ')">NASDAQ</div>
        <div class="source-pill" data-filter="NasdaqGainers" onclick="filterSource('NasdaqGainers')">NASDAQ Gainers</div>
        <div class="source-pill" data-filter="YahooTrending" onclick="filterSource('YahooTrending')">Yahoo Trending</div>
    </div>

    <div class="results-container" id="resultsContainer">
        <table id="signalTable">
            <thead>
                <tr>
                    <th data-col="symbol" data-type="string" onclick="sortTable('symbol')">Symbol<span class="arrow"></span></th>
                    <th data-col="source" data-type="string" onclick="sortTable('source')">Source<span class="arrow"></span></th>
                    <th data-col="strategy" data-type="string" onclick="sortTable('strategy')">Strategy<span class="arrow"></span></th>
                    <th data-col="trigger" data-type="string" onclick="sortTable('trigger')">Trigger<span class="arrow"></span></th>
                    <th data-col="trigger_pct" data-type="number" onclick="sortTable('trigger_pct')">Trigger %<span class="arrow"></span></th>
                    <th data-col="price" data-type="number" onclick="sortTable('price')">Price<span class="arrow"></span></th>
                    <th data-col="vol" data-type="number" onclick="sortTable('vol')">Volume<span class="arrow"></span></th>
                    <th data-col="avg_vol" data-type="number" onclick="sortTable('avg_vol')">Avg Vol<span class="arrow"></span></th>
                    <th data-col="spike" data-type="number" onclick="sortTable('spike')">Spike<span class="arrow"></span></th>
                    <th data-col="rsi" data-type="number" onclick="sortTable('rsi')">RSI<span class="arrow"></span></th>
                    <th data-col="mom3d" data-type="number" onclick="sortTable('mom3d')">3d Mom<span class="arrow"></span></th>
                    <th data-col="band" data-type="string" onclick="sortTable('band')">Band<span class="arrow"></span></th>
                    <th data-col="isin" data-type="string" onclick="sortTable('isin')">ISIN<span class="arrow"></span></th>
                    <th data-col="comment" data-type="string" onclick="sortTable('comment')">Comment<span class="arrow"></span></th>
                </tr>
            </thead>
            <tbody id="signalBody">
                </tbody>
        </table>
    </div>

    <div id="isinModal" class="isin-modal">
        <div class="isin-modal-content">
            <span class="isin-modal-close" onclick="closeISINModal()">&times;</span>
            <h3>Select ISIN for <span id="isinModalSymbol"></span></h3>
            <div id="isinModalResults"></div>
        </div>
    </div>

    <script>
    // ─── Global debug/logging ──────────────────────────────────────────────
    const DEBUG = true;

    function log(level, ...args) {
        const container = document.getElementById('logContainer');
        if (!container) return;
        const timestamp = new Date().toLocaleTimeString();
        const message = args.join(' ');
        const entry = document.createElement('div');
        entry.className = 'log-entry';
        const levelClass = 'level-' + (level || 'info');
        entry.innerHTML = `<span class="timestamp">[${timestamp}]</span><span class="${levelClass}">${level.toUpperCase()}:</span> ${escapeHtml(message)}`;
        container.appendChild(entry);
        container.scrollTop = container.scrollHeight;
        console.log(`[${timestamp}]`, ...args);
    }

    function escapeHtml(str) {
        const div = document.createElement('div');
        div.textContent = str;
        return div.innerHTML;
    }

    function clearLog() {
        const container = document.getElementById('logContainer');
        if (container) container.innerHTML = '';
    }

    // ─── Status bar update ──────────────────────────────────────────────────

    let currentFilter = 'all';
    let allSignals = [];
    let eventSource = null;
    let isinCache = {};
    let stats = {
        tv_checked: 0, tv_signals: 0, tv_total: 0,
        nas_checked: 0, nas_signals: 0, nas_total: 0,
        nas_skipped_price: 0, nas_skipped_change: 0, nas_skipped_cap: 0,
        nas_skipped_total: 0,
        nasg_checked: 0, nasg_signals: 0, nasg_total: 0,
        ytrend_checked: 0, ytrend_signals: 0, ytrend_total: 0,
    };

    // ─── Sorting State ────────────────────────────────────────────────────────
    let sortColumn = 'trigger_pct';
    let sortDirection = 'desc';
    let sortType = 'number';

    const SOURCE_KEY_MAP = {
        'TradingView': 'tv',
        'NASDAQ': 'nas',
        'NasdaqGainers': 'nasg',
        'YahooTrending': 'ytrend',
    };

    // ─── Fetch company name using local proxy ──────────────────────────────
    async function fetchCompanyName(symbol) {
        log('debug', 'fetchCompanyName() called for:', symbol);
        try {
            const url = '?yahoo_proxy=1&q=' + encodeURIComponent(symbol);
            log('debug', 'Fetching from local proxy:', url);
            const response = await fetch(url);
            if (!response.ok) {
                log('error', 'Proxy fetch failed with status:', response.status);
                return null;
            }
            const data = await response.json();
            log('debug', 'Proxy response:', JSON.stringify(data).substring(0, 300) + '...');
            if (data && data.quotes && data.quotes.length > 0) {
                const name = data.quotes[0].longname || data.quotes[0].shortname || null;
                log('info', 'Found company name via proxy:', name);
                return name;
            }
            log('debug', 'No company name found in proxy response');
            return null;
        } catch (e) {
            log('error', 'Proxy fetch error:', e);
            return null;
        }
    }

    // ─── ISIN Lookup Function ──────────────────────────────────────────────
    async function lookupISIN(symbol, companyName, rowElement) {
        log('info', '======= lookupISIN() called =======');
        log('info', 'symbol:', symbol);
        log('info', 'companyName provided:', companyName || '(null)');

        const isinCell = rowElement.querySelector('td[data-cell="isin"]');
        const link = isinCell.querySelector('.isin-link');
        if (!link) {
            log('error', 'ERROR: link element not found!');
            return;
        }

        link.textContent = '⏳ Searching...';
        link.className = 'isin-link loading';
        
        // --- Step 1: Get a valid company name ---
        let effectiveName = companyName;
        if (!effectiveName || effectiveName === symbol) {
            log('info', 'Company name missing or same as symbol, fetching from Yahoo via proxy...');
            const fetched = await fetchCompanyName(symbol);
            if (fetched) {
                effectiveName = fetched;
                log('info', 'Fetched effectiveName:', effectiveName);
            } else {
                log('warn', 'Could not fetch company name, will fallback to symbol');
                effectiveName = symbol;
            }
        } else {
            log('info', 'Using provided company name:', effectiveName);
        }
        
        // --- Step 2: Build search terms (same as process.php) ---
        let searchTerms = [];
        if (effectiveName && effectiveName !== symbol) {
            // First word of the company name
            let firstWord = effectiveName.split(' ')[0];
            if (firstWord && firstWord !== symbol) {
                searchTerms.push(firstWord);
                log('debug', 'Added first word:', firstWord);
            }
            // Full company name
            searchTerms.push(effectiveName);
            log('debug', 'Added full name:', effectiveName);
        }
        // Always fallback to symbol as last resort
        searchTerms.push(symbol);
        log('debug', 'Added symbol fallback:', symbol);
        
        // Remove duplicates
        searchTerms = [...new Set(searchTerms)];
        log('info', 'Final search terms:', searchTerms.join(', '));
        
        let allResults = [];
        let rawJsonData = null;
        let currentTermIndex = 0;
        
        // --- Step 3: Recursive search ────────────────────────────────────
        function tryNextTerm() {
            log('debug', 'tryNextTerm() index:', currentTermIndex, 'of', searchTerms.length);
            if (currentTermIndex >= searchTerms.length) {
                log('debug', 'All terms tried, results:', allResults.length);
                if (allResults.length > 0) {
                    displayAllResults(allResults);
                    return;
                }
                log('error', 'No results found');
                link.textContent = '❌ Not found';
                link.className = 'isin-link';
                link.style.color = '#f85149';
                link.style.borderColor = '#f85149';
                isinCache[symbol] = null;
                return;
            }
            
            const term = searchTerms[currentTermIndex];
            log('info', 'Searching term: "' + term + '"');
            if (currentTermIndex > 0) {
                link.textContent = '⏳ Searching: "' + term + '"...';
            }
            
            const url = 'ingdiba.php?symbol=' + encodeURIComponent(term) + '&json';
            log('debug', 'Fetching URL:', url);
            
            fetch(url)
                .then(response => {
                    log('debug', 'Response status:', response.status);
                    return response.json();
                })
                .then(data => {
                    log('debug', 'ING DiBa response for term "' + term + '":', JSON.stringify(data).substring(0, 300) + '...');
                    rawJsonData = data;
                    
                    if (data.status === 'multiple_results' && data.search && data.search.results) {
                        const count = data.search.results.length;
                        log('info', 'Multiple results found, count:', count);
                        data.search.results.forEach(result => {
                            if (result.isin && !allResults.some(r => r.isin === result.isin)) {
                                allResults.push({
                                    isin: result.isin,
                                    name: result.name || result.longName || effectiveName || symbol,
                                    price: result.price || result.regularMarketPrice || result.close,
                                    currency: result.currency || 'USD'
                                });
                                log('debug', 'Added result:', result.isin, result.name);
                            }
                        });
                    }
                    
                    if (data.status === 'success' && data.data && data.data.price && data.data.price.isin) {
                        const isin = data.data.price.isin;
                        log('info', 'Single success result, ISIN:', isin);
                        if (!allResults.some(r => r.isin === isin)) {
                            allResults.push({
                                isin: isin,
                                name: data.data.price.name || effectiveName || symbol,
                                price: data.data.price.price || data.data.price.regularMarketPrice || data.data.price.close,
                                currency: data.data.price.currency || 'USD'
                            });
                            log('debug', 'Added success result:', isin);
                        }
                    }
                    
                    currentTermIndex++;
                    tryNextTerm();
                })
                .catch(error => {
                    log('error', 'Fetch error for term "' + term + '":', error);
                    currentTermIndex++;
                    tryNextTerm();
                });
        }
        
        function displayAllResults(results) {
            log('info', 'displayAllResults() called with', results.length, 'results');
            if (!results || results.length === 0) {
                log('error', 'No results to display');
                link.textContent = '❌ Not found';
                link.className = 'isin-link';
                link.style.color = '#f85149';
                link.style.borderColor = '#f85149';
                isinCache[symbol] = null;
                return;
            }
            
            if (results.length === 1) {
                const foundIsin = results[0].isin;
                log('success', 'Single result found:', foundIsin);
                link.textContent = foundIsin;
                link.className = 'isin-link';
                link.style.color = '#3fb950';
                link.style.borderColor = '#3fb950';
                isinCache[symbol] = foundIsin;
                appendMarketIframe(isinCell, foundIsin);
                allSignals.forEach(sig => {
                    if (sig.symbol === symbol) {
                        sig.isin = foundIsin;
                    }
                });
                return;
            }
            
            // Multiple results
            log('info', 'Multiple results found, count:', results.length);
            link.textContent = 'Multiple (' + results.length + ') ▼';
            link.className = 'isin-link';
            link.style.color = '#d29922';
            link.style.borderColor = '#d29922';
            isinCache[symbol] = results;
            link.onclick = function(e) {
                e.stopPropagation();
                log('info', 'Opening modal for multiple results');
                openISINModal(symbol, results);
            };
        }
        
        // Start the search
        log('info', 'Starting recursive search...');
        tryNextTerm();
    }

    // ─── ISIN Modal Functions ──────────────────────────────────────────────

    function openISINModal(symbol, isinData) {
        log('info', 'openISINModal() called for', symbol);
        const modal = document.getElementById('isinModal');
        const symbolSpan = document.getElementById('isinModalSymbol');
        const resultsDiv = document.getElementById('isinModalResults');
        
        symbolSpan.textContent = symbol;
        resultsDiv.innerHTML = '';
        
        if (Array.isArray(isinData)) {
            isinData.forEach(result => {
                const div = document.createElement('div');
                div.className = 'isin-modal-item';
                div.innerHTML = `
                    <div><span class="isin-code">${result.isin}</span></div>
                    <div style="font-size:12px;color:#8b949e;">${result.name || 'Unknown'}</div>
                    <div style="font-size:11px;color:#484f58;">Price: ${result.price || 'N/A'} ${result.currency || ''}</div>
                `;
                div.onclick = function() {
                    selectISIN(symbol, result.isin);
                    closeISINModal();
                };
                resultsDiv.appendChild(div);
            });
        }
        
        modal.style.display = 'block';
    }

    function closeISINModal() {
        document.getElementById('isinModal').style.display = 'none';
    }

    function selectISIN(symbol, isin) {
        log('info', 'selectISIN() called for', symbol, '->', isin);
        isinCache[symbol] = isin;
        
        const rows = document.querySelectorAll(`#signalBody tr[data-symbol="${symbol}"]`);
        rows.forEach(row => {
            const isinCell = row.querySelector('td[data-cell="isin"]');
            const link = isinCell.querySelector('.isin-link');
            if (link) {
                link.textContent = isin;
                link.className = 'isin-link';
                link.style.color = '#3fb950';
                link.style.borderColor = '#3fb950';
                link.onclick = null;
                appendMarketIframe(isinCell, isin);
            }
        });
        
        allSignals.forEach(sig => {
            if (sig.symbol === symbol) {
                sig.isin = isin;
            }
        });
    }

    // ─── Embed market iframe badge (clickable) ──────────────────────────────

    function appendMarketIframe(containerElement, isin) {
        // Remove existing wrapper if any
        const existingWrapper = containerElement.querySelector('.market-badge-wrapper');
        if (existingWrapper) {
            existingWrapper.remove();
        }

        const wrapper = document.createElement('div');
        wrapper.className = 'market-badge-wrapper';
        wrapper.style.cssText = 'cursor:pointer; display:block; margin-top:4px;';
        wrapper.title = 'Click to check on xchangemarketcheck_gettex';
        wrapper.onclick = function(e) {
            window.open('xchangemarketcheck_gettex.php?q=' + encodeURIComponent(isin), '_blank');
            e.stopPropagation();
        };

        const iframe = document.createElement('iframe');
        iframe.className = 'market-badge-iframe';
        iframe.src = 'xchangemarket_badge.php?q=' + encodeURIComponent(isin);
        iframe.style.cssText = 'width:100%; height:60px; border:none; display:block; pointer-events:none;';
        iframe.loading = 'lazy';

        wrapper.appendChild(iframe);
        containerElement.appendChild(wrapper);
    }

    // ─── Render stored gettex status as plain text (no iframe) ──────────────
    // Used when restoring from stockscreener.json - we already know the status,
    // so there's no need to load an iframe per row just to re-fetch it.
    function appendGettexStatusText(containerElement, isin, statusText) {
        const existingWrapper = containerElement.querySelector('.market-badge-wrapper');
        if (existingWrapper) {
            existingWrapper.remove();
        }

        const wrapper = document.createElement('div');
        wrapper.className = 'market-badge-wrapper';
        wrapper.style.cssText = 'cursor:pointer; display:block; margin-top:4px; font-size:11px; padding:2px 6px; border-radius:4px; background:#21262d; color:#8b949e; border:1px solid #30363d;';
        wrapper.title = 'Click to check on xchangemarketcheck_gettex';
        wrapper.textContent = statusText && statusText.trim() ? statusText.trim() : '—';
        wrapper.onclick = function(e) {
            window.open('xchangemarketcheck_gettex.php?q=' + encodeURIComponent(isin), '_blank');
            e.stopPropagation();
        };

        containerElement.appendChild(wrapper);
    }

    // ─── Comment handling ────────────────────────────────────────────────────

    function applyReversesplitRowState(row, commentText) {
        const isReverseSplit = !!(commentText && commentText.toLowerCase().includes('reversesplit'));
        row.classList.toggle('reversesplit-row', isReverseSplit);
        return isReverseSplit;
    }

    function handleCommentInput(symbol, inputEl) {
        const value = inputEl.value;
        const sig = allSignals.find(s => s.symbol === symbol);
        if (sig) sig.comment = value;

        const row = inputEl.closest('tr');
        if (row) applyReversesplitRowState(row, value);
    }

    // ─── Apply stored data from JSON (auto-restore) ──────────────────────

    function applyStoredData() {
        log('info', '🔄 Applying stored data from stockscreener.json...');
        fetch('?get_json=1')
            .then(res => res.json())
            .then(data => {
                if (!data || !Array.isArray(data) || data.length === 0) {
                    log('debug', 'No stored data found or empty JSON');
                    return;
                }
                // Build map symbol -> {isin, status, comment}
                const map = {};
                data.forEach(item => {
                    if (item.symbol && item.isin) {
                        map[item.symbol] = {
                            isin: item.isin,
                            status: item.gettex_status || '',
                            comment: item.comment || ''
                        };
                    }
                });

                const rows = document.querySelectorAll('#signalBody tr');
                let updatedCount = 0;
                rows.forEach(row => {
                    const symbol = row.dataset.symbol;
                    if (!symbol) return;
                    const entry = map[symbol];
                    if (!entry) return;

                    // ── Restore comment (independent of ISIN lookup state) ──
                    const commentInput = row.querySelector('.comment-input');
                    if (commentInput && entry.comment) {
                        commentInput.value = entry.comment;
                        const sig = allSignals.find(s => s.symbol === symbol);
                        if (sig) sig.comment = entry.comment;
                        applyReversesplitRowState(row, entry.comment);
                    }

                    const isinCell = row.querySelector('td[data-cell="isin"]');
                    if (!isinCell) return;

                    // Check if already has an ISIN (manual lookup already done)
                    const existingLink = isinCell.querySelector('.isin-link');
                    if (existingLink) {
                        const text = existingLink.textContent.trim();
                        if (/^[A-Z]{2}[A-Z0-9]{10}$/.test(text)) {
                            // Already has ISIN, skip to preserve manual selection
                            updatedCount++;
                            return;
                        }
                        // It's a lookup link – we'll replace it
                    }

                    // Remove all children (lookup link, any iframes)
                    isinCell.innerHTML = '';

                    // Add ISIN link (green)
                    const isinSpan = document.createElement('span');
                    isinSpan.className = 'isin-link';
                    isinSpan.style.color = '#3fb950';
                    isinSpan.style.borderColor = '#3fb950';
                    isinSpan.textContent = entry.isin;
                    isinCell.appendChild(isinSpan);

                    // We already know the status from JSON — mark the cell so
                    // saveToJSON() uses this value directly (no iframe present to scrape)
                    isinCell.dataset.gettexStatus = entry.status;
                    isinCell.dataset.fromJson = '1';

                    // Render the known status as plain text - no iframe needed
                    appendGettexStatusText(isinCell, entry.isin, entry.status);

                    // Also update the allSignals object for sorting
                    const sig = allSignals.find(s => s.symbol === symbol);
                    if (sig) {
                        sig.isin = entry.isin;
                        sig.gettexStatus = entry.status;
                        sig.gettexKnown = true;
                    }

                    updatedCount++;
                });

                if (updatedCount > 0) {
                    log('success', `✅ Applied stored data to ${updatedCount} rows`);
                    // Re-sort to reflect ISIN/comment changes
                    sortTable(sortColumn);
                } else {
                    log('debug', 'No rows needed updating from stored data');
                }
            })
            .catch(err => {
                log('error', 'Failed to load stored data:', err);
            });
    }

    // ─── Save to JSON ────────────────────────────────────────────────────────

    function saveToJSON() {
        const btn = document.getElementById('saveBtn');
        btn.disabled = true;
        btn.textContent = '⏳ Saving...';
        setStatus('scanning', 'Collecting data from rows with ISIN...');

        const rows = document.querySelectorAll('#signalBody tr');
        const dataToSave = [];

        rows.forEach(row => {
            const symbol = row.dataset.symbol;
            if (!symbol) return;

            // Check if ISIN is already known (valid format)
            const isinCell = row.querySelector('td[data-cell="isin"]');
            const isinLink = isinCell ? isinCell.querySelector('.isin-link') : null;
            if (!isinLink) return;
            const linkText = isinLink.textContent.trim();
            // ISIN pattern: two letters + 10 alphanumeric
            if (!/^[A-Z]{2}[A-Z0-9]{10}$/.test(linkText)) return;
            const isin = linkText;

            // Find the iframe inside the same cell
            const iframe = isinCell.querySelector('.market-badge-iframe');
            let gettexStatus = '';
            if (iframe) {
                try {
                    const iframeDoc = iframe.contentDocument || iframe.contentWindow.document;
                    if (iframeDoc) {
                        // PRIMARY: get the badge element directly
                        const badgeElement = iframeDoc.querySelector('.gettex-badge');
                        if (badgeElement) {
                            gettexStatus = badgeElement.textContent.trim();
                        } else {
                            // FALLBACK: remove scripts and get body text
                            const bodyClone = iframeDoc.body.cloneNode(true);
                            bodyClone.querySelectorAll('script, style, link').forEach(el => el.remove());
                            gettexStatus = bodyClone.textContent.trim();
                        }
                    }
                } catch (e) {
                    log('error', 'Could not read iframe content for ' + symbol, e);
                }
            } else {
                // No iframe (JSON-restored row) - read the status text wrapper directly
                const textWrapper = isinCell.querySelector('.market-badge-wrapper');
                if (textWrapper) {
                    const text = textWrapper.textContent.trim();
                    gettexStatus = (text && text !== '—') ? text : '';
                }
            }

            // Comment is only saved when the row has a valid ISIN (see above 'if (!isinLink) return;')
            const commentInput = row.querySelector('.comment-input');
            const comment = commentInput ? commentInput.value.trim() : '';

            dataToSave.push({
                symbol: symbol,
                isin: isin,
                gettex_status: gettexStatus || '',
                comment: comment
            });
        });

        if (dataToSave.length === 0) {
            setStatus('error', 'No rows with valid ISIN found to save.');
            btn.disabled = false;
            btn.textContent = '💾 Save to JSON';
            return;
        }

        log('info', 'Saving ' + dataToSave.length + ' entries to JSON');

        fetch('?save_json=1', {
            method: 'POST',
            headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
            body: 'save_json=1&data=' + encodeURIComponent(JSON.stringify(dataToSave))
        })
        .then(res => res.json())
        .then(result => {
            if (result.success) {
                const updated = result.updated || 0;
                setStatus('done', '✅ Added ' + result.added + ' new, updated ' + updated + ' — ' + result.count + ' total in stockscreener.json');
                log('success', 'Saved to JSON: +' + result.added + ' new, ' + updated + ' updated, ' + result.count + ' total');
            } else {
                setStatus('error', '❌ Save failed: ' + (result.error || 'Unknown error'));
                log('error', 'Save failed', result);
            }
        })
        .catch(err => {
            setStatus('error', '❌ Network error while saving');
            log('error', 'Network error', err);
        })
        .finally(() => {
            btn.disabled = false;
            btn.textContent = '💾 Save to JSON';
        });
    }

    // ─── Start Scan ──────────────────────────────────────────────────────────

    function startScan() {
        const btn = document.getElementById('scanBtn');
        btn.disabled = true;
        btn.textContent = '⏳ Scanning...';
        btn.className = 'scan-btn scanning';

        allSignals = [];
        document.getElementById('signalBody').innerHTML = '';
        document.getElementById('totalCount').textContent = '...';
        document.getElementById('totalCount').className = 'stat-value loading';

        setStatus('scanning', 'Initializing scan...');
        log('info', '=== Scan started ===');

        if (eventSource) {
            eventSource.close();
            eventSource = null;
        }

        eventSource = new EventSource('?stream=1');

        eventSource.addEventListener('status', function(e) {
            const data = JSON.parse(e.data);
            setStatus('scanning', data.message);
            log('info', 'STATUS:', data.message);
        });

        eventSource.addEventListener('progress', function(e) {
            const data = JSON.parse(e.data);
            const source = data.source;
            const checked = data.checked;
            const total = data.total;
            const skipped = data.skipped || 0;
            const keptPct = data.kept_pct || 0;

            const key = SOURCE_KEY_MAP[source];
            if (key) {
                stats[`${key}_checked`] = checked;
                stats[`${key}_total`] = total;
                if (skipped) stats[`${key}_skipped_total`] = skipped;
            }

            const totalItems = Object.keys(SOURCE_KEY_MAP).reduce((sum, s) => sum + (stats[`${SOURCE_KEY_MAP[s]}_total`] || 0), 0);
            const checkedItems = Object.keys(SOURCE_KEY_MAP).reduce((sum, s) => sum + (stats[`${SOURCE_KEY_MAP[s]}_checked`] || 0), 0);
            const progress = totalItems > 0 ? Math.round((checkedItems / totalItems) * 100) : 0;

            document.getElementById('progressCount').textContent = progress + '%';

            let msg = `${source}: ${checked}/${total}`;
            if (skipped > 0) msg += ` (kept ${keptPct}% of original)`;
            if (data.signals) msg += `, ${data.signals} signals`;
            setStatus('scanning', msg);
            log('debug', 'PROGRESS:', msg);
        });

        eventSource.addEventListener('signal', function(e) {
            const sig = JSON.parse(e.data);

            if (sig.stats) {
                stats = sig.stats;
                updateStats();
            }

            allSignals.push(sig);
            renderAllSignals();

            document.getElementById('totalCount').textContent = allSignals.length;
            document.getElementById('totalCount').className = 'stat-value';

            const container = document.getElementById('resultsContainer');
            container.scrollTop = container.scrollHeight;
            
            log('info', 'SIGNAL:', sig.symbol, sig.strategy, sig.price);
        });

        eventSource.addEventListener('done', function(e) {
            const data = JSON.parse(e.data);
            setStatus('done', data.message);
            log('success', '=== Scan complete ===', data.message);

            btn.disabled = false;
            btn.textContent = '🔄 Scan Again';
            btn.className = 'scan-btn';

            if (eventSource) {
                eventSource.close();
                eventSource = null;
            }

            if (data.stats) {
                stats = data.stats;
                updateStats();
            }

            document.getElementById('progressCount').textContent = '100%';

            // ─── 🔁 Auto‑apply stored data ──────────────────────────────────
            applyStoredData();
        });

        eventSource.addEventListener('error', function(e) {
            log('error', 'EventSource error:', e);
            if (eventSource && eventSource.readyState === EventSource.CLOSED) {
                btn.disabled = false;
                btn.textContent = '🔄 Scan Again';
                btn.className = 'scan-btn';
                setStatus('error', 'Connection closed unexpectedly');
                log('error', 'Connection closed unexpectedly');
            }
        });

        eventSource.addEventListener('close', function(e) {
            btn.disabled = false;
            btn.textContent = '🔄 Scan Again';
            btn.className = 'scan-btn';
            log('info', 'EventSource closed');
        });
    }

    // ─── Sort Table ──────────────────────────────────────────────────────────

    function sortTable(column) {
        if (sortColumn === column) {
            sortDirection = sortDirection === 'asc' ? 'desc' : 'asc';
        } else {
            sortColumn = column;
            sortDirection = 'desc';
        }

        const th = document.querySelector(`th[data-col="${column}"]`);
        sortType = th ? th.dataset.type : 'string';

        document.querySelectorAll('th').forEach(h => {
            h.classList.remove('sorted', 'sorted-asc', 'sorted-desc');
        });
        th.classList.add('sorted', `sorted-${sortDirection}`);

        renderAllSignals();
    }

    // ─── Render All Signals ──────────────────────────────────────────────────

    function renderAllSignals() {
        const tbody = document.getElementById('signalBody');
        tbody.innerHTML = '';

        const sorted = [...allSignals].sort((a, b) => {
            let valA = a[sortColumn];
            let valB = b[sortColumn];
            
            if (valA === null || valA === undefined) valA = '';
            if (valB === null || valB === undefined) valB = '';
            
            if (sortType === 'string') {
                valA = String(valA).toLowerCase();
                valB = String(valB).toLowerCase();
            }
            
            if (sortType === 'number') {
                valA = parseFloat(valA) || 0;
                valB = parseFloat(valB) || 0;
            }
            
            if (valA < valB) return sortDirection === 'asc' ? -1 : 1;
            if (valA > valB) return sortDirection === 'asc' ? 1 : -1;
            return 0;
        });

        sorted.forEach(sig => {
            const row = createSignalRow(sig);
            tbody.appendChild(row);
        });
    }

    // ─── Create a single signal row ──────────────────────────────────────────

    function createSignalRow(sig) {
        const rsiClass = sig.rsi > 70 ? 'rsi-hot' : (sig.rsi > 50 ? 'rsi-warn' : 'rsi-ok');
        const stratClass = {
            'BREAKOUT': 'strat-breakout',
            'VOL-SURGE': 'strat-vol',
            'REVERSAL': 'strat-rev',
            'HIGH-MOMENTUM': 'strat-high',
            'MOM-GAP': 'strat-gap',
        }[sig.strategy] || '';
        const sourceClassMap = {
            'TradingView': 'source-tv',
            'NASDAQ': 'source-nas',
            'NasdaqGainers': 'source-nasg',
            'YahooTrending': 'source-ytrend',
        };
        const sourceLabelMap = {
            'TradingView': 'TV',
            'NASDAQ': 'NAS',
            'NasdaqGainers': 'NASG',
            'YahooTrending': 'YTR',
        };
        const sourceClass = sourceClassMap[sig.source] || '';
        const sourceLabel = sourceLabelMap[sig.source] || sig.source;
        const bandClass = sig.band ? 'band-' + sig.band.toLowerCase() : '';

        let isinHtml = '';
        if (sig.isin && sig.gettexKnown) {
            // Restored from stockscreener.json - status already known, NO iframe
            const escapedIsin = sig.isin;
            const statusText = (sig.gettexStatus && sig.gettexStatus.trim()) ? sig.gettexStatus.trim() : '—';
            isinHtml = `
                <span class="isin-link" style="color:#3fb950;border-color:#3fb950;">${escapedIsin}</span>
                <div class="market-badge-wrapper" style="cursor:pointer; display:block; margin-top:4px; font-size:11px; padding:2px 6px; border-radius:4px; background:#21262d; color:#8b949e; border:1px solid #30363d;"
                     title="Click to check on xchangemarketcheck_gettex"
                     onclick="window.open('xchangemarketcheck_gettex.php?q=' + encodeURIComponent('${escapedIsin}'), '_blank')">${statusText}</div>
            `;
        } else if (sig.isin) {
            // ISIN known live (fresh lookup) – show clickable ISIN and live iframe badge
            const escapedIsin = sig.isin;
            isinHtml = `
                <span class="isin-link" style="color:#3fb950;border-color:#3fb950;">${escapedIsin}</span>
                <div class="market-badge-wrapper" style="cursor:pointer; display:block; margin-top:4px;" 
                     title="Click to check on xchangemarketcheck_gettex"
                     onclick="window.open('xchangemarketcheck_gettex.php?q=' + encodeURIComponent('${escapedIsin}'), '_blank')">
                    <iframe class="market-badge-iframe" 
                            src="xchangemarket_badge.php?q=${encodeURIComponent(escapedIsin)}" 
                            style="width:100%;height:60px;border:none;display:block;pointer-events:none;" 
                            loading="lazy">
                    </iframe>
                </div>
            `;
        } else {
            // No ISIN yet – show lookup link
            const companyName = sig.companyName || sig.symbol;
            const escapedCompany = companyName.replace(/'/g, "\\'").replace(/"/g, '&quot;');
            isinHtml = `<span class="isin-link" onclick="lookupISIN('${sig.symbol}', '${escapedCompany}', this.closest('tr'))">🔍 Lookup ISIN</span>`;
        }

        const commentValue = sig.comment || '';
        const commentHtml = `<input type="text" class="comment-input" placeholder="Add note..." value="${escapeHtml(commentValue)}" oninput="handleCommentInput('${sig.symbol}', this)">`;

        const display = (currentFilter === 'all' || sig.source === currentFilter) ? '' : 'style="display:none;"';

        const tr = document.createElement('tr');
        tr.className = 'signal-flash';
        tr.setAttribute('data-symbol', escapeHtml(sig.symbol));
        tr.setAttribute('data-source', escapeHtml(sig.source));
        tr.setAttribute('data-strategy', escapeHtml(sig.strategy));
        tr.setAttribute('data-trigger', escapeHtml(sig.trigger));
        tr.setAttribute('data-trigger_pct', sig.trigger_pct);
        tr.setAttribute('data-price', sig.price);
        tr.setAttribute('data-vol', sig.vol);
        tr.setAttribute('data-avg_vol', sig.avg_vol);
        tr.setAttribute('data-spike', sig.spike);
        tr.setAttribute('data-rsi', sig.rsi);
        tr.setAttribute('data-mom3d', sig.mom3d);
        tr.setAttribute('data-band', sig.band || '');
        tr.setAttribute('data-isin', sig.isin || '');
        tr.setAttribute('data-company', sig.companyName || sig.symbol);
        tr.setAttribute('style', display);

        tr.innerHTML = `
            <td class="sym">
                <a href="<?= $TICKER_BASE_URL ?>${escapeHtml(sig.symbol)}" target="_blank" rel="noopener">${escapeHtml(sig.symbol)}</a>
                <span class="company-name">${escapeHtml(sig.companyName || sig.symbol)}</span>
            </td>
            <td><span class="source-badge ${sourceClass}">${sourceLabel}</span></td>
            <td><span class="strat ${stratClass}">${sig.strategy}</span></td>
            <td style="color:#8b949e;font-size:12px;">${escapeHtml(sig.trigger)}</td>
            <td>${sig.trigger_pct >= 0 ? '+' : ''}${sig.trigger_pct}%</td>
            <td>$${sig.price.toFixed(2)}</td>
            <td>${formatVol(sig.vol)}</td>
            <td>${formatVol(sig.avg_vol)}</td>
            <td class="spike">${sig.spike}x</td>
            <td class="${rsiClass}">${sig.rsi}</td>
            <td class="${sig.mom3d >= 0 ? 'mom-pos' : 'mom-neg'}">${sig.mom3d > 0 ? '+' : ''}${sig.mom3d}%</td>
            <td>${sig.band ? `<span class="band-badge ${bandClass}">${sig.band}</span>` : ''}</td>
            <td data-cell="isin">${isinHtml}</td>
            <td data-cell="comment">${commentHtml}</td>
        `;

        // Apply strikethrough state on initial render if the restored comment already flags a reverse split
        applyReversesplitRowState(tr, commentValue);

        return tr;
    }

    // ─── Update Stats ──────────────────────────────────────────────────────────

    function updateStats() {
        document.getElementById('tvCount').textContent = stats.tv_signals || 0;
        document.getElementById('nasCount').textContent = stats.nas_signals || 0;
        document.getElementById('nasgCount').textContent = stats.nasg_signals || 0;
        document.getElementById('ytrendCount').textContent = stats.ytrend_signals || 0;

        const boCount = allSignals.filter(s => s.strategy === 'BREAKOUT').length;
        const vsCount = allSignals.filter(s => s.strategy === 'VOL-SURGE').length;
        const rvCount = allSignals.filter(s => s.strategy === 'REVERSAL').length;
        const hmCount = allSignals.filter(s => s.strategy === 'HIGH-MOMENTUM').length;
        const mgCount = allSignals.filter(s => s.strategy === 'MOM-GAP').length;

        document.getElementById('boCount').textContent = boCount;
        document.getElementById('vsCount').textContent = vsCount;
        document.getElementById('rvCount').textContent = rvCount;
        document.getElementById('hmCount').textContent = hmCount;
        document.getElementById('mgCount').textContent = mgCount;

        const totalItems = Object.keys(SOURCE_KEY_MAP).reduce((sum, s) => sum + (stats[`${SOURCE_KEY_MAP[s]}_total`] || 0), 0);
        const checkedItems = Object.keys(SOURCE_KEY_MAP).reduce((sum, s) => sum + (stats[`${SOURCE_KEY_MAP[s]}_checked`] || 0), 0);
        const progress = totalItems > 0 ? Math.round((checkedItems / totalItems) * 100) : 0;
        document.getElementById('progressCount').textContent = progress + '%';
    }

    // ─── Status Bar ──────────────────────────────────────────────────────────

    function setStatus(type, message) {
        const dot = document.getElementById('statusDot');
        const msg = document.getElementById('statusMessage');

        dot.className = 'status-dot ' + type;
        msg.textContent = message;
    }

    // ─── Filtering ────────────────────────────────────────────────────────────

    function filterSource(source) {
        currentFilter = source;

        document.querySelectorAll('.source-pill').forEach(p => {
            p.classList.toggle('active', p.dataset.filter === source);
        });

        const rows = document.querySelectorAll('#signalBody tr');
        rows.forEach(row => {
            if (source === 'all' || row.dataset.source === source) {
                row.style.display = '';
            } else {
                row.style.display = 'none';
            }
        });
    }

    // ─── Helpers ──────────────────────────────────────────────────────────────

    function formatVol(v) {
        return v >= 1000000 ? (v/1000000).toFixed(1) + 'M' : (v/1000).toFixed(1) + 'K';
    }

    // ─── Initialize ────────────────────────────────────────────────────────────

    document.addEventListener('DOMContentLoaded', function() {
        const defaultTh = document.querySelector('th[data-col="trigger_pct"]');
        if (defaultTh) {
            defaultTh.classList.add('sorted', 'sorted-desc');
        }
        sortColumn = 'trigger_pct';
        sortDirection = 'desc';
        sortType = 'number';
        
        window.onclick = function(event) {
            const modal = document.getElementById('isinModal');
            if (event.target === modal) {
                closeISINModal();
            }
        };

        log('info', 'Page loaded, ISIN lookup ready (proxy active).');
    });
    </script>

</body>
</html>