lasthourcloud/app/Livewire/ActivityMonitor.php

56 lines
1.4 KiB
PHP
Raw Normal View History

2023-05-03 05:23:45 +00:00
<?php
2023-12-07 18:06:32 +00:00
namespace App\Livewire;
2023-05-03 05:23:45 +00:00
2023-05-08 07:16:50 +00:00
use App\Enums\ProcessStatus;
2023-05-03 05:23:45 +00:00
use Livewire\Component;
use Spatie\Activitylog\Models\Activity;
class ActivityMonitor extends Component
{
2023-12-08 12:55:55 +00:00
public ?string $header = null;
2023-05-03 05:23:45 +00: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()
{
2023-12-08 12:55:55 +00:00
$this->activity = Activity::find($this->activityId);
}
2023-05-03 05:23:45 +00:00
public function polling()
{
$this->hydrateActivity();
2023-12-08 12:55:55 +00:00
// $this->setStatus(ProcessStatus::IN_PROGRESS);
2023-05-08 07:16:50 +00:00
$exit_code = data_get($this->activity, 'properties.exitCode');
if ($exit_code !== null) {
if ($exit_code === 0) {
2023-12-08 12:55:55 +00:00
// $this->setStatus(ProcessStatus::FINISHED);
2023-05-08 07:16:50 +00:00
} else {
2023-12-08 12:55:55 +00:00
// $this->setStatus(ProcessStatus::ERROR);
2023-05-08 07:16:50 +00:00
}
2023-05-03 05:23:45 +00:00
$this->isPollingActive = false;
2023-12-07 18:06:32 +00:00
$this->dispatch('activityFinished');
2023-05-03 05:23:45 +00:00
}
}
2023-12-08 12:55:55 +00:00
// protected function setStatus($status)
// {
// $this->activity->properties = $this->activity->properties->merge([
// 'status' => $status,
// ]);
// $this->activity->save();
// }
}