General.php

<?php
 
namespace Bitrix\Im\Configuration;
 
use Bitrix\Im\Call\VideoStrategyType;
use Bitrix\Im\Model\OptionStateTable;
use Bitrix\Im\Model\OptionUserTable;
use Bitrix\Main\ArgumentException;
use Bitrix\Main\Config\Option;
use Bitrix\Main\Loader;
use Bitrix\Main\ObjectPropertyException;
use Bitrix\Main\ORM\Fields\ExpressionField;
use Bitrix\Main\ORM\Fields\Relations\Reference;
use Bitrix\Main\ORM\Query\Join;
use Bitrix\Main\SystemException;
use Bitrix\Main\UserTable;
use Exception;
 
class General extends Base
{
    public const ENTITY = 'se';
 
    public const PRIVACY_RESULT_ALL = 'all';
    public const PRIVACY_RESULT_CONTACT = 'contact';
    public const PRIVACY_RESULT_NOBODY = 'nobody';
 
    protected $userId;
 
    protected $userSettings;
 
    protected static $instanceList = [];
 
    protected function __construct()
    {
 
    }
 
    public static function createWithUserId(int $userId): General
    {
        if (!isset(self::$instanceList[$userId]))
        {
            $instance = new static();
            $instance->setUserId($userId);
            $instance->fillUserSettings();
 
            self::$instanceList[$userId] = $instance;
        }
 
        return self::$instanceList[$userId];
    }
 
    public function getValue($settingName)
    {
        return $this->userSettings[$settingName];
    }
 
    protected function setUserId(int $userId): void
    {
        $this->userId = $userId;
    }
 
    protected function fillUserSettings(): void
    {
        $preset = Configuration::getUserPresetFromCache($this->userId);
        if (!empty($preset) && isset($preset['general']['settings']) && is_array($preset['general']['settings']))
        {
            $preset['general']['settings'] =
                array_replace_recursive(self::getDefaultSettings(), $preset['general']['settings'])
            ;
 
            $this->userSettings =  $preset['general']['settings'];
        }
        else
        {
            $this->userSettings = self::getUserSettings($this->userId);
        }
    }
 
    public static function getDefaultSettings(): array
    {
        return [
            'status' => 'online',
            'backgroundImage' => false,
            'bxdNotify' => true,
            'sshNotify' => true,
            'generalNotify' => true,
            'trackStatus' => '',
            'nativeNotify' => true,
            'openDesktopFromPanel' => true,
            'viewOffline' => Option::get("im", "view_offline"),
            'viewGroup' => Option::get("im", "view_group"),
            'viewLastMessage' => true,
            'viewBirthday' => true,
            'viewCommonUsers' => true,
            'enableSound' => true,
            'enableBigSmile' => true,
            'enableDarkTheme' => 'auto',
            'isCurrentThemeDark' => false,
            'enableRichLink' => true,
            'linesTabEnable' => true,
            'linesNewGroupEnable' => false,
            'sendByEnter' => Option::get("im", "send_by_enter"),
            'correctText' => Option::get("im", "correct_text"),
            'panelPositionHorizontal' => Option::get("im", "panel_position_horizontal"),
            'panelPositionVertical' => Option::get("im", "panel_position_vertical"),
            'loadLastMessage' => true,
            'loadLastNotify' => Option::get("im", "load_last_notify"),
            'notifyAutoRead' => true,
            'notifyScheme' => 'simple',
            'notifySchemeLevel' => 'important',
            'notifySchemeSendSite' => true,
            'notifySchemeSendEmail' => !IsModuleInstalled('bitrix24'),
            'notifySchemeSendXmpp' => true,
            'notifySchemeSendPush' => true,
            'privacyMessage' => Option::get("im", "privacy_message"),
            'privacyChat' => Option::get("im", "privacy_chat"),
            'privacyCall' => Option::get("im", "privacy_call"),
            'privacySearch' => Option::get("im", "privacy_search"),
            'privacyProfile' => Option::get("im", "privacy_profile"),
            'callAcceptIncomingVideo' => VideoStrategyType::ALLOW_ALL,
            'backgroundImageId' => 1,
            'chatAlignment' => 'left',
            'next' => false,
            'pinnedChatSort' => 'byCost',
        ];
    }
 
    public static function setSettings(int $groupId, array $settings = [], bool $forInitialize = false): void
    {
        if (empty($settings) && !$forInitialize)
        {
            return;
        }
        $settings = self::checkingValues($settings);
        $encodedSettings = self::encodeSettings($settings);
        $defaultSettings = self::encodeSettings(self::getDefaultSettings());
 
        $encodedSettings = array_merge($defaultSettings, $encodedSettings);
 
        $rows = [];
        foreach ($encodedSettings as $name => $value)
        {
            $rows[] = [
                'GROUP_ID' => $groupId,
                'NAME' => $name,
                'VALUE' => $value
            ];
        }
 
        OptionStateTable::addMulti($rows, true);
    }
 
