app\components\MediaManager

Complexity

Total Complexity

8

Size/Duplication

Total Lines	101
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
B	update()	0	31	4
A	updateTags()	0	21	1
B	updateUsernames()	0	24	3

<?php
/**
 * Created for IG Monitoring.
 * User: jakim <pawel@jakimowski.info>
 * Date: 12.01.2018
 */

namespace app\components;


use app\components\instagram\AccountScraper;
use app\models\Account;
use app\models\Media;
use app\models\MediaAccount;
use app\models\MediaStats;

The type app\models\MediaStats was not found. Maybe you did not declare it correctly or list all dependencies?

use app\models\MediaTag;
use app\models\Tag;
use jakim\ig\Text;
use Jakim\Model\Post;
use yii\base\Component;
use yii\base\Exception;

class MediaManager extends Component
{
    /**
     * @var \app\models\Account
     */
    public $account;

    /**
     * @param \app\models\Media $media
     * @param \Jakim\Model\Post $data
     * @throws \yii\base\Exception
     * @throws \yii\base\InvalidConfigException
     * @throws \yii\db\Exception
     */
    public function update(Media $media, Post $data)
    {
        $this->account = $media->account ?? $this->account;

        $media->instagram_id = $data->id;
        $media->shortcode = $data->shortcode;
        $media->is_video = $data->isVideo;
        $media->caption = $data->caption;
        $media->taken_at = (new \DateTime('@' . $data->takenAt))->format('Y-m-d H:i:s');

        $media->likes = $data->likes;
        $media->comments = $data->comments;
        if ($this->account->lastAccountStats) {
            $media->account_followed_by = $this->account->lastAccountStats->followed_by;
            $media->account_follows = $this->account->lastAccountStats->follows;
        }

        $media->account_id = $this->account->id;

        if (!$media->save()) {
            throw new Exception(json_encode($media->errors));
        }

        if ($media->caption) {
            $tags = (array)Text::getTags($media->caption);
            $this->updateTags($media, $tags);

            $usernames = (array)Text::getUsernames($media->caption);
            // ignore owner of media
            ArrayHelper::removeValue($usernames, $this->account->username);
            $this->updateUsernames($media, $usernames);
        }
    }

    public function updateUsernames(Media $media, array $usernames)
    {
        $manager = \Yii::createObject(AccountManager::class);
        $manager->saveUsernames($usernames);
        if ($this->account && $this->account->accounts_monitoring_level) {
            $manager->monitorMultiple($usernames, $this->account);
        }

        $createdAt = (new \DateTime())->format('Y-m-d H:i:s');
        $rows = array_map(function ($id) use ($media, $createdAt) {
            return [
                $media->id,
                $id,
                $createdAt,
            ];
        }, Account::find()
            ->andWhere(['username' => $usernames])
            ->column());

        $sql = \Yii::$app->db->queryBuilder
            ->batchInsert(MediaAccount::tableName(), ['media_id', 'account_id', 'created_at'], $rows);
        $sql = str_replace('INSERT INTO ', 'INSERT IGNORE INTO ', $sql);
        \Yii::$app->db->createCommand($sql)
            ->execute();
    }

    /**
     * @param \app\models\Media $media
     * @param array $tags
     * @throws \yii\base\InvalidConfigException
     * @throws \yii\db\Exception
     */
    public function updateTags(Media $media, array $tags)
    {
        $manager = \Yii::createObject(TagManager::class);
        $manager->saveTags($tags);

        $createdAt = (new \DateTime())->format('Y-m-d H:i:s');
        $rows = array_map(function ($id) use ($media, $createdAt) {
            return [
                $media->id,
                $id,
                $createdAt,
            ];
        }, Tag::find()
            ->andWhere(['name' => $tags])
            ->column());

        $sql = \Yii::$app->db->queryBuilder
            ->batchInsert(MediaTag::tableName(), ['media_id', 'tag_id', 'created_at'], $rows);
        $sql = str_replace('INSERT INTO ', 'INSERT IGNORE INTO ', $sql);
        \Yii::$app->db->createCommand($sql)
            ->execute();
    }

}