97 lines
2.8 KiB
PHP
97 lines
2.8 KiB
PHP
<?php
|
|
|
|
namespace App\Jobs\Services;
|
|
|
|
use App\Enums\DeploymentStatus;
|
|
use App\Enums\ServiceStatus;
|
|
use App\Models\Step;
|
|
use Illuminate\Contracts\Queue\ShouldQueue;
|
|
use Illuminate\Foundation\Queue\Queueable;
|
|
use Symfony\Component\Process\Process;
|
|
|
|
class RunStep implements ShouldQueue
|
|
{
|
|
use Queueable;
|
|
|
|
public function __construct(
|
|
protected Step $step,
|
|
) {
|
|
//
|
|
}
|
|
|
|
public function handle(): void
|
|
{
|
|
$this->step->load('deployment.target.server');
|
|
$this->step->update([
|
|
'status' => DeploymentStatus::IN_PROGRESS,
|
|
'started_at' => now(),
|
|
]);
|
|
|
|
$server = $this->step->deployment->target->server;
|
|
|
|
$ssh = $server->sshClient()
|
|
->onOutput(function ($type, $output) {
|
|
if (trim($output) === '') {
|
|
return;
|
|
}
|
|
if ($type === Process::OUT) {
|
|
$this->step->update([
|
|
'logs' => $this->step->logs . "\n" . trim($output),
|
|
]);
|
|
} else {
|
|
$this->step->update([
|
|
'error_logs' => $this->step->error_logs . "\n" . trim($output),
|
|
]);
|
|
}
|
|
});
|
|
|
|
$result = $ssh->execute($this->step->script);
|
|
|
|
if (! $result->isSuccessful()) {
|
|
$this->step->update([
|
|
'status' => DeploymentStatus::FAILED,
|
|
'finished_at' => now(),
|
|
'error_logs' => $this->step->error_logs . "\n" . trim($result->getErrorOutput()),
|
|
]);
|
|
|
|
return;
|
|
}
|
|
|
|
$this->step->update([
|
|
'status' => DeploymentStatus::COMPLETED,
|
|
'finished_at' => now(),
|
|
'secrets' => null,
|
|
]);
|
|
|
|
// Dispatch the next step if available
|
|
if ($nextStep = $this->step->deployment->steps()->where('order', '>', $this->step->order)->orderBy('order', 'asc')->first()) {
|
|
$nextStep->dispatchJob();
|
|
} else {
|
|
$this->step->deployment->update([
|
|
'status' => DeploymentStatus::COMPLETED,
|
|
'finished_at' => now(),
|
|
]);
|
|
$this->step->deployment->target->update([
|
|
'status' => ServiceStatus::RUNNING,
|
|
]);
|
|
}
|
|
}
|
|
|
|
public function failed(\Throwable $exception): void
|
|
{
|
|
$this->step->update([
|
|
'status' => DeploymentStatus::FAILED,
|
|
'finished_at' => now(),
|
|
'error_logs' => $this->step->error_logs . "\n" . trim($exception->getMessage()),
|
|
]);
|
|
|
|
$this->step->deployment->steps()->where('order', '>', $this->step->order)->update([
|
|
'status' => DeploymentStatus::CANCELLED,
|
|
]);
|
|
|
|
$this->step->deployment->update([
|
|
'status' => DeploymentStatus::FAILED,
|
|
]);
|
|
}
|
|
}
|