| Server IP : 78.140.185.180 / Your IP : 216.73.216.170 Web Server : LiteSpeed System : Linux cpanel13.v.fozzy.com 4.18.0-513.11.1.lve.el8.x86_64 #1 SMP Thu Jan 18 16:21:02 UTC 2024 x86_64 User : builderbox ( 1072) PHP Version : 7.3.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /home/builderbox/./././www/vendor/laravel/horizon/src/ |
Upload File : |
<?php
namespace Laravel\Horizon;
use Illuminate\Contracts\Events\Dispatcher;
use Illuminate\Queue\QueueManager;
use Illuminate\Support\Facades\Route;
use Illuminate\Support\ServiceProvider;
use Laravel\Horizon\Connectors\RedisConnector;
class HorizonServiceProvider extends ServiceProvider
{
use EventMap, ServiceBindings;
/**
* Bootstrap any application services.
*
* @return void
*/
public function boot()
{
$this->registerEvents();
$this->registerRoutes();
$this->registerResources();
$this->defineAssetPublishing();
$this->offerPublishing();
$this->registerCommands();
}
/**
* Register the Horizon job events.
*
* @return void
*/
protected function registerEvents()
{
$events = $this->app->make(Dispatcher::class);
foreach ($this->events as $event => $listeners) {
foreach ($listeners as $listener) {
$events->listen($event, $listener);
}
}
}
/**
* Register the Horizon routes.
*
* @return void
*/
protected function registerRoutes()
{
Route::group([
'domain' => config('horizon.domain', null),
'prefix' => config('horizon.path'),
'namespace' => 'Laravel\Horizon\Http\Controllers',
'middleware' => config('horizon.middleware', 'web'),
], function () {
$this->loadRoutesFrom(__DIR__.'/../routes/web.php');
});
}
/**
* Register the Horizon resources.
*
* @return void
*/
protected function registerResources()
{
$this->loadViewsFrom(__DIR__.'/../resources/views', 'horizon');
}
/**
* Define the asset publishing configuration.
*
* @return void
*/
public function defineAssetPublishing()
{
$this->publishes([
HORIZON_PATH.'/public' => public_path('vendor/horizon'),
], ['horizon-assets', 'laravel-assets']);
}
/**
* Setup the resource publishing groups for Horizon.
*
* @return void
*/
protected function offerPublishing()
{
if ($this->app->runningInConsole()) {
$this->publishes([
__DIR__.'/../stubs/HorizonServiceProvider.stub' => app_path('Providers/HorizonServiceProvider.php'),
], 'horizon-provider');
$this->publishes([
__DIR__.'/../config/horizon.php' => config_path('horizon.php'),
], 'horizon-config');
}
}
/**
* Register the Horizon Artisan commands.
*
* @return void
*/
protected function registerCommands()
{
if ($this->app->runningInConsole()) {
$this->commands([
Console\ClearCommand::class,
Console\ContinueCommand::class,
Console\ContinueSupervisorCommand::class,
Console\ForgetFailedCommand::class,
Console\HorizonCommand::class,
Console\InstallCommand::class,
Console\ListCommand::class,
Console\PauseCommand::class,
Console\PauseSupervisorCommand::class,
Console\PublishCommand::class,
Console\PurgeCommand::class,
Console\StatusCommand::class,
Console\SupervisorCommand::class,
Console\SupervisorsCommand::class,
Console\TerminateCommand::class,
Console\TimeoutCommand::class,
Console\WorkCommand::class,
]);
}
$this->commands([Console\SnapshotCommand::class]);
}
/**
* Register any application services.
*
* @return void
*/
public function register()
{
if (! defined('HORIZON_PATH')) {
define('HORIZON_PATH', realpath(__DIR__.'/../'));
}
$this->app->bind(Console\WorkCommand::class, function ($app) {
return new Console\WorkCommand($app['queue.worker'], $app['cache.store']);
});
$this->configure();
$this->registerServices();
$this->registerQueueConnectors();
}
/**
* Setup the configuration for Horizon.
*
* @return void
*/
protected function configure()
{
$this->mergeConfigFrom(
__DIR__.'/../config/horizon.php', 'horizon'
);
Horizon::use(config('horizon.use', 'default'));
}
/**
* Register Horizon's services in the container.
*
* @return void
*/
protected function registerServices()
{
foreach ($this->serviceBindings as $key => $value) {
is_numeric($key)
? $this->app->singleton($value)
: $this->app->singleton($key, $value);
}
}
/**
* Register the custom queue connectors for Horizon.
*
* @return void
*/
protected function registerQueueConnectors()
{
$this->app->resolving(QueueManager::class, function ($manager) {
$manager->addConnector('redis', function () {
return new RedisConnector($this->app['redis']);
});
});
}
}