<?php
/**
 * HabboLibre Presence Reporter
 *
 * Rename this file to habbolibre-presence-reporter.php and run it every
 * minute with cron from your hotel server.
 *
 * Required environment variables:
 * - HL_HOTEL_SLUG: your HabboLibre hotel slug
 * - HL_API_KEY: your Pingback Secret from HabboLibre
 * - HL_DB_DSN: PDO DSN, for example mysql:host=127.0.0.1;dbname=hotel;charset=utf8mb4
 * - HL_DB_USER: database user
 * - HL_DB_PASS: database password
 *
 * Optional:
 * - HL_ONLINE_COUNT_SQL: SQL that returns one numeric column.
 *   Default: SELECT COUNT(*) FROM users WHERE online = 1
 * - HL_API_BASE: API base URL. Default: https://api.habbolibre.org/api/v1
 * - HL_TIMEOUT_SECONDS: total API timeout. Default: 8
 * - HL_CONNECT_TIMEOUT_SECONDS: API connection timeout. Default: 4
 * - HL_LOCK_PATH: custom lock file path to avoid overlapping cron runs.
 * - HL_DRY_RUN: set to 1 to print the payload without sending it.
 * - HL_REPORT_OFFLINE_ON_DB_ERROR: set to 1 to report offline when the DB query fails.
 * - HL_LOG_FILE: append every run to this file (recommended for cron diagnostics).
 *   Each line: ISO timestamp | status | users_online | api_http_status
 *   Tail with: tail -f /path/to/habbolibre-presence.log
 *
 * You can also place these values in a .env.habbolibre file next to this script.
 *
 * Diagnostics:
 *   - If you don't see ad-hoc reports landing on HabboLibre, set HL_LOG_FILE
 *     and check it for clues: rows = cron firing; gaps = cron stopped;
 *     non-2xx api_http_status = network or auth issue.
 *   - HabboLibre's owner dashboard ("Salud del reporter") shows the same
 *     heartbeat from the server side — use it to confirm reports are
 *     arriving at the expected ~60/h rate.
 */

loadHabboLibreEnv(__DIR__.'/.env.habbolibre');

$slug = getenv('HL_HOTEL_SLUG') ?: '';
$apiKey = getenv('HL_API_KEY') ?: '';
$apiBase = rtrim(getenv('HL_API_BASE') ?: 'https://api.habbolibre.org/api/v1', '/');
$dsn = getenv('HL_DB_DSN') ?: '';
$dbUser = getenv('HL_DB_USER') ?: '';
$dbPass = getenv('HL_DB_PASS') ?: '';
$sql = getenv('HL_ONLINE_COUNT_SQL') ?: 'SELECT COUNT(*) FROM users WHERE online = 1';
$dryRun = envFlag('HL_DRY_RUN');
$reportOfflineOnDbError = envFlag('HL_REPORT_OFFLINE_ON_DB_ERROR');
$timeoutSeconds = envInt('HL_TIMEOUT_SECONDS', 8, 1, 60);
$connectTimeoutSeconds = envInt('HL_CONNECT_TIMEOUT_SECONDS', 4, 1, $timeoutSeconds);
$logFile = getenv('HL_LOG_FILE') ?: '';

if ($slug === '' || $apiKey === '' || $dsn === '') {
    fwrite(STDERR, "Missing HL_HOTEL_SLUG, HL_API_KEY or HL_DB_DSN\n");
    exit(1);
}

$lockHandle = acquireHabboLibreLock($slug, getenv('HL_LOCK_PATH') ?: '');
$status = 'online';

try {
    if (!extension_loaded('pdo')) {
        throw new RuntimeException('PHP PDO extension is not enabled.');
    }

    $pdo = new PDO($dsn, $dbUser, $dbPass, [
        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
        PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_NUM,
    ]);

    $stmt = $pdo->query($sql);
    $count = $stmt ? $stmt->fetchColumn() : false;
    if ($count === false || !is_numeric($count)) {
        throw new RuntimeException('HL_ONLINE_COUNT_SQL did not return a numeric value.');
    }

    $usersOnline = max(0, min(65535, (int) $count));
} catch (Throwable $e) {
    if (!$reportOfflineOnDbError) {
        fwrite(STDERR, "Database error: {$e->getMessage()}\n");
        exit(1);
    }

    fwrite(STDERR, "Database error; reporting offline because HL_REPORT_OFFLINE_ON_DB_ERROR=1: {$e->getMessage()}\n");
    $usersOnline = 0;
    $status = 'offline';
}

