<?php

use Bitrix\Main\Text\Emoji;
use Bitrix\Socialnetwork\Integration;
use Bitrix\Main\Localization\Loc;
use Bitrix\Socialnetwork\UserToGroupTable;

class CAllSocNetSubscription
{
	public static function CheckFields($ACTION, &$arFields, $ID = 0): bool
	{
		global $APPLICATION;

		if (
			$ACTION != "ADD"
			&& intval($ID) <= 0
		)
		{
			$APPLICATION->ThrowException("System error 870164", "ERROR");
			return false;
		}

		if (
			(is_set($arFields, "USER_ID") || $ACTION == "ADD")
			&& intval($arFields["USER_ID"]) <= 0
		)
		{
			$APPLICATION->ThrowException(Loc::getMessage("SONET_SS_EMPTY_USER_ID"), "EMPTY_USER_ID");
			return false;
		}
		elseif (is_set($arFields, "USER_ID"))
		{
			$dbResult = CUser::GetByID($arFields["USER_ID"]);
			if (!$dbResult->Fetch())
			{
				$APPLICATION->ThrowException(Loc::getMessage("SONET_SS_ERROR_NO_USER_ID"), "ERROR_NO_USER_ID");
				return false;
			}
		}

		if (
			(is_set($arFields, "CODE") || $ACTION == "ADD")
			&& trim($arFields["CODE"]) == ''
		)
		{
			$APPLICATION->ThrowException(Loc::getMessage("SONET_SS_EMPTY_CODE"), "EMPTY_CODE");
			return false;
		}

		return True;
	}

	public static function Delete($ID)
	{
		global $DB;

		if (!CSocNetGroup::__ValidateID($ID))
			return false;

		$ID = intval($ID);

		return $DB->Query("DELETE FROM b_sonet_subscription WHERE ID = ".$ID."", true);
	}

	public static function DeleteEx($userID = false, $code = false): bool
	{
		global $DB, $CACHE_MANAGER;

		$userID = intval($userID);
		$code = trim($code);

		if (
			$userID <= 0
			&& $code == ''
		)
			return false;

		$DB->Query("DELETE FROM b_sonet_subscription WHERE 1=1 ".
			(intval($userID) > 0 ? "AND USER_ID = ".$userID." " : "").
			($code <> '' ? "AND CODE = '".$code."' " : "")
		, true);

		if(defined("BX_COMP_MANAGED_CACHE"))
		{
			$CACHE_MANAGER->ClearByTag("sonet_subscription".($code ? '_'.$code : ''));
		}

		return true;
	}

	public static function Set($userID, $code, $value = false): bool
	{
		global $CACHE_MANAGER;

		if (!CSocNetGroup::__ValidateID($userID))
		{
			return false;
		}

		$userID = intval($userID);
		$code = trim($code);

		if (
			$userID <= 0
			|| $code == ''
		)
		{
			return false;
		}

		$value = ($value == "Y" ? "Y" : "N");

		$rsSubscription = CSocNetSubscription::GetList(
			array(),
			array(
				"USER_ID" => $userID,
				"CODE" => $code
			)
		);

		$result = false;

		if ($arSubscription = $rsSubscription->Fetch())
		{
			if ($value != "Y")
			{
				$result = CSocNetSubscription::delete($arSubscription["ID"]);
			}
		}
		else
		{
			if ($value == "Y")
			{
				$result = CSocNetSubscription::add(array(
					"USER_ID" => $userID,
					"CODE" => $code
				));
			}
		}

		if (
			$result
			&& preg_match('/^SG(\d+)$/i', $code, $matches)
		)
		{
			$chatId = false;
			$groupId = $matches[1];
			$chatData = \Bitrix\Socialnetwork\Integration\Im\Chat\Workgroup::getChatData(Array(
				'group_id' => $groupId
			));
			if (!empty($chatData[$groupId]) && intval($chatData[$groupId]) > 0)
			{
				$chatId = $chatData[$groupId];
			}

			if ($chatId)
			{
				$CIMChat = new CIMChat($userID);
				$CIMChat->muteNotify($chatId, ($value != "Y"));
			}
		}

		if(defined("BX_COMP_MANAGED_CACHE"))
		{
			$CACHE_MANAGER->ClearByTag("sonet_subscription_".$code);
		}

		return true;
	}

