transportcall.php

<?php
namespace Bitrix\Sender\Integration\VoxImplant;
 
use Bitrix\Main\Localization\Loc;
use Bitrix\Main\Web\HttpClient;
 
use Bitrix\Sender\Message;
use Bitrix\Sender\Transport;
use Bitrix\Sender\Recipient;
 
Loc::loadMessages(__FILE__);
 
class TransportCall implements Transport\iBase, Transport\iDuration, Transport\iLimitation
{
    const CODE = self::CODE_CALL;
 
    protected $configuration;
 
    protected $limiter;
 
    protected $httpClient = array();
 
    public function __construct()
    {
        $this->configuration = new Message\Configuration();
    }
 
    public function getName()
    {
        return Loc::getMessage('SENDER_INTEGRATION_CALL_TRANSPORT_NAME');
    }
 
    public function getCode()
    {
        return self::CODE;
    }
 
    public function getSupportedRecipientTypes()
    {
        return array(Recipient\Type::PHONE);
    }
 
    public function loadConfiguration()
    {
        return $this->configuration;
    }
 
    public function saveConfiguration(Message\Configuration $configuration)
    {
        $this->configuration = $configuration;
    }
 
    public function start()
    {
        $clientOptions = array(
            'waitResponse' => false,
            'socketTimeout' => 5,
        );
        $this->httpClient = new HttpClient($clientOptions);
        $this->httpClient->setTimeout(1);
    }
 
    public function send(Message\Adapter $message)
    {
        $outputNumber = $message->getConfiguration()->get('OUTPUT_NUMBER');
        $number = $message->getTo();
        $text = $message->getConfiguration()->get('MESSAGE_TEXT');
        $text = $message->replaceFields($text);
        $voiceLanguage = $message->getConfiguration()->get('VOICE_LANGUAGE');
        $voiceSpeed = $message->getConfiguration()->get('VOICE_SPEED');
        $voiceVolume = $message->getConfiguration()->get('VOICE_VOLUME');
 
        $callId = Service::send(
            $outputNumber,
            $number,
            $text,
            $voiceLanguage,
            $voiceSpeed,
            $voiceVolume
        );
 
        if ($callId && $message->getRecipientId())
        {
            CallLogTable::add(array(
                'CALL_ID' => $callId,
                'RECIPIENT_ID' => $message->getRecipientId()
            ));
        }
 
        return !!$callId;
    }
 
    public function end()
    {
 
    }
 
    public function getDuration(Message\Adapter $message = null)
    {
        $messageText = $message->getConfiguration()->get('MESSAGE_TEXT');
        $voiceSpeed = $message->getConfiguration()->get('VOICE_SPEED');
        $length = SpeechRate::create()
            ->withSpeed($voiceSpeed)
            ->withText($messageText)
            ->getDuration();
 
        $length = $length ?: 20;
        $magic = 5;
        $limit = $this->getCountLimiter()->getLimit();
 
        return round(($length + $magic) / $limit);
    }
 
    public function getLimiters(Message\iBase $message = null)
    {
        return [
            $this->getCountLimiter(),
            Transport\TimeLimiter::create()
                ->withLetter($message)
        ];
    }
 
    protected function getCountLimiter()
    {
        if ($this->limiter === null)
        {
            $this->limiter = new Limiter();
        }
 
        return $this->limiter;
    }
}