Data Sources

DataRefreshCommand::class => static function (ContainerInterface $c) {
    $apiKey = self::getSecret('CFBD_API_KEY');

    return new DataRefreshCommand(
        new Client([
            'base_uri' => 'https://api.collegefootballdata.com',
            RequestOptions::HEADERS => [
                'Authorization' => 'Bearer ' . $apiKey,
                'Accept' => 'application/json',
            ],
        ]),
        $c->get(PDO::class),
    );
}

private function fetchFromCfbdApi(): array
{
    $apiResponse = $this->cfbdApiClient->get(
        '/games',
        [
            RequestOptions::QUERY => [
                'year' => '2025',
                'classification' => 'fbs',
                'seasonType' => 'regular',
            ],
        ],
    )->getBody()->getContents();

    /** @var CfbdApiGamesResponse $data */
    $data = json_decode($apiResponse, true, flags: JSON_THROW_ON_ERROR);

    return $data;
}

public function pullAndStoreFreshData(): void
{
    $this->logger->notice('Starting data refresh from the CollegeFootballData.com API...');

    $data = $this->fetchFromCfbdApi();
    $this->logger->notice('Successfully fetched data');

    [$games, $teams] = $this->extractGamesAndTeams($data);
    $this->logger->notice('Extracted ' . count($teams) . ' teams and ' . count($games) . ' games');

    $this->saveTeams($teams);

    $games = $this->applyDataCorrectionsToGames($games);

    $this->saveGames($games);

    $this->logger->notice('Data refresh completed successfully');
}

private function extractGamesAndTeams(array $data): array
{
    $games = [];
    $teams = [];

    foreach ($data as $game) {
        $gameId = (int) $game['id'];

        $gameDate = DateTimeImmutable::createFromFormat(DateFormat::CFBDAPI, $game['startDate']);
        if ($gameDate === false) {
            throw new RuntimeException('Failed to parse game date: ' . $game['startDate']);
        }

        $games[$gameId] = [
            'date' => $gameDate,
            'week_number' => (int) $game['week'],
            'neutral_site' => (int) $game['neutralSite'],
            'home_team_cfbd_id' => (int) $game['homeId'],
            'away_team_cfbd_id' => (int) $game['awayId'],
            'home_team_points' => $game['homePoints'],
            'away_team_points' => $game['awayPoints'],
        ];

        $homeId = (int) $game['homeId'];

        $teams[$homeId] = [
            'name' => $game['homeTeam'],
            'subdivision' => Subdivision::fromString($game['homeClassification']),
            'conference' => Conference::fromString($game['homeConference']),
        ];

        $awayId = (int) $game['awayId'];

        $teams[$awayId] = [
            'name' => $game['awayTeam'],
            'subdivision' => Subdivision::fromString($game['awayClassification']),
            'conference' => Conference::fromString($game['awayConference']),
        ];
    }

    return [$games, $teams];
}

private function applyDataCorrectionsToGames(array $games): array
{
    foreach ($games as $cfbdId => $game) {
        // Sam Houston home games are hosted at Shell Energy Stadium for 2025. 
        // These are not neutral site games.
        if (in_array($cfbdId, [401757224, 401757279, 401757284, 401757300, 401757311], true)) {
            $games[$cfbdId]['neutral_site'] = 0;
        }
    }

    return $games;
}

private function determineWinner(array $game): Winner|null
{
    if ($game['home_team_points'] === null || $game['away_team_points'] === null) {
        return null;
    }

    if ($game['home_team_points'] > $game['away_team_points']) {
        return Winner::Home;
    }

    if ($game['home_team_points'] < $game['away_team_points']) {
        return Winner::Away;
    }

    $this->logger->error(
        'Home and away team points are equal for the week ' . $game['week_number'] . ' game between ' .
        $game['home_team_cfbd_id'] . ' and ' . $game['away_team_cfbd_id'] . '. Not declaring a winner yet.',
    );

    return null;
}

$stmt = $this->pdo->prepare(<<<'SQL'
INSERT INTO teams (name, subdivision, conference, cfbd_id)
    VALUES (:name, :subdivision, :conference, :cfbd_id)
ON CONFLICT(cfbd_id) DO UPDATE SET
    name = :name,
    subdivision = :subdivision,
    conference = :conference;
SQL);

public function getTeams(): array
{
    $query = $this->pdo->query(
        'SELECT id, name, subdivision, conference FROM teams',
        PDO::FETCH_ASSOC,
    );

    if ($query === false) {
        throw new RuntimeException('Failed to fetch teams from database');
    }

    $teams = [];

    /** @var TeamRow $row */
    foreach ($query as $row) {
        $teams[] = new Team(
            TeamId::fromDatabase($row['id']),
            $row['name'],
            Subdivision::fromString($row['subdivision']),
            Conference::fromString($row['conference']),
        );
    }

    return $teams;
}

public function getTeams(): array
{
    if ($this->identityMap->count() === 0) {
        $teams = $this->repository->getTeams();

        foreach ($teams as $team) {
            $this->identityMap->add($team->id, $team);
        }
    }

    return $this->identityMap->getAll();
}