OCA\News\Controller\FeedApiController

Complexity

Total Complexity

18

Size/Duplication

Total Lines	198
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	15	1
A	index()	0	17	2
B	create()	0	22	4
A	delete()	0	9	2
A	read()	0	3	1
A	move()	0	11	2
A	rename()	0	11	2
A	fromAllUsers()	0	13	2
A	update()	0	9	2

<?php
/**
 * ownCloud - News
 *
 * This file is licensed under the Affero General Public License version 3 or
 * later. See the COPYING file.
 *
 * @author Alessandro Cosentino <cosenal@gmail.com>
 * @author Bernhard Posselt <dev@bernhard-posselt.com>
 * @copyright Alessandro Cosentino 2012
 * @copyright Bernhard Posselt 2012, 2014
 */

namespace OCA\News\Controller;

use \OCP\IRequest;
use \OCP\ILogger;
use \OCP\AppFramework\ApiController;

This use statement conflicts with another class in this namespace, OCA\News\Controller\ApiController.

use \OCP\AppFramework\Http;

use \OCA\News\Service\FeedService;
use \OCA\News\Service\ItemService;
use \OCA\News\Service\ServiceNotFoundException;
use \OCA\News\Service\ServiceConflictException;


class FeedApiController extends ApiController {

    use JSONHttpError;

    private $itemService;
    private $feedService;
    private $userId;
    private $logger;
    private $loggerParams;
    private $serializer;

    public function __construct($AppName,
                                IRequest $request,
                                FeedService $feedService,
                                ItemService $itemService,
                                ILogger $logger,
                                $UserId,
                                $LoggerParameters){
        parent::__construct($AppName, $request);
        $this->feedService = $feedService;
        $this->itemService = $itemService;
        $this->userId = $UserId;
        $this->logger = $logger;
        $this->loggerParams = $LoggerParameters;
        $this->serializer = new EntityApiSerializer('feeds');
    }


    /**
     * @NoAdminRequired
     * @NoCSRFRequired
     * @CORS
     */
    public function index() {

        $result = [
            'starredCount' => $this->itemService->starredCount($this->userId),
            'feeds' => $this->feedService->findAll($this->userId)
        ];


        try {
            $result['newestItemId'] =
                $this->itemService->getNewestItemId($this->userId);

        // in case there are no items, ignore
        } catch(ServiceNotFoundException $ex) {}

        return $this->serializer->serialize($result);
    }


    /**
     * @NoAdminRequired
     * @NoCSRFRequired
     * @CORS
     *
     * @param string $url
     * @param int $folderId
     * @return array|mixed|\OCP\AppFramework\Http\JSONResponse
     */
    public function create($url, $folderId=0) {
        try {
            $this->feedService->purgeDeleted($this->userId, false);

            $feed = $this->feedService->create($url, $folderId, $this->userId);
            $result = ['feeds' => [$feed]];

            try {
                $result['newestItemId'] =
                    $this->itemService->getNewestItemId($this->userId);

            // in case there are no items, ignore
            } catch(ServiceNotFoundException $ex) {}

            return $this->serializer->serialize($result);

        } catch(ServiceConflictException $ex) {
            return $this->error($ex, Http::STATUS_CONFLICT);
        } catch(ServiceNotFoundException $ex) {
            return $this->error($ex, Http::STATUS_NOT_FOUND);
        }
    }


    /**
     * @NoAdminRequired
     * @NoCSRFRequired
     * @CORS
     *
     * @param int $feedId
     * @return array|\OCP\AppFramework\Http\JSONResponse
     */
    public function delete($feedId) {
        try {
            $this->feedService->delete($feedId, $this->userId);
        } catch(ServiceNotFoundException $ex) {
            return $this->error($ex, Http::STATUS_NOT_FOUND);
        }

        return [];
    }


    /**
     * @NoAdminRequired
     * @NoCSRFRequired
     * @CORS
     *
     * @param int $feedId
     * @param int $newestItemId
     */
    public function read($feedId, $newestItemId) {
        $this->itemService->readFeed($feedId, $newestItemId, $this->userId);
    }


    /**
     * @NoAdminRequired
     * @NoCSRFRequired
     * @CORS
     *
     * @param int $feedId
     * @param int $folderId
     * @return array|\OCP\AppFramework\Http\JSONResponse
     */
    public function move($feedId, $folderId) {
        try {
            $this->feedService->patch(
                $feedId, $this->userId, ['folderId' => $folderId]
            );
        } catch(ServiceNotFoundException $ex) {
            return $this->error($ex, Http::STATUS_NOT_FOUND);
        }

        return [];
    }


    /**
     * @NoAdminRequired
     * @NoCSRFRequired
     * @CORS
     *
     * @param int $feedId
     * @param string $feedTitle
     * @return array|\OCP\AppFramework\Http\JSONResponse
     */
    public function rename($feedId, $feedTitle) {
        try {
            $this->feedService->patch(
                $feedId, $this->userId, ['title' => $feedTitle]
            );
        } catch(ServiceNotFoundException $ex) {
            return $this->error($ex, Http::STATUS_NOT_FOUND);
        }

        return [];
    }


    /**
     * @NoCSRFRequired
     * @CORS
     */
    public function fromAllUsers() {
        $feeds = $this->feedService->findAllFromAllUsers();
        $result = ['feeds' => []];

        foreach ($feeds as $feed) {
            $result['feeds'][] = [
                'id' => $feed->getId(),
                'userId' => $feed->getUserId()
            ];
        }

        return $result;
    }


    /**
     * @NoCSRFRequired
     *
     * @param string $userId
     * @param int $feedId
     */
    public function update($userId, $feedId) {
        try {
            $this->feedService->update($feedId, $userId);
        // ignore update failure
        } catch(\Exception $ex) {
            $this->logger->debug('Could not update feed ' . $ex->getMessage(),
                    $this->loggerParams);
        }
    }


}