A5hleyRich / wp-queue

src/WP_Queue/Connections/RedisConnection.php

Spacing +4 added lines, -4 removed lines

@@ -15,7 +15,7 @@ 
 	 *
 	 * @return bool|int
 	 */
-	public function push( Job $job, $delay = 0 ) {
+	public function push(Job $job, $delay = 0) {
 		//
 	}
 
@@ -33,7 +33,7 @@ 
 	 *
 	 * @param Job $job
 	 */
-	public function delete( $job ) {
+	public function delete($job) {
 		//
 	}
 
@@ -42,7 +42,7 @@ 
 	 *
 	 * @param Job $job
 	 */
-	public function release( $job ) {
+	public function release($job) {
 		//
 	}
 
@@ -52,7 +52,7 @@ 
 	 * @param Job       $job
 	 * @param Exception $exception
 	 */
-	public function failure( $job, Exception $exception ) {
+	public function failure($job, Exception $exception) {
 		//
 	}
 

src/WP_Queue/Connections/ConnectionInterface.php

Spacing +4 added lines, -4 removed lines

@@ -15,7 +15,7 @@ 
 	 *
 	 * @return bool|int
 	 */
-	public function push( Job $job, $delay = 0 );
+	public function push(Job $job, $delay = 0);
 
 	/**
 	 * Retrieve a job from the queue.
@@ -29,14 +29,14 @@ 
 	 *
 	 * @param Job $job
 	 */
-	public function delete( $job );
+	public function delete($job);
 
 	/**
 	 * Release a job back onto the queue.
 	 *
 	 * @param Job $job
 	 */
-	public function release( $job );
+	public function release($job);
 
 	/**
 	 * Push a job onto the failure queue.
@@ -46,7 +46,7 @@ 
 	 *
 	 * @return
 	 */
-	public function failure( $job, Exception $exception );
+	public function failure($job, Exception $exception);
 
 	/**
 	 * Get total jobs in the queue.

src/WP_Queue/Job.php

Spacing +9 added lines, -9 removed lines

@@ -61,7 +61,7 @@ 
 	 *
 	 * @param int $id
 	 */
-	public function set_id( $id ) {
+	public function set_id($id) {
 		$this->id = $id;
 	}
 
@@ -79,7 +79,7 @@ 
 	 *
 	 * @param int $attempts
 	 */
-	public function set_attempts( $attempts ) {
+	public function set_attempts($attempts) {
 		$this->attempts = $attempts;
 	}
 
@@ -97,7 +97,7 @@ 
 	 *
 	 * @param null|Carbon $reserved_at
 	 */
-	public function set_reserved_at( $reserved_at ) {
+	public function set_reserved_at($reserved_at) {
 		$this->reserved_at = $reserved_at;
 	}
 
@@ -115,7 +115,7 @@ 
 	 *
 	 * @param Carbon $available_at
 	 */
-	public function set_available_at( Carbon $available_at ) {
+	public function set_available_at(Carbon $available_at) {
 		$this->available_at = $available_at;
 	}
 
@@ -133,7 +133,7 @@ 
 	 *
 	 * @param Carbon $created_at
 	 */
-	public function set_created_at( Carbon $created_at ) {
+	public function set_created_at(Carbon $created_at) {
 		$this->created_at = $created_at;
 	}
 
@@ -176,7 +176,7 @@ 
 	 * @return array
 	 */
 	public function __sleep() {
-		$object_props   = get_object_vars( $this );
+		$object_props   = get_object_vars($this);
 		$excluded_props = array(
 			'id',
 			'attempts',
@@ -187,11 +187,11 @@ 
 			'failed',
 		);
 
-		foreach ( $excluded_props as $prop ) {
-			unset( $object_props[ $prop ] );
+		foreach ($excluded_props as $prop) {
+			unset($object_props[$prop]);
 		}
 
-		return array_keys( $object_props );
+		return array_keys($object_props);
 	}
 
 }
\ 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

src/WP_Queue/Cron.php

Spacing +27 added lines, -27 removed lines

@@ -33,8 +33,8 @@ 
 	 * @param Worker $worker
 	 * @param int    $interval
 	 */
-	public function __construct( $id, $worker, $interval ) {
-		$this->id       = strtolower( str_replace( '\\', '_', $id ) );
+	public function __construct($id, $worker, $interval) {
+		$this->id       = strtolower(str_replace('\\', '_', $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( $this->id, array( $this, 'cron_worker' ) );
+		add_filter('cron_schedules', array($this, 'schedule_cron'));
+		add_action($this->id, array($this, 'cron_worker'));
 
-		if ( ! wp_next_scheduled( $this->id ) ) {
+		if ( ! wp_next_scheduled($this->id)) {
 			// Schedule health check
-			wp_schedule_event( time(), $this->id, $this->id );
+			wp_schedule_event(time(), $this->id, $this->id);
 		}
 
 		return true;
@@ -80,10 +80,10 @@ 
 	 *
 	 * @return array
 	 */
-	public function schedule_cron( $schedules ) {
-		$schedules[ $this->id ] = array(
+	public function schedule_cron($schedules) {
+		$schedules[$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;
@@ -93,7 +93,7 @@ 
 	 * Process any jobs in the queue.
 	 */
 	public function cron_worker() {
-		if ( $this->is_worker_locked() ) {
+		if ($this->is_worker_locked()) {
 			return;
 		}
 
@@ -101,8 +101,8 @@ 
 
 		$this->lock_worker();
 
-		while ( ! $this->time_exceeded() && ! $this->memory_exceeded() ) {
-			if ( ! $this->worker->process() ) {
+		while ( ! $this->time_exceeded() && ! $this->memory_exceeded()) {
+			if ( ! $this->worker->process()) {
 				break;
 			}
 		}
@@ -116,21 +116,21 @@ 
 	 * @return bool
 	 */
 	protected function is_worker_locked() {
-		return (bool) get_site_transient( $this->id );
+		return (bool) get_site_transient($this->id);
 	}
 
 	/**
 	 * Lock the cron worker.
 	 */
 	protected function lock_worker() {
-		set_site_transient( $this->id, time(), 300 );
+		set_site_transient($this->id, time(), 300);
 	}
 
 	/**
 	 * Unlock the cron worker.
 	 */
 	protected function unlock_worker() {
-		delete_site_transient( $this->id );
+		delete_site_transient($this->id);
 	}
 
 	/**
@@ -143,14 +143,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);
 	}
 
 	/**
@@ -159,18 +159,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;
 	}
 
 	/**
@@ -182,13 +182,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/Worker.php

Spacing +10 added lines, -10 removed lines

@@ -24,7 +24,7 @@ 
 	 * @param ConnectionInterface $connection
 	 * @param int                 $attempts
 	 */
-	public function __construct( $connection, $attempts = 3 ) {
+	public function __construct($connection, $attempts = 3) {
 		$this->connection = $connection;
 		$this->attempts   = $attempts;
 	}
@@ -37,7 +37,7 @@ 
 	public function process() {
 		$job = $this->connection->pop();
 
-		if ( ! $job ) {
+		if ( ! $job) {
 			return false;
 		}
 
@@ -45,24 +45,24 @@ 
 
 		try {
 			$job->handle();
-		} catch ( Exception $exception ) {
+		} catch (Exception $exception) {
 			$job->release();
 		}
 
-		if ( $job->attempts() >= $this->attempts ) {
-			if ( empty( $exception ) ) {
+		if ($job->attempts() >= $this->attempts) {
+			if (empty($exception)) {
 				$exception = new WorkerAttemptsExceededException();
 			}
 			
 			$job->fail();
 		}
 
-		if ( $job->failed() ) {
-			$this->connection->failure( $job, $exception );
-		} else if ( $job->released() ) {
-			$this->connection->release( $job );
+		if ($job->failed()) {
+			$this->connection->failure($job, $exception);
+		} else if ($job->released()) {
+			$this->connection->release($job);
 		} else {
-			$this->connection->delete( $job );
+			$this->connection->delete($job);
 		}
 
 		return true;

src/WP_Queue/Connections/DatabaseConnection.php

Spacing +47 added lines, -47 removed lines

@@ -28,7 +28,7 @@ 
 	 *
 	 * @param wpdb $wpdb
 	 */
-	public function __construct( $wpdb ) {
+	public function __construct($wpdb) {
 		$this->database       = $wpdb;
 		$this->jobs_table     = $this->database->prefix . 'queue_jobs';
 		$this->failures_table = $this->database->prefix . 'queue_failures';
@@ -42,14 +42,14 @@ 
 	 *
 	 * @return bool|int
 	 */
-	public function push( Job $job, $delay = 0 ) {
-		$result = $this->database->insert( $this->jobs_table, array(
-			'job'          => serialize( $job ),
-			'available_at' => $this->datetime( $delay ),
+	public function push(Job $job, $delay = 0) {
+		$result = $this->database->insert($this->jobs_table, array(
+			'job'          => serialize($job),
+			'available_at' => $this->datetime($delay),
 			'created_at'   => $this->datetime(),
-		) );
+		));
 
-		if ( ! $result ) {
+		if ( ! $result) {
 			return false;
 		}
 
@@ -64,23 +64,23 @@ 
 	public function pop() {
 		$this->release_reserved();
 
-		$sql = $this->database->prepare( "
+		$sql = $this->database->prepare("
 			SELECT * FROM {$this->jobs_table}
 			WHERE reserved_at IS NULL
 			AND available_at <= %s
 			ORDER BY available_at
 			LIMIT 1
-		", $this->datetime() );
+		", $this->datetime());
 
-		$raw_job = $this->database->get_row( $sql );
+		$raw_job = $this->database->get_row($sql);
 
-		if ( is_null( $raw_job ) ) {
+		if (is_null($raw_job)) {
 			return false;
 		}
 
-		$job = $this->vitalize_job( $raw_job );
+		$job = $this->vitalize_job($raw_job);
 
-		$this->reserve( $job );
+		$this->reserve($job);
 
 		return $job;
 	}
@@ -92,12 +92,12 @@ 
 	 *
 	 * @return bool
 	 */
-	public function delete( $job ) {
+	public function delete($job) {
 		$where = array(
 			'id' => $job->id(),
 		);
 
-		if ( $this->database->delete( $this->jobs_table, $where ) ) {
+		if ($this->database->delete($this->jobs_table, $where)) {
 			return true;
 		}
 
@@ -111,9 +111,9 @@ 
 	 *
 	 * @return bool
 	 */
-	public function release( $job ) {
-		$data  = array(
-			'job'         => serialize( $job ),
+	public function release($job) {
+		$data = array(
+			'job'         => serialize($job),
 			'attempts'    => $job->attempts(),
 			'reserved_at' => null,
 		);
@@ -121,7 +121,7 @@ 
 			'id' => $job->id(),
 		);
 
-		if ( $this->database->update( $this->jobs_table, $data, $where ) ) {
+		if ($this->database->update($this->jobs_table, $data, $where)) {
 			return true;
 		}
 
@@ -136,15 +136,15 @@ 
 	 *
 	 * @return bool
 	 */
-	public function failure( $job, Exception $exception ) {
-		$insert = $this->database->insert( $this->failures_table, array(
-			'job'       => serialize( $job ),
-			'error'     => $this->format_exception( $exception ),
+	public function failure($job, Exception $exception) {
+		$insert = $this->database->insert($this->failures_table, array(
+			'job'       => serialize($job),
+			'error'     => $this->format_exception($exception),
 			'failed_at' => $this->datetime(),
-		) );
+		));
 
-		if ( $insert ) {
-			$this->delete( $job );
+		if ($insert) {
+			$this->delete($job);
 
 			return true;
 		}
@@ -160,7 +160,7 @@ 
 	public function jobs() {
 		$sql = "SELECT COUNT(*) FROM {$this->jobs_table}";
 		
-		return (int) $this->database->get_var( $sql );
+		return (int) $this->database->get_var($sql);
 	}
 
 	/**
@@ -171,7 +171,7 @@ 
 	public function failed_jobs() {
 		$sql = "SELECT COUNT(*) FROM {$this->failures_table}";
 
-		return (int) $this->database->get_var( $sql );
+		return (int) $this->database->get_var($sql);
 	}
 
 	/**
@@ -179,14 +179,14 @@ 
 	 *
 	 * @param Job $job
 	 */
-	protected function reserve( $job ) {
+	protected function reserve($job) {
 		$data = array(
 			'reserved_at' => $this->datetime(),
 		);
 
-		$this->database->update( $this->jobs_table, $data, array(
+		$this->database->update($this->jobs_table, $data, array(
 			'id' => $job->id(),
-		) );
+		));
 	}
 
 	/**
@@ -195,12 +195,12 @@ 
 	protected function release_reserved() {
 		$expired = $this->datetime( -300 );
 
-		$sql = $this->database->prepare( "
+		$sql = $this->database->prepare("
 				UPDATE {$this->jobs_table}
 				SET attempts = attempts + 1, reserved_at = NULL
-				WHERE reserved_at <= %s", $expired );
+				WHERE reserved_at <= %s", $expired);
 
-		$this->database->query( $sql );
+		$this->database->query($sql);
 	}
 
 	/**
@@ -210,14 +210,14 @@ 
 	 *
 	 * @return Job
 	 */
-	protected function vitalize_job( $raw_job ) {
-		$job = unserialize( $raw_job->job );
+	protected function vitalize_job($raw_job) {
+		$job = unserialize($raw_job->job);
 
-		$job->set_id( $raw_job->id );
-		$job->set_attempts( $raw_job->attempts );
-		$job->set_reserved_at( empty( $raw_job->reserved_at ) ? null : new Carbon( $raw_job->reserved_at ) );
-		$job->set_available_at( new Carbon( $raw_job->available_at ) );
-		$job->set_created_at( new Carbon( $raw_job->created_at ) );
+		$job->set_id($raw_job->id);
+		$job->set_attempts($raw_job->attempts);
+		$job->set_reserved_at(empty($raw_job->reserved_at) ? null : new Carbon($raw_job->reserved_at));
+		$job->set_available_at(new Carbon($raw_job->available_at));
+		$job->set_created_at(new Carbon($raw_job->created_at));
 
 		return $job;
 	}
@@ -229,10 +229,10 @@ 
 	 *
 	 * @return string
 	 */
-	protected function datetime( $offset = 0 ) {
+	protected function datetime($offset = 0) {
 		$timestamp = time() + $offset;
 
-		return gmdate( 'Y-m-d H:i:s', $timestamp );
+		return gmdate('Y-m-d H:i:s', $timestamp);
 	}
 
 	/**
@@ -242,14 +242,14 @@ 
 	 *
 	 * @return string
 	 */
-	protected function format_exception( Exception $exception ) {
-		$string = get_class( $exception );
+	protected function format_exception(Exception $exception) {
+		$string = get_class($exception);
 
-		if ( ! empty( $exception->getMessage() ) ) {
+		if ( ! empty($exception->getMessage())) {
 			$string .= " : {$exception->getMessage()}";
 		}
 
-		if ( ! empty( $exception->getCode() ) ) {
+		if ( ! empty($exception->getCode())) {
 			$string .= " (#{$exception->getCode()})";
 		}
 

src/WP_Queue/QueueManager.php

Spacing +10 added lines, -10 removed lines

@@ -21,12 +21,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);
 	}
 
 	/**
@@ -37,16 +37,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];
 	}
 
 	/**
@@ -56,11 +56,11 @@ 
 	 */
 	protected static function connections() {
 		$connections = array(
-			'database' => new DatabaseConnection( $GLOBALS['wpdb'] ),
+			'database' => new DatabaseConnection($GLOBALS['wpdb']),
 			'redis'    => new RedisConnection(),
 			'sync'     => new SyncConnection(),
 		);
 
-		return apply_filters( 'wp_queue_connections', $connections );
+		return apply_filters('wp_queue_connections', $connections);
 	}
 }
\ No newline at end of file

src/functions.php

Spacing +9 added lines, -9 removed lines

@@ -3,7 +3,7 @@ 
 use WP_Queue\Queue;
 use WP_Queue\QueueManager;
 
-if ( ! function_exists( 'wp_queue' ) ) {
+if ( ! function_exists('wp_queue')) {
 	/**
 	 * Return Queue instance.
 	 *
@@ -11,23 +11,23 @@ 
 	 *
 	 * @return Queue
 	 */
-	function wp_queue( $connection = '' ) {
-		if( empty( $connection ) ) {
-			$connection = apply_filters( 'wp_queue_default_connection', 'database' );
+	function wp_queue($connection = '') {
+		if (empty($connection)) {
+			$connection = apply_filters('wp_queue_default_connection', 'database');
 		}
 		
-		return QueueManager::resolve( $connection );
+		return QueueManager::resolve($connection);
 	}
 }
 
-if ( ! function_exists( 'wp_queue_install_tables' ) ) {
+if ( ! function_exists('wp_queue_install_tables')) {
 	/**
 	 * Install database tables
 	 */
 	function wp_queue_install_tables() {
 		global $wpdb;
 
-		require_once( ABSPATH . 'wp-admin/includes/upgrade.php' );
+		require_once(ABSPATH . 'wp-admin/includes/upgrade.php');
 
 		$wpdb->hide_errors();
 		$charset_collate = $wpdb->get_charset_collate();
@@ -42,7 +42,7 @@ 
 				PRIMARY KEY  (id)
 				) $charset_collate;";
 
-		dbDelta( $sql );
+		dbDelta($sql);
 
 		$sql = "CREATE TABLE {$wpdb->prefix}queue_failures (
 				id bigint(20) NOT NULL AUTO_INCREMENT,
@@ -52,6 +52,6 @@ 
 				PRIMARY KEY  (id)
 				) $charset_collate;";
 
-		dbDelta( $sql );
+		dbDelta($sql);
 	}
 }
\ No newline at end of file