<?php

namespace App\Controllers;

use App\Core\Request;
use App\Core\Response;
use App\Models\WhatsAppSession;

/**
 * Handles WhatsApp Session Management and communicates with Baileys Node.js Gateway
 */
class WhatsAppController extends BaseController
{
    /**
     * Get the current WhatsApp connection status for the company
     */
    public function status(Request $request, Response $response)
    {
        $companyId = $request->company_id; // Added by AuthMiddleware
        $session = WhatsAppSession::findOrCreate($companyId);
        
        // Strip sensitive/internal data before sending to frontend
        unset($session['phone_hash']);
        
        $response->json([
            'status' => 'success',
            'data' => $session
        ]);
    }

    /**
     * Request a new connection/QR code from the Baileys service
     */
    public function requestQr(Request $request, Response $response)
    {
        $companyId = $request->company_id;
        $session = WhatsAppSession::findOrCreate($companyId);
        
        // Temporarily set to connecting
        WhatsAppSession::updateState($session['id'], ['status' => 'connecting']);
        
        // Call Baileys Node.js Service on port 3722
        $appUrl = rtrim(getenv('APP_URL') ?: 'https://nabeh.intaleqapp.com', '/');
        $nodeUrl = 'http://127.0.0.1:3722/api/sessions/start';
        $payload = json_encode([
            'session_key' => $session['session_key'],
            'webhook_url' => $appUrl . '/api/whatsapp/webhook'
        ]);
        
        $ch = curl_init($nodeUrl);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_POST, true);
        curl_setopt($ch, CURLOPT_POSTFIELDS, $payload);
        curl_setopt($ch, CURLOPT_HTTPHEADER, [
            'Content-Type: application/json',
            'X-Webhook-Secret: ' . getenv('WEBHOOK_SECRET')
        ]);
        curl_setopt($ch, CURLOPT_TIMEOUT, 5);
        $result = curl_exec($ch);
        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        curl_close($ch);
        
