<?php
namespace Bitrix\Im;

use Bitrix\Im\Model\AliasTable;
use Bitrix\Main\Result;
use Bitrix\Main\Type\DateTime;

class Alias
{
	const ENTITY_TYPE_USER = 'USER';
	const ENTITY_TYPE_CHAT = 'CHAT';
	const ENTITY_TYPE_OPEN_LINE = 'LINES';
	const ENTITY_TYPE_LIVECHAT = 'LIVECHAT';
	const ENTITY_TYPE_VIDEOCONF = 'VIDEOCONF';
	const ENTITY_TYPE_OTHER = 'OTHER';

	const CACHE_TTL = 31536000;
	const CACHE_PATH = '/bx/im/alias/';

	const FILTER_BY_ALIAS = 'alias';
	const FILTER_BY_ID = 'id';

	public static function add(array $fields)
	{
		$alias = self::prepareAlias($fields['ALIAS']);
		$entityType = $fields['ENTITY_TYPE'];
		$entityId = $fields['ENTITY_ID'];

		if (
			($fields['ENTITY_TYPE'] !== self::ENTITY_TYPE_VIDEOCONF && empty($entityId))
			|| empty($entityType)
			|| empty($alias))
		{
			return false;
		}

		$aliasData = self::get($alias);
		if ($aliasData)
			return false;

		$result = \Bitrix\Im\Model\AliasTable::add(Array(
			'ALIAS' => $alias,
			'ENTITY_TYPE' => $entityType,
			'ENTITY_ID' => $entityId,
			'DATE_CREATE' => new DateTime()
		));
		if (!$result->isSuccess())
		{
			return false;
		}

		self::cleanChatCache($entityType, (int)$entityId);

		return $result->getId();
	}

	public static function addUnique(array $fields)
	{
		$alias = \Bitrix\Im\Alias::prepareAlias(self::generateUnique());
		$fields['ALIAS'] = $alias;

		$id = self::add($fields);
		if (!$id)
		{
			return self::addUnique($fields);
		}

		return Array(
			'ID' => $id,
			'ALIAS' => $alias,
			'LINK' => self::getPublicLink($fields['ENTITY_TYPE'], $alias)
		);
	}

	public static function update($id, $fields)
	{
		$id = intval($id);
		if ($id <= 0)
			return false;

		$update = Array();
		if (isset($fields['ALIAS']))
		{
			$update['ALIAS'] = self::prepareAlias($fields['ALIAS']);
			$result = self::get($update['ALIAS']);
			if ($result)
			{
				return false;
			}
		}

		if (isset($fields['ENTITY_TYPE']))
		{
			$update['ENTITY_TYPE'] = $fields['ENTITY_TYPE'];
		}
		if (isset($fields['ENTITY_ID']))
		{
			$update['ENTITY_ID'] = $fields['ENTITY_ID'];
		}

		if (empty($update))
			return false;

		$oldRecord = AliasTable::getByPrimary($id)->fetch();
		\Bitrix\Im\Model\AliasTable::update($id, $update);
		if ((int)$oldRecord['ENTITY_ID'] !== 0)
		{
			self::cleanChatCache($oldRecord['ENTITY_TYPE'], (int)$oldRecord['ENTITY_ID']);
		}
		if (
			isset($fields['ENTITY_TYPE'], $fields['ENTITY_ID'])
			&& (int)$fields['ENTITY_ID'] !== (int)$oldRecord['ENTITY_ID']
			&& (int)$fields['ENTITY_ID'] !== 0
		)
		{
			self::cleanChatCache($fields['ENTITY_TYPE'], (int)$fields['ENTITY_ID']);
		}

		return true;
	}

	public static function delete($id, $filter = self::FILTER_BY_ID)
	{
		if ($filter == self::FILTER_BY_ALIAS)
		{
			$aliasData = self::get($id);
			if (!$aliasData)
				return new Result();
		}
		else
		{
			$aliasData = AliasTable::getByPrimary($id)->fetch();
		}

		$result = \Bitrix\Im\Model\AliasTable::delete((int)$aliasData['ID']);
		self::cleanChatCache($aliasData['ENTITY_TYPE'], (int)$aliasData['ENTITY_ID']);

		return $result;
	}

	public static function get($alias)
	{
		$alias = self::prepareAlias($alias);
		if (empty($alias))
		{
			return false;
		}

		$query = \Bitrix\Im\Model\AliasTable::query();

		$connection = \Bitrix\Main\Application::getConnection();
		if ($connection instanceof \Bitrix\Main\DB\PgsqlConnection)
		{
			$alias = $connection->getSqlHelper()->forSql($alias);
			$query
				->setSelect(['*'])
				->whereExpr("LOWER(%s) = LOWER('{$alias}')", ['ALIAS'])
			;
		}
		else
		{
			$query
				->setSelect(['*'])
				->where('ALIAS', $alias)
			;
		}

		$result = $query->exec()->fetch();

		if (!$result)
		{
			return false;
		}

		$result['LINK'] = self::getPublicLink($result['ENTITY_TYPE'], $result['ALIAS']);

		return $result;
	}

	public static function getByIdAndCode($id, $code)
	{
		$query = \Bitrix\Im\Model\AliasTable::query();
		$query
			->setSelect(['*'])
			->where('ID', $id)
		;

		$connection = \Bitrix\Main\Application::getConnection();
		if ($connection instanceof \Bitrix\Main\DB\PgsqlConnection)
		{
			$code = $connection->getSqlHelper()->forSql($code);
			$query->whereExpr("LOWER(%s) = LOWER('{$code}')", ['ALIAS']);
		}
		else
		{
			$query->where('ALIAS', $code);
		}

		return $query->exec()->fetch();
	}

	public static function getByEntity($entityType, $entityId)
	{
		$result = \Bitrix\Im\Model\AliasTable::getList(Array(
			'filter' => ['=ENTITY_TYPE' => $entityType, '=ENTITY_ID' => $entityId]
		))->fetch();

		if (!$result)
		{
			return false;
		}

		$result['LINK'] = self::getPublicLink($result['ENTITY_TYPE'], $result['ALIAS']);

		return $result;
	}

	public static function prepareAlias($alias)
	{
		$alias = preg_replace("/[^\.\-0-9a-zA-Z]+/", "", $alias);
		$alias = mb_substr($alias, 0, 255);

		return $alias;
	}

	public static function getPublicLink($type, $alias)
	{
		$path = '/online/';

		if ($type === self::ENTITY_TYPE_VIDEOCONF)
		{
			$path = '/video/';
		}
		else if ($type === self::ENTITY_TYPE_LIVECHAT)
		{
			return '';
		}

		return \Bitrix\Im\Common::getPublicDomain() . $path . $alias;
	}

	public static function generateUnique()
	{
		if (\Bitrix\Main\Loader::includeModule('security'))
		{
			return \Bitrix\Main\Security\Random::getString(8, true);
		}
		else
		{
			return mb_substr(uniqid(),-8);
		}
	}

	protected static function cleanChatCache(string $entityType, int $entityId): void
	{
		if ($entityType !== self::ENTITY_TYPE_USER)
		{
			\Bitrix\Im\V2\Chat::cleanCache($entityId);
		}
	}
}