    public static function getUserSettings(int $userId): array
    {
        $defaultSettings = self::getDefaultSettings();
        $result =
            OptionUserTable::query()
                ->addSelect('GENERAL_GROUP_ID')
                ->where('USER_ID', $userId)
                ->fetch()
        ;
 
        $groupId = is_array($result) ? $result['GENERAL_GROUP_ID'] : null;
        if (!$groupId)
        {
            return $defaultSettings;
        }
 
        $query =
            OptionStateTable::query()
                ->setSelect(['NAME', 'VALUE'])
                ->where('GROUP_ID', $groupId)
                ->whereLike('NAME', static::ENTITY.'%')
        ;
 
        $settings = [];
        foreach ($query->exec() as $rowSetting)
        {
            $settings[$rowSetting['NAME']] = $rowSetting['VALUE'];
        }
 
        if(empty($settings))
        {
            return $defaultSettings;
        }
 
        $settings = static::decodeSettings($settings);
 
        return array_replace_recursive($defaultSettings, $settings);
    }
 
    public static function allowedUserBySimpleNotificationSettings(int $userId, string $notifyType): bool
    {
        $userSettings = static::createWithUserId($userId);
        if ($userSettings->getValue('notifyScheme') === 'simple')
        {
            $settingName = static::getNotifySettingByType($notifyType);
            return (bool)$userSettings->getValue($settingName);
        }
 
        return true;
    }
 
    public static function filterAllowedUsersBySimpleNotificationSettings(array $userList, string $notifyType): array
    {
        if (empty($userList))
        {
            return $userList;
        }
 
        $settingName = static::getNotifySettingByType($notifyType);
        if ($settingName === '')
        {
            return $userList;
        }
 
        $encodedSettingName = static::encodeName($settingName);
        $encodedDefaultSettings = static::encodeSettings(static::getDefaultSettings());
 
        if (!array_key_exists($encodedSettingName, $encodedDefaultSettings))
        {
            return $userList;
        }
 
        $filteredUsers = [];
        if (count($userList) < 1000)
        {
            $filteredUsers = static::filterChunk($userList, $settingName);
        }
        else
        {
            $chunkList = array_chunk($userList, static::CHUNK_LENGTH);
            foreach ($chunkList as $chunk)
            {
                $filteredUsers = array_merge($filteredUsers, static::filterChunk($chunk, $settingName));
            }
        }
 
        return $filteredUsers;
    }
 
    protected static function filterChunk(array $userList, string $settingName): array
    {
        $notifySchemas = static::getUserNotifySchemas($userList);
        $filteredUserListWithSimpleScheme = static::filterUsersWithSimpleNotifyScheme($notifySchemas['simple'], $settingName);
 
        return array_merge($filteredUserListWithSimpleScheme, $notifySchemas['expert']);
    }
 
    protected static function getNotifySettingByType(string $notifyType): string
    {
        switch ($notifyType)
        {
            case Notification::SITE:
                return 'notifySchemeSendSite';
            case Notification::MAIL:
                return 'notifySchemeSendEmail';
            case Notification::XMPP:
                return 'notifySchemeSendXmpp';
            case Notification::PUSH:
                return 'notifySchemeSendPush';
            default:
                return '';
        }
    }
 
    protected static function getUserNotifySchemas(array $userList): array
    {
        if (empty($userList))
        {
            return [];
        }
 
        $default = static::getDefaultSettings();
        $notifySchemeValue = $default['notifyScheme'];
        $encodedSettingName = static::encodeName('notifyScheme');
 
        $query =
            OptionUserTable::query()
                ->addSelect('USER_ID')
                ->addSelect(new ExpressionField('NOTIFY_SCHEMA',"COALESCE(%s, '$notifySchemeValue')", ['OPTION_STATE.VALUE']))
                ->registerRuntimeField(
                    'USER',
                    new Reference(
                        'USER',
                        UserTable::class,
                        Join::on('this.USER_ID', 'ref.ID'),
                        ['join_type' => Join::TYPE_INNER]
                    )
                )
                ->registerRuntimeField(
                    'OPTION_STATE',
                    new Reference(
                        'OPTION_STATE',
                        OptionStateTable::class,
                        Join::on('this.GENERAL_GROUP_ID', 'ref.GROUP_ID')
                            ->where('ref.NAME', $encodedSettingName),
                        ['join_type' => Join::TYPE_LEFT]
                    )
                )
                ->whereIn('USER_ID', $userList)
                ->where('USER.ACTIVE', 'Y')
                ->where('USER.IS_REAL_USER', 'Y')
        ;
        $notifySchemas = [
            'simple' => [],
            'expert' => [],
        ];
 
        foreach ($query->exec() as $row)
        {
            if($row['NOTIFY_SCHEMA'] === 'simple')
            {
                $notifySchemas['simple'][] = (int)$row['USER_ID'];
            }
            elseif ($row['NOTIFY_SCHEMA'] === 'expert')
            {
                $notifySchemas['expert'][] = (int)$row['USER_ID'];
            }
        }
 
        return $notifySchemas;
    }
 
