trueskill/examples/motogp/goat.php

<?php

require __DIR__ . "/../../vendor/autoload.php";

use League\Csv\Reader;
use League\Csv\Statement;
use DNW\Skills\TrueSkill\FactorGraphTrueSkillCalculator;
use DNW\Skills\GameInfo;
use DNW\Skills\Player;
use DNW\Skills\Team;
use DNW\Skills\Teams;

//load the CSV document from a stream
$stream = fopen('motogp.csv', 'r');
$csv = Reader::createFromStream($stream);
$csv->setDelimiter(',');
$csv->setHeaderOffset(0);

//build a statement
$stmt = Statement::create()->where(static fn (array $record): bool => $record['category']=="MotoGP" ||  $record['category']=="500cc");
//$stmt = Statement::create();

/** @var $riders Player[] */
$riders = [];
//query your records from the document
$records = $stmt->process($csv);

$gameInfo = new GameInfo();
$calculator = new FactorGraphTrueSkillCalculator();
$first_record = $records->first();
$year_race = $first_record['year'].'_'.$first_record['sequence'].'_'.$first_record['category'];

$race_rate = [];
foreach($records as $record)
{
    if ($year_race !== $record['year'].'_'.$record['sequence'].'_'.$record['category'])
    {
        //Calculate the old race
        $newRatings = $calculator->calculateNewRatings($gameInfo, $teams, $pos);

        //update ratings
        $highest_rate = 0;
        $highest_rider = "";
        foreach($riders as $rider) {
            //echo $rider['P']->getId().": ". $newRatings->getRating($rider['P'])->getConservativeRating() . PHP_EOL;
            $rider['T']->setRating($rider['P'], $newRatings->getRating($rider['P']));
            if($newRatings->getRating($rider['P'])->getConservativeRating() > $highest_rate)
            {
                $highest_rate = $newRatings->getRating($rider['P'])->getConservativeRating();
                $highest_rider = $rider['P']->getId();
            }
        }

        echo sprintf('Highest rider: %s => %s', $highest_rider, $highest_rate).PHP_EOL;

        foreach($global_riders as $r)
        {
            $rate = $r['T']->getRating($r['P'])->getConservativeRating();

            $race_rate[$year_race][$r['P']->getId()] = $rate;
            if (!isset($top_rating[$r['P']->getId()]) || $top_rating[$r['P']->getId()] < $rate)
            {
                $top_rating[$r['P']->getId()] = $rate;
            }
        }

        //prepare for next race
        $year_race = $record['year'].'_'.$record['sequence'].'_'.$record['category'];
        $races[] =['year' => $record['year'], 'race'=> $record['sequence'], 'circuit'=> $record['circuit_name']];
        echo "New Race: ".$year_race. ' => '. $record['circuit_name'].PHP_EOL;
        $riders = [];
        $teams = [];
        $pos = [];
    }

    //Is it a new rider? 
    if(!isset($global_riders[$record['rider']]))
    {
        $global_riders[$record['rider']]['P'] = new Player($record['rider_name']);
        $global_riders[$record['rider']]['T'] = new Team($global_riders[$record['rider']]['P'], $gameInfo->getDefaultRating());
        //echo "New Rider: ". $record['rider'] . " => ".$global_riders[$record['rider']]['P']->getId().PHP_EOL;
    }

    $riders[] = $global_riders[$record['rider']];
    $teams[] = $global_riders[$record['rider']]['T'];
    
    //Position or DNF?
    $pos[] = $record['position'] >= 1 ? $record['position'] : end($pos);
}

echo "All time top score".PHP_EOL;
asort($top_rating);
foreach($top_rating as $n=>$r)
{
    echo sprintf('%s => %s', $n, $r).PHP_EOL;
}