transportaudiocall.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 TransportAudioCall implements Transport\iBase, Transport\iDuration, Transport\iLimitation
{
    const CODE = self::CODE_AUDIO_CALL;
 
    protected $configuration;
 
    protected $limiter;
 
    protected $httpClient = array();
 
    public function __construct()
    {
        $this->configuration = new Message\Configuration();
    }
 
    public function getName()
    {
        return Loc::getMessage('SENDER_INTEGRATION_AUDIOCALL_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();
        $fileJson = $message->getConfiguration()->get('AUDIO_FILE');
 
        $audio = (new Audio())
            ->withJsonString($fileJson)
            ->withMessageCode($message->getCode());
 
        $callId = Service::sendFile(
            $outputNumber,
            $number,
            $audio->getFileUrl(true)
        );
 
        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)
    {
        $length = 0;
        $fileJson = $message->getConfiguration()->get('AUDIO_FILE');
        if ($fileJson)
        {
            $audio = (new Audio())
                ->withJsonString($fileJson)
                ->withMessageCode($message->getCode());
 
            $length = $audio->getDuration();
        }
        $length = $length ?: 20;
        $magic = 5;
        $limit = $this->getCountLimiter()->getLimit();
 
        return round(($length + $magic) / $limit);
    }
 
    public function getLimiters(Message\iBase $message = null)
    {
        return array(
            $this->getCountLimiter(),
            Transport\TimeLimiter::create()
                ->withLetter($message)
        );
    }
 
    protected function getCountLimiter()
    {
        if ($this->limiter === null)
        {
            $this->limiter = new Limiter();
        }
 
        return $this->limiter;
    }
}