<?php

class CAllSocNetLogFavorites
{
	public static function Change($user_id, $log_id, array $params = array('TRIGGER_EVENT' => true))
	{
		global $DB, $APPLICATION;

		$user_id = intval($user_id);
		$log_id = intval($log_id);

		if ($user_id <= 0 || $log_id <= 0)
		{
			if ($user_id <= 0)
				$APPLICATION->ThrowException(GetMessage("SONET_LF_WRONG_PARAMETER_USER_ID"), "EMPTY_USER_ID");
			else
				$APPLICATION->ThrowException(GetMessage("SONET_LF_WRONG_PARAMETER_LOG_ID"), "EMPTY_LOG_ID");

			return false;
		}

		$strSQL = "SELECT * FROM b_sonet_log_favorites WHERE USER_ID = ".$user_id." AND LOG_ID = ".$log_id;
		$dbRes = $DB->Query($strSQL);

		$pool = \Bitrix\Main\Application::getInstance()->getConnectionPool();
		$pool->useMasterOnly(true);

		$connection = \Bitrix\Main\Application::getConnection();

		$result = false;
		if (!$arRes = $dbRes->Fetch())
		{
			$strSQL = $connection->getSqlHelper()->getInsertIgnore(
				'b_sonet_log_favorites',
				' (USER_ID, LOG_ID) ',
				"VALUES(" . $user_id . ", " . $log_id . ")"
			);

			if ($connection->query($strSQL))
				$result = "Y";
			else
				$APPLICATION->ThrowException(GetMessage("SONET_LF_CANNOT_INSERT"), "CANNOT_INSERT");
		}
		else
		{
			$strSQL = "DELETE FROM b_sonet_log_favorites WHERE USER_ID = ".$user_id." AND LOG_ID = ".$log_id;
			if ($DB->Query($strSQL))
				$result = "N";
			else
				$APPLICATION->ThrowException(GetMessage("SONET_LF_CANNOT_INSERT"), "CANNOT_DELETE");
		}

		$pool->useMasterOnly(false);

		if(
			$result
			&& (!isset($params['TRIGGER_EVENT']) || $params['TRIGGER_EVENT'] === true)
		)
		{
			foreach(GetModuleEvents('socialnetwork', 'OnSonetLogFavorites', true) as $arEvent)
			{
				ExecuteModuleEventEx($arEvent, array(array('USER_ID' => $user_id, 'LOG_ID' => $log_id, 'OPERATION' => $result == 'Y' ? 'ADD' : 'DELETE')));
			}
		}

		return $result;
	}
}