<?php
/**
 * Simple Foreground Processor - Browser-based continuous processing
 * This fixes the JSON parsing issue and provides reliable browser-based processing
 */

require_once 'includes/config.php';
require_once 'includes/db.php';
require_once 'includes/auth.php';

// Handle AJAX requests
if (isset($_GET['action']) && $_GET['action'] === 'process_batch') {
    // Clean output buffer to prevent HTML/text contamination
    if (ob_get_level()) {
        ob_clean();
    }
    
    header('Content-Type: application/json');
    
    try {
        $auth = new Auth();
        if (!$auth->isLoggedIn()) {
            throw new Exception('Unauthorized');
        }

        $db = Database::getInstance();
        
        // Load GptHelper
        if (!class_exists('GptHelper')) {
            require_once 'includes/GptHelper.php';
        }
        
        if (!class_exists('GptHelper')) {
            throw new Exception('GptHelper class not found');
        }
        
        // Get a small batch to process
        $batchSize = 3; // Small batch for reliability
        $query = $db->query("
            SELECT id, attribute1_id, attribute2_id, choice1, choice2, attribute1_name, attribute2_name 
            FROM panel_directives 
            WHERE llm_checked = 0 
            ORDER BY id ASC 
            LIMIT $batchSize
        ");
        
        $combinations = [];
        $processed = 0;
        $errors = 0;
        
        if ($query && $query->num_rows > 0) {
            while ($combination = $query->fetch_assoc()) {
                try {
                    $result = processCombination($combination, $db);
                    
                    $combinations[] = [
                        'id' => $combination['id'],
                        'combination' => "{$combination['attribute1_name']}={$combination['choice1']} + {$combination['attribute2_name']}={$combination['choice2']}",
                        'result' => $result['success'] ? ($result['is_impossible'] ? 'IMPOSSIBLE' : 'POSSIBLE') : 'ERROR',
                        'reasoning' => $result['success'] ? substr($result['reasoning'], 0, 100) : $result['error']
                    ];
                    
                    if ($result['success']) {
                        $processed++;
                    } else {
                        $errors++;
                    }
                } catch (Exception $e) {
                    $errors++;
                    $combinations[] = [
                        'id' => $combination['id'],
                        'combination' => "{$combination['attribute1_name']}={$combination['choice1']} + {$combination['attribute2_name']}={$combination['choice2']}",
                        'result' => 'ERROR',
                        'reasoning' => $e->getMessage()
                    ];
                }
            }
        }
        
        // Check if more combinations exist
        $remainingQuery = $db->query("SELECT COUNT(*) as count FROM panel_directives WHERE llm_checked = 0");
        $remaining = $remainingQuery->fetch_assoc()['count'];
        
        // Get total progress
        $totalQuery = $db->query("SELECT COUNT(*) as count FROM panel_directives");
        $total = $totalQuery->fetch_assoc()['count'];
        
        $processedTotal = $db->query("SELECT COUNT(*) as count FROM panel_directives WHERE llm_checked = 1")->fetch_assoc()['count'];
        
        echo json_encode([
            'success' => true,
            'processed' => $processed,
            'errors' => $errors,
            'combinations' => $combinations,
            'has_more' => $remaining > 0,
            'progress' => [
                'total' => $total,
                'processed' => $processedTotal,
                'remaining' => $remaining,
                'percentage' => $total > 0 ? round(($processedTotal / $total) * 100, 2) : 0
            ]
        ]);
        
    } catch (Exception $e) {
        echo json_encode([
            'success' => false,
            'message' => $e->getMessage(),
            'error_type' => 'exception'
        ]);
    }
    
    exit;
}

// Regular page display
try {
    $auth = new Auth();
    if (!$auth->isLoggedIn()) {
        die("❌ Please log in first");
    }

    $db = Database::getInstance();
    
    // Get current statistics
    $totalQuery = $db->query("SELECT COUNT(*) as count FROM panel_directives");
    $total = $totalQuery->fetch_assoc()['count'];
    
    $processedQuery = $db->query("SELECT COUNT(*) as count FROM panel_directives WHERE llm_checked = 1");
    $processed = $processedQuery->fetch_assoc()['count'];
    
    $impossibleQuery = $db->query("SELECT COUNT(*) as count FROM panel_directives WHERE llm_checked = 1 AND is_impossible = 1");
    $impossible = $impossibleQuery->fetch_assoc()['count'];
    
    $remaining = $total - $processed;
    $percentage = $total > 0 ? round(($processed / $total) * 100, 2) : 0;

} catch (Exception $e) {
    die("❌ Error: " . htmlspecialchars($e->getMessage()));
}
?>
<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <meta name="viewport" content="width=device-width, initial-scale=1.0">
    <title>Simple Foreground Processor</title>
    <style>
        body { font-family: Arial, sans-serif; margin: 20px; line-height: 1.6; }
        .success { color: green; font-weight: bold; }
        .error { color: red; font-weight: bold; }
        .warning { color: orange; font-weight: bold; }
        .info { color: blue; }
        .section { margin: 20px 0; padding: 15px; border: 1px solid #ddd; border-radius: 5px; }
        .progress { width: 100%; height: 30px; background: #ddd; border-radius: 15px; margin: 10px 0; overflow: hidden; }
        .progress-bar { height: 100%; background: linear-gradient(90deg, #28a745, #20c997); transition: width 0.3s; text-align: center; line-height: 30px; color: white; font-weight: bold; }
        .stats { display: grid; grid-template-columns: repeat(auto-fit, minmax(150px, 1fr)); gap: 15px; margin: 20px 0; }
        .stat-card { background: #f8f9fa; padding: 15px; border-radius: 8px; text-align: center; border-left: 4px solid #007bff; }
        .stat-value { font-size: 24px; font-weight: bold; color: #007bff; }
        .stat-label { font-size: 14px; color: #666; margin-top: 5px; }
        .log { height: 400px; overflow-y: scroll; border: 1px solid #ddd; padding: 15px; margin: 15px 0; background: #f8f9fa; font-family: monospace; font-size: 13px; }
        .log-entry { margin: 3px 0; padding: 5px; border-radius: 3px; }
        .log-success { background: #d4edda; color: #155724; }
        .log-error { background: #f8d7da; color: #721c24; }
        .log-info { background: #d1ecf1; color: #0c5460; }
        .log-warning { background: #fff3cd; color: #856404; }
        .controls { margin: 20px 0; }
        .btn { padding: 12px 24px; margin: 5px; border: none; border-radius: 5px; cursor: pointer; font-size: 16px; }
        .btn-success { background: #28a745; color: white; }
        .btn-danger { background: #dc3545; color: white; }
        .btn-primary { background: #007bff; color: white; }
        .processing { animation: pulse 2s infinite; }
        @keyframes pulse { 0% { opacity: 1; } 50% { opacity: 0.7; } 100% { opacity: 1; } }
    </style>
</head>
<body>
    <h1>🚀 Simple Foreground Processor</h1>
    
    <div class="section">
        <h2>📊 Current Statistics</h2>
        <div class="stats">
            <div class="stat-card">
                <div class="stat-value"><?php echo number_format($total); ?></div>
                <div class="stat-label">Total Combinations</div>
            </div>
            <div class="stat-card">
                <div class="stat-value"><?php echo number_format($processed); ?></div>
                <div class="stat-label">Processed</div>
            </div>
            <div class="stat-card">
                <div class="stat-value"><?php echo number_format($impossible); ?></div>
                <div class="stat-label">Impossible Found</div>
            </div>
            <div class="stat-card">
                <div class="stat-value"><?php echo number_format($remaining); ?></div>
                <div class="stat-label">Remaining</div>
            </div>
        </div>
        
        <div class="progress">
            <div class="progress-bar" id="progressBar" style="width: <?php echo $percentage; ?>%">
                <?php echo $percentage; ?>% Complete
            </div>
        </div>
    </div>
    
    <div class="section">
        <h2>🎮 Processing Controls</h2>
        <div class="controls">
            <button id="startBtn" class="btn btn-success" onclick="startProcessing()">🚀 Start Processing</button>
            <button id="stopBtn" class="btn btn-danger" onclick="stopProcessing()" disabled>⏹ Stop Processing</button>
            <button class="btn btn-primary" onclick="location.reload()">🔄 Refresh Stats</button>
        </div>
        
        <div id="status" class="info">Ready to start processing</div>
        <div id="rate" class="info"></div>
    </div>
    
    <div class="section">
        <h2>📋 Processing Log</h2>
        <div id="log" class="log">
            <div class="log-info">Ready to start processing. Click "Start Processing" to begin.</div>
        </div>
    </div>
    
    <div class="section">
        <h2>🔗 Navigation</h2>
        <a href="optimaize.php" class="btn btn-primary">Back to OptimAIze Page</a>
        <a href="fix_stuck_analysis.php" class="btn btn-primary">Back to Diagnostics</a>
    </div>

    <script>
        let isProcessing = false;
        let processCount = 0;
        let errorCount = 0;
        let batchNumber = 0;
        let startTime = null;
        let totalProcessed = <?php echo $processed; ?>;
        
        function addLog(message, type = 'info') {
            const log = document.getElementById('log');
            const timestamp = new Date().toLocaleTimeString();
            const logEntry = document.createElement('div');
            logEntry.className = `log-entry log-${type}`;
            logEntry.textContent = `[${timestamp}] ${message}`;
            log.appendChild(logEntry);
            log.scrollTop = log.scrollHeight;
            
            // Keep only last 100 log entries
            while (log.children.length > 100) {
                log.removeChild(log.firstChild);
            }
        }
        
        function updateStatus(message, isActive = false) {
            const statusElement = document.getElementById('status');
            statusElement.textContent = message;
            statusElement.className = isActive ? 'info processing' : 'info';
        }
        
        function updateProgress(data) {
            const progressBar = document.getElementById('progressBar');
            const percentage = data.progress.percentage;
            progressBar.style.width = percentage + '%';
            progressBar.textContent = percentage + '% Complete';
            
            // Update stats
            const statCards = document.querySelectorAll('.stat-value');
            if (statCards[1]) statCards[1].textContent = data.progress.processed.toLocaleString();
            if (statCards[3]) statCards[3].textContent = data.progress.remaining.toLocaleString();
            
            totalProcessed = data.progress.processed;
        }
        
        function updateRate() {
            if (startTime && processCount > 0) {
                const elapsed = (Date.now() - startTime) / 1000 / 60; // minutes
                const rate = Math.round(processCount / elapsed);
                const remaining = <?php echo $remaining; ?> - processCount;
                const eta = rate > 0 ? Math.round(remaining / rate) : 0;
                
                document.getElementById('rate').textContent = 
                    `Rate: ${rate}/min | Processed this session: ${processCount} | ETA: ${eta} minutes`;
            }
        }
        
        async function processBatch() {
            if (!isProcessing) return;
            
            try {
                batchNumber++;
                updateStatus(`Processing batch ${batchNumber}...`, true);
                addLog(`Starting batch ${batchNumber}`);
                
                const response = await fetch('?action=process_batch');
                const text = await response.text();
                
                let data;
                try {
                    data = JSON.parse(text);
                } catch (e) {
                    throw new Error(`JSON Parse Error. Server returned: ${text.substring(0, 200)}...`);
                }
                
                if (data.success) {
                    processCount += data.processed;
                    errorCount += data.errors;
                    
                    addLog(`Batch ${batchNumber} complete: ${data.processed} processed, ${data.errors} errors`, 'success');
                    
                    // Log individual results
                    if (data.combinations) {
                        data.combinations.forEach(combo => {
                            const type = combo.result === 'POSSIBLE' ? 'success' : 
                                        combo.result === 'IMPOSSIBLE' ? 'warning' : 'error';
                            addLog(`→ ${combo.combination} = ${combo.result}`, type);
                            if (combo.reasoning && combo.result !== 'POSSIBLE') {
                                addLog(`  Reason: ${combo.reasoning}`, 'info');
                            }
                        });
                    }
                    
                    updateProgress(data);
                    updateRate();
                    
                    if (data.has_more && isProcessing) {
                        // Continue with next batch after delay
                        setTimeout(processBatch, 3000); // 3 second delay between batches
                    } else {
                        stopProcessing();
                        if (!data.has_more) {
                            updateStatus('✅ All combinations processed!');
                            addLog('🎉 Processing complete! All combinations have been analyzed.', 'success');
                        }
                    }
                } else {
                    throw new Error(data.message || 'Unknown error occurred');
                }
            } catch (error) {
                addLog(`Batch ${batchNumber} failed: ${error.message}`, 'error');
                updateStatus('❌ Processing stopped due to error');
                stopProcessing();
            }
        }
        
        function startProcessing() {
            if (isProcessing) return;
            
            isProcessing = true;
            startTime = Date.now();
            processCount = 0;
            errorCount = 0;
            batchNumber = 0;
            
            document.getElementById('startBtn').disabled = true;
            document.getElementById('stopBtn').disabled = false;
            
            updateStatus('🚀 Starting processing...', true);
            addLog('Processing started. Keep this tab open and active.', 'info');
            
            // Start processing after 1 second
            setTimeout(processBatch, 1000);
        }
        
        function stopProcessing() {
            isProcessing = false;
            
            document.getElementById('startBtn').disabled = false;
            document.getElementById('stopBtn').disabled = true;
            
            updateStatus('⏹ Processing stopped');
            addLog(`Processing stopped. Session stats: ${processCount} processed, ${errorCount} errors`, 'info');
        }
        
        // Warn user when leaving the page
        window.addEventListener('beforeunload', function(e) {
            if (isProcessing) {
                e.preventDefault();
                e.returnValue = 'Processing is active. Are you sure you want to leave?';
            }
        });
        
        // Auto-update rate every 30 seconds
        setInterval(updateRate, 30000);
    </script>
</body>
</html>

<?php
function processCombination($combination, $db) {
    try {
        $prompt = sprintf(
            "Analyze this demographic combination:\n\n%s = %s\n%s = %s\n\nIs this combination logically possible in real-world demographics? Respond with 'POSSIBLE' or 'IMPOSSIBLE' followed by a brief reason.",
            $combination['attribute1_name'],
            $combination['choice1'],
            $combination['attribute2_name'],
            $combination['choice2']
        );
        
        $messages = [
            [
                'role' => 'system',
                'content' => 'You are an expert demographic analyst. Analyze if the given combination is logically possible.'
            ],
            [
                'role' => 'user',
                'content' => $prompt
            ]
        ];
        
        $response = GptHelper::makeRequest($messages, 'gpt-4', 0.1);
        
        if (!$response['success']) {
            throw new Exception("GPT request failed: " . $response['error']);
        }
        
        $content = trim($response['response']);
        $isImpossible = stripos($content, 'IMPOSSIBLE') === 0 ? 1 : 0;
        
        // Extract reasoning
        $reasoning = trim(str_ireplace(['POSSIBLE', 'IMPOSSIBLE'], '', $content));
        if (empty($reasoning)) {
            $reasoning = $content;
        }
        
        // Update database
        $stmt = $db->prepare("UPDATE panel_directives SET 
            llm_checked = 1, 
            is_impossible = ?, 
            llm_reasoning = ?,
            updated_at = NOW()
            WHERE id = ?");
        
        $stmt->bind_param('isi', $isImpossible, $reasoning, $combination['id']);
        
        if (!$stmt->execute()) {
            throw new Exception("Database update failed");
        }
        
        return [
            'success' => true,
            'is_impossible' => $isImpossible,
            'reasoning' => $reasoning
        ];
        
    } catch (Exception $e) {
        return [
            'success' => false,
            'error' => $e->getMessage()
        ];
    }
}
?>