coolify/app/Providers/HorizonServiceProvider.php

64 lines
1.9 KiB
PHP
Raw Permalink Normal View History

2023-05-10 07:26:25 +00:00
<?php
namespace App\Providers;
2025-01-10 13:28:46 +00:00
use App\Contracts\CustomJobRepositoryInterface;
use App\Models\ApplicationDeploymentQueue;
2025-01-10 18:00:18 +00:00
use App\Models\User;
2025-01-10 13:28:46 +00:00
use App\Repositories\CustomJobRepository;
use Illuminate\Support\Facades\Event;
2025-01-10 18:00:18 +00:00
use Illuminate\Support\Facades\Gate;
2025-01-10 13:28:46 +00:00
use Laravel\Horizon\Contracts\JobRepository;
use Laravel\Horizon\Events\JobReserved;
use Laravel\Horizon\HorizonApplicationServiceProvider;
2023-05-10 07:26:25 +00:00
class HorizonServiceProvider extends HorizonApplicationServiceProvider
2023-05-10 07:26:25 +00:00
{
/**
2025-01-10 13:28:46 +00:00
* Register services.
2023-05-10 07:26:25 +00:00
*/
2025-01-10 13:28:46 +00:00
public function register(): void
2023-05-10 07:26:25 +00:00
{
2025-01-10 13:28:46 +00:00
$this->app->singleton(JobRepository::class, CustomJobRepository::class);
$this->app->singleton(CustomJobRepositoryInterface::class, CustomJobRepository::class);
2023-05-10 07:26:25 +00:00
}
/**
2025-01-10 13:28:46 +00:00
* Bootstrap services.
2023-05-10 07:26:25 +00:00
*/
2025-01-10 13:28:46 +00:00
public function boot(): void
2023-05-10 07:26:25 +00:00
{
parent::boot();
2025-01-10 17:27:48 +00:00
Event::listen(function (JobReserved $event) {
$payload = $event->payload->decoded;
$jobName = $payload['displayName'];
if ($jobName === 'App\Jobs\ApplicationDeploymentJob') {
$tags = $payload['tags'];
$id = $payload['id'];
$deploymentQueueId = collect($tags)->first(function ($tag) {
return str_contains($tag, 'App\Models\ApplicationDeploymentQueue');
});
if (blank($deploymentQueueId)) {
return;
}
2025-01-10 17:27:48 +00:00
$deploymentQueueId = explode(':', $deploymentQueueId)[1];
$deploymentQueue = ApplicationDeploymentQueue::find($deploymentQueueId);
$deploymentQueue->update([
'horizon_job_id' => $id,
]);
}
});
2025-01-10 18:00:18 +00:00
}
protected function gate(): void
{
Gate::define('viewHorizon', function ($user) {
$root_user = User::find(0);
2025-01-10 18:00:18 +00:00
return in_array($user->email, [
$root_user->email,
]);
});
2023-05-10 07:26:25 +00:00
}
}