	public static function NotifyGroup($arFields): array
	{
		$arUserIDSent = array();

		if (!CModule::IncludeModule("im"))
		{
			return $arUserIDSent;
		}

		if (!is_array($arFields["GROUP_ID"] ?? null))
		{
			$arFields["GROUP_ID"] = array($arFields["GROUP_ID"] ?? null);
		}

		if (empty($arFields["GROUP_ID"]))
		{
			return $arUserIDSent;
		}

		if (empty($arFields["EXCLUDE_USERS"]))
		{
			$arFields["EXCLUDE_USERS"] = array();
		}

		if (intval($arFields["LOG_ID"] ?? null) > 0)
		{
			$rsUnFollower = CSocNetLogFollow::GetList(
				array(
					"CODE" => "L".intval($arFields["LOG_ID"]),
					"TYPE" => "N"
				),
				array("USER_ID")
			);

			while ($arUnFollower = $rsUnFollower->Fetch())
			{
				$arFields["EXCLUDE_USERS"][] = $arUnFollower["USER_ID"];
			}

			$arFields["EXCLUDE_USERS"] = array_unique($arFields["EXCLUDE_USERS"], SORT_REGULAR);
		}

		$roleList = array();

		if (
			!empty($arFields['PERMISSION'])
			&& !empty($arFields['PERMISSION']['FEATURE'])
			&& !empty($arFields['PERMISSION']['OPERATION'])
		)
		{
			$roleList = CSocNetFeaturesPerms::getOperationPerm(SONET_ENTITY_GROUP, $arFields["GROUP_ID"], $arFields['PERMISSION']['FEATURE'], $arFields['PERMISSION']['OPERATION']);
		}

		$chatData = [];
		if (!empty($arFields["MESSAGE_CHAT"]))
		{
			$chatData = Integration\Im\Chat\Workgroup::getChatData(array(
				'group_id' => $arFields["GROUP_ID"]
			));
		}

		if (!empty($chatData))
		{
			$arFields["GROUP_ID"] = array_diff($arFields["GROUP_ID"], array_unique(array_keys($chatData)));

			$tmp = CSocNetLogTools::processPath(
				array(
					"URL" => $arFields["URL"],
				),
				(intval($arFields["FROM_USER_ID"]) > 0 ? $arFields["FROM_USER_ID"] : 1),
				SITE_ID
			);
			$chatUrl = $tmp["URLS"]["URL"];

			$chatMessageFields = array(
				"MESSAGE" => str_replace(
					array("#URL#", "#url#"),
					$chatUrl,
					$arFields["MESSAGE_CHAT"]
				),
			);

			if (intval($arFields["FROM_USER_ID"]) > 0)
			{
				$chatMessageFields["FROM_USER_ID"] = intval($arFields["FROM_USER_ID"]);
			}

			foreach($chatData as $groupId => $chatId)
			{
				// don't send message to chat if it's unavailable for all members
				if (
					isset($roleList[$groupId])
					&& $roleList[$groupId] < UserToGroupTable::ROLE_USER
				)
				{
					continue;
				}

				CIMChat::addMessage(array_merge(
					$chatMessageFields, array(
						"TO_CHAT_ID" => $chatId
					)
				));
			}
		}

		// if all groups processed by chats
		if (empty($arFields["GROUP_ID"]))
		{
			return $arUserIDSent;
		}

		$arMessageFields = array(
			"MESSAGE_TYPE" => IM_MESSAGE_SYSTEM,
			"NOTIFY_TYPE" => IM_NOTIFY_FROM,
			"NOTIFY_MODULE" => "socialnetwork",
			"NOTIFY_EVENT" => "sonet_group_event",
			"NOTIFY_TAG" => ""
		);

		if (intval($arFields["FROM_USER_ID"] ?? null) > 0)
		{
			$arMessageFields["FROM_USER_ID"] = $arFields["FROM_USER_ID"];
		}

		if (!empty($arFields["NOTIFY_TAG"]))
		{
			$arMessageFields["NOTIFY_TAG"] = $arFields["NOTIFY_TAG"];
			CIMNotify::DeleteByTag(
				$arFields["NOTIFY_TAG"],
				(intval($arFields["FROM_USER_ID"]) > 0 ? intval($arFields["FROM_USER_ID"]) : false)
			);
		}
		elseif (intval($arFields["LOG_ID"] ?? null) > 0)
		{
			$arMessageFields["NOTIFY_TAG"] = "SONET|EVENT|".intval($arFields["LOG_ID"]);
		}

		$arUserToSend = array();
		$arUserIDToSend = array();
		$arGroupID = array();
		$arCodes = array();

		foreach ($arFields["GROUP_ID"] as $group_id)
		{
			$arCodes[] = "SG".$group_id;
		}

		$rsSubscriber = CSocNetSubscription::GetList(
			array(),
			array(
				"CODE" => $arCodes
			),
			false,
			false,
			array("USER_ID", "CODE")
		);

		while($arSubscriber = $rsSubscriber->Fetch())
		{
			if (
				!in_array($arSubscriber["USER_ID"], $arFields["EXCLUDE_USERS"])
				&& !in_array($arSubscriber["USER_ID"], $arUserIDToSend)
			)
			{
				if (preg_match('/^SG(\d+)$/', $arSubscriber["CODE"], $matches))
				{
					$arUserToSend[] = array(
						"USER_ID" => $arSubscriber["USER_ID"],
						"GROUP_ID" => $matches[1]
					);
					$arUserIDToSend[] = $arSubscriber["USER_ID"];
					$arGroupID[] = $matches[1];
				}
			}
		}

		$arGroups = array();

		$rsGroup = CSocNetGroup::GetList(
			array(),
			array("ID" => $arGroupID),
			false,
			false,
			array("ID", "NAME", "OWNER_ID")
		);

		while($arGroup = $rsGroup->GetNext())
		{
			if (!empty($arGroup['NAME']))
			{
				$arGroup['NAME'] = Emoji::decode($arGroup['NAME']);
			}
			$arGroups[$arGroup["ID"]] = $arGroup;
		}

		$workgroupsPage = COption::GetOptionString("socialnetwork", "workgroups_page", "/workgroups/", SITE_ID);
		$groupUrlTemplate = \Bitrix\Socialnetwork\Helper\Path::get('group_path_template');
		$groupUrlTemplate = "#GROUPS_PATH#".mb_substr($groupUrlTemplate, mb_strlen($workgroupsPage), mb_strlen($groupUrlTemplate) - mb_strlen($workgroupsPage));

		$canViewUserIdList = array();

		foreach($arUserToSend as $arUser)
		{
			$groupId = $arUser['GROUP_ID'];

			if (isset($roleList[$groupId]))
			{
				if (!isset($canViewUserIdList[$groupId]))
				{
					$canViewUserIdList[$groupId] = array();
					$res = UserToGroupTable::getList(array(
						'filter' => array(
							'=GROUP_ID' => $groupId,
							'<=ROLE' => $roleList[$groupId]
						),
						'select' => array('USER_ID')
					));
					while($relation = $res->fetch())
					{
						$canViewUserIdList[$groupId][] = $relation['USER_ID'];
					}
				}

				if (!in_array($arUser["USER_ID"], $canViewUserIdList[$groupId]))
				{
					continue;
				}
			}

			$arMessageFields["TO_USER_ID"] = $arUser["USER_ID"];
			if (intval($arFields["LOG_ID"] ?? null) > 0)
			{
				$arMessageFields["NOTIFY_SUB_TAG"] = "SONET|EVENT|".intval($arFields["LOG_ID"])."|".intval($arUser["USER_ID"]);
			}

			$arTmp = CSocNetLogTools::ProcessPath(
				array(
					"URL" => $arFields["URL"] ?? null,
					"GROUP_URL" => str_replace(array("#group_id#", "#GROUP_ID#"), $arUser["GROUP_ID"], $groupUrlTemplate)
				),
				$arUser["USER_ID"],
				SITE_ID
			);
			$url = $arTmp["URLS"]["URL"];

			$serverName = (
			mb_strpos($url, "http://") === 0
				|| mb_strpos($url, "https://") === 0
					? ""
					: $arTmp["SERVER_NAME"]
			);

			$groupUrl = $serverName.$arTmp["URLS"]["GROUP_URL"];

			$group_name = (array_key_exists($arUser["GROUP_ID"], $arGroups) ? $arGroups[$arUser["GROUP_ID"]]["NAME"] : "");

			$message = $arFields["MESSAGE"] ?? '';
			$messageOut = $arFields["MESSAGE_OUT"] ?? '';

			$arMessageFields["NOTIFY_MESSAGE"] = fn (?string $languageId = null) => str_replace(
				array("#URL#", "#url#", "#group_name#", "#GROUP_ID#", "#group_id#"),
				array($url, $url, "<a href=\"".$groupUrl."\" class=\"bx-notifier-item-action\">".$group_name."</a>", $arUser["GROUP_ID"], $arUser["GROUP_ID"]),
				is_callable($message) ? $message($languageId) : $message
			);
			$arMessageFields["NOTIFY_MESSAGE_OUT"] = fn (?string $languageId = null) => str_replace(
				array("#URL#", "#url#", "#group_name#"),
				array($serverName.$url, $serverName.$url, $group_name),
				is_callable($messageOut) ? $messageOut($languageId) : $messageOut
			);

			$arMessageFields["PUSH_PARAMS"] = array(
				"ACTION" => "sonet_group_event",
				"TAG" => $arMessageFields["NOTIFY_TAG"]
			);

			if ((int)($arFields["FROM_USER_ID"] ?? null) > 0)
			{
				$dbAuthor = CUser::getByID($arFields["FROM_USER_ID"]);
				if($arAuthor = $dbAuthor->fetch())
				{
					if (!empty($arAuthor["PERSONAL_PHOTO"]))
					{
						$imageResized = CFile::resizeImageGet(
							$arAuthor["PERSONAL_PHOTO"],
							array(
								"width" => 100,
								"height" => 100
							),
							BX_RESIZE_IMAGE_EXACT
						);
						if ($imageResized)
						{
							$authorAvatarUrl = \Bitrix\Im\Common::getPublicDomain().$imageResized["src"];
						}
					}

					$authorName = CUser::formatName(CSite::getNameFormat(), $arAuthor, true);
				}
			}

			if (empty($authorName))
			{
				$authorName = Loc::getMessage("SONET_SS_PUSH_USER");
			}

			$arMessageFields["PUSH_PARAMS"]["ADVANCED_PARAMS"] = array(
				'senderName' => $authorName
			);

			if (!empty($authorAvatarUrl))
			{
				$arMessageFields["PUSH_PARAMS"]["ADVANCED_PARAMS"]["avatarUrl"] = $authorAvatarUrl;
			}

			$arMessageFields["PUSH_MESSAGE"] = fn (?string $languageId = null) => str_replace(
				array("[URL=#URL#]", "[URL=#url#]", "[/URL]", "#group_name#", "#GROUP_ID#", "#group_id#"),
				array('', '', '', $group_name, $arUser["GROUP_ID"], $arUser["GROUP_ID"]),
				is_callable($message) ? $message($languageId) : $message
			);

			$arMessageFields2Send = $arMessageFields;
			if (
				!is_set($arMessageFields2Send["FROM_USER_ID"])
				|| (int)$arMessageFields2Send["FROM_USER_ID"] <= 0
			)
			{
				$arMessageFields2Send["NOTIFY_TYPE"] = IM_NOTIFY_SYSTEM;
				$arMessageFields2Send["FROM_USER_ID"] = 0;
			}

			CIMNotify::Add($arMessageFields2Send);

			$arUserIDSent[] = $arUser["USER_ID"];
		}

		return $arUserIDSent;
	}

