<?php
namespace Bitrix\Im;

use Bitrix\Im\Model\ChatTable;
use Bitrix\Im\Model\RelationTable;
use Bitrix\Main\ORM\Fields\Relations\OneToMany;
use Bitrix\Main\ORM\Fields\Relations\Reference;
use Bitrix\Main\ORM\Query\Join;

class Dialog
{
	public static function getTitle($dialogId, $userId = null):? string
	{
		if (Common::isChatId($dialogId))
		{
			if (!Dialog::hasAccess($dialogId, $userId))
			{
				return null;
			}

			$chatId = Dialog::getChatId($dialogId);

			$chatData = ChatTable::getRow([
				'select' => ['TITLE'],
				'filter' => ['=ID' => $chatId],
			]);
			if (!$chatData)
			{
				return null;
			}

			return $chatData['TITLE'];
		}

		$userId = Common::getUserId($userId);
		$chatId = \CIMMessage::GetChatId($dialogId, $userId);
		if (!$chatId)
		{
			return null;
		}

		$userNames = [
			User::getInstance($dialogId)->getFullName(false),
			User::getInstance($userId)->getFullName(false),
		];

		return implode(" - ", $userNames);
	}

	public static function getDialogId(int $chatId, $userId = null): string
	{
		$userId = \Bitrix\Im\Common::getUserId($userId);
		if (!$userId)
		{
			return '';
		}

		$chat = \Bitrix\Im\Chat::getById($chatId, ['USER_ID' => $userId]);

		if (!$chat)
		{
			return '';
		}

		if ($chat['MESSAGE_TYPE'] !== Chat::TYPE_PRIVATE)
		{
			return "chat{$chat['ID']}";
		}

		$query = ChatTable::query()
			->setSelect(['DIALOG_ID' => 'RELATION.USER_ID'])
			->registerRuntimeField(
				'RELATION',
				(
					new OneToMany('RELATION', RelationTable::class, 'CHAT')
				)->configureJoinType('inner')
			)
			->where('ID', (int)$chatId)
			->where('TYPE', Chat::TYPE_PRIVATE)
			->whereNot('RELATION.USER_ID', $userId)
			->setLimit(1)
		;

		$queryResult = $query->fetch();
		if (!$queryResult)
		{
			return '';
		}

		return $queryResult['DIALOG_ID'];
	}

	public static function getChatId($dialogId, $userId = null)
	{
		if (preg_match('/^chat[0-9]{1,}$/i', $dialogId))
		{
			$chatId = (int)mb_substr($dialogId, 4);
		}
		else if (preg_match('/^\d{1,}$/i', $dialogId))
		{
			$dialogId = intval($dialogId);
			if (!$dialogId)
			{
				return false;
			}

			$userId = \Bitrix\Im\Common::getUserId($userId);
			if (!$userId)
			{
				return false;
			}

			$chatId = \CIMMessage::GetChatId($dialogId, $userId);
			if (!$chatId)
			{
				return false;
			}
		}
		else if (preg_match('/^crm\|\w+?\|\d+?$/i', $dialogId))
		{
			$chatId = \CIMChat::GetCrmChatId(mb_substr($dialogId, 4));
		}
		else if (preg_match('/^sg[0-9]{1,}$/i', $dialogId))
		{
			$chatId = \CIMChat::GetSonetGroupChatId(mb_substr($dialogId, 2));
		}
		else
		{
			$chatId = 0;
		}

		return $chatId;
	}

	public static function getChatIds(array $dialogIds, int $currentUserId): array
	{
		$dialogIds = array_filter($dialogIds, function($dialogId) use ($currentUserId) {
			return (int)$dialogId !== $currentUserId;
		});

		if (empty($dialogIds))
		{
			return [];
		}

		$chatIds = [];

		$query = RelationTable::query()
			->setSelect(['CHAT_ID', 'USER_ID'])
			->registerRuntimeField(
				'RELATION',
				new Reference(
					'RELATION',
					RelationTable::class,
					Join::on('this.CHAT_ID', 'ref.CHAT_ID')
						->where('ref.USER_ID', $currentUserId)
						->where('ref.MESSAGE_TYPE', Chat::TYPE_PRIVATE),
					['join_type' => Join::TYPE_INNER]
				)
			)
			->whereIn('USER_ID', $dialogIds)
			->where('MESSAGE_TYPE', Chat::TYPE_PRIVATE)
			->exec()
		;

		while ($row = $query->Fetch())
		{
			$chatIds[(int)$row['USER_ID']] = (int)$row['CHAT_ID'];
		}

		return $chatIds;
	}

	public static function getLink($dialogId, $userId = null):? string
	{
		if (!Dialog::hasAccess($dialogId, $userId))
		{
			return null;
		}

		return '/online/?IM_DIALOG='.$dialogId;
	}

	public static function hasAccess($dialogId, $userId = null)
	{
		$userId = \Bitrix\Im\Common::getUserId($userId);
		if (!$userId)
		{
			return false;
		}

		if (\Bitrix\Im\Common::isChatId($dialogId))
		{
			$chatId = self::getChatId($dialogId, $userId);

			return \Bitrix\Im\V2\Chat::getInstance($chatId)->checkAccess($userId)->isSuccess();
		}

		return \Bitrix\Im\V2\Entity\User\User::getInstance($dialogId)->checkAccess($userId)->isSuccess();
	}

	public static function read($dialogId, $messageId = null, $userId = null)
	{
		$userId = \Bitrix\Im\Common::getUserId($userId);
		if (!$userId)
		{
			return false;
		}

		if (\Bitrix\Im\Common::isChatId($dialogId))
		{
			$chatId = self::getChatId($dialogId);

			$chat = new \CIMChat($userId);
			$result = $chat->SetReadMessage($chatId, $messageId);
		}
		else if ($dialogId === 'notify')
		{
			$notify = new \CIMNotify();
			$notify->MarkNotifyRead(0, true);

			return true;
		}
		else
		{
			$CIMMessage = new \CIMMessage($userId);
			$result = $CIMMessage->SetReadMessage($dialogId, $messageId);
		}

		return $result;
	}

	public static function readAll($userId = null)
	{
		$userId = \Bitrix\Im\Common::getUserId($userId);
		if (!$userId)
		{
			return false;
		}

		\Bitrix\Im\V2\Chat::readAllChats($userId);

		return true;
	}

	public static function unread($dialogId, $messageId = null, $userId = null)
	{
		$userId = \Bitrix\Im\Common::getUserId($userId);
		if (!$userId)
		{
			return false;
		}

		if (\Bitrix\Im\Common::isChatId($dialogId))
		{
			$chatId = self::getChatId($dialogId);

			$chat = new \CIMChat($userId);
			$chat->SetUnReadMessage($chatId, $messageId);
		}
		else
		{
			$CIMMessage = new \CIMMessage($userId);
			$CIMMessage->SetUnReadMessage($dialogId, $messageId);
		}

		return false;
	}

	public static function getRelation($userId1, $userId2, $params = array())
	{
		$userId1 = intval($userId1);
		$userId2 = intval($userId2);

		if ($userId1 <= 0 || $userId2 <= 0)
		{
			return false;
		}

		$chatId = \CIMMessage::GetChatId($userId1, $userId2);
		if (!$chatId)
		{
			return false;
		}

		return Chat::getRelation($chatId, $params);
	}



}