statushandler.php

<?php
namespace Bitrix\Im\Replica;
 
use Bitrix\Main\Loader;
 
if (Loader::includeModule('replica'))
{
    class StatusHandler extends \Bitrix\Replica\Client\BaseHandler
    {
        public $insertIgnore = true;
 
        protected $tableName = "b_im_status";
        protected $moduleId = "im";
        protected $className = "\\Bitrix\\Im\\Model\\StatusTable";
        protected $primary = array(
            "USER_ID" => "integer",
        );
        protected $predicates = array(
            "USER_ID" => "b_im_status.USER_ID",
        );
        protected $translation = array(
            "USER_ID" => "b_im_status.USER_ID",
        );
        protected $fields = array(
            "IDLE" => "datetime",
            "DESKTOP_LAST_DATE" => "datetime",
            "MOBILE_LAST_DATE" => "datetime",
            "EVENT_UNTIL_DATE" => "datetime",
        );
 
        public function afterInsertTrigger(array $newRecord)
        {
            if ($newRecord["USER_ID"] && \CIMStatus::Enable())
            {
                \CPullStack::AddShared(Array(
                    'module_id' => 'online',
                    'command' => 'user_status',
                    'expiry' => 120,
                    'params' => array(
                        "USER_ID" => $newRecord["USER_ID"],
                        "STATUS" => $newRecord["STATUS"],
                    ),
                ));
            }
        }
 
        public function afterUpdateTrigger(array $oldRecord, array $newRecord)
        {
            if ($oldRecord["STATUS"] !== $newRecord["STATUS"])
            {
                if (\CIMStatus::Enable())
                {
                    \CPullStack::AddShared(Array(
                        'module_id' => 'online',
                        'command' => 'user_status',
                        'expiry' => 120,
                        'params' => array(
                            "USER_ID" => $newRecord["USER_ID"],
                            "STATUS" => $newRecord["STATUS"],
                        ),
                    ));
                }
            }
        }
 
        public function onUserSetLastActivityDate(\Bitrix\Main\Event $event)
        {
            $users = $event->getParameter(0);
            foreach ($users as $userId)
            {
                $cache = \Bitrix\Main\Data\Cache::createInstance();
                if ($cache->startDataCache(60, $userId, '/im/status'))
                {
                    $mapper = \Bitrix\Replica\Mapper::getInstance();
                    $map = $mapper->getByPrimaryValue("b_im_status.USER_ID", false, $userId);
                    if ($map)
                    {
                        $guid = \Bitrix\Replica\Client\User::getLocalUserGuid($userId).'@'.getNameByDomain();
                        if ($guid && $map[$guid])
                        {
                            $event = array(
                                "operation" => "im_status_update",
                                "guid" => $guid,
                                "nodes" => $map[$guid],
                                "ts" => time(),
                                "ip" => \Bitrix\Main\Application::getInstance()->getContext()->getServer()->get('REMOTE_ADDR'),
                            );
                            \Bitrix\Replica\Log\Client::getInstance()->write($map[$guid], $event);
                        }
                    }
                    $cache->endDataCache(true);
                }
            }
        }
 
        public function handleStatusUpdateOperation($event, $nodeFrom, $nodeTo)
        {
            /*
            global $USER;
            if (!isset($event["guid"]))
            {
                return;
            }
 
            $mapper = \Bitrix\Replica\Mapper::getInstance();
            $userId = $mapper->getByGuid("b_im_status.USER_ID", $event["guid"], $nodeFrom);
            if (!$userId)
            {
                return;
            }
 
            $USER->setLastActivityDate($userId);
            */
        }
 
        public function onStartUserReplication(\Bitrix\Main\Event $event)
        {
            $parameters = $event->getParameters();
 
            $userId = $parameters[0];
            $domain = $parameters[2];
 
            $domainId = getNameByDomain($domain);
            if (!$domainId)
            {
                return;
            }
 
            $mapper = \Bitrix\Replica\Mapper::getInstance();
            $map = $mapper->getByPrimaryValue("b_user.ID", false, $userId);
            if (!$map)
            {
                return;
            }
 
            $guid = key($map);
            $event = array(
                "operation" => "im_status_bind",
                "guid" => $guid.'@'.$domainId,
                "nodes" => array($domainId),
                "ts" => time(),
                "ip" => \Bitrix\Main\Application::getInstance()->getContext()->getServer()->get('REMOTE_ADDR'),
            );
            \Bitrix\Replica\Log\Client::getInstance()->write(array($domainId), $event);
            \Bitrix\Replica\Mapper::getInstance()->add("b_im_status.USER_ID", $userId, $domainId, $event["guid"]);
        }
 
        public function handleStatusBindOperation($event, $nodeFrom, $nodeTo)
        {
            if (!isset($event["guid"]))
            {
                return;
            }
 
            list ($userGuid,) = explode('@', $event["guid"]);
            if (!$userGuid)
            {
                return;
            }
 
            $userId = \Bitrix\Replica\Client\User::getLocalUserId($userGuid);
            if (!$userId)
            {
                return;
            }
 
            $mapper = \Bitrix\Replica\Mapper::getInstance();
            $mapper->add("b_im_status.USER_ID", $userId, $nodeFrom, $event["guid"]);
 
            $res = \Bitrix\Im\Model\StatusTable::getById($userId);
            if ($res->fetch())
            {
                //Insert operation
                \Bitrix\Replica\Db\Operation::writeInsert(
                    "b_im_status",
                    $this->getPrimary(),
                    array("USER_ID" => $userId)
                );
            }
        }
 
        public function OnAfterRecentDelete(\Bitrix\Main\Event $event)
        {
            $userId = $event->getParameter('user_id');
            if (!$userId)
            {
                return;
            }
 
            $mapper = \Bitrix\Replica\Mapper::getInstance();
            $map = $mapper->getByPrimaryValue("b_im_status.USER_ID", false, $userId);
            if (!$map)
            {
                return;
            }
 
            $guid = key($map);
            list(, $targetNode) = explode("@", $guid, 2);
 
            $domainId = getNameByDomain();
            $event = array(
                "operation" => "im_status_unbind",
                "guid" => $guid,
                "nodes" => array($domainId),
                "ts" => time(),
                "ip" => \Bitrix\Main\Application::getInstance()->getContext()->getServer()->get('REMOTE_ADDR'),
            );
            \Bitrix\Replica\Log\Client::getInstance()->write(array($targetNode), $event);
 
        }
 
        public function handleStatusUnbindOperation($event, $nodeFrom, $nodeTo)
        {
            if (!isset($event["guid"]))
            {
                return;
            }
 
            list ($userGuid,) = explode('@', $event["guid"]);
            $userId = \Bitrix\Replica\Client\User::getLocalUserId($userGuid);
            if (!$userId > 0)
            {
                return;
            }
 
            $mapper = \Bitrix\Replica\Mapper::getInstance();
            $mapper->deleteByGuid("b_im_status.USER_ID", $event["guid"], $nodeFrom);
        }
 
        public function OnAfterRecentAdd(\Bitrix\Main\Event $event)
        {
            $userId = $event->getParameter('user_id');
            if (!$userId)
            {
                return;
            }
 
            $userGuid = \Bitrix\Replica\Client\User::getRemoteUserGuid($userId);
            if (!$userGuid)
            {
                return;
            }
 
            $mapper = \Bitrix\Replica\Mapper::getInstance();
            $map = $mapper->getByPrimaryValue("b_user.ID", false, $userId);
            if (!$map)
            {
                return;
            }
 
            $guid = key($map);
            $targetNode = current($map[$guid]);
 
            $domainId = getNameByDomain();
            $event = array(
                "operation" => "im_status_rebind",
                "guid" => $userGuid."@".$targetNode,
                "nodes" => array($domainId),
                "ts" => time(),
                "ip" => \Bitrix\Main\Application::getInstance()->getContext()->getServer()->get('REMOTE_ADDR'),
            );
            \Bitrix\Replica\Log\Client::getInstance()->write(array($targetNode), $event);
        }
 
        public function handleStatusRebindOperation($event, $nodeFrom, $nodeTo)
        {
            if (!isset($event["guid"]))
            {
                return;
            }
 
            list ($userGuid,) = explode('@', $event["guid"]);
            $userId = \Bitrix\Replica\Client\User::getLocalUserId($userGuid);
            if (!$userId)
            {
                return;
            }
 
            \Bitrix\Replica\Mapper::getInstance()->add("b_im_status.USER_ID", $userId, $nodeFrom, $event["guid"]);
 
            $res = \Bitrix\Im\Model\StatusTable::getById($userId);
            if ($res->fetch())
            {
                //Update operation
                \Bitrix\Replica\Db\Operation::writeUpdate(
                    "b_im_status",
                    $this->getPrimary(),
                    array("USER_ID" => $userId)
                );
            }
        }
    }
}