calluser.php

<?php
 
namespace Bitrix\Im\Call;
 
use Bitrix\Im\Model\CallUserTable;
use Bitrix\Main\ArgumentException;
use Bitrix\Main\Type\DateTime;
 
class CallUser
{
    const LAST_SEEN_THRESHOLD = 75;
    const STATE_UNAVAILABLE = 'unavailable';
    const STATE_IDLE = 'idle';
    const STATE_CALLING = 'calling';
    const STATE_DECLINED = 'declined';
    const STATE_BUSY = 'busy';
    const STATE_READY = 'ready';
 
    protected $userId;
    protected $callId;
    protected $state;
    protected $lastSeen;
    protected $firstJoined;
    protected $isMobile;
    protected $sharedScreen;
    protected $recorded;
 
    public static function create(array $fields)
    {
        if(!isset($fields['USER_ID']) || !$fields['USER_ID'])
        {
            throw new ArgumentException('USER_ID should be positive integer');
        }
        $instance = new static();
        $instance->setFields($fields);
        return $instance;
    }
 
    public function getState()
    {
        return $this->isSeenRecently() ? $this->state : static::STATE_IDLE;
    }
 
    public function isSeenRecently()
    {
        if(!($this->lastSeen instanceof DateTime))
        {
            return false;
        }
        $now = time();
        $delta = $now - $this->lastSeen->getTimestamp();
        return $delta <= static::LAST_SEEN_THRESHOLD;
    }
 
    public function updateState($state)
    {
        $fields = ['STATE' => $state];
        if ($state === self::STATE_CALLING)
        {
            $fields['LAST_SEEN'] = new DateTime();
        }
        $this->update($fields);
    }
 
    public function getLastSeen()
    {
        return $this->lastSeen;
    }
 
    public function updateLastSeen(DateTime $lastSeen)
    {
        $this->update(['LAST_SEEN' => $lastSeen]);
    }
 
    public function getFirstJoined() : ?DateTime
    {
        return $this->firstJoined;
    }
 
    public function wasScreenShared()
    {
        return $this->sharedScreen;
    }
 
    public function wasRecorded()
    {
        return $this->recorded;
    }
 
 
    public function isActive()
    {
        $seenRecently = false;
 
        if($this->lastSeen instanceof DateTime)
        {
            $now = time();
            $delta = $now - $this->lastSeen->getTimestamp();
            $seenRecently = $delta <= static::LAST_SEEN_THRESHOLD;
        }
 
        return in_array($this->state, [static::STATE_READY, static::STATE_CALLING]) && $seenRecently;
    }
 
    public function isUaMobile()
    {
        return $this->isMobile;
    }
 
    public function setFields(array $fields)
    {
        $this->userId = array_key_exists('USER_ID', $fields) ? $fields['USER_ID'] : $this->userId;
        $this->callId = array_key_exists('CALL_ID', $fields) ? $fields['CALL_ID'] : $this->callId;
        $this->state = array_key_exists('STATE', $fields) ? $fields['STATE'] : $this->state;
        $this->lastSeen = array_key_exists('LAST_SEEN', $fields) ? $fields['LAST_SEEN'] : $this->lastSeen;
        $this->firstJoined = array_key_exists('FIRST_JOINED', $fields) ? $fields['FIRST_JOINED'] : $this->firstJoined;
        $this->isMobile = array_key_exists('IS_MOBILE', $fields) ? $fields['IS_MOBILE'] === 'Y' : $this->isMobile;
        $this->sharedScreen = array_key_exists('SHARED_SCREEN', $fields) ? $fields['SHARED_SCREEN'] === 'Y' : $this->sharedScreen;
        $this->recorded = array_key_exists('RECORDED', $fields) ? $fields['RECORDED'] === 'Y' : $this->recorded;
    }
 
    public function save()
    {
        CallUserTable::merge($this->toArray());
    }
 
    public function toArray()
    {
        return [
            'USER_ID' => $this->userId,
            'CALL_ID' => $this->callId,
            'STATE' => $this->state,
            'LAST_SEEN' => $this->lastSeen,
            'FIRST_JOINED' => $this->firstJoined,
            'IS_MOBILE' => is_bool($this->isMobile) ? $this->isMobile : null,
            'SHARED_SCREEN' => is_bool($this->sharedScreen) ? $this->sharedScreen : null,
            'RECORDED' => is_bool($this->recorded) ? $this->recorded : null
        ];
    }
 
    public function update(array $fields)
    {
        $updateResult = CallUserTable::update(['CALL_ID' => $this->callId, 'USER_ID' => $this->userId], $fields);
 
        if($updateResult->isSuccess())
        {
            $updateData = $updateResult->getData();
            $this->setFields($updateData);
        }
        $this->setFields($fields);
    }
 
    public static function delete($callId, $userId)
    {
        CallUserTable::delete([
            'CALL_ID' => $callId,
            'USER_ID' => $userId
        ]);
    }
}