    protected static function filterUsersWithSimpleNotifyScheme(array $userList, string $settingName): array
    {
        if (empty($userList))
        {
            return [];
        }
 
        $encodedSettingName = static::encodeName($settingName);
        $defaultSettingValue = static::getDefaultSettings()[$settingName] ? 'Y' : 'N';
        $query =
            OptionUserTable::query()
                ->addSelect('USER_ID')
                ->registerRuntimeField(
                    'USER',
                    new Reference(
                        'USER',
                        UserTable::class,
                        Join::on('this.USER_ID', 'ref.ID'),
                        ['join_type' => Join::TYPE_INNER]
                    )
                )
                ->registerRuntimeField(
                    'OPTION_STATE',
                    new Reference(
                        'OPTION_STATE',
                        OptionStateTable::class,
                        Join::on('this.GENERAL_GROUP_ID', 'ref.GROUP_ID')
                            ->where('ref.NAME', $encodedSettingName),
                        ['join_type' => Join::TYPE_LEFT]
                    )
                )
                ->whereIn('USER_ID', $userList)
                ->where('USER.ACTIVE', 'Y')
                ->where('USER.IS_REAL_USER', 'Y')
                ->whereExpr("COALESCE(%s, '$defaultSettingValue') = 'Y'", ['OPTION_STATE.VALUE'])
        ;
 
        $filteredUserList = [];
        foreach ($query->exec() as $row)
        {
            $filteredUserList[] = (int)$row['USER_ID'];
        }
 
        return $filteredUserList;
    }
 
    public static function getGroupSettings(int $groupId): array
    {
        $defaultSettings = self::getDefaultSettings();
 
        $query =
            OptionStateTable::query()
            ->setSelect(['NAME', 'VALUE'])
            ->where('GROUP_ID', $groupId)
            ->whereLike('NAME', static::ENTITY.'%')
        ;
 
        $settings = [];
        foreach ($query->exec() as $rowSetting)
        {
            $settings[$rowSetting['NAME']] = $rowSetting['VALUE'];
        }
 
        if (empty($settings))
        {
            return $defaultSettings;
        }
 
        $settings = static::decodeSettings($settings);
 
        return array_replace_recursive($defaultSettings, $settings);
    }
 
    public static function updateGroupSettings(int $groupId, array $settings): void
    {
        if ($settings === [])
        {
            return;
        }
 
        $settings = self::checkingValues($settings);
        $encodedSettings = self::encodeSettings($settings);
 
        $query =
            OptionStateTable::query()
                ->setSelect(['NAME', 'VALUE'])
                ->where('GROUP_ID', $groupId)
                ->whereLike('NAME', self::ENTITY.'%')
        ;
 
        foreach ($query->exec() as $row)
        {
            if (array_key_exists($row['NAME'], $encodedSettings))
            {
                if ($row['VALUE'] === $encodedSettings[$row['NAME']])
                {
                    unset($encodedSettings[$row['NAME']]);
                    continue;
                }
                OptionStateTable::update(
                    [
                        'GROUP_ID' => $groupId,
                        'NAME' => $row['NAME']
                    ],
                    ['VALUE' => $encodedSettings[$row['NAME']]]
                );
                unset($encodedSettings[$row['NAME']]);
            }
        }
 
        $addedSettings = [];
        foreach ($encodedSettings as $name => $value)
        {
            $addedSettings[] = [
                'GROUP_ID' => $groupId,
                'NAME' => $name,
                'VALUE' => $value
            ];
        }
        if ($addedSettings !== [])
        {
            OptionStateTable::addMulti($addedSettings, true);
        }
    }
 
    public static function encodeSettings(array $settings): array
    {
        $encodedSettings = [];
        foreach ($settings as $name => $value)
        {
            $encodeName = self::encodeName($name);
 
            if (mb_strlen($encodeName) > 64 || mb_strlen($value) > 255)
            {
                continue;
            }
 
            if ($value === true)
            {
                $encodedSettings[$encodeName] = 'Y';
            }
            elseif ($value === false)
            {
                $encodedSettings[$encodeName] = 'N';
            }
            else
            {
                $encodedSettings[$encodeName] = $value;
            }
        }
 
        return $encodedSettings;
    }
 
