coolify/app/Livewire/ActivityMonitor.php

57 lines
1.4 KiB
PHP
Raw Normal View History

2023-05-03 07:23:45 +02:00
<?php
2023-12-07 19:06:32 +01:00
namespace App\Livewire;
2023-05-03 07:23:45 +02:00
2023-05-08 09:16:50 +02:00
use App\Enums\ProcessStatus;
2023-05-03 07:23:45 +02:00
use Livewire\Component;
use Spatie\Activitylog\Models\Activity;
class ActivityMonitor extends Component
{
public string|null $header = null;
2023-05-03 07:23:45 +02:00
public $activityId;
public $isPollingActive = false;
protected $activity;
protected $listeners = ['newMonitorActivity'];
public function newMonitorActivity($activityId)
{
$this->activityId = $activityId;
$this->hydrateActivity();
$this->isPollingActive = true;
}
public function hydrateActivity()
{
$this->activity = Activity::query()
->find($this->activityId);
}
2023-05-03 07:23:45 +02:00
public function polling()
{
$this->hydrateActivity();
2023-05-08 09:16:50 +02:00
$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);
}
2023-05-03 07:23:45 +02:00
$this->isPollingActive = false;
2023-12-07 19:06:32 +01:00
$this->dispatch('activityFinished');
2023-05-03 07:23:45 +02:00
}
}
2023-05-08 09:16:50 +02:00
protected function setStatus($status)
{
$this->activity->properties = $this->activity->properties->merge([
'status' => $status,
]);
$this->activity->save();
}
}