	public static function IsUserSubscribed($userID, $code): bool
	{
		global $CACHE_MANAGER;

		$userID = intval($userID);
		if ($userID <= 0)
		{
			return false;
		}

		$code = trim($code);
		if ($code == '')
		{
			return false;
		}

		$cache = new CPHPCache;
		$cache_time = 31536000;
		$cache_id = "entity_".$code;
		$cache_path = "/sonet/subscription/";

		if ($cache->InitCache($cache_time, $cache_id, $cache_path))
		{
			$arCacheVars = $cache->GetVars();
			$arSubscriberID = $arCacheVars["arSubscriberID"];
		}
		else
		{
			$cache->StartDataCache($cache_time, $cache_id, $cache_path);
			$arSubscriberID = array();

			$rsSubscription = CSocNetSubscription::GetList(
				array(),
				array("CODE" => $code)
			);

			while ($arSubscription = $rsSubscription->Fetch())
				$arSubscriberID[] = $arSubscription["USER_ID"];

			if (defined("BX_COMP_MANAGED_CACHE"))
			{
				$CACHE_MANAGER->StartTagCache($cache_path);
				$CACHE_MANAGER->RegisterTag("sonet_subscription_".$code);
				$CACHE_MANAGER->RegisterTag("sonet_group");
			}

			$arCacheData = Array(
				"arSubscriberID" => $arSubscriberID
			);
			$cache->EndDataCache($arCacheData);

			if(defined("BX_COMP_MANAGED_CACHE"))
			{
				$CACHE_MANAGER->EndTagCache();
			}
		}

		return (in_array($userID, $arSubscriberID));
	}

	public static function OnAfterChatMuteNotify($fields): bool
	{
		$result = false;

		if (
			!is_array($fields)
			|| empty($fields['USER_ID'])
			|| !isset($fields['MUTE'])
			|| empty($fields['CHAT'])
			|| !isset($fields['CHAT']['ENTITY_TYPE'])
			|| $fields['CHAT']['ENTITY_TYPE'] != Integration\Im\Chat\Workgroup::CHAT_ENTITY_TYPE
			|| empty($fields['CHAT']['ENTITY_ID'])
		)
		{
			return $result;
		}

		$groupId = intval($fields['CHAT']['ENTITY_ID']);
		$userId = intval($fields['USER_ID']);

		return self::set($userId, "SG".$groupId, ($fields['MUTE'] ? "N" : "Y"));
	}
}