OCA\Chat\OCH\Push\Get

Complexity

Total Complexity

8

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	setRequestData()	0	3	1
A	__construct()	0	5	1
B	execute()	0	25	6

<?php
/**
 * Copyright (c) 2014, Tobia De Koninck hey--at--ledfan.be
 * This file is licensed under the AGPL version 3 or later.
 * See the COPYING file.
 */

namespace OCA\Chat\OCH\Push;

use OCA\Chat\Controller\OCH\ApiController;
use \OCA\Chat\OCH\ChatAPI;
use \OCA\Chat\OCH\Db\PushMessageMapper;
use \OCA\Chat\Db\DoesNotExistException;
use \OCP\AppFramework\Http\JSONResponse;
use \OCA\Chat\OCH\Responses\Error;

class Get extends ChatAPI{

	private $cycles = 0;

	private $pushMessages = array();

	/**
	 * @var $pushMessageMapper \OCA\Chat\OCH\Db\PushMessageMapper
	 */
	private $pushMessageMapper;

	public function __construct(
		PushMessageMapper $pushMessageMapper
	) {
		$this->pushMessageMapper = $pushMessageMapper;
	}

	public function setRequestData(array $requestData){
		$this->requestData = $requestData;
	}

	public function execute(){
		session_write_close();
		do {
			if ($this->cycles > 0){
				sleep(1);
			}
			try {
				$this->pushMessages = $this->pushMessageMapper->findBysSessionId($this->requestData['session_id']);
				break;
			} catch(DoesNotExistException $e){

Consider adding a comment why this CATCH block is empty.

			}
			$this->cycles++;
		} while ($this->cycles < 50);

		if(count($this->pushMessages) > 0) {
			$commands = array();
			foreach ($this->pushMessages as $pushMessage) {
				$command = json_decode($pushMessage->getCommand());
				$commands[$pushMessage->getId()] = $command;
			}
			return new JSONResponse(array('push_msgs' => $commands));
		} else {
			return new Error('push', 'get', ApiController::TIME_EXCEEDED);
		}
	}
}