A5hleyRich / wp-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/Connections/DatabaseConnection.php

Spacing +46 added lines, -46 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,12 +242,12 @@ 
 	 *
 	 * @return null|string
 	 */
-	protected function format_exception( Exception $exception ) {
-		if ( is_null( $exception ) ) {
+	protected function format_exception(Exception $exception) {
+		if (is_null($exception)) {
 			return null;
 		}
 
-		$class = get_class( $exception );
+		$class = get_class($exception);
 
 		return "{$class}: {$exception->getMessage()} (#{$exception->getCode()})";
 	}