Pink-Crab / Perique-Queue

src/Listener/Abstract_Listener.php

Spacing +4 added lines, -4 removed lines

@@ -52,7 +52,7 @@ 
 	 */
 	final public function __invoke(): void {
 		$args = func_get_args();
-		$this->handle( $args );
+		$this->handle($args);
 	}
 
 	/**
@@ -61,8 +61,8 @@ 
 	 * @param \PinkCrab\Loader\Hook_Loader $loader
 	 * @return void
 	 */
-	final public function register( Hook_Loader $loader ): void {
-		$loader->action( $this->hook, $this );
+	final public function register(Hook_Loader $loader): void {
+		$loader->action($this->hook, $this);
 	}
 
 	/**
@@ -71,6 +71,6 @@ 
 	 * @param mixed[] $args
 	 * @return void
 	 */
-	abstract protected function handle( array $args): void;
+	abstract protected function handle(array $args): void;
 
 }

src/Listener/Listener.php

Spacing +1 added lines, -1 removed lines

@@ -30,5 +30,5 @@
 interface Listener {
 	public function __invoke(): void;
 	public function get_hook(): string;
-	public function register( Hook_Loader $loader ): void;
+	public function register(Hook_Loader $loader): void;
 }

src/Queue_Driver/Queue.php

Spacing +6 added lines, -6 removed lines

@@ -57,21 +57,21 @@ 
 	 * @param Event $event
 	 * @return int|null
 	 */
-	public function dispatch( Event $event) : ?int;
+	public function dispatch(Event $event) : ?int;
 
 	/**
 	 * Cancel next occurrence of Event
 	 *
 	 * @param Event $event
 	 */
-	public function cancel_next( Event $event): void;
+	public function cancel_next(Event $event): void;
 
 	/**
 	 * Cancel all occurrences of Event
 	 *
 	 * @param Event $event
 	 */
-	public function cancel_all( Event $event): void;
+	public function cancel_all(Event $event): void;
 
 	/**
 	 * Get next occurrence of Event
@@ -79,7 +79,7 @@ 
 	 * @param Event $event
 	 * @return DateTimeImmutable|null
 	 */
-	public function find_next( Event $event): ?DateTimeImmutable;
+	public function find_next(Event $event): ?DateTimeImmutable;
 
 	/**
 	 * Get all occurrences of Event
@@ -87,7 +87,7 @@ 
 	 * @param Event $event
 	 * @return DateTimeImmutable[]
 	 */
-	public function find_all( Event $event): array;
+	public function find_all(Event $event): array;
 
 
 	/**
@@ -96,6 +96,6 @@ 
 	 * @param Event $event
 	 * @return bool
 	 */
-	public function is_scheduled( Event $event): bool;
+	public function is_scheduled(Event $event): bool;
 
 }

src/Queue_Driver/Action_Scheduler/Action_Scheduler_Queue_Manager.php

Spacing +11 added lines, -11 removed lines

@@ -38,8 +38,8 @@ 
 	 * @param bool $next_only
 	 * @return void
 	 */
