A5hleyRich / wp-queue

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/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 bool
 	 */
-	public function failure( $job, Exception $exception );
+	public function failure($job, Exception $exception);
 
 	/**
 	 * Get total jobs in the 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) {
 		//
 	}
 
@@ -54,7 +54,7 @@ 
 	 *
 	 * @return bool
 	 */
-	public function failure( $job, Exception $exception ) {
+	public function failure($job, Exception $exception) {
 		//
 	}
 

src/WP_Queue/QueueManager.php

Spacing +10 added lines, -10 removed lines

@@ -22,12 +22,12 @@ 
 	 * @return Queue
 	 * @throws \Exception
 	 */
-	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);
 	}
 
 	/**
@@ -38,16 +38,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];
 	}
 
 	/**
@@ -57,11 +57,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.
 	 *
@@ -12,23 +12,23 @@ 
 	 * @return Queue
 	 * @throws Exception
 	 */
-	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();
@@ -43,7 +43,7 @@ 
 				PRIMARY KEY  (id)
 				) $charset_collate;";
 
-		dbDelta( $sql );
+		dbDelta($sql);
 
 		$sql = "CREATE TABLE {$wpdb->prefix}queue_failures (
 				id bigint(20) NOT NULL AUTO_INCREMENT,
@@ -53,6 +53,6 @@ 
 				PRIMARY KEY  (id)
 				) $charset_collate;";
 
-		dbDelta( $sql );
+		dbDelta($sql);
 	}
 }
\ No newline at end of file