        // Note: Even if it fails immediately, the webhook will try to correct the state
        if ($httpCode >= 200 && $httpCode < 300) {
            $response->json([
                'status' => 'success',
                'message' => 'Connection requested. Please poll status to get QR code.'
            ]);
        } else {
            // Revert state on failure
            WhatsAppSession::updateState($session['id'], ['status' => 'disconnected']);
            $response->status(500)->json([
                'status' => 'error',
                'message' => 'Failed to reach WhatsApp Gateway.'
            ]);
        }
    }

    /**
     * Disconnect the current WhatsApp session
     */
    public function disconnect(Request $request, Response $response)
    {
        $companyId = $request->company_id;
        $session = WhatsAppSession::findByCompany($companyId);
        
        if ($session && $session['status'] !== 'disconnected') {
            // Call Baileys Node.js Service to disconnect
            $nodeUrl = 'http://127.0.0.1:3722/api/sessions/disconnect';
            $payload = json_encode(['session_key' => $session['session_key']]);
            
            $ch = curl_init($nodeUrl);
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
            curl_setopt($ch, CURLOPT_POST, true);
            curl_setopt($ch, CURLOPT_POSTFIELDS, $payload);
            curl_setopt($ch, CURLOPT_HTTPHEADER, [
                'Content-Type: application/json',
                'X-Webhook-Secret: ' . getenv('WEBHOOK_SECRET')
            ]);
            curl_setopt($ch, CURLOPT_TIMEOUT, 5);
            curl_exec($ch);
            curl_close($ch);
            
            WhatsAppSession::updateState($session['id'], [
                'status' => 'disconnected',
                'qr_code' => null,
                'phone' => null,
                'phone_hash' => null
            ]);
        }
        
        $response->json(['status' => 'success', 'message' => 'Session disconnected']);
    }

    /**
     * Webhook called by Baileys Node.js server to sync state
     */
    public function webhook(Request $request, Response $response)
    {
        // Internal Security Check
        $secret = $request->getHeader('X-Webhook-Secret');
        if ($secret !== getenv('WEBHOOK_SECRET')) {
            $response->status(403)->json(['error' => 'Unauthorized webhook access']);
            return;
        }

        $body = $request->getBody();
        if (empty($body['session_key']) || empty($body['state'])) {
            $response->status(400)->json(['error' => 'Missing session_key or state']);
            return;
        }

        $session = WhatsAppSession::findBySessionKey($body['session_key']);
        
        if (!$session) {
            $response->status(404)->json(['error' => 'Session not found']);
            return;
        }

        // Handle message received events
        if ($body['state'] === 'message_received') {
            if (empty($body['message'])) {
                $response->status(400)->json(['error' => 'Missing message payload']);
                return;
            }
            
            $msgData = $body['message'];
            
            // 1. Find or create the contact in the CRM
            $contact = \App\Models\Contact::findByPhone($session['company_id'], $msgData['phone']);
            if (!$contact) {

                
                // Determine a fallback name
                $contactName = !empty($msgData['name']) ? $msgData['name'] : 'WA-' . substr($msgData['phone'], -4);
                \App\Models\Contact::createSecure([
                    'company_id' => $session['company_id'],
                    'name' => $contactName,
                    'phone' => $msgData['phone'],
                    'notes' => 'Auto-created via incoming WhatsApp message'
                ]);
            }
            
            // 2. Log the incoming message in history log
            \App\Models\MessageLog::logMessage([
                'company_id' => $session['company_id'],
                'session_id' => $session['id'],
                'contact_phone' => $msgData['phone'],
                'direction' => 'inbound',
                'message_type' => 'text',
                'message_body' => $msgData['body'],
                'whatsapp_message_id' => $msgData['id'],
                'status' => 'read'
            ]);
            
            // 3. Placeholder for Phase 5 Gemini AI auto-reply
            $this->triggerAutoReply($session, $msgData);
            
            $response->json(['status' => 'success', 'message' => 'Incoming message logged']);
            return;
        }

        // Handle connection state sync
        $updateData = [
            'status' => $body['state'] // 'waiting_qr', 'connected', 'disconnected'
        ];

        if ($body['state'] === 'waiting_qr' && !empty($body['qr_code'])) {
            $updateData['qr_code'] = $body['qr_code'];
        } elseif ($body['state'] === 'connected') {
            $updateData['qr_code'] = null; // Clear QR when connected
            if (!empty($body['phone'])) {
                $updateData['phone'] = $body['phone'];
            }
        } elseif ($body['state'] === 'disconnected') {
            $updateData['qr_code'] = null;
        }

        WhatsAppSession::updateState($session['id'], $updateData);

        $response->json(['status' => 'success']);
    }

    /**
     * Trigger Gemini AI Auto-Replies or Keyword rules (Phase 5)
     */
    private function triggerAutoReply(array $session, array $msgData)
    {
        try {
            $rule = \App\Models\ChatbotRule::findActiveForRule($session['company_id'], $session['id']);
            if (!$rule || !$rule['is_active']) {
                return;
            }

            $incomingText = trim($msgData['body']);
            if (empty($incomingText)) {
                return;
            }

            $replyText = null;

            if ($rule['trigger_type'] === 'keyword') {
                $keywords = array_filter(array_map('trim', explode(',', $rule['keyword'])));
                $matched = false;
                foreach ($keywords as $kw) {
                    if (mb_stripos($incomingText, $kw) !== false) {
                        $matched = true;
                        break;
                    }
                }
                if ($matched) {
                    $replyText = $rule['ai_prompt']; // Under keyword rules, ai_prompt stores the predefined static reply
                }
            } elseif ($rule['trigger_type'] === 'gemini_ai') {
                $apiKey = $rule['gemini_api_key'] ?: getenv('GEMINI_API_KEY');
                if (empty($apiKey)) {
                    error_log("[Chatbot Warning] Gemini API Key is not set globally or for company " . $session['company_id']);
                    return;
                }
                $systemPrompt = $rule['ai_prompt'] ?: 'You are a helpful customer support assistant.';
                
                $replyText = \App\Services\GeminiService::generateResponse($apiKey, $systemPrompt, $incomingText);
            }

            if (!empty($replyText)) {
                // Send reply back to the contact via Node.js Gateway
                $gatewayUrl = rtrim(getenv('WHATSAPP_GATEWAY_URL') ?: 'http://localhost:3722', '/');
                if (substr($gatewayUrl, -4) === '/api') {
                    $sendUrl = $gatewayUrl . '/messages/send';
                } else {
                    $sendUrl = $gatewayUrl . '/api/messages/send';
                }

                $payload = json_encode([
                    'session_key' => $session['session_key'],
                    'phone' => $msgData['phone'],
                    'message' => $replyText
                ]);

                $ch = curl_init($sendUrl);
                curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
                curl_setopt($ch, CURLOPT_POST, true);
                curl_setopt($ch, CURLOPT_POSTFIELDS, $payload);
                curl_setopt($ch, CURLOPT_HTTPHEADER, [
                    'Content-Type: application/json',
                    'X-Webhook-Secret: ' . getenv('WEBHOOK_SECRET')
                ]);
                curl_setopt($ch, CURLOPT_TIMEOUT, 10);
                
                $response = curl_exec($ch);
                $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
                curl_close($ch);

                $status = 'failed';
                $errorMsg = null;
                $waMsgId = null;

                if ($httpCode === 200) {
                    $status = 'sent';
                    $resData = json_decode($response, true);
                    $waMsgId = $resData['data']['key']['id'] ?? null;
                } else {
                    $resData = json_decode($response, true);
                    $errorMsg = $resData['error'] ?? 'HTTP Code ' . $httpCode;
                    error_log("[Chatbot Gateway Error] failed to send auto-reply: " . $errorMsg);
                }

                // Log the outbound auto-reply message
                \App\Models\MessageLog::logMessage([
                    'company_id' => $session['company_id'],
                    'session_id' => $session['id'],
                    'contact_phone' => $msgData['phone'],
                    'direction' => 'outbound',
                    'message_type' => 'text',
                    'message_body' => $replyText,
                    'whatsapp_message_id' => $waMsgId,
                    'status' => $status,
                    'error_message' => $errorMsg
                ]);
            }
        } catch (\Exception $e) {
            error_log("[Chatbot Exception] Error: " . $e->getMessage() . " in " . $e->getFile() . ":" . $e->getLine());
        }
    }
}