Просмотр архива RotorCms 14.2.1


<?php

namespace AppServices;

use IlluminateSupportFacadesCache;
use IlluminateSupportFacadesHttp;
use RuntimeException;
use Throwable;

class GithubService
{
    protected string $baseUrl = 'https://api.github.com/repos/visavi/rotor/';
    protected int $defaultCacheTtl = 3600;

    /**
     * Получает последние коммиты
     */
    public function getLatestCommits(): array
    {
        return $this->cachedFetch('commits', fn () => $this->fetchGitHubData(
            endpoint: 'commits',
            params: ['per_page' => 100]
        ));
    }

    /**
     * Get last release
     */
    public function getLatestRelease(): array
    {
        return $this->getLatestReleases()[0] ?? [];
    }

    /**
     * Get last version
     */
    public function getLatestVersion(): string
    {
        $release = $this->getLatestRelease();

        return $release['tag_name'] ?? '';
    }

    /**
     * Get last version
     */
    public function getLatestVersionClean(): string
    {
        $version = $this->getLatestVersion();
        $clean = ltrim($version, 'v');

        return str_replace(['-alpha', '-beta', '-rc'], '', $clean);
    }

    /**
     * Получает последние релизы
     */
    public function getLatestReleases(): array
    {
        return $this->cachedFetch('releases', fn () => $this->fetchGitHubData(
            endpoint: 'releases',
            params: ['per_page' => 100]
        ));
    }

    /**
     * Отдаёт данные из кэша сразу (даже протухшие), протухший кэш обновляет
     * после отправки ответа. Синхронный запрос к GitHub — только на холодном
     * кэше, чтобы страница не подвисала на каждом промахе.
     */
    protected function cachedFetch(string $key, callable $fetcher): array
    {
        $cached = Cache::get($key);

        // Холодный кэш: тянем синхронно, иначе данных вообще не будет
        if (! is_array($cached)) {
            return $this->store($key, $fetcher);
        }

        // Протухло: отдаём старое, обновляем в фоне после ответа
        if (($cached['cached_at'] ?? 0) < now()->getTimestamp() - $this->defaultCacheTtl) {
            dispatch(fn () => $this->store($key, $fetcher))->afterResponse();
        }

        return $cached['data'] ?? [];
    }

    /**
     * Запрашивает данные и кладёт в кэш вместе с меткой времени
     */
    protected function store(string $key, callable $fetcher): array
    {
        $data = $fetcher();

        Cache::forever($key, [
            'data'      => $data,
            'cached_at' => now()->getTimestamp(),
        ]);

        return $data;
    }

    /**
     * Обращается к GitHub API
     */
    protected function fetchGitHubData(string $endpoint, array $params = []): array
    {
        $headers = [
            'Accept' => 'application/vnd.github+json',
        ];

        try {
            $response = Http::withHeaders($headers)
                ->timeout(3)
                ->retry(3, 100)
                ->get($this->baseUrl . $endpoint, $params);

            if ($response->failed()) {
                throw new RuntimeException(
                    'GitHub API error: ' . $response->body(),
                    $response->status()
                );
            }

            return $response->json() ?? [];
        } catch (Throwable) {
            return [];
        }
    }
}