-	public function cancel( Event $event, bool $next_only = false ): void {
-		if ( $next_only ) {
+	public function cancel(Event $event, bool $next_only = false): void {
+		if ($next_only) {
 			\as_unschedule_action(
 				$event->get_hook(),
 				$event->get_data() ?? array(),
@@ -61,15 +61,15 @@ 
 	 * @param Event $event
 	 * @return DateTimeImmutable|null
 	 */
-	public function find_next( Event $event ): ?DateTimeImmutable {
+	public function find_next(Event $event): ?DateTimeImmutable {
 		$next = as_next_scheduled_action(
 			$event->get_hook(),
 			$event->get_data() ?? array(),
 			$event->get_group()
 		);
 
-		return is_int( $next )
-			? ( DateTimeImmutable::createFromFormat( 'U', \strval( $next ), wp_timezone() ) ?: null ) //phpcs:ignore
+		return is_int($next)
+			? (DateTimeImmutable::createFromFormat('U', \strval($next), wp_timezone()) ?: null) //phpcs:ignore
 			: null;
 	}
 
@@ -79,7 +79,7 @@ 
 	 * @param Event $event
 	 * @return array<int, DateTimeImmutable>
 	 */
-	public function find_all( Event $event ): array {
+	public function find_all(Event $event): array {
 		$events = as_get_scheduled_actions(
 			array(
 				'hook'         => $event->get_hook(),
@@ -88,21 +88,21 @@ 
 				'status'       => \ActionScheduler_Store::STATUS_PENDING,
 				'orderby'      => 'date',
 				'per_page'     => -1,
-				'date'         => DateTimeImmutable::createFromFormat( 'U', 'now', wp_timezone() ),
+				'date'         => DateTimeImmutable::createFromFormat('U', 'now', wp_timezone()),
 				'date_compare' => '>',
 			)
 		);
 
 		return array_reduce(
 			$events,
-			function ( array $carry, \ActionScheduler_Action $event ): array {
+			function(array $carry, \ActionScheduler_Action $event): array {
 				/** @var ActionScheduler_SimpleSchedule */
 				$schedule = $event->get_schedule();
 
 				// Get the date from schedule, if valid add to array.
 				$date = $schedule->get_date();
-				if ( $date instanceof \DateTime ) {
-					$carry[] = DateTimeImmutable::createFromMutable( $date );
+				if ($date instanceof \DateTime) {
+					$carry[] = DateTimeImmutable::createFromMutable($date);
 				}
 				return $carry;
 			},
@@ -116,7 +116,7 @@ 
 	 * @param \PinkCrab\Queue\Event\Event $event
 	 * @return bool
 	 */
-	public function exists( Event $event ): bool {
+	public function exists(Event $event): bool {
 		return as_has_scheduled_action(
 			$event->get_hook(),
 			$event->get_data() ?? array(),

src/Queue_Driver/Action_Scheduler/Action_Scheduler_Driver.php

Spacing +19 added lines, -19 removed lines

@@ -46,7 +46,7 @@ 
 	/** @var bool */
 	private static $included = false;
 
-	public function __construct( Action_Scheduler_Dispatcher $dispatcher, Action_Scheduler_Queue_Manager $queue_manager ) {
+	public function __construct(Action_Scheduler_Dispatcher $dispatcher, Action_Scheduler_Queue_Manager $queue_manager) {
 		$this->dispatcher    = $dispatcher;
 		$this->queue_manager = $queue_manager;
 	}
@@ -73,7 +73,7 @@ 
 	public function setup(): void {
 
 		// If the lib has already been included, bail.
-		if ( self::$included ) {
+		if (self::$included) {
 			return;
 		}
 
@@ -81,7 +81,7 @@ 
 		$path = join(
 			\DIRECTORY_SEPARATOR,
 			array(
-				dirname( __FILE__, 4 ),
+				dirname(__FILE__, 4),
 				'lib',
 				'action-scheduler',
 				'action-scheduler.php',
@@ -89,11 +89,11 @@ 
 		);
 
 		// Filter the path to the action-scheduler path.
-		$path = apply_filters( 'pinkcrab_queue_action_scheduler_path', $path );
+		$path = apply_filters('pinkcrab_queue_action_scheduler_path', $path);
 
 		// Check if the file exists.
-		if ( ! file_exists( $path ) ) {
-			throw new \RuntimeException( 'Action Scheduler is not installed.' );
+		if ( ! file_exists($path)) {
+			throw new \RuntimeException('Action Scheduler is not installed.');
 		}
 
 		// Include the Action Scheduler plugin.
@@ -128,9 +128,9 @@ 
 	 *
 	 * @param Event $event
 	 */
-	public function dispatch( Event $event ): ?int {
-		$result = $this->dispatcher->dispatch( $event );
-		return \is_int( $result ) ? $result : null;
+	public function dispatch(Event $event): ?int {
+		$result = $this->dispatcher->dispatch($event);
+		return \is_int($result) ? $result : null;
 	}
 
 	/**
@@ -138,8 +138,8 @@ 
 	 *
 	 * @param Event $event
 	 */
-	public function cancel_next( Event $event ): void {
-		$this->queue_manager->cancel( $event, true );
+	public function cancel_next(Event $event): void {
+		$this->queue_manager->cancel($event, true);
 	}
 
 	/**
@@ -147,8 +147,8 @@ 
 	 *
 	 * @param Event $event
 	 */
-	public function cancel_all( Event $event ): void {
-		$this->queue_manager->cancel( $event, false );
+	public function cancel_all(Event $event): void {
+		$this->queue_manager->cancel($event, false);
 	}
 
 	/**
@@ -157,8 +157,8 @@ 
 	 * @param Event $event
 	 * @return DateTimeImmutable|null
 	 */
-	public function find_next( Event $event ): ?DateTimeImmutable {
-		return $this->queue_manager->find_next( $event );
+	public function find_next(Event $event): ?DateTimeImmutable {
+		return $this->queue_manager->find_next($event);
 	}
 
 	/**
@@ -167,8 +167,8 @@ 
 	 * @param Event $event
 	 * @return DateTimeImmutable[]
 	 */
-	public function find_all( Event $event ): array {
-		return $this->queue_manager->find_all( $event );
+	public function find_all(Event $event): array {
+		return $this->queue_manager->find_all($event);
 	}
 
 
@@ -178,7 +178,7 @@ 
 	 * @param Event $event
 	 * @return bool
 	 */
-	public function is_scheduled( Event $event ): bool {
-		return $this->queue_manager->exists( $event );
+	public function is_scheduled(Event $event): bool {
+		return $this->queue_manager->exists($event);
 	}
 }

src/Module/Perique_Queue.php

Spacing +8 added lines, -8 removed lines

@@ -43,11 +43,11 @@ 
 	 * @param Queue $queue_driver
 	 * @return self
 	 */
-	public function set_queue_driver( Queue $queue_driver ): self {
+	public function set_queue_driver(Queue $queue_driver): self {
 		$this->queue_driver = $queue_driver;
 
 		// Init the queue driver.
-		add_action( 'init', array( $this, 'init_driver' ), -1 );
+		add_action('init', array($this, 'init_driver'), -1);
 
 		return $this;
 	}
@@ -82,7 +82,7 @@ 
 	 */
 	private function verify_queue_driver(): void {
 		// If the queue driver is not set, default to the Action Scheduler Driver.
-		if ( ! $this->queue_driver instanceof Queue ) {
+		if ( ! $this->queue_driver instanceof Queue) {
 			$this->queue_driver = Action_Scheduler_Driver::get_instance();
 		}
 	}
@@ -95,7 +95,7 @@ 
 	 * @pram DI_Container $container
 	 * @return void
 	 */
-	public function pre_boot( App_Config $config, Hook_Loader $loader, DI_Container $container ): void { // phpcs:ignore Generic.CodeAnalysis.UnusedFunctionParameter.FoundInImplementedInterfaceBeforeLastUsed, Generic.CodeAnalysis.UnusedFunctionParameter.FoundInImplementedInterfaceAfterLastUsed
+	public function pre_boot(App_Config $config, Hook_Loader $loader, DI_Container $container): void { // phpcs:ignore Generic.CodeAnalysis.UnusedFunctionParameter.FoundInImplementedInterfaceBeforeLastUsed, Generic.CodeAnalysis.UnusedFunctionParameter.FoundInImplementedInterfaceAfterLastUsed
 
 		$this->verify_queue_driver();
 
@@ -106,7 +106,7 @@ 
 		$container->addRule(
 			'*',
 			array(
-				'substitutions' => array( Queue::class => $this->queue_driver ),
+				'substitutions' => array(Queue::class => $this->queue_driver),
 			)
 		);
 
@@ -115,17 +115,17 @@ 
 			Listener::class,
 			array(
 				'call' => array(
-					array( 'register', array( $loader ) ),
+					array('register', array($loader)),
 				),
 			)
 		);
 	}
 
 	/** @inheritDoc */
-	public function pre_register( App_Config $config, Hook_Loader $loader, DI_Container $container ): void {} // phpcs:ignore Generic.CodeAnalysis.UnusedFunctionParameter.FoundInImplementedInterfaceBeforeLastUsed
+	public function pre_register(App_Config $config, Hook_Loader $loader, DI_Container $container): void {} // phpcs:ignore Generic.CodeAnalysis.UnusedFunctionParameter.FoundInImplementedInterfaceBeforeLastUsed
 
 	/** @inheritDoc */
-	public function post_register( App_Config $config, Hook_Loader $loader, DI_Container $container ): void { // phpcs:ignore Generic.CodeAnalysis.UnusedFunctionParameter.FoundInImplementedInterfaceBeforeLastUsed, Generic.CodeAnalysis.UnusedFunctionParameter.FoundInImplementedInterfaceAfterLastUsed
+	public function post_register(App_Config $config, Hook_Loader $loader, DI_Container $container): void { // phpcs:ignore Generic.CodeAnalysis.UnusedFunctionParameter.FoundInImplementedInterfaceBeforeLastUsed, Generic.CodeAnalysis.UnusedFunctionParameter.FoundInImplementedInterfaceAfterLastUsed
 		// If the queue driver is not set, default to the Action Scheduler Driver.
 		$this->verify_queue_driver();
 

src/Dispatch/Queue.php

Spacing +15 added lines, -15 removed lines

@@ -37,14 +37,14 @@ 
 	 * @return Queue_Service
 	 */
 	public static function service(): Queue_Service {
-		if ( self::$instance === null ) {
+		if (self::$instance === null) {
 			/** @var Queue_Service|null */
-			$service        = App::make( Queue_Service::class );
+			$service        = App::make(Queue_Service::class);
 			self::$instance = $service;
 		}
 
 		// If we  still dont have an instance, throw an exception.
-		if ( self::$instance === null ) {
+		if (self::$instance === null) {
 			return self::service();
 		}
 
@@ -57,8 +57,8 @@ 
 	 * @param Event $event
 	 * @return int|null
 	 */
-	public static function dispatch( Event $event ): ?int {
-		return self::service()->dispatch( $event );
+	public static function dispatch(Event $event): ?int {
+		return self::service()->dispatch($event);
 	}
 
 	/**
@@ -67,8 +67,8 @@ 
 	 * @param Event $event
 	 * @return void
 	 */
-	public static function cancel_next( Event $event ): void {
-		self::service()->cancel_next( $event );
+	public static function cancel_next(Event $event): void {
+		self::service()->cancel_next($event);
 	}
 
 	/**
@@ -77,8 +77,8 @@ 
 	 * @param Event $event
 	 * @return void
 	 */
-	public static function cancel_all( Event $event ): void {
-		self::service()->cancel_all( $event );
+	public static function cancel_all(Event $event): void {
+		self::service()->cancel_all($event);
 	}
 
 	/**
@@ -87,8 +87,8 @@ 
 	 * @param Event $event
 	 * @return ?DateTimeImmutable
 	 */
-	public static function next( Event $event ): ?DateTimeImmutable {
-		return self::service()->next( $event );
+	public static function next(Event $event): ?DateTimeImmutable {
+		return self::service()->next($event);
 	}
 
 	/**
@@ -97,8 +97,8 @@ 
 	 * @param Event $event
 	 * @return array<int, DateTimeImmutable>
 	 */
-	public static function all( Event $event ): array {
-		return self::service()->all( $event );
+	public static function all(Event $event): array {
+		return self::service()->all($event);
 	}
 
 	/**
@@ -107,8 +107,8 @@ 
 	 * @param Event $event
 	 * @return bool
 	 */
-	public static function exists( Event $event ): bool {
-		return self::service()->exists( $event );
+	public static function exists(Event $event): bool {
+		return self::service()->exists($event);
 	}
 
 }

src/Dispatch/Queue_Service.php

Spacing +13 added lines, -13 removed lines

@@ -33,7 +33,7 @@ 
 
 	private Queue $queue;
 
-	public function __construct( Queue $queue ) {
+	public function __construct(Queue $queue) {
 		$this->queue = $queue;
 	}
 
@@ -42,8 +42,8 @@ 
 	 *
 	 * @param Event $event
 	 */
-	public function dispatch( Event $event ): ?int {
-		return $this->queue->dispatch( $event );
+	public function dispatch(Event $event): ?int {
+		return $this->queue->dispatch($event);
 	}
 
 	/**
@@ -51,8 +51,8 @@ 
 	 *
 	 * @param Event $event
 	 */
-	public function cancel_next( Event $event ): void {
-		$this->queue->cancel_next( $event );
+	public function cancel_next(Event $event): void {
+		$this->queue->cancel_next($event);
 	}
 
 	/**
@@ -60,8 +60,8 @@ 
 	 *
 	 * @param Event $event
 	 */
-	public function cancel_all( Event $event ): void {
-		$this->queue->cancel_all( $event );
+	public function cancel_all(Event $event): void {
+		$this->queue->cancel_all($event);
 	}
 
 	/**
@@ -70,8 +70,8 @@ 
 	 * @param Event $event
 	 * @return DateTimeImmutable|null
 	 */
-	public function next( Event $event ): ?DateTimeImmutable {
-		return $this->queue->find_next( $event );
+	public function next(Event $event): ?DateTimeImmutable {
+		return $this->queue->find_next($event);
 	}
 
 	/**
@@ -80,8 +80,8 @@ 
 	 * @param Event $event
 	 * @return DateTimeImmutable[]
 	 */
-	public function all( Event $event ): array {
-		return $this->queue->find_all( $event );
+	public function all(Event $event): array {
+		return $this->queue->find_all($event);
 	}
 
 
@@ -91,7 +91,7 @@ 
 	 * @param Event $event
 	 * @return bool
 	 */
-	public function exists( Event $event ): bool {
-		return $this->queue->is_scheduled( $event );
+	public function exists(Event $event): bool {
+		return $this->queue->is_scheduled($event);
 	}
 }

src/Queue_Driver/Action_Scheduler/Action_Scheduler_Dispatcher.php

Spacing +22 added lines, -22 removed lines

@@ -39,10 +39,10 @@ 
 	 * @param Event $event
 	 * @return int|null Returns the event id.
 	 */
-	public function dispatch( Event $event ): ?int {
+	public function dispatch(Event $event): ?int {
 		// @phpstan-ignore-next-line
-		$queue_id = \call_user_func( array( $this, $this->get_dispatch_type( $event ) ), $event );
-		return \is_int( $queue_id ) ? $queue_id : null;
+		$queue_id = \call_user_func(array($this, $this->get_dispatch_type($event)), $event);
+		return \is_int($queue_id) ? $queue_id : null;
 	}
 
 	/**
@@ -51,33 +51,33 @@ 
 	 * @param Event $event
 	 * @return string
 	 */
-	private function get_dispatch_type( Event $event ): string {
+	private function get_dispatch_type(Event $event): string {
 		// If the event is async or there is no delay or interval.
-		if ( $event instanceof Async_Event
-		|| ( is_null( $event->delayed_until() ) && is_null( $event->interval() ) )
+		if ($event instanceof Async_Event
+		|| (is_null($event->delayed_until()) && is_null($event->interval()))
 		) {
 			// Return async.
 			return 'dispatch_async';
 		}
 
 		// If the event is delayed or has no interval.
-		if ( $event instanceof Delayed_Event
-		|| ( $event->delayed_until() instanceof DateTimeImmutable && is_null( $event->interval() ) )
+		if ($event instanceof Delayed_Event
+		|| ($event->delayed_until() instanceof DateTimeImmutable && is_null($event->interval()))
 		) {
 			// Return delayed.
 			return 'dispatch_at';
 		}
 
 		// If the event is a recurring event and has an interval.
-		if ( $event instanceof Recurring_Event
-		|| ( is_int( $event->interval() ) && $event->interval() > 0 )
+		if ($event instanceof Recurring_Event
+		|| (is_int($event->interval()) && $event->interval() > 0)
 		) {
 			// Return recurring.
 			return 'dispatch_recurring';
 		}
 
 		// If we get to the end and none has passed, throw exception.
-		throw new \Exception( 'Unable to determine dispatch type.' );
+		throw new \Exception('Unable to determine dispatch type.');
 	}
 
 	/**
@@ -86,7 +86,7 @@ 
 	 * @param Event $event
 	 * @return int Returns the event id.
 	 */
-	private function dispatch_async( Event $event ): int {
+	private function dispatch_async(Event $event): int {
 		return \as_enqueue_async_action(
 			$event->get_hook(),
 			$event->get_data() ?? array(),
@@ -101,16 +101,16 @@ 
 	 * @param Event $event
 	 * @return int Returns the event id.
 	 */
-	private function dispatch_at( Event $event ): int {
-		if ( ! $event->delayed_until() instanceof DateTimeImmutable ) {
-			throw new \InvalidArgumentException( 'Event must have a delayed_until date/time.' );
+	private function dispatch_at(Event $event): int {
+		if ( ! $event->delayed_until() instanceof DateTimeImmutable) {
+			throw new \InvalidArgumentException('Event must have a delayed_until date/time.');
 		}
 
 		/** @var DateTimeImmutable */
 		$delayed_until = $event->delayed_until();
 
 		return as_schedule_single_action(
-			(int) $delayed_until->setTimezone( wp_timezone() )->format( 'U' ),
+			(int) $delayed_until->setTimezone(wp_timezone())->format('U'),
 			$event->get_hook(),
 			$event->get_data() ?? array(),
 			$event->get_group(),
@@ -124,18 +124,18 @@ 
 	 * @param Event $event
 	 * @return int Returns the event id.
 	 */
-	private function dispatch_recurring( Event $event ): int {
-		if ( $event->interval() === null ) {
-			throw new \InvalidArgumentException( 'Event must have an for it to be recurring.' );
+	private function dispatch_recurring(Event $event): int {
+		if ($event->interval() === null) {
+			throw new \InvalidArgumentException('Event must have an for it to be recurring.');
 		}
 
 		/** @var DateTimeImmutable */
 		$delayed_until = $event->delayed_until() instanceof \DateTimeImmutable
-			? $event->delayed_until()->setTimezone( wp_timezone() )
-			: DateTimeImmutable::createFromFormat( 'U', '0', wp_timezone() );
+			? $event->delayed_until()->setTimezone(wp_timezone())
+			: DateTimeImmutable::createFromFormat('U', '0', wp_timezone());
 
 		return as_schedule_recurring_action(
-			(int) $delayed_until->format( 'U' ),
+			(int) $delayed_until->format('U'),
 			$event->interval(),
 			$event->get_hook(),
 			$event->get_data() ?? array(),