<?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): static
	{
		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;
	}

	/**
	 * @return string
	 */
	public function getState()
	{
		// previous version with 'lastSeen' field check
		// ($this->isSeenRecently() ? $this->state : static::STATE_IDLE)
		// will return wrong state for new scheme
		// because this field will not be updated during a call
		// because 'ping' requests from client side were removed
		return $this->state;
	}

	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);
	}

	/**
	 * @return DateTime
	 */
	public function getLastSeen()
	{
		return $this->lastSeen;
	}

	/**
	 * Update user's last seen date.
	 *
	 * @param DateTime $lastSeen
	 */
	public function updateLastSeen(DateTime $lastSeen)
	{
		$this->update(['LAST_SEEN' => $lastSeen]);
	}

	public function getFirstJoined() : ?DateTime
	{
		return $this->firstJoined;
	}

	/**
	 * @return mixed
	 */
	public function wasScreenShared()
	{
		return $this->sharedScreen;
	}

	/**
	 * @return mixed
	 */
	public function wasRecorded()
	{
		return $this->recorded;
	}


	/**
	 * Returns true if the user is an active participant of the call and false otherwise.
	 *
	 * @return bool
	 */
	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
		]);
	}
}