ReceiveBundleController.php

<?php

namespace App\Http\Controllers\Guest;

use App\Models\PendingClientResponse;
use App\Models\Server;
use Illuminate\Http\Request;

class ReceiveBundleController
{
    public function post(Request $request)
    {
        if ($request->bearerToken() !== config('watchtower.client_auth_token')) {
            abort(401);
        }

        ['server_uuid' => $serverUuid, 'bundle' => $bundle] = $request->validate([
            'server_uuid' => 'required|uuid',
            'bundle' => 'required|file',
        ]);

        Server::receiveBundle($bundle->getRealPath());

        $responses = PendingClientResponse::query()
            ->select(['id', 'message'])
            ->where('server_uuid', $serverUuid)
            ->get();

        if ($responses->isNotEmpty()) {
            PendingClientResponse::query()
                ->whereIn('id', $responses->pluck('id'))
                ->delete();
        }

        return implode("\n", [
            'Acknowledged!',
            'Current-client-version: '.sha1_file(public_path('watchtower-client.tar.gz')),
            ...$responses->map(fn (PendingClientResponse $response) => $response->message),
        ]);
    }

    public function isAvailable(Request $request)
    {
        if ($request->bearerToken() !== config('watchtower.client_auth_token')) {
            abort(401);
        }
    }
}