UniSenderWrapper.php

<?php

namespace omgdef\unisender;


class UniSenderWrapper extends BaseUniSenderWrapper
{
    /**
     * @param string $name
     * @param array $arguments
     * @return string
     */
    public function __call($name, $arguments)
    {
        if (!is_array($arguments) || empty($arguments)) {
            $params = [];
        } else {
            $params = $arguments[0];
        }

        return $this->sendQuery($name, $params);
    }

    /**
     * @param array $params
     * @return mixed
     */
    public function sendSms($params)
    {
        $params['sender'] = $this->senderName ?: $this->senderPhone;

        return $this->sendQuery('sendSms', $params);
    }

    /**
     * Подписывает email на рассылку
     *
     * @param string $list_ids Перечисленные через запятую коды списков, в которые надо добавить подписчика. Коды можно узнать с помощью методаgetLists. Они совпадают с кодами, используемыми в форме подписки.
     * @param array $fields Ассоциативный массив дополнительных полей. Обязательно должно присутствовать хотя бы поле «email» или «phone», иначе метод возвратит ошибку.
     * В случае наличия и e-mail, и телефона, подписчик будет включён и в e-mail, и в SMS списки рассылки.
     * @param array $params Остальные необязательные параметры. Больше информации http://www.unisender.com/ru/help/api/subscribe/
     * @throws \Exception
     * @return array
     */
    public function subscribe($list_ids, array $fields, $params = [])
    {
        $params['list_ids'] = $list_ids;

        if (empty($fields["email"]) && empty($fields["phone"])) {
            throw new \Exception('email or phone keys are required in array $fields');
        }

        $params['fields'] = $fields;

        return $this->sendQuery('subscribe', $params);
    }

    /**
     * @param string $methodName
     * @param array $params
     * @return array
     */
    public function sendQuery($methodName, array $params = [])
    {
        $this->convertParamsEncoding($params);
        $params['api_key'] = $this->apiKey;
        $body = http_build_query($params);

        $getParams = http_build_query(
            [
                'format' => 'json',
                'test_mode' => (int)$this->testMode
            ]
        );

        $ch = curl_init();
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_POST, 1);
        curl_setopt($ch, CURLOPT_POSTFIELDS, $body);
        curl_setopt($ch, CURLOPT_TIMEOUT, $this->timeout ?: 10);

        $retryCount = 0;
        do {
            curl_setopt($ch, CURLOPT_URL, $this->getApiHost() . $methodName . '?' . $getParams);
            $result = curl_exec($ch);
            $retryCount++;
        } while ($result === false && $retryCount < $this->retryCount);

        curl_close($ch);

        return $result !== false ? json_decode($result, true) : null;
    }

    /**
     * @inheritdoc
     */
    protected function getApiHost()
    {
        return parent::getApiHost() . "api/";
    }
}