A5hleyRich / wp-queue

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