app\components\services\AccountFullUpdate

Complexity

Total Complexity

16

Size/Duplication

Total Lines	112
Duplicated Lines	0 %

Importance

Changes	3
Bugs	1	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
C	run()	0	75	10
A	fetchAccountData()	0	25	6

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

namespace app\components\services;


use app\components\http\Client;
use app\components\http\ProxyManager;
use app\components\instagram\AccountScraper;
use app\components\instagram\models\Account;
use app\components\MediaManager;
use app\components\services\contracts\ServiceInterface;
use app\components\updaters\AccountUpdater;
use app\dictionaries\AccountInvalidationType;
use GuzzleHttp\Exception\ClientException;
use GuzzleHttp\Exception\RequestException;
use Jakim\Exception\RestrictedProfileException;
use Yii;
use yii\base\BaseObject;
use yii\web\NotFoundHttpException;

class AccountFullUpdate extends BaseObject implements ServiceInterface
{
    /**
     * @var \app\models\Account
     */
    public $account;

    public function run()
    {
        /**
         * @var ProxyManager $proxyManager
         */
        $proxyManager = Yii::createObject(ProxyManager::class);
        /**
         * @var AccountUpdater $accountUpdater
         */
        $accountUpdater = Yii::createObject([
            'class' => AccountUpdater::class,
            'account' => $this->account,
        ]);

        $proxy = $proxyManager->reserve($this->account);
        try {
            $httpClient = Client::factory($proxy, [], 3600);

            $scraper = Yii::createObject(AccountScraper::class, [
                $httpClient,
            ]);

            $accountData = $this->fetchAccountData($scraper);
            $posts = $scraper->fetchLastPosts($accountData->username);

            $proxyManager->release($proxy);
            unset($proxy);


            if ($accountData->isPrivate) {
                $accountUpdater
                    ->setIsInValid(AccountInvalidationType::IS_PRIVATE)
                    ->setNextStatsUpdate(true)
                    ->save();
            } else {
                $accountUpdater
                    ->setDetails($accountData)
                    ->setIdents($accountData)
                    ->setIsValid()
                    ->setStats($accountData, $posts)
                    ->setNextStatsUpdate()
                    ->save();

                $mediaManager = Yii::createObject(MediaManager::class);
                $mediaManager->addToAccount($this->account, $posts);

            }

        } catch (NotFoundHttpException $exception) {
            $accountUpdater
                ->setIsInValid(AccountInvalidationType::NOT_FOUND)
                ->setNextStatsUpdate(true)
                ->save();
        } catch (RestrictedProfileException $exception) {
            $accountUpdater
                ->setIsInValid(AccountInvalidationType::RESTRICTED_PROFILE)
                ->setNextStatsUpdate(true)
                ->save();
        } catch (RequestException $exception) {
            if (isset($proxy) && (strpos($exception->getMessage(), "Failed to connect to " . $proxy->ip) !== false || strpos($exception->getMessage(), "malformed") !== false)) {
                $type = strpos($exception->getMessage(), "malformed") !== false ? AccountInvalidationType::PROXY_ERROR : AccountInvalidationType::PROXY_TIMEOUT;
                $proxyManager->invalidate($proxy);
                $accountUpdater
                    ->setIsInvalid($type)
                    ->setNextStatsUpdate(true)
                    ->save();
            } else {
                $accountUpdater
                    ->setIsInvalidUnknown($exception->getMessage())
                    ->setNextStatsUpdate(true)
                    ->save();
            }
        } finally {
            if (isset($proxy)) {
                $proxyManager->release($proxy);
            }
        }

    }

    private function fetchAccountData(AccountScraper $scraper): Account
    {
        $idents = array_filter([
            $this->account->username,
            $this->account->instagram_id,
        ]);

        foreach ($idents as $ident) {
            try {
                $accountData = $scraper->fetchOne($ident);
                if ($this->account->instagram_id && $accountData->id != $this->account->instagram_id) {
                    continue;
                }
            } catch (ClientException $exception) {
                Yii::error($exception->getMessage(), __METHOD__);
                continue;
            }
            break;
        }

        if (empty($accountData)) {
            throw new NotFoundHttpException();
        }

        return $accountData;
    }

}