coolify/app/Livewire/ActivityMonitor.php

<?php

namespace App\Livewire;

use App\Enums\ProcessStatus;
use App\Models\User;
use Livewire\Component;
use Spatie\Activitylog\Models\Activity;

class ActivityMonitor extends Component
{
    public ?string $header = null;

    public $activityId;

    public $eventToDispatch = 'activityFinished';

    public $isPollingActive = false;

    public bool $fullHeight = false;

    public bool $showWaiting = false;

    protected $activity;

    protected $listeners = ['activityMonitor' => 'newMonitorActivity'];

    public function newMonitorActivity($activityId, $eventToDispatch = 'activityFinished')
    {
        $this->activityId = $activityId;
        $this->eventToDispatch = $eventToDispatch;

        $this->hydrateActivity();

        $this->isPollingActive = true;
    }

    public function hydrateActivity()
    {
        $this->activity = Activity::find($this->activityId);
    }

    public function polling()
    {
        $this->hydrateActivity();
        // $this->setStatus(ProcessStatus::IN_PROGRESS);
        $exit_code = data_get($this->activity, 'properties.exitCode');
        if ($exit_code !== null) {
            // if ($exit_code === 0) {
            //     // $this->setStatus(ProcessStatus::FINISHED);
            // } else {
            //     // $this->setStatus(ProcessStatus::ERROR);
            // }
            $this->isPollingActive = false;
            if ($exit_code === 0) {
                if ($this->eventToDispatch !== null) {
                    if (str($this->eventToDispatch)->startsWith('App\\Events\\')) {
                        $causer_id = data_get($this->activity, 'causer_id');
                        $user = User::find($causer_id);
                        if ($user) {
                            foreach ($user->teams as $team) {
                                $teamId = $team->id;
                                $this->eventToDispatch::dispatch($teamId);
                            }
                        }

                        return;
                    }
                    $this->dispatch($this->eventToDispatch);
                }
            }
        }
    }

    // protected function setStatus($status)
    // {
    //     $this->activity->properties = $this->activity->properties->merge([
    //         'status' => $status,
    //     ]);
    //     $this->activity->save();
    // }
}