lucent-laravel/src/Http/Controller/BuildController.php

<?php

namespace Lucent\Http\Controller;

use App\Http\Controllers\Controller;
use Illuminate\Contracts\View\View;
use Illuminate\Http\Request;
use Lucent\Channel\ChannelService;
use Lucent\Svelte\Svelte;

class BuildController extends Controller
{
    public function __construct(
        public readonly Svelte         $svelte,
        public readonly ChannelService $channelService,
    )
    {
    }

    public function build(Request $request)
    {
        $commandSignature = $request->route("signature");
        $buildLogFile = $this->getLogFile($commandSignature);
        $pidFile = $this->getPidFile($commandSignature);
        if (file_exists($buildLogFile)) {
            unlink($buildLogFile);
        }
        if (file_exists($pidFile)) {
            unlink($pidFile);
        }

        exec("cd " . base_path() . " && php8.3 artisan {$commandSignature} > " . $buildLogFile . " 2>&1 & echo $!", $op);
        $pid = (int)$op[0];
        file_put_contents($pidFile, $pid);
        return redirect($this->channelService->channel->lucentUrl . "/command-report/" . $commandSignature);
    }

    public function report(Request $request): View
    {
        $commandSignature = $request->route("signature");
        $command = $this->channelService->channel->commands->firstWhere("signature", $commandSignature);

        return $this->svelte->render(
            layout: "channel",
            view: "buildReport",
            title: $command->name,
            data: [
                "command" => $command,
            ]
        );
    }

    public function reportSource(Request $request)
    {
        $commandSignature = $request->route("signature");
        return response()->stream(function () use ($commandSignature) {
            while (true) {
                $data["date"] = date("Y-m-d H:i:s");
                $data["logs"] = file_get_contents($this->getLogFile($commandSignature));
//                $lines = explode("\n",$data["logs"]);

                echo 'data: ' . json_encode($data);
                echo "\n\n";

                ob_flush();
                flush();

                $pidFile = $this->getPidFile($commandSignature);
                if (file_exists($pidFile)) {
                    $pid = file_get_contents($pidFile);
                } else {
                    break;
                }

                if (empty($pid)) {
                    break;
                }

                if (!file_exists("/proc/$pid")) {
                    break;
                }

                // Break the loop if the client aborted the connection (closed the page)
                if (connection_aborted()) {
                    break;
                }
                sleep(1); // 50ms
            }
        }, 200, [
            'Cache-Control' => 'no-cache',
            'X-Accel-Buffering' => 'no',
            'Content-Type' => 'text/event-stream',
        ]);
    }

    private function getLogFile(string $signature): string
    {
        return storage_path("lucent/$signature.log");
    }

    private function getPidFile(string $signature): string
    {
        return storage_path("lucent/$signature.pid.log");
    }
}