archived-doctrine-website/lib/Github/ProdGithubProjectContributors.php

<?php

declare(strict_types=1);

namespace Doctrine\Website\Github;

use Doctrine\Website\Model\Project;
use Github\Api\Repo;
use Github\Client;
use Psr\Cache\CacheItemPoolInterface;
use RuntimeException;

use function assert;
use function sleep;
use function sprintf;

final readonly class ProdGithubProjectContributors implements GithubProjectContributors
{
    public function __construct(
        private CacheItemPoolInterface $cache,
        private Client $githubClient,
        private int $maxChecks = 15,
    ) {
    }

    /** @param Project[] $projects */
    public function warmProjectsContributors(array $projects): void
    {
        foreach ($projects as $project) {
            $this->warmProjectContributors($project);
        }

        foreach ($projects as $project) {
            $this->waitForProjectContributorsData($project);
        }
    }

    private function warmProjectContributors(Project $project): void
    {
        // Trigger api call to github to build statistics. The GitHub API may return
        // results right away, in that case we will go ahead and store the results in the cache.
        $this->doGetProjectContributors($project, false);
    }

    private function waitForProjectContributorsData(Project $project): void
    {
        $count  = 1;
        $sleep  = 1;
        $waited = 0;

        while ($count <= $this->maxChecks) {
            $contributors = $this->doGetProjectContributors($project, false);

            if ($contributors !== []) {
                return;
            }

            $sleep *= $count;
            $count++;

            sleep($sleep);

            $waited += $sleep;
        }

        throw new RuntimeException(
            sprintf(
                'Waited for %d seconds with %d checks but could not get contributor data.',
                $waited,
                $count,
            ),
        );
    }

    /** @return mixed[] */
    public function getProjectContributors(Project $project): array
    {
        return $this->doGetProjectContributors($project, true);
    }

    /** @return mixed[] */
    private function doGetProjectContributors(Project $project, bool $throwOnEmpty): array
    {
        $id = sprintf('doctrine-%s-contributors-data', $project->getSlug());

        $item = $this->cache->getItem($id);

        if ($item->isHit()) {
            return $item->get();
        }

        $repo = $this->githubClient->api('repo');
        assert($repo instanceof Repo);

        $repositoryName = $project->getRepositoryName();

        $contributors = $repo->statistics('doctrine', $repositoryName);

        if ($contributors !== []) {
            $this->cache->save($item->set($contributors)->expiresAfter(86400));
        }

        if ($contributors === [] && $throwOnEmpty) {
            throw new RuntimeException(sprintf(
                'The GitHub API should not return an empty array here for repository %s.',
                $repositoryName,
            ));
        }

        return $contributors;
    }
}