<?php
header('Content-Type: application/json; charset=utf-8');
header('Access-Control-Allow-Origin: *');
header('Access-Control-Allow-Methods: POST, OPTIONS');
header('Access-Control-Allow-Headers: Content-Type, Authorization');
if ($_SERVER['REQUEST_METHOD'] === 'OPTIONS') exit;

include_once __DIR__ . '/connection.php'; // $conn (mysqli)
include_once __DIR__ . '/unified_config.php';

function human_upload_err($code) {
    return [
        UPLOAD_ERR_OK         => 'OK',
        UPLOAD_ERR_INI_SIZE   => 'Exceeds upload_max_filesize',
        UPLOAD_ERR_FORM_SIZE  => 'Exceeds MAX_FILE_SIZE in form',
        UPLOAD_ERR_PARTIAL    => 'Partial upload',
        UPLOAD_ERR_NO_FILE    => 'No file uploaded',
        UPLOAD_ERR_NO_TMP_DIR => 'Missing temp dir',
        UPLOAD_ERR_CANT_WRITE => 'Cannot write to disk',
        UPLOAD_ERR_EXTENSION  => 'Blocked by PHP extension'
    ][$code] ?? ('Unknown error '.$code);
}

/* ---------- Parse body ---------- */
$ct  = $_SERVER['CONTENT_TYPE'] ?? '';
$raw = file_get_contents('php://input');
$data = null;
if (stripos($ct, 'application/json') !== false) {
    $data = json_decode($raw, true);
}
if (!is_array($data)) $data = $_POST;

// /* ---------- A) Fetch accounts ---------- */
// if (($data['action'] ?? '') === 'fetch_accounts') {
//     $user_id = (int)($data['user_id'] ?? 0);
//     // $stmt = $conn->prepare("SELECT trade_id, email, account_name, account_type FROM liveaccounts WHERE user_id=?");
//     $stmt = $conn->prepare("
//     SELECT trade_id, email, account_name, account_type 
//     FROM liveaccounts 
//     WHERE user_id=? 
//     AND LOWER(account_type) <> 'demo'
// ");

