ddlzz / amocrm-api-client

src/Request/DataSender.php

<?php

namespace ddlzz\AmoAPI\Request;

use ddlzz\AmoAPI\Exception\ErrorCodeException;
use ddlzz\AmoAPI\Exception\FailedAuthException;
use ddlzz\AmoAPI\SettingsStorage;

/**
 * Class DataSender. It's responsible for interacting with amoCRM.
 *
 * @author ddlzz
 */
class DataSender
{
    /** @var SettingsStorage */
    private $settings;

    /** @var Curl */
    private $curl;

    /** DataSender constructor.
     * @param Curl            $curl
     * @param SettingsStorage $settings
     */
    public function __construct(Curl $curl, SettingsStorage $settings)
    {
        $this->curl = $curl;
        $this->settings = $settings;
    }

    /**
     * @param string $url
     * @param array  $data
     *
     * @return string
     */
    public function send($url, array $data = [])
    {
        $this->curl->init();

        $this->curl->setReturnTransfer(true);
        $this->curl->setUserAgent($this->settings->getUserAgent());
        $this->curl->setUrl($url);
        $this->curl->setHttpHeader([SettingsStorage::SENDER_HTTP_HEADER]);
        $this->curl->setHeader(false);
        $this->curl->setCookieFile($this->settings->getCookiePath());
        $this->curl->setCookieJar($this->settings->getCookiePath());
        $this->curl->setSSLVerifyPeer(false);
        $this->curl->setSSLVerifyHost(2);

        if (!empty($data)) {
            $this->curl->setCustomRequest('POST');
            $this->curl->setPostFields(json_encode($data));
        }

        $response = $this->curl->exec();
        $code = $this->curl->getHttpCode();

        $this->curl->close();
        $this->validateCode($code, $url, $response);

$response of type false|array is incompatible with the type string expected by parameter $response of ddlzz\AmoAPI\Request\DataSender::validateCode().

        return (string) $response;
    }

    /**
     * @param int $code
     *
     * @return string
     */
    private static function getErrorByHttpCode($code)
    {
        $errors = [
            301 => '301 Moved permanently',
            400 => '400 Bad request',
            401 => '401 Unauthorized or Blocked',
            403 => '403 Forbidden',
            404 => '404 Not found',
            429 => '429 Too Many Requests',
            500 => '500 Internal server error',
            502 => '502 Bad gateway',
            503 => '503 Service unavailable',
            504 => '504 Gateway Timeout',
        ];

        return isset($errors[$code]) ? $errors[$code] : $code.' Unknown error';
    }

    /**
     * @param int    $code
     * @param string $url
     * @param string $response
     *
     * @throws ErrorCodeException
     * @throws FailedAuthException
     *
     * @return bool
     */
    private function validateCode($code, $url, $response)
    {
        switch ($code) {
            case 401:
            case 403:
                throw new FailedAuthException('Auth failed! '.self::getErrorByHttpCode($code), $response);
                break;
            case 200 !== $code && 204 !== $code:
                throw new ErrorCodeException(self::getErrorByHttpCode($code), $response, $url);
                break;
        }

        return true;
    }
}