    public static function decodeSettings(array $rowSettings): array
    {
        $decodedSettings = [];
        foreach ($rowSettings as $name => $value)
        {
            $decodedName = self::decodeName($name);
            if ($value === 'Y')
            {
                $decodedSettings[$decodedName] = true;
            }
            elseif ($value === 'N')
            {
                $decodedSettings[$decodedName] = false;
            }
            else
            {
                $decodedSettings[$decodedName] = $value;
            }
        }
 
        return $decodedSettings;
    }
 
    private static function encodeName(string $name): string
    {
        return static::ENTITY . static::SEPARATOR . $name;
    }
 
    private static function decodeName(string $setting): string
    {
        return str_replace(static::ENTITY . static::SEPARATOR, '', $setting);
    }
 
    public static function checkingValues(array $settings): array
    {
        $verifiedSettings = [];
 
        $defaultSettings = self::getDefaultSettings();
        foreach($settings as $name => $value)
        {
            if (!array_key_exists($name , $defaultSettings))
            {
                continue;
            }
 
            switch ($name)
            {
                case 'status':
                    $verifiedSettings[$name] =
                        in_array($value, ['online', 'dnd', 'away'])
                            ? $value
                            : $defaultSettings[$name]
                    ;
 
                    break;
                case 'panelPositionHorizontal':
                    $verifiedSettings[$name] =
                        in_array($value, ['left', 'center', 'right'])
                            ? $value
                            : $defaultSettings[$name]
                    ;
 
                    break;
                case 'panelPositionVertical':
                    $verifiedSettings[$name] =
                        in_array($value, ['top', 'bottom'])
                            ? $value
                            : $defaultSettings[$name]
                    ;
 
                    break;
                case 'notifyScheme':
                    $verifiedSettings[$name] =
                        in_array($value, ['simple', 'expert'])
                            ? $value
                            : $defaultSettings[$name]
                    ;
 
                    break;
                case 'enableDarkTheme':
                    $verifiedSettings[$name] =
                        in_array($value, ['auto', 'light', 'dark'])
                            ? $value
                            : $defaultSettings[$name]
                    ;
 
                    break;
                case 'privacyMessage':
                case 'privacyChat':
                case 'privacyCall':
                case 'privacySearch':
                    $verifiedSettings[$name] =
                        in_array($value, [self::PRIVACY_RESULT_ALL, self::PRIVACY_RESULT_CONTACT], true)
                            ? $value
                            : $defaultSettings[$name]
                    ;
 
                    break;
                case 'privacyProfile':
                    $verifiedSettings[$name] =
                        in_array(
                            $value,
                            [
                                self::PRIVACY_RESULT_ALL,
                                self::PRIVACY_RESULT_CONTACT,
                                self::PRIVACY_RESULT_NOBODY
                            ],
                            true
                        )
                            ? $value
                            : $defaultSettings[$name];
 
                    break;
                case 'backgroundImage':
                    $verifiedSettings[$name] = $value;
 
                    break;
                case 'notifySchemeLevel':
                    $verifiedSettings[$name] =
                        in_array($value, ['normal', 'important'])
                            ? $value
                            : $defaultSettings[$name];
 
                    break;
                case 'trackStatus':
                    $status = explode(',', $value);
                    foreach ($status as $key => $val)
                    {
                        if ($val !== 'all')
                        {
                            $status[$key] = (int)$val;
                            if ($status[$key] === 0)
                            {
                                unset($status[$key]);
                            }
                        }
                    }
                    $verifiedSettings[$name] = implode(',', $status);
 
                    break;
                case 'callAcceptIncomingVideo':
                    $verifiedSettings[$name] =
                        in_array($value, VideoStrategyType::getList())
                            ? $value
                            : $defaultSettings[$name]
                    ;
 
                    break;
                case 'sendByEnter': // for legacy
                    $verifiedSettings[$name] = $value === 'Y' || $value === true;
                    break;
                case 'enableSound': // for legacy
                    $verifiedSettings[$name] = !($value === 'N' || $value === false);
                    break;
                case 'backgroundImageId':
                    $verifiedSettings[$name] = (int)$value > 0 ? (int)$value : 1;
                    break;
                case 'chatAlignment':
                    $verifiedSettings[$name] =
                        in_array($value, ['left', 'center'])
                            ? $value
                            : $defaultSettings[$name]
                    ;
                    break;
                case 'pinnedChatSort':
                    $verifiedSettings[$name] =
                        ($value === 'byDate')
                            ? $value
                            : $defaultSettings[$name]
                    ;
                    break;
                default:
                    if (array_key_exists($name, $defaultSettings))
                    {
                        $verifiedSettings[$name] = is_bool($value) ? $value : $defaultSettings[$name];
                    }
 
                    break;
            }
        }
 
        return $verifiedSettings;
    }
 
}