AlexisLefebvre\Bundle\AsyncTweetsBundle\Utils\PersistTweet

Complexity

Total Complexity

20

Size/Duplication

Total Lines	179
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	persistUser()	0	18	2
A	iterateMedias()	0	8	3
A	addMedias()	0	7	3
A	createTweet()	0	13	1
A	persistTweet()	0	21	3
A	persistRetweetedTweet()	0	14	2
A	persistMedia()	0	16	2
A	addTweet()	0	17	3

<?php

namespace AlexisLefebvre\Bundle\AsyncTweetsBundle\Utils;

use AlexisLefebvre\Bundle\AsyncTweetsBundle\Entity\Media;
use AlexisLefebvre\Bundle\AsyncTweetsBundle\Entity\Tweet;
use AlexisLefebvre\Bundle\AsyncTweetsBundle\Entity\User;

class PersistTweet
{
    private $em;
    private $displayTable;
    private $table;

    public function __construct($em, $displayTable, $table)
    {
        $this->em = $em;
        $this->displayTable = $displayTable;
        $this->table = $table;
    }

    /**
     * @param \stdClass $userTmp
     *
     * @return User
     */
    protected function persistUser(\stdClass $userTmp)
    {
        $user = $this->em
            ->getRepository('AsyncTweetsBundle:User')
            ->findOneById($userTmp->id);

        if (!$user) {
            // Only set the id when adding the User
            $user = new User($userTmp->id);
        }

        // Update other fields
        $user->setValues($userTmp);

        $this->em->persist($user);

        return $user;
    }

    /**
     * @param array $medias
     * @param Tweet $tweet
     */
    public function iterateMedias($medias, Tweet $tweet)
    {
        foreach ($medias as $mediaTmp) {
            if ($mediaTmp->type == 'photo') {
                $this->persistMedia($tweet, $mediaTmp);
            }
        }
    }

    /**
     * @param \stdClass $tweetTmp
     * @param Tweet     $tweet
     */
    protected function addMedias(\stdClass $tweetTmp, Tweet $tweet)
    {
        if ((isset($tweetTmp->entities))
            && (isset($tweetTmp->entities->media))) {
            $this->iterateMedias($tweetTmp->entities->media, $tweet);
        }
    }

    /**
     * Create a Tweet object and return it.
     *
     * @param \stdClass $tweetTmp
     * @param User      $user
     * @param bool      $inTimeline
     *
     * @return Tweet
     */
    protected function createTweet(\stdClass $tweetTmp, $user, $inTimeline)
    {
        $tweet = new Tweet($tweetTmp->id);

        $tweet
            ->setValues($tweetTmp)
            ->setUser($user)
            ->setInTimeline($inTimeline);

        $this->addMedias($tweetTmp, $tweet);

        return $tweet;
    }

    /**
     * @param \stdClass $tweetTmp
     * @param User      $user
     * @param bool      $inTimeline
     *
     * @return Tweet
     */
    protected function persistTweet(\stdClass $tweetTmp, User $user,
        $inTimeline)
    {
        $tweet = $this->em
            ->getRepository('AsyncTweetsBundle:Tweet')
            ->findOneById($tweetTmp->id);

        if (!$tweet) {
            $tweet = $this->createTweet($tweetTmp, $user, $inTimeline);
        }

        if (isset($tweetTmp->retweeted_status)) {
            $retweet = $this->persistRetweetedTweet($tweetTmp);
            $tweet->setRetweetedStatus($retweet);
        }

        $this->em->persist($tweet);
        $this->em->flush();

        return $tweet;
    }

    /**
     * @param \stdClass $tweetTmp
     *
     * @return Tweet
     */
    protected function persistRetweetedTweet(\stdClass $tweetTmp)
    {
        $retweet = $this->em
            ->getRepository('AsyncTweetsBundle:Tweet')
            ->findOneById($tweetTmp->retweeted_status->id);

        if (!$retweet) {
            $retweet = $this->addTweet(
                $tweetTmp->retweeted_status
            );
        }

        return $retweet;
    }

    /**
     * @param Tweet     $tweet
     * @param \stdClass $mediaTmp
     */
    protected function persistMedia(Tweet $tweet, \stdClass $mediaTmp)
    {
        $media = $this->em
            ->getRepository('AsyncTweetsBundle:Media')
            ->findOneById($mediaTmp->id);

        if (!$media) {
            // Only set the id and values when adding the Media
            $media = new Media($mediaTmp->id);
            $media->setValues($mediaTmp);
            $this->em->persist($media);
            $this->em->flush();
        }

        $tweet->addMedia($media);
    }

    /**
     * @param \stdClass $tweetTmp
     * @param bool      $inTimeline
     *
     * @return Tweet
     */
    public function addTweet(\stdClass $tweetTmp, $inTimeline = false)
    {
        $user = $this->persistUser($tweetTmp->user);

        $tweet = $this->persistTweet($tweetTmp, $user, $inTimeline);

        // Ignore retweeted tweets
        if ($this->displayTable && $inTimeline) {
            $this->table->addRow([
                $tweet->getCreatedAt()->format('Y-m-d H:i:s'),
                mb_substr($tweet->getText(), 0, 40),
                $user->getName(),
            ]);
        }

        return $tweet;
    }
}