A5hleyRich / wp-queue

src/WP_Queue/QueueManager.php

Spacing +10 added lines, -10 removed lines

@@ -20,12 +20,12 @@ 
 	 *
 	 * @return Queue
 	 */
-	public static function resolve( $connection ) {
-		if ( isset( static::$instances[ $connection ] ) ) {
-			return static::$instances[ $connection ];
+	public static function resolve($connection) {
+		if (isset(static::$instances[$connection])) {
+			return static::$instances[$connection];
 		}
 
-		return static::build( $connection );
+		return static::build($connection);
 	}
 
 	/**
@@ -36,16 +36,16 @@ 
 	 * @return Queue
 	 * @throws \Exception
 	 */
-	protected static function build( $connection ) {
+	protected static function build($connection) {
 		$connections = static::connections();
 
-		if ( empty( $connections[ $connection ] ) ) {
+		if (empty($connections[$connection])) {
 			throw new ConnectionNotFoundException();
 		}
 
-		static::$instances[ $connection ] = new Queue( $connections[ $connection ] );
+		static::$instances[$connection] = new Queue($connections[$connection]);
 
-		return static::$instances[ $connection ];
+		return static::$instances[$connection];
 	}
 
 	/**
@@ -55,10 +55,10 @@ 
 	 */
 	protected static function connections() {
 		$connections = array(
-			'database' => new DatabaseConnection( $GLOBALS['wpdb'] ),
+			'database' => new DatabaseConnection($GLOBALS['wpdb']),
 			'redis'    => new RedisConnection(),
 		);
 
-		return apply_filters( 'wp_queue_connections', $connections );
+		return apply_filters('wp_queue_connections', $connections);
 	}
 }
\ No newline at end of file

src/WP_Queue/Cron.php

Spacing +21 added lines, -21 removed lines

@@ -33,7 +33,7 @@ 
 	 * @param Worker $worker
 	 * @param int    $interval
 	 */
-	public function __construct( $id, $worker, $interval ) {
+	public function __construct($id, $worker, $interval) {
 		$this->id       = $id;
 		$this->worker   = $worker;
 		$this->interval = $interval;
@@ -45,7 +45,7 @@ 
 	 * @return bool
 	 */
 	protected function is_enabled() {
-		if ( defined( 'DISABLE_WP_QUEUE_CRON' ) && DISABLE_WP_QUEUE_CRON ) {
+		if (defined('DISABLE_WP_QUEUE_CRON') && DISABLE_WP_QUEUE_CRON) {
 			return false;
 		}
 
@@ -58,16 +58,16 @@ 
 	 * @return bool
 	 */
 	public function init() {
-		if ( ! $this->is_enabled() ) {
+		if ( ! $this->is_enabled()) {
 			return false;
 		}
 
-		add_filter( 'cron_schedules', array( $this, 'schedule_cron' ) );
-		add_action( "wp_queue_worker_{$this->id}", array( $this, 'cron_worker' ) );
+		add_filter('cron_schedules', array($this, 'schedule_cron'));
+		add_action("wp_queue_worker_{$this->id}", array($this, 'cron_worker'));
 
-		if ( ! wp_next_scheduled( "wp_queue_worker_{$this->id}" ) ) {
+		if ( ! wp_next_scheduled("wp_queue_worker_{$this->id}")) {
 			// Schedule health check
-			wp_schedule_event( time(), 'wp_queue_cron_interval', "wp_queue_worker_{$this->id}" );
+			wp_schedule_event(time(), 'wp_queue_cron_interval', "wp_queue_worker_{$this->id}");
 		}
 
 		return true;
@@ -80,10 +80,10 @@ 
 	 *
 	 * @return array
 	 */
-	public function schedule_cron( $schedules ) {
+	public function schedule_cron($schedules) {
 		$schedules["wp_queue_cron_interval_{$this->id}"] = array(
 			'interval' => MINUTE_IN_SECONDS * $this->interval,
-			'display'  => sprintf( __( 'Every %d Minutes' ), $this->interval ),
+			'display'  => sprintf(__('Every %d Minutes'), $this->interval),
 		);
 
 		return $schedules;
@@ -95,8 +95,8 @@ 
 	public function cron_worker() {
 		$this->start_time = time();
 
-		while ( ! $this->time_exceeded() && ! $this->memory_exceeded() ) {
-			if ( ! $this->worker->process() ) {
+		while ( ! $this->time_exceeded() && ! $this->memory_exceeded()) {
+			if ( ! $this->worker->process()) {
 				break;
 			}
 		}
@@ -112,14 +112,14 @@ 
 	 */
 	protected function memory_exceeded() {
 		$memory_limit   = $this->get_memory_limit() * 0.8; // 80% of max memory
-		$current_memory = memory_get_usage( true );
+		$current_memory = memory_get_usage(true);
 		$return         = false;
 
-		if ( $current_memory >= $memory_limit ) {
+		if ($current_memory >= $memory_limit) {
 			$return = true;
 		}
 
-		return apply_filters( 'wp_queue_cron_memory_exceeded', $return );
+		return apply_filters('wp_queue_cron_memory_exceeded', $return);
 	}
 
 	/**
@@ -128,18 +128,18 @@ 
 	 * @return int
 	 */
 	protected function get_memory_limit() {
-		if ( function_exists( 'ini_get' ) ) {
-			$memory_limit = ini_get( 'memory_limit' );
+		if (function_exists('ini_get')) {
+			$memory_limit = ini_get('memory_limit');
 		} else {
 			$memory_limit = '256M';
 		}
 
-		if ( ! $memory_limit || - 1 == $memory_limit ) {
+		if ( ! $memory_limit || - 1 == $memory_limit) {
 			// Unlimited, set to 1GB
 			$memory_limit = '1000M';
 		}
 
-		return intval( $memory_limit ) * 1024 * 1024;
+		return intval($memory_limit) * 1024 * 1024;
 	}
 
 	/**
@@ -151,13 +151,13 @@ 
 	 * @return bool
 	 */
 	protected function time_exceeded() {
-		$finish = $this->start_time + apply_filters( 'wp_queue_cron_time_limit', 20 ); // 20 seconds
+		$finish = $this->start_time + apply_filters('wp_queue_cron_time_limit', 20); // 20 seconds
 		$return = false;
 
-		if ( time() >= $finish ) {
+		if (time() >= $finish) {
 			$return = true;
 		}
 
-		return apply_filters( 'wp_queue_cron_time_exceeded', $return );
+		return apply_filters('wp_queue_cron_time_exceeded', $return);
 	}
 }
\ No newline at end of file

src/WP_Queue/Queue.php

Spacing +8 added lines, -8 removed lines

@@ -21,7 +21,7 @@ 
 	 *
 	 * @param ConnectionInterface $connection
 	 */
-	public function __construct( ConnectionInterface $connection ) {
+	public function __construct(ConnectionInterface $connection) {
 		$this->connection = $connection;
 	}
 
@@ -33,8 +33,8 @@ 
 	 *
 	 * @return bool|int
 	 */
-	public function push( Job $job, $delay = 0 ) {
-		return $this->connection->push( $job, $delay );
+	public function push(Job $job, $delay = 0) {
+		return $this->connection->push($job, $delay);
 	}
 
 	/**
@@ -45,9 +45,9 @@ 
 	 *
 	 * @return Cron
 	 */
-	public function cron( $attempts = 3, $interval = 5 ) {
-		if ( is_null( $this->cron ) ) {
-			$this->cron	= new Cron( get_class( $this->connection ), $this->worker( $attempts ), $interval );
+	public function cron($attempts = 3, $interval = 5) {
+		if (is_null($this->cron)) {
+			$this->cron = new Cron(get_class($this->connection), $this->worker($attempts), $interval);
 			$this->cron->init();
 		}
 
@@ -61,7 +61,7 @@ 
 	 *
 	 * @return Worker
 	 */
-	public function worker( $attempts ) {
-		return new Worker( $this->connection, $attempts );
+	public function worker($attempts) {
+		return new Worker($this->connection, $attempts);
 	}
 }
\ No newline at end of file