PhpEarth\Stats\Fetcher

Complexity

Total Complexity

14

Size/Duplication

Total Lines	128
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
C	getNewMembers()	0	39	7
B	getFeed()	0	37	6

<?php

namespace PhpEarth\Stats;

use Symfony\Component\Console\Helper\ProgressBar;
use Facebook\Facebook;
use Facebook\Exceptions\FacebookSDKException;
use Facebook\Exceptions\FacebookResponseException;

/**
 * Class Fetcher.
 */
class Fetcher
{
    /**
     * @var Facebook
     */
    protected $fb;

    /**
     * @var Config
     */
    protected $config;

    /**
     * @var ProgressBar
     */
    protected $progress;

    /**
     * @var array
     */
    protected $feed = [];

    /**
     * Mapper constructor.
     *
     * @param Config $config
     * @param ProgressBar $progress
     * @param Facebook $fb
     */
    public function __construct(Config $config, ProgressBar $progress, Facebook $fb)
    {
        $this->config = $config;
        $this->progress = $progress;
        $this->fb = $fb;
    }

    /**
     * Fetch feed from API data.
     *
     * @return array
     *
     * @throws \Exception
     */
    public function getFeed()
    {
        $this->progress->setMessage('Fetching feed...');
        $this->progress->advance();

        $this->feed = [];

        try {
            $pagesCount = 0;
            $since = $this->config->getParameter('start_datetime')->getTimestamp() - $this->config->getParameter('offset');
            $until = $this->config->getParameter('end_datetime')->getTimestamp() + $this->config->getParameter('offset');
            $response = $this->fb->get('/'.$this->config->getParameter('group_id').'/feed?fields=comments.limit(200).summary(1){comment_count,from,created_time,message,can_comment,reactions.limit(0).summary(1),comments.limit(200).summary(1){comment_count,from,created_time,message,reactions.limit(0).summary(1)}},reactions.limit(0).summary(1),from,created_time,updated_time,message,type,attachments{type},shares&include_hidden=true&limit=50&since='.$since.'&until='.$until);

            $feedEdge = $response->getGraphEdge();

            if (count($feedEdge) > 0) {
                do {
                    ++$pagesCount;
                    $this->progress->setMessage('Fetching feed from API page '.$pagesCount.' and with the topic updated '.$feedEdge[0]->getField('updated_time')->format('Y-m-d H:i:s'));
                    $this->progress->advance();
                    foreach ($feedEdge as $topic) {
                        $this->feed[] = $topic;
                    }
                } while ($feedEdge = $this->fb->next($feedEdge));
            }
        } catch (FacebookResponseException $e) {
            // When Graph returns an error
            throw new \Exception('Graph returned an error: '.$e->getMessage());
        } catch (FacebookSDKException $e) {
            // When validation fails or other local issues
            throw new \Exception('Facebook SDK returned an error: '.$e->getMessage());
        }

        $this->progress->setMessage('Adding topics to collection...');
        $this->progress->advance();

        return $this->feed;
    }

    /**
     * Get number of new users since the user's name set in app configuration.
     *
     * @return int
     *
     * @throws \Exception
     */
    public function getNewMembers()
    {
        $this->progress->setMessage('Retrieving members...');
        $this->progress->advance();
        $newMembers = [];
        $pagesCount = 0;

        try {
            $response = $this->fb->get('/'.$this->config->getParameter('group_id').'/members?fields=id,name,joined&limit=1000');

            $feedEdge = $response->getGraphEdge();
            do {
                ++$pagesCount;
                $this->progress->setMessage('Retrieving members from API page '.$pagesCount);
                $this->progress->advance();

                foreach ($feedEdge as $status) {
                    $newMembers[] = [$status->asArray()['id'], $status->asArray()['name']];

                    if ($status->asArray()['joined'] <= $this->config->getParameter('start_datetime')->getTimestamp()) {
                        break 2;
                    }
                }

                if ($pagesCount == $this->config->getParameter('api_pages')) {
                    break;
                }
            } while ($feedEdge = $this->fb->next($feedEdge));
        } catch (FacebookResponseException $e) {
            // When Graph returns an error
            throw new \Exception('Graph returned an error: '.$e->getMessage());
        } catch (FacebookSDKException $e) {
            // When validation fails or other local issues
            throw new \Exception('Facebook SDK returned an error: '.$e->getMessage());
        }

        $this->progress->advance();

        return $newMembers;

The expression return $newMembers returns the type array|array<mixed,array> which is incompatible with the documented return type integer.

    }
}