Tul xxx Tul

Viewing: jobs-events.php

<?php

use App\Storage\Database;

require_once __DIR__ . '/../app/helpers/Session.php';

spl_autoload_register(static function (string $class): void {
    $prefix = 'App\\';
    $baseDir = __DIR__ . '/../app/';

    if (!str_starts_with($class, $prefix)) {
        return;
    }

    $relativeClass = substr($class, strlen($prefix));
    $relativePath = str_replace('\\', '/', $relativeClass) . '.php';
    $pathsToTry = [$baseDir . $relativePath];

    $segments = explode('/', $relativePath);
    if (!empty($segments)) {
        $segments[0] = strtolower($segments[0]);
        $pathsToTry[] = $baseDir . implode('/', $segments);
    }

    foreach ($pathsToTry as $path) {
        if (file_exists($path)) {
            require_once $path;
            return;
        }
    }
});

header('Content-Type: text/event-stream; charset=utf-8');
header('Cache-Control: no-store, no-cache, must-revalidate, max-age=0');
header('Pragma: no-cache');
header('Connection: keep-alive');

@ini_set('zlib.output_compression', '0');
@ini_set('output_buffering', '0');
@ini_set('implicit_flush', '1');
@set_time_limit(0);

while (ob_get_level() > 0) {
    ob_end_flush();
}
ob_implicit_flush(true);

$lastId = 0;
if (isset($_SERVER['HTTP_LAST_EVENT_ID'])) {
    $lastId = (int) $_SERVER['HTTP_LAST_EVENT_ID'];
}
if (isset($_GET['last_id'])) {
    $lastId = max($lastId, (int) $_GET['last_id']);
}

$pdo = Database::connection();

$timeoutSeconds = 55;
$pollIntervalUs = 2500000;
$pingIntervalSeconds = 15;

$startedAt = time();
$lastPingAt = time();

echo "retry: 5000\n\n";

while (true) {
    if (connection_aborted()) {
        break;
    }

    if ((time() - $startedAt) >= $timeoutSeconds) {
        break;
    }

    $stmt = $pdo->prepare(
        'SELECT j.id, j.title, j.location, j.state, j.country, j.created_at, e.company AS company '
        . 'FROM jobs j '
        . 'LEFT JOIN employers e ON e.id = j.employer_id '
        . 'WHERE j.status = 1 AND j.id > :last_id '
        . 'ORDER BY j.id ASC '
        . 'LIMIT 10'
    );
    $stmt->execute(['last_id' => $lastId]);
    $rows = $stmt->fetchAll();

    foreach ($rows as $row) {
        $id = (int) ($row['id'] ?? 0);
        if ($id <= 0) {
            continue;
        }

        $lastId = $id;

        $payload = [
            'id' => $id,
            'title' => $row['title'] ?? 'Nueva vacante',
            'company' => $row['company'] ?? 'Empresa',
            'location' => $row['location'] ?? '',
            'state' => $row['state'] ?? '',
            'country' => $row['country'] ?? '',
            'created_at' => $row['created_at'] ?? null,
        ];

        echo 'id: ' . $id . "\n";
        echo "event: job_published\n";
        echo 'data: ' . json_encode($payload, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES) . "\n\n";
    }

    if ((time() - $lastPingAt) >= $pingIntervalSeconds) {
        echo "event: ping\n";
        echo "data: {}\n\n";
        $lastPingAt = time();
    }

    usleep($pollIntervalUs);
}

echo "event: close\n";
echo "data: {}\n\n";
User / IP	: 216.73.216.159
Host / Server	: 45.84.207.204 / aircan.me
System	: Linux lt-bnk-web1726.main-hosting.eu 5.14.0-611.36.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Mar 3 11:23:52 EST 2026 x86_64