osu-web / app / Models / BeatmapLeader.php

<?php

// Copyright (c) ppy Pty Ltd <[e-mail]>. Licensed under the GNU Affero General Public License v3.0.
// See the LICENCE file in the repository root for full licence text.

namespace App\Models;

use App\Libraries\Search\ScoreSearch;
use App\Libraries\Search\ScoreSearchParams;
use DB;

/**
 * @property int $id
 * @property int $ruleset_id
 * @property int $beatmap_id
 * @property int $user_id
 * @property int $score_id
 */
class BeatmapLeader extends Model
{
    public $timestamps = false;

    protected $primaryKey = 'score_id';

    public static function sync(int $beatmapId, int $rulesetId): void
    {
        $searchParams = ScoreSearchParams::fromArray([
            'beatmap_ids' => [$beatmapId],
            'is_legacy' => false,
            'limit' => 1,
            'ruleset_id' => $rulesetId,
            'sort' => 'score_desc',
        ]);

        $score = (new ScoreSearch($searchParams))->records()->first();

        DB::transaction(function () use ($beatmapId, $rulesetId, $score): void {
            $scoreLeader = static::where([
                'beatmap_id' => $beatmapId,
                'ruleset_id' => $rulesetId,
            ])->lockForUpdate()->first();

            if ($score === null) {
                $scoreLeader?->delete();

                return;
            }

            $params = [
                'beatmap_id' => $beatmapId,
                'ruleset_id' => $rulesetId,
                'score_id' => $score->getKey(),
                'user_id' => $score->user_id,
            ];

            if ($scoreLeader === null) {
                static::create($params);
            } else {
                $scoreLeader->update($params);
            }
        });
    }
}