//     $stmt->bind_param("i", $user_id);
//     $stmt->execute();
//     $res = $stmt->get_result();
//     $accounts = [];
//     while ($row = $res->fetch_assoc()) $accounts[] = $row;
//     echo json_encode(['success'=>true, 'accounts'=>$accounts]);
//     exit;
// }/* ---------- A) Fetch accounts ---------- */
if (($data['action'] ?? '') === 'fetch_accounts') {
    $user_id = (int)($data['user_id'] ?? 0);

    $stmt = $conn->prepare("
        SELECT 
            l.trade_id, 
            l.email, 
            l.account_name, 
            l.account_type,
            at.ac_min_deposit AS min_deposit
        FROM liveaccounts l
        LEFT JOIN account_types at 
            ON l.account_type = at.ac_name
        WHERE 
            l.user_id = ? 
            AND LOWER(l.account_type) <> 'demo'
    ");

    $stmt->bind_param("i", $user_id);
    $stmt->execute();
    $res = $stmt->get_result();
    $accounts = [];

    while ($row = $res->fetch_assoc()) {
        $accounts[] = [
            'trade_id'     => $row['trade_id'],
            'email'        => $row['email'],
            'account_name' => $row['account_name'],
            'account_type' => $row['account_type'],
            'min_deposit'  => (int)$row['min_deposit']
        ];
    }

    echo json_encode(['success'=>true, 'accounts'=>$accounts]);
    exit;
}


/* ---------- B) Recent deposits ---------- */
if ((isset($_GET['action']) && $_GET['action']==='recent') || (($data['action'] ?? '')==='recent')) {
    $user_id = (int)($data['user_id'] ?? 0);
    if ($user_id <= 0) {
        echo json_encode(['success'=>false, 'error'=>'Invalid user_id']); exit;
    }

    $stmt = $conn->prepare("
        SELECT dr.*, l.email, l.account_name, l.account_type
        FROM deposit_requests dr
        JOIN liveaccounts l ON l.trade_id = dr.trade_id
        WHERE dr.user_id = ?
        ORDER BY dr.created_at DESC LIMIT 5
    ");
    $stmt->bind_param("i", $user_id);
    $stmt->execute();
    $res = $stmt->get_result();
    $out = [];
    while ($r = $res->fetch_assoc()) {
        $out[] = [
            'email'            => $r['email'],
            'amount'           => $r['amount'],
            'type'             => $r['type'],
            'account_name'     => $r['account_name'],
            'account_type'     => $r['account_type'],
            'status'           => $r['status'],
            'created_at'       => $r['created_at'],
            'transaction_proof'=> $r['transaction_proof'],
            'deposit_address'  => $r['deposit_address'] ?? null, // ✅ fetch deposit_address
        ];
    }
    echo json_encode(['success'=>true, 'deposits'=>$out]);
    exit;
}

/* ---------- C) Create deposit request ---------- */
$trade_id           = trim((string)($data['trade_id'] ?? ''));
$amount             = (float)($data['amount'] ?? 0);
$type               = (string)($data['type'] ?? 'balance');
$comment            = (string)($data['comment'] ?? 'Deposit via UI');
$transaction_proof  = $data['transaction_proof'] ?? null;
$wallet_address     = trim((string)($data['wallet_address'] ?? '')); 
$transaction_id     = trim((string)($data['transaction_id'] ?? ''));


/* Handle uploaded file */
if (isset($_FILES['transaction_proof']) && $_FILES['transaction_proof']['error'] !== UPLOAD_ERR_NO_FILE) {
    $f = $_FILES['transaction_proof'];
    if ($f['error'] !== UPLOAD_ERR_OK) {
        echo json_encode(['success'=>false,'error'=>"Upload error: ".human_upload_err($f['error'])]); exit;
    }

    $webRoot = rtrim($_SERVER['DOCUMENT_ROOT'] ?? dirname(__DIR__), DIRECTORY_SEPARATOR);
    $uploadsDirAbs = $webRoot . DIRECTORY_SEPARATOR . 'uploads' . DIRECTORY_SEPARATOR;
    if (!is_dir($uploadsDirAbs)) @mkdir($uploadsDirAbs, 0755, true);

    $ext = pathinfo($f['name'], PATHINFO_EXTENSION);
    $nameBase = preg_replace('/[^a-zA-Z0-9_.-]/','_', pathinfo($f['name'], PATHINFO_FILENAME));
    $newName = uniqid('proof_', true) . '_' . $nameBase . '.' . $ext;
    $destAbs = $uploadsDirAbs . $newName;

    if (!move_uploaded_file($f['tmp_name'], $destAbs)) {
        echo json_encode(['success'=>false,'error'=>'Failed to store uploaded file']); exit;
    }

    $transaction_proof = '/uploads/' . $newName;
}

/* Validate trade_id & amount */
if ($trade_id === '' || $amount <= 0) {
    echo json_encode(['success'=>false,'error'=>'Invalid trade ID or amount']); exit;
}

/* Verify account exists */
$stmt = $conn->prepare("SELECT id, user_id FROM liveaccounts WHERE trade_id=? LIMIT 1");
$stmt->bind_param("s", $trade_id);
$stmt->execute();
$userRow = $stmt->get_result()->fetch_assoc();
if (!$userRow) {
    echo json_encode(['success'=>false,'error'=>'User not found']); exit;
}

/* Insert deposit request with deposit_address */
$stmt = $conn->prepare("
    INSERT INTO deposit_requests
(user_id, trade_id, amount, type, comment, transaction_id, transaction_proof, deposit_address, status)
VALUES (?, ?, ?, ?, ?, ?, ?, ?, 'pending')

");
$stmt->bind_param("isdsssss",
    $userRow['user_id'],
    $trade_id,
    $amount,
    $type,
    $comment,
    $transaction_id,    
    $transaction_proof,
    $wallet_address
);


if ($stmt->execute()) {
    $depositId = $conn->insert_id;
    
    $emailSent = false;
    if (EMAIL_AUTOMATION_ENABLED) {
        $stmtUserDetails = $conn->prepare("SELECT email, first_name, last_name FROM loginusers WHERE id = ?");
        $stmtUserDetails->bind_param("i", $userRow['user_id']);
        $stmtUserDetails->execute();
        $userResult = $stmtUserDetails->get_result();
        if ($userDetails = $userResult->fetch_assoc()) {
            $mailSystem = getMailSystem();
            $fullName = trim($userDetails['first_name'] . ' ' . $userDetails['last_name']);
            
            $emailResult = $mailSystem->sendDepositRequestSubmitted(
                $userDetails['email'], 
                $fullName, 
                $amount, 
                'USD',
                $type,
                'DEP-' . $depositId
            );
            
            $emailSent = $emailResult['success'];
            if (!$emailResult['success']) {
                error_log("Failed to send deposit request email to " . $userDetails['email'] . ": " . $emailResult['message']);
            }
        }
        $stmtUserDetails->close();
    }
    
    echo json_encode([
        'success'=>true,
        'message'=>'Deposit request submitted successfully. Waiting for admin approval.',
        'ticket'=>$depositId,
        'transaction_id'=>$transaction_id,
        'proof'=>$transaction_proof,
        'deposit_address'=>$wallet_address, // ✅ return deposit_address
        'email_sent'=>$emailSent
    ]);
} else {
    echo json_encode(['success'=>false, 'error'=>'Failed to submit deposit request: '.$stmt->error]);
}
