ddlzz\AmoAPI\Client

Complexity

Total Complexity

13

Size/Duplication

Total Lines	154
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	1
A	set()	0	11	1
A	add()	0	3	1
A	waitASec()	0	14	3
A	update()	0	4	1
A	checkAuth()	0	8	4
A	findById()	0	17	2

<?php


namespace ddlzz\AmoAPI;

use ddlzz\AmoAPI\Entities\EntityFactory;
use ddlzz\AmoAPI\Entities\EntityInterface;
use ddlzz\AmoAPI\Exceptions\InvalidArgumentException;
use ddlzz\AmoAPI\Exceptions\RuntimeException;
use ddlzz\AmoAPI\Request\DataSender;
use ddlzz\AmoAPI\Request\UrlBuilder;


/**
 * Class Client. The main class for interacting with amoCRM.
 * @package ddlzz\AmoAPI
 * @author ddlzz
 */
class Client
{
    /** @var CredentialsManager */
    private $credentials;

    /** @var DataSender */
    private $dataSender;

    /** @var SettingsStorage */
    private $settings;

    /** @var UrlBuilder */
    private $urlBuilder;

    /** @var Auth */
    private $auth;

    /**
     * Client constructor.
     * @param CredentialsManager $credentials
     * @param DataSender $dataSender
     * @param \ddlzz\AmoAPI\SettingsStorage $settings
     * @throws Exceptions\CurlException
     * @throws Exceptions\ErrorCodeException
     * @throws Exceptions\FailedAuthException
     * @throws InvalidArgumentException
     * @throws RuntimeException
     */
    public function __construct(CredentialsManager $credentials, DataSender $dataSender, SettingsStorage $settings)
    {
        $this->credentials = $credentials;
        $this->dataSender = $dataSender;
        $this->settings = $settings;
        $this->urlBuilder = new UrlBuilder($this->settings, $this->credentials->getSubdomain()); // Composition
        $this->auth = new Auth($this->credentials->getLogin(), $this->settings->getCookiePath());

        $this->checkAuth();
    }

    /**
     * @param $type
     * @param $id
     * @return EntityInterface
     * @throws Exceptions\CurlException
     * @throws Exceptions\EntityFactoryException
     * @throws Exceptions\ErrorCodeException
     * @throws Exceptions\FailedAuthException
     * @throws InvalidArgumentException
     */
    public function findById($type, $id)
    {
        $method = $this->settings->getMethodCodeByType($type);
        $params = ['id' => $id];
        $url = $this->urlBuilder->prepareMethodUrl($method, $params);
        $result = json_decode($this->dataSender->send($url), true);

        if (empty($result)) {
            throw new InvalidArgumentException("The $type with id $id is not found on the server");
        }

        $entityFactory = new EntityFactory($this->settings);
        /** @var EntityInterface $entity */
        $entity = $entityFactory->create($type);
        $entity->fill($result['_embedded']['items'][0]);

        return $entity;
    }

    /**
     * @param EntityInterface $entity
     * @return string
     * @throws Exceptions\CurlException
     * @throws Exceptions\ErrorCodeException
     * @throws Exceptions\FailedAuthException
     * @throws InvalidArgumentException
     */
    public function add(EntityInterface $entity)
    {
        return $this->set($entity, 'add');
    }

    /**
     * @param EntityInterface $entity
     * @return string
     * @throws Exceptions\CurlException
     * @throws Exceptions\ErrorCodeException
     * @throws Exceptions\FailedAuthException
     * @throws InvalidArgumentException
     */
    public function update(EntityInterface $entity)
    {
        $entity->setUpdatedAtParam();
        return $this->set($entity, 'update');
    }

    /**
     * @throws Exceptions\CurlException
     * @throws Exceptions\ErrorCodeException
     * @throws Exceptions\FailedAuthException
     * @throws InvalidArgumentException
     * @throws RuntimeException
     */
    private function checkAuth()
    {
        if (!$this->auth->isAuthenticated()) {
            $result = $this->dataSender->send($this->urlBuilder->prepareMethodUrl('auth'), $this->credentials->getCredentials());

            if (!empty($result) && (!file_exists($this->settings->getCookiePath()))) {
                $message = 'An error occurred while creating the cookie file ' . $this->settings->getCookiePath();
                throw new RuntimeException($message);
            }
        }
    }

    /**
     * Adds or updates an entity
     * @param EntityInterface $entity
     * @param string $action
     * @return string
     * @throws Exceptions\CurlException
     * @throws Exceptions\ErrorCodeException
     * @throws Exceptions\FailedAuthException
     * @throws InvalidArgumentException
     */
    private function set(EntityInterface $entity, $action)
    {
        $entity->setFieldsParams($action);

        $data = [];
        $data[$action][] = $entity->getFields();
        $url = $this->urlBuilder->prepareMethodUrl($entity->getRequestName());
        $this->waitASec();
        $result = $this->dataSender->send($url, $data);

        return $result;
    }

    /**
     * Adds a one second pause because of Amo request limits
     */
    private function waitASec()
    {
        $now = microtime(true);
        static $lastCheck = null;

        if (null !== $lastCheck) {
            $sleepTime = 1;
            $lastRequest = $now - $lastCheck;
            if ($lastRequest < $sleepTime) {
                usleep(($sleepTime - $lastRequest) * 1000000);
            }
        }

        $lastCheck = microtime(true);
    }
}