GetStream\Doctrine\FeedManager

Complexity

Total Complexity

13

Size/Duplication

Total Lines	142
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	2
Bugs	0	Features	0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	getNotificationFeed()	0	3	1
A	setUserFeed()	0	5	1
A	setNotificationFeed()	0	5	1
A	getNewsFeeds()	0	5	1
A	setNewsFeeds()	0	5	1
A	followUser()	0	7	2
A	__construct()	0	3	1
A	unfollowUser()	0	7	2
A	getFeed()	0	3	1
A	getClient()	0	3	1
A	getUserFeed()	0	3	1

<?php

namespace GetStream\Doctrine;

use GetStream\Stream\Client;
use GetStream\Stream\Feed;

class FeedManager implements FeedManagerInterface
{
    /**
     * @var Client
     */
    private $client;

    /**
     * @var string
     */
    private $userFeed = 'user';

    /**
     * @var string
     */
    private $notificationFeed = 'notification';

    /**
     * @var string[]
     */
    private $newsFeeds = [];

    /**
     * @param Client $client
     */
    public function __construct(Client $client)
    {
        $this->client = $client;
    }

    /**
     * @param string $userFeed
     *
     * @return $this
     */
    public function setUserFeed($userFeed)
    {
        $this->userFeed = $userFeed;

        return $this;
    }

    /**
     * @param string $notificationFeed
     *
     * @return $this
     */
    public function setNotificationFeed($notificationFeed)
    {
        $this->notificationFeed = $notificationFeed;

        return $this;
    }

    /**
     * @param array $newsFeeds
     *
     * @return $this
     */
    public function setNewsFeeds(array $newsFeeds)
    {
        $this->newsFeeds = $newsFeeds;

        return $this;
    }

    /**
     * @return Client
     */
    public function getClient()
    {
        return $this->client;
    }

    /**
     * @param string $feed
     * @param string $id
     *
     * @return Feed
     */
    public function getFeed($feed, $id)
    {
        return $this->client->feed($feed, $id);
    }

    /**
     * @param string $userId
     *
     * @return Feed
     */
    public function getUserFeed($userId)
    {
        return $this->getFeed($this->userFeed, $userId);
    }

    /**
     * @param string $userId
     *
     * @return Feed
     */
    public function getNotificationFeed($userId)
    {
        return $this->getFeed($this->notificationFeed, $userId);
    }

    /**
     * @param string $userId
     *
     * @return Feed[]
     */
    public function getNewsFeeds($userId)
    {
        return array_map(function ($feed) use ($userId) {
            return $this->getFeed($feed, $userId);
        }, array_combine($this->newsFeeds, $this->newsFeeds));
    }

    /**
     * @param string $userId
     * @param string $targetUserId
     */
    public function followUser($userId, $targetUserId)
    {
        $newsFeeds = $this->getNewsFeeds($userId);
        $targetFeed = $this->getUserFeed($targetUserId);

        foreach ($newsFeeds as $feed) {
            $feed->follow($targetFeed->getSlug(), $targetFeed->getUserId());
        }
    }

    /**
     * @param string $userId
     * @param string $targetUserId
     */
    public function unfollowUser($userId, $targetUserId)
    {
        $newsFeeds = $this->getNewsFeeds($userId);
        $targetFeed = $this->getUserFeed($targetUserId);

        foreach ($newsFeeds as $feed) {
            $feed->unfollow($targetFeed->getSlug(), $targetFeed->getUserId());
        }
    }
}