cron.php

<?php
declare(strict_types=1);

const CACHE_TTL_SECONDS = 300; // 5 minutes

$configFile = __DIR__ . '/.env.php';
if (!file_exists($configFile)) {
    fwrite(STDERR, sprintf('Config file missing: %s%s', $configFile, PHP_EOL));
    exit(1);
}

$config = require $configFile;
if (!is_array($config)) {
    fwrite(STDERR, sprintf('Config file must return an array: %s%s', $configFile, PHP_EOL));
    exit(1);
}

$targets = $config['targets'] ?? null;
if (!is_array($targets) || $targets === []) {
    fwrite(STDERR, sprintf('Config missing "targets" array: %s%s', $configFile, PHP_EOL));
    exit(1);
}

foreach ($targets as $target) {
    $file = $target['file'];
    if (isCacheFresh($file)) {
        continue;
    }

    $fetch = fetchJson($target['url']);
    if (!$fetch['ok']) {
        logError($target['name'], $fetch['message']);
        continue;
    }

    if (!writeAtomically($file, $fetch['body'])) {
        logError($target['name'], sprintf('failed to write cache file "%s"', $file));
        continue;
    }
}

/**
 * Determine whether the existing cache file is still fresh.
 */
function isCacheFresh(string $path): bool
{
    if (!file_exists($path)) {
        return false;
    }

    $age = time() - (int) filemtime($path);
    return $age < CACHE_TTL_SECONDS;
}

/**
 * Fetch JSON from the remote endpoint and validate the response.
 *
 * @return array{ok:bool, body?:string, message:string|null}
 */
function fetchJson(string $url): array
{
    $body = httpRequest($url, $statusCode, $err);

    if ($body === null) {
        return [
            'ok' => false,
            'message' => $err ?? 'unknown error',
        ];
    }

    if ($statusCode < 200 || $statusCode >= 300) {
        return [
            'ok' => false,
            'message' => sprintf('unexpected HTTP status %d', $statusCode),
        ];
    }

    json_decode($body);
    if (json_last_error() !== JSON_ERROR_NONE) {
        return [
            'ok' => false,
            'message' => sprintf('invalid JSON payload: %s', json_last_error_msg()),
        ];
    }

    return [
        'ok' => true,
        'body' => $body,
        'message' => null,
    ];
}

/**
 * Perform an HTTP GET request and return the response body.
 *
 * @param int|null    $status Status code returned by the request (if known)
 * @param string|null $error  Error message when the request fails
 */
function httpRequest(string $url, ?int &$status, ?string &$error): ?string
{
    $error = null;
    $status = null;

    $ch = curl_init($url);
    if ($ch === false) {
        $error = 'unable to initialize cURL';
        return null;
    }

    $headers = [
        'Accept: application/json',
    ];

    curl_setopt_array($ch, [
        CURLOPT_RETURNTRANSFER => true,
        CURLOPT_FOLLOWLOCATION => true,
        CURLOPT_CONNECTTIMEOUT => 10,
        CURLOPT_TIMEOUT => 30,
        CURLOPT_FAILONERROR => false,
        CURLOPT_HTTPHEADER => $headers,
        CURLOPT_REFERER => 'https://reg.howloween.ca/',
        CURLOPT_USERAGENT => 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/126.0.0.0 Safari/537.36',
    ]);

    // $responseHeaders = [];
    // curl_setopt($ch, CURLOPT_HEADERFUNCTION, function ($ch, string $header) use (&$responseHeaders) {
    //     $len = strlen($header);
    //     $normalized = trim($header);
    //     if ($normalized === '') {
    //         return $len;
    //     }
    //     $responseHeaders[] = $normalized;
    //     return $len;
    // });

    $body = curl_exec($ch);

    // $info = curl_getinfo($ch);

    // file_put_contents(
    //     __DIR__ . '/cron-debug.log',
    //     sprintf(
    //         "[%s]\nURL: %s\nStatus: %d\nResponse headers:\n%s\nBody (first 2 KB):\n%s\n\n",
    //         (new DateTimeImmutable())->format(DateTimeInterface::ATOM),
    //         $info['url'] ?? $url,
    //         $info['http_code'] ?? 0,
    //         implode("\n", $responseHeaders) ?: '(none)',
    //         $body //substr($body, 0, 2048)
    //     ),
    //     FILE_APPEND
    // );


    if ($body === false) {
        $error = curl_error($ch) ?: 'curl_exec failed';
        curl_close($ch);
        return null;
    }

    $status = (int) curl_getinfo($ch, CURLINFO_RESPONSE_CODE);
    curl_close($ch);

    return $body;
}

/**
 * Write the supplied content to the target path atomically.
 */
function writeAtomically(string $path, string $content): bool
{
    $dir = dirname($path);
    $temp = tempnam($dir, 'tmp');
    if ($temp === false) {
        return false;
    }

    $bytes = file_put_contents($temp, $content, LOCK_EX);
    if ($bytes === false) {
        @unlink($temp);
        return false;
    }

    if (!rename($temp, $path)) {
        @unlink($temp);
        return false;
    }

    return true;
}

/**
 * Log an error message to STDERR for visibility in cron output.
 */
function logError(string $name, string $message): void
{
    $timestamp = (new DateTimeImmutable())->format(DateTimeInterface::ATOM);
    $line = sprintf('[%s] %s: %s', $timestamp, $name, $message);
    fwrite(STDERR, $line . PHP_EOL);
}