ReactionMessage.php

См. документацию.

<?php
 
namespace Bitrix\Im\V2\Message\Reaction;
 
use Bitrix\Im\V2\Entity\User\UserShortPopupItem;
use Bitrix\Im\V2\Rest\PopupData;
use Bitrix\Im\V2\Rest\PopupDataAggregatable;
use Bitrix\Im\V2\Rest\RestConvertible;
use Bitrix\Main\Engine\Response\Converter;
 
class ReactionMessage implements RestConvertible, PopupDataAggregatable
{
    public const COUNT_DISPLAYED_USERS = 5;
 
    private int $messageId;
    private array $reactionCounters = [];
    private array $reactionUsers = [];
    private array $ownReactions = [];
    private bool $haveDisplayedUsers = false;
    private bool $haveUndisplayedUsers = false;
 
    public function __construct(int $messageId)
    {
        $this->messageId = $messageId;
    }
 
    public static function getByMessageId(int $messageId): self
    {
        return (new ReactionMessages([$messageId]))->getReactionMessage($messageId);
    }
 
    public function addCounter(string $reaction, int $counter): self
    {
        $this->reactionCounters[$reaction] = $counter;
 
        if ($counter <= self::COUNT_DISPLAYED_USERS)
        {
            $this->haveDisplayedUsers = true;
        }
        else
        {
            $this->haveUndisplayedUsers = true;
        }
 
        return $this;
    }
 
    public function addUsers(string $reaction, array $users): self
    {
        if (isset($this->reactionUsers[$reaction]))
        {
            $this->reactionUsers[$reaction] = array_merge($this->reactionUsers[$reaction], $users);
        }
        else
        {
            $this->reactionUsers[$reaction] = $users;
        }
 
        return $this;
    }
 
    public function addOwnReaction(string $reaction): self
    {
        $this->ownReactions[] = $reaction;
 
        return $this;
    }
 
    public function getMessageId(): int
    {
        return $this->messageId;
    }
 
    public function needToFillOwnReactions(): bool
    {
        return empty($this->ownReactions) && $this->haveUndisplayedUsers;
    }
 
    public function haveReactions(): bool
    {
        return !empty($this->reactionCounters);
    }
 
    public function haveDisplayedUsers(): bool
    {
        return $this->haveDisplayedUsers;
    }
 
    public function toRestFormat(array $option = []): array
    {
        $converter = new Converter(Converter::KEYS | Converter::VALUES | Converter::TO_LOWER | Converter::LC_FIRST);
        $rest = [
            'messageId' => $this->messageId,
            'reactionCounters' => $converter->process($this->reactionCounters),
            'reactionUsers' => $converter->process($this->reactionUsers),
        ];
 
        if (!isset($option['WITHOUT_OWN_REACTIONS']) || $option['WITHOUT_OWN_REACTIONS'] === false)
        {
            $rest['ownReactions'] = $converter->process($this->ownReactions);
        }
 
        return $rest;
    }
 
    public static function getRestEntityName(): string
    {
        return 'reaction';
    }
 
    public function getPopupData(array $excludedList = []): PopupData
    {
        return new PopupData([new UserShortPopupItem($this->getUserIds())], $excludedList);
    }

    public function getUserIds(): array
    {
        $userIds = [];
 
        foreach ($this->reactionUsers as $reaction)
        {
            foreach ($reaction as $user)
            {
                $userIds[$user] = $user;
            }
        }
 
        return $userIds;
    }
}