Pink-Crab / Perique-Queue

plugin.php

Spacing +7 added lines, -7 removed lines

@@ -8,13 +8,13 @@ 
 use PinkCrab\Queue\Queue_Driver\Action_Scheduler\Action_Scheduler_Driver;
 
 $r = Action_Scheduler_Driver::get_instance();
-Queue_Bootstrap::init( $r );
+Queue_Bootstrap::init($r);
 
 
-$app = ( new App_Factory( __DIR__ ) )->with_wp_dice( true )
-	->di_rules( array() )
-	->registration_classes( array() )
-	->construct_registration_middleware( Queue_Middleware::class )
+$app = (new App_Factory(__DIR__))->with_wp_dice(true)
+	->di_rules(array())
+	->registration_classes(array())
+	->construct_registration_middleware(Queue_Middleware::class)
 	->boot();
 
 // add_action('init', function() use( $app ) {
@@ -25,12 +25,12 @@ 
 // Debug helpers, remove this in production.
 add_filter(
 	'wp_php_error_args',
-	function( $message, $error ) {
+	function($message, $error) {
 		echo "<strong>Error type</strong> : {$error['type']}<hr>";
 		echo "<strong>Message </strong> : <pre style='color: #333; font-face:monospace; font-size:8pt;'>{$error['message']}</pre><hr>";
 		echo "<strong>File </strong> : {$error['file']}<hr>";
 		echo "<strong>Line </strong> : {$error['line']}<hr>";
-		dd( $error, $message );
+		dd($error, $message);
 	},
 	2,
 	10

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/Registration_Middleware/Queue_Middleware.php

Spacing +5 added lines, -5 removed lines

@@ -45,7 +45,7 @@ 
 	 * @param \PinkCrab\Loader\Hook_Loader $loader
 	 * @return void
 	 */
-	public function set_hook_loader( Hook_Loader $loader ) {
+	public function set_hook_loader(Hook_Loader $loader) {
 		$this->loader = $loader;
 	}
 
@@ -55,7 +55,7 @@ 
 	 * @param \PinkCrab\Perique\Interfaces\DI_Container $container
 	 * @return void
 	 */
-	public function set_di_container( DI_Container $container ): void {
+	public function set_di_container(DI_Container $container): void {
 		$this->container = $container;
 	}
 
@@ -65,9 +65,9 @@ 
 	 * @param object|Listener $class
 	 * @return object
 	 */
-	public function process( $class ) {
-		if ( $class instanceof Listener ) {
-			$class->register( $this->loader );
+	public function process($class) {
+		if ($class instanceof Listener) {
+			$class->register($this->loader);
 		}
 
 		return $class;

src/Queue_Bootstrap.php

Spacing +4 added lines, -4 removed lines

@@ -36,13 +36,13 @@ 
 	 * @param Queue $queue_driver The Queue Driver.
 	 * @return void
 	 */
-	public static function init( Queue $queue_driver ): void {
+	public static function init(Queue $queue_driver): void {
 		$queue_driver->setup();
 
 		// initialize the queue driver
 		add_action(
 			'init',
-			function() use ( $queue_driver ) {
+			function() use ($queue_driver) {
 				$queue_driver->init();
 			},
 			-1
@@ -50,7 +50,7 @@ 
 
 		add_filter(
 			Hooks::APP_INIT_SET_DI_RULES,
-			function( $rules ) use ( $queue_driver ) {
+			function($rules) use ($queue_driver) {
 
 				$rules['*'] = array(
 					'substitutions' => array(
@@ -65,7 +65,7 @@ 
 
 		add_action(
 			HOOKS::APP_INIT_POST_REGISTRATION,
-			function() use ( $queue_driver ) {
+			function() use ($queue_driver) {
 				$queue_driver->teardown();
 			}
 		);

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_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(),

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);
 	}
 }