Queue_Service_Provider.php

<?php
/**
 * Queue_Service_Provider class file.
 *
 * @package Mantle
 */

namespace Mantle\Queue;

use Mantle\Contracts\Queue\Queue_Manager as Queue_Manager_Contract;
use Mantle\Queue\Console\Cleanup_Jobs_Command;
use Mantle\Queue\Console\Run_Command;
use Mantle\Queue\Dispatcher;
use Mantle\Queue\Queue_Manager;
use Mantle\Queue\Worker;
use Mantle\Support\Service_Provider;

use function Mantle\Support\Helpers\tap;

/**
 * Queue Service Provider
 */
class Queue_Service_Provider extends Service_Provider {
	/**
	 * Register the service provider.
	 */
	public function register(): void {
		$this->app->singleton_if(
			'queue',
			fn ( $app ) => tap(
				// Register the Queue Manager with the supported providers when resolved.
				new Queue_Manager( $app ),
				$this->register_providers( ... ),
			),
		);

		$this->app->singleton_if(
			'queue.worker',
			fn ( $app ) => new Worker( $app['queue'], $app['events'] ),
		);

		$this->app->singleton_if(
			'queue.dispatcher',
			fn ( $app ) => new Dispatcher( $app ),
		);

		// Register queue console commands.
		$this->add_command( Cleanup_Jobs_Command::class );
		$this->add_command( Run_Command::class );

		// Register the queue service providers.
		$this->app->register( Providers\WordPress\Service_Provider::class );
	}

	/**
	 * Boot the service provider.
	 */
	public function boot(): void {
		$this->app->make( Queue_Manager_Contract::class );
	}

	/**
	 * Register Queue Providers
	 *
	 * Fire an event to allow other plugins to register queue providers.
	 *
	 * @param Queue_Manager_Contract $manager Queue Manager.
	 */
	protected function register_providers( Queue_Manager_Contract $manager ): void {
		$this->app['events']->dispatch(
			new Events\Providers_Registered( $manager ),
		);
	}
}