69 lines
1.7 KiB
PHP
69 lines
1.7 KiB
PHP
<?php
|
|
|
|
namespace App\Jobs\Middleware;
|
|
|
|
use App\Models\OperationRun;
|
|
use App\Services\OperationRunService;
|
|
use App\Support\OperationRunStatus;
|
|
use App\Support\Operations\OperationRunCorrelationResolver;
|
|
use Closure;
|
|
|
|
class TrackOperationRun
|
|
{
|
|
/**
|
|
* Process the queued job.
|
|
*
|
|
* @param mixed $job
|
|
* @param callable $next
|
|
* @return mixed
|
|
*/
|
|
public function handle($job, Closure $next)
|
|
{
|
|
$run = $this->resolveRun($job);
|
|
|
|
if (! $run instanceof OperationRun) {
|
|
return $next($job);
|
|
}
|
|
|
|
/** @var OperationRunService $service */
|
|
$service = app(OperationRunService::class);
|
|
|
|
$run->refresh();
|
|
|
|
if ($run->status === OperationRunStatus::Completed->value) {
|
|
return null;
|
|
}
|
|
|
|
if ($run->status !== OperationRunStatus::Running->value) {
|
|
$service->updateRun($run, OperationRunStatus::Running->value);
|
|
}
|
|
|
|
try {
|
|
$response = $next($job);
|
|
|
|
if (property_exists($job, 'job') && $job->job && method_exists($job->job, 'isReleased') && $job->job->isReleased()) {
|
|
return $response;
|
|
}
|
|
|
|
$run->refresh();
|
|
|
|
if ($run->status === OperationRunStatus::Running->value) {
|
|
$service->updateRun($run, OperationRunStatus::Completed->value, 'succeeded');
|
|
}
|
|
|
|
return $response;
|
|
} catch (\Throwable $e) {
|
|
$service->failRun($run, $e);
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* @param mixed $job
|
|
*/
|
|
private function resolveRun($job): ?OperationRun
|
|
{
|
|
return app(OperationRunCorrelationResolver::class)->resolve($job);
|
|
}
|
|
}
|