WP_Queue\Worker::process()

Complexity

Conditions	6
Paths	13

Size

Total Lines	28
Code Lines	17

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	11
CRAP Score	7.0986

Importance

Changes

0

<?php
	public function process() {
		$job = $this->connection->pop();

		if ( ! $job ) {
			return false;
		}

		$exception = null;

		try {
			$job->handle();
		} catch ( Exception $exception ) {
			$job->release();
		}

		if ( $job->attempts() >= $this->attempts ) {
			$job->fail();
		}

		if ( $job->failed() ) {
			$this->connection->failure( $job, $exception );

It seems like $job can also be of type true; however, parameter $job of WP_Queue\Connections\ConnectionInterface::failure() does only seem to accept WP_Queue\Job, maybe add an additional type check?

It seems like $exception can also be of type null; however, parameter $exception of WP_Queue\Connections\ConnectionInterface::failure() does only seem to accept Exception, maybe add an additional type check?

		} else if ( $job->released() ) {
			$this->connection->release( $job );

It seems like $job can also be of type true; however, parameter $job of WP_Queue\Connections\ConnectionInterface::release() does only seem to accept WP_Queue\Job, maybe add an additional type check?

		} else {
			$this->connection->delete( $job );

It seems like $job can also be of type true; however, parameter $job of WP_Queue\Connections\ConnectionInterface::delete() does only seem to accept WP_Queue\Job, maybe add an additional type check?

		}

		return true;
	}
}