OCA\Ocr\Service\StatusService

Complexity

Total Complexity

5

Size/Duplication

Total Lines	100
Duplicated Lines	11 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	getStatus()	0	23	2
A	handleException()	11	11	2

<?php

/**
 * Nextcloud - OCR
 *
 * This file is licensed under the Affero General Public License version 3 or
 * later. See the COPYING file.
 *
 * @author Janis Koehr <janiskoehr@icloud.com>
 * @copyright Janis Koehr 2017
 */
namespace OCA\Ocr\Service;

use Exception;
use OCP\IL10N;
use OCP\ILogger;
use OCA\Ocr\Db\OcrJobMapper;

/**
 * Class StatusService
 * 
 * @package OCA\Ocr\Service
 */
class StatusService {
	
	/**
	 *
	 * @var ILogger
	 */
	private $logger;
	
	/**
	 *
	 * @var String
	 */
	private $userId;
	
	/**
	 *
	 * @var IL10N
	 */
	private $l10n;
	
	/**
	 *
	 * @var OcrJobMapper
	 */
	private $jobMapper;
	
	/**
	 *
	 * @var JobService
	 */
	private $jobService;
	
	/**
	 * StatusService constructor.
	 *
	 * @param IL10N $l10n        	
	 * @param ILogger $logger        	
	 * @param unknown $userId        	
	 * @param OcrJobMapper $mapper        	
	 * @param JobService $jobService        	
	 */
	public function __construct(IL10N $l10n, ILogger $logger, $userId, OcrJobMapper $mapper, JobService $jobService) {
		$this->logger = $logger;
		$this->jobMapper = $mapper;
		$this->userId = $userId;

It seems like $userId of type object<OCA\Ocr\Service\unknown> is incompatible with the declared type string of property $userId.

		$this->l10n = $l10n;
		$this->jobService = $jobService;
	}
	
	/**
	 * A function which returns the JSONResponse for all required status checks and tasks.
	 * It will check for already processed, pending and failed ocr tasks and return them as needed.
	 *
	 * @codeCoverageIgnore
	 * 
	 * @return string
	 */
	public function getStatus() {
		try {
			// TODO: release lock
			// returns user specific processed files
			$processed = $this->jobMapper->findAllProcessed ( $this->userId );
			$this->jobService->handleProcessed ();
			
			// return user specific pending state
			$pending = $this->jobMapper->findAllPending ( $this->userId );
			
			// return user specific failed state and set up error
			$failed = $this->jobMapper->findAllFailed ( $this->userId );
			$this->jobService->handleFailed ();
			
			return [ 
					'processed' => count ( $processed ),
					'failed' => count ( $failed ),
					'pending' => count ( $pending ) 
			];
		} catch ( Exception $e ) {
			$this->handleException ( $e );
		}
	}
	
	/**
	 * Handle the possible thrown Exceptions from all methods of this class.
	 *
	 * @param Exception $e        	
	 * @throws Exception
	 * @throws NotFoundException
	 */
	private function handleException($e) {
		$this->logger->logException ( $e, [ 
				'app' => 'ocr',
				'message' => 'Exception during status service function processing' 
		] );
		if ($e instanceof NotFoundException) {
			throw new NotFoundException ( $e->getMessage () );
		} else {
			throw $e;
		}
	}
}