$endpoint = $apiBase.'/hotels/'.rawurlencode($slug).'/presence';
$payload = json_encode([
    'users_online' => $usersOnline,
    'status' => $status,
], JSON_THROW_ON_ERROR);

if ($dryRun) {
    echo "Dry run: would POST to {$endpoint}\n";
    echo $payload."\n";
    exit(0);
}

if (!extension_loaded('curl')) {
    fwrite(STDERR, "PHP cURL extension is not enabled.\n");
    exit(1);
}

$ch = curl_init($endpoint);
curl_setopt_array($ch, [
    CURLOPT_POST => true,
    CURLOPT_RETURNTRANSFER => true,
    CURLOPT_HTTPHEADER => [
        'Authorization: Bearer '.$apiKey,
        'Content-Type: application/json',
        'Accept: application/json',
        'User-Agent: HabboLibre-Presence-Reporter/1.2',
    ],
    CURLOPT_POSTFIELDS => $payload,
    CURLOPT_CONNECTTIMEOUT => $connectTimeoutSeconds,
    CURLOPT_TIMEOUT => $timeoutSeconds,
]);

$body = curl_exec($ch);
$httpStatus = curl_getinfo($ch, CURLINFO_RESPONSE_CODE);
$error = curl_error($ch);
curl_close($ch);

if ($body === false || $httpStatus < 200 || $httpStatus >= 300) {
    fwrite(STDERR, "HabboLibre API error HTTP {$httpStatus}: ".($error ?: $body)."\n");
    appendHabboLibreLog($logFile, $status, $usersOnline, $httpStatus);
    exit(1);
}

// Append a heartbeat line to the optional diagnostic log so the owner can
// verify cron is firing without checking HabboLibre.
appendHabboLibreLog($logFile, $status, $usersOnline, $httpStatus);

$response = json_decode($body, true);
$reportedAt = is_array($response) ? ($response['reported_at'] ?? null) : null;
$freshForSeconds = is_array($response) ? ($response['fresh_for_seconds'] ?? null) : null;

echo "Reported {$usersOnline} users online to HabboLibre";
if ($reportedAt) {
    echo " at {$reportedAt}";
}
if ($freshForSeconds) {
    echo " (fresh for {$freshForSeconds}s)";
}
echo "\n";

function appendHabboLibreLog(string $path, string $status, int $usersOnline, int $httpStatus): void
{
    if ($path === '') {
        return;
    }

    $line = sprintf(
        "%s | %s | users_online=%d | http=%d\n",
        date('c'),
        $status,
        $usersOnline,
        $httpStatus,
    );

    @file_put_contents($path, $line, FILE_APPEND | LOCK_EX);
}

/** @return resource|null */
function acquireHabboLibreLock(string $slug, string $path)
{
    $safeSlug = preg_replace('/[^a-zA-Z0-9_-]/', '_', $slug) ?: 'hotel';
    $path = $path !== '' ? $path : sys_get_temp_dir()."/habbolibre-presence-{$safeSlug}.lock";
    $handle = @fopen($path, 'c');

    if (!$handle) {
        fwrite(STDERR, "Could not open lock file {$path}; continuing without lock.\n");
        return null;
    }

    if (!flock($handle, LOCK_EX | LOCK_NB)) {
        echo "Another HabboLibre presence reporter run is still active; skipping.\n";
        exit(0);
    }

    return $handle;
}

function envFlag(string $key, bool $default = false): bool
{
    $value = getenv($key);
    if ($value === false || $value === '') {
        return $default;
    }

    return in_array(strtolower((string) $value), ['1', 'true', 'yes', 'on'], true);
}

function envInt(string $key, int $default, int $min, int $max): int
{
    $value = getenv($key);
    if ($value === false || $value === '' || !is_numeric($value)) {
        return $default;
    }

    return max($min, min($max, (int) $value));
}

function loadHabboLibreEnv(string $path): void
{
    if (!is_readable($path)) {
        return;
    }

    $lines = file($path, FILE_IGNORE_NEW_LINES | FILE_SKIP_EMPTY_LINES);
    if ($lines === false) {
        return;
    }

    foreach ($lines as $line) {
        $line = trim($line);
        if ($line === '' || $line[0] === '#') {
            continue;
        }

        [$key, $value] = array_pad(explode('=', $line, 2), 2, '');
        $key = trim($key);
        $value = trim(trim($value), "\"'");

        if ($key === '' || getenv($key) !== false) {
            continue;
        }

        putenv($key.'='.$value);
        $_ENV[$key] = $value;
    }
}