REDROOM

Edit File Size: 3.33 KB

/home/getspomw/royalsquad.us/vendor/laravel/framework/src/Illuminate/Bus/BusServiceProvider.php

Text Base64

<?php

namespace Illuminate\Bus;

use Aws\DynamoDb\DynamoDbClient;
use Illuminate\Contracts\Bus\Dispatcher as DispatcherContract;
use Illuminate\Contracts\Bus\QueueingDispatcher as QueueingDispatcherContract;
use Illuminate\Contracts\Queue\Factory as QueueFactoryContract;
use Illuminate\Contracts\Support\DeferrableProvider;
use Illuminate\Support\Arr;
use Illuminate\Support\ServiceProvider;

class BusServiceProvider extends ServiceProvider implements DeferrableProvider
{
    /**
     * Register the service provider.
     *
     * @return void
     */
    public function register()
    {
        $this->app->singleton(Dispatcher::class, function ($app) {
            return new Dispatcher($app, function ($connection = null) use ($app) {
                return $app[QueueFactoryContract::class]->connection($connection);
            });
        });

$this->registerBatchServices();

$this->app->alias(
            Dispatcher::class, DispatcherContract::class
        );

$this->app->alias(
            Dispatcher::class, QueueingDispatcherContract::class
        );
    }

/**
     * Register the batch handling services.
     *
     * @return void
     */
    protected function registerBatchServices()
    {
        $this->app->singleton(BatchRepository::class, function ($app) {
            $driver = $app->config->get('queue.batching.driver', 'database');

return $driver === 'dynamodb'
                ? $app->make(DynamoBatchRepository::class)
                : $app->make(DatabaseBatchRepository::class);
        });

$this->app->singleton(DatabaseBatchRepository::class, function ($app) {
            return new DatabaseBatchRepository(
                $app->make(BatchFactory::class),
                $app->make('db')->connection($app->config->get('queue.batching.database')),
                $app->config->get('queue.batching.table', 'job_batches')
            );
        });

$this->app->singleton(DynamoBatchRepository::class, function ($app) {
            $config = $app->config->get('queue.batching');

$dynamoConfig = [
                'region' => $config['region'],
                'version' => 'latest',
                'endpoint' => $config['endpoint'] ?? null,
            ];

if (! empty($config['key']) && ! empty($config['secret'])) {
                $dynamoConfig['credentials'] = Arr::only($config, ['key', 'secret']);

if (! empty($config['token'])) {
                    $dynamoConfig['credentials']['token'] = $config['token'];
                }
            }

return new DynamoBatchRepository(
                $app->make(BatchFactory::class),
                new DynamoDbClient($dynamoConfig),
                $app->config->get('app.name'),
                $app->config->get('queue.batching.table', 'job_batches'),
                ttl: $app->config->get('queue.batching.ttl', null),
                ttlAttribute: $app->config->get('queue.batching.ttl_attribute', 'ttl'),
            );
        });
    }

/**
     * Get the services provided by the provider.
     *
     * @return array
     */
    public function provides()
    {
        return [
            Dispatcher::class,
            DispatcherContract::class,
            QueueingDispatcherContract::class,
            BatchRepository::class,
            DatabaseBatchRepository::class,
        ];
    }
}

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Name	Size	Perms	Modified	Actions
Events DIR	-	drwxrwxrwx	2025-09-17 06:53:02	Edit Download recursive recursive
Batch.php	12.46 KB	lrw-rw-rw-	2025-09-17 06:53:02	Edit Download recursive recursive
Batchable.php	2.76 KB	lrw-rw-rw-	2025-09-17 06:53:02	Edit Download recursive recursive
BatchFactory.php	1.71 KB	lrw-rw-rw-	2025-09-17 06:53:02	Edit Download recursive recursive
BatchRepository.php	2.26 KB	lrw-rw-rw-	2025-09-17 06:53:02	Edit Download recursive recursive
BusServiceProvider.php	3.33 KB	lrw-rw-rw-	2025-09-17 06:53:02	Edit Download recursive recursive
ChainedBatch.php	3.72 KB	lrw-rw-rw-	2025-09-17 06:53:02	Edit Download recursive recursive
composer.json	998 B	lrw-rw-rw-	2025-09-17 06:53:02	Edit Download recursive recursive
DatabaseBatchRepository.php	10.79 KB	lrw-rw-rw-	2025-09-17 06:53:02	Edit Download recursive recursive
Dispatcher.php	7.46 KB	lrw-rw-rw-	2025-09-17 06:53:02	Edit Download recursive recursive
DynamoBatchRepository.php	14.94 KB	lrw-rw-rw-	2025-09-17 06:53:02	Edit Download recursive recursive
LICENSE.md	1.05 KB	lrw-rw-rw-	2025-09-17 06:53:02	Edit Download recursive recursive
PendingBatch.php	9.29 KB	lrw-rw-rw-	2025-09-17 06:53:02	Edit Download recursive recursive
PrunableBatchRepository.php	318 B	lrw-rw-rw-	2025-09-17 06:53:02	Edit Download recursive recursive
Queueable.php	7.72 KB	lrw-rw-rw-	2025-09-17 06:53:02	Edit Download recursive recursive
UniqueLock.php	1.69 KB	lrw-rw-rw-	2025-09-17 06:53:02	Edit Download recursive recursive
UpdatedBatchJobCounts.php	856 B	lrw-rw-rw-	2025-09-17 06:53:02	Edit Download recursive recursive

Directory Contents