Pink-Crab / Perique-Queue

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,5 +96,5 @@ 
 	 * @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_Dispatcher.php

Indentation +2 added lines, -2 removed lines

@@ -107,7 +107,7 @@ 
 		}
 
 		/**
- * @var DateTimeImmutable
+		 * @var DateTimeImmutable
 */
 		$delayed_until = $event->delayed_until();
 
@@ -132,7 +132,7 @@ 
 		}
 
 		/**
- * @var DateTimeImmutable
+		 * @var DateTimeImmutable
 */
 		$delayed_until = $event->delayed_until() instanceof \DateTimeImmutable
 			? $event->delayed_until()->setTimezone( wp_timezone() )

Spacing +22 added lines, -22 removed lines

@@ -39,10 +39,10 @@ 
 	 * @param Event $event
 	 * @return integer|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 integer 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,9 +101,9 @@ 
 	 * @param Event $event
 	 * @return integer 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.');
 		}
 
 		/**
@@ -112,7 +112,7 @@ 
 		$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(),
@@ -126,20 +126,20 @@ 
 	 * @param Event $event
 	 * @return integer 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(),

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;
 	}
@@ -72,7 +72,7 @@ 
 	public function setup(): void {
 
 		// If the lib has already been included, bail.
-		if ( self::$included ) {
+		if (self::$included) {
 			return;
 		}
 
@@ -80,7 +80,7 @@ 
 		$path = join(
 			\DIRECTORY_SEPARATOR,
 			array(
-				dirname( __DIR__, 3 ),
+				dirname(__DIR__, 3),
 				'lib',
 				'action-scheduler',
 				'action-scheduler.php',
@@ -88,11 +88,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.
@@ -127,9 +127,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;
 	}
 
 	/**
@@ -137,8 +137,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);
 	}
 
 	/**
@@ -146,8 +146,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);
 	}
 
 	/**
@@ -156,8 +156,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);
 	}
 
 	/**
@@ -166,8 +166,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);
 	}
 
 
@@ -177,7 +177,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/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,5 +71,5 @@ 
 	 * @param mixed[] $args
 	 * @return void
 	 */
-	abstract protected function handle( array $args ): void;
+	abstract protected function handle(array $args): void;
 }