AspireCloud/app/Services/PluginServices/PluginUpdateService.php

<?php
declare(strict_types=1);

namespace App\Services\PluginServices;

use App\Models\WpOrg\Plugin;
use App\Values\WpOrg\Plugins\PluginUpdateCheckRequest;
use App\Values\WpOrg\Plugins\PluginUpdateCheckResponse;
use App\Values\WpOrg\Plugins\PluginUpdateData;

class PluginUpdateService
{
    public function checkForUpdates(PluginUpdateCheckRequest $req): PluginUpdateCheckResponse
    {
        $bySlug = collect($req->plugins)
            ->mapWithKeys(
                fn($pluginData, $pluginFile) => [$this->extractSlug($pluginFile) => [$pluginFile, $pluginData]],
            );

        $isUpdated = fn(Plugin $plugin) => version_compare($plugin->version, $bySlug[$plugin->slug][1]['Version'] ?? '', '>');

        $mkUpdate = function (Plugin $plugin) use ($bySlug) {
            $file = (string)$bySlug[$plugin->slug][0];
            return [$file => PluginUpdateData::from($plugin)->with(plugin: $file)];
        };

        /** @noinspection PhpParamsInspection (broken on Collection::partition) */
        [$updates, $no_updates] = Plugin::query()
            ->whereIn('slug', $bySlug->keys())
            ->get()
            ->partition($isUpdated)
            ->map(fn($collection) => $collection->mapWithKeys($mkUpdate));

        return PluginUpdateCheckResponse::from(plugins: $updates, no_update: $no_updates, translations: collect([]));
    }

    /**
     * Extract the plugin slug from the plugin file path
     */
    private function extractSlug(string $pluginFile): string
    {
        return str_contains($pluginFile, '/')
            ? explode('/', $pluginFile)[0]
            : pathinfo($pluginFile, PATHINFO_FILENAME);
    }
}