OCA\Calendar\Controller\SubscriptionController

Complexity

Total Complexity

14

Size/Duplication

Total Lines	170
Duplicated Lines	15.88 %

Coupling/Cohesion

Components	1
Dependencies	9

Importance

Changes	6
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	16	1
A	index()	11	11	2
A	show()	0	10	2
B	create()	0	30	4
A	update()	0	20	3
A	destroy()	16	16	2

<?php
/**
 * ownCloud - Calendar App
 *
 * @author Georg Ehrke
 * @copyright 2014 Georg Ehrke <oc.list@georgehrke.com>
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU AFFERO GENERAL PUBLIC LICENSE
 * License as published by the Free Software Foundation; either
 * version 3 of the License, or any later version.
 *
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU AFFERO GENERAL PUBLIC LICENSE for more details.
 *
 * You should have received a copy of the GNU Affero General Public
 * License along with this library.  If not, see <http://www.gnu.org/licenses/>.
 *
 */
namespace OCA\Calendar\Controller;

use OCA\Calendar\Backend\Exception as BackendException;
use OCA\Calendar\BusinessLayer\Subscription;
use OCA\Calendar\Db\SubscriptionFactory;
use OCA\Calendar\Http\JSON;
use OCA\Calendar\Http\ReaderException;
use OCA\Calendar\IBackend;
use OCA\Calendar\IBackendCollection;
use OCA\Calendar\ISubscription;

use OCP\AppFramework\Http;
use OCP\AppFramework\Http\JSONResponse;
use OCP\IRequest;
use OCP\IUserSession;

class SubscriptionController extends Controller {

	/**
	 * BusinessLayer for managing backends
	 * @var Subscription
	 */
	protected $subscriptions;


	/**
	 * @var IBackendCollection
	 */
	protected $backends;


	/**
	 * @param string $appName
	 * @param IRequest $request an instance of the request
	 * @param IUserSession $userSession
	 * @param Subscription $subscriptions
	 * @param SubscriptionFactory $subscriptionFactory
	 * @param IBackendCollection $backends
	 */
	public function __construct($appName, IRequest $request, IUserSession $userSession,
								Subscription $subscriptions, SubscriptionFactory $subscriptionFactory,
								IBackendCollection $backends) {
		parent::__construct($appName, $request, $userSession);
		$this->subscriptions = $subscriptions;
		$this->backends = $backends;

		$this->registerReader('json', function(IRequest $request) use ($subscriptionFactory) {
			$reader = new JSON\SubscriptionReader($request, $subscriptionFactory);
			return $reader;
		});

		$this->registerResponder('json', function($value) {
			return new JSON\SubscriptionResponse($value, $this->getSuccessfulStatusCode());
		});
	}


	/**
	 * @param int $limit
	 * @param int $offset
	 * @return \OCP\AppFramework\Http\Response
	 *
	 * @NoAdminRequired
	 * @NoCSRFRequired
	 */
	public function index($limit=null, $offset=null) {

This method seems to be duplicated in your project.

		try {
			return $this->subscriptions->findAll(
				$this->user->getUID(),
				$limit,
				$offset
			);
		} catch (\Exception $ex) {
			return $this->handleException($ex);
		}
	}


	/**
	 * @param integer $id
	 * @return \OCP\AppFramework\Http\Response
	 *
	 * @NoAdminRequired
	 * @NoCSRFRequired
	 */
	 public function show($id) {
		try {
			return $this->subscriptions->find(
				$id,
				$this->user->getUID()
			);
		} catch (\Exception $ex) {
			return $this->handleException($ex);
		}
	}


	/**
	 * @NoAdminRequired
	 * @NoCSRFRequired
	 */
	public function create() {
		try {
			$subscription = $this->readInput();

			if (!($subscription instanceof ISubscription)) {
				throw new ReaderException(
					'Reader returned unrecognised format'
				);
			}

			$subscription->setUserId($this->user->getUID());

			// todo - move scanner call to businesslayer
			$subscription = $this->subscriptions->create(
				$subscription
			);

			$backend = $this->backends->bySubscriptionType(
				$subscription->getType()
			);

			if ($backend instanceof IBackend) {
				$backend->getBackendCollection()->getScanner()->scan($this->user->getUID());
			}

			return $subscription;
		} catch (\Exception $ex) {
			return $this->handleException($ex);
		}
	}


	/**
	 * @param int $id
	 * @return \OCP\AppFramework\Http\Response
	 *
	 * @NoAdminRequired
	 * @NoCSRFRequired
	 */
	public function update($id) {
		try {
			$subscription = $this->readInput();

			if (!($subscription instanceof ISubscription)) {
				throw new ReaderException(
					'Reader returned unrecognised format'
				);
			}

			$subscription->setUserId($this->user->getUID());
			$subscription->setId($id);

			return $this->subscriptions->update(
				$subscription
			);
		} catch (\Exception $ex) {
			return $this->handleException($ex);
		}
	}


	/**
	 * @param integer $id
	 * @return \OCP\AppFramework\Http\Response
	 *
	 * @NoAdminRequired
	 * @NoCSRFRequired
	 */
	public function destroy($id) {

This method seems to be duplicated in your project.

		try {
			$subscription = $this->subscriptions->find(
				$id,
				$this->user->getUID()
			);

			$this->subscriptions->delete($subscription);

			return new JSONResponse([
				'message' => 'Subscription was deleted successfully',
			]);
		} catch (\Exception $ex) {
			return $this->handleException($ex);
		}
	}
}