ILIAS\OnScreenChat\Repository\Conversation Class Reference

Collaboration diagram for ILIAS\OnScreenChat\Repository\Conversation:

Public Member Functions
	__construct (private readonly ilDBInterface $db, protected ilObjUser $user)
	findByIds (array $conversationIds)

Detailed Description

Definition at line 32 of file Conversation.php.

Constructor & Destructor Documentation

__construct()

ILIAS\OnScreenChat\Repository\Conversation::__construct	(	private readonly ilDBInterface	$db,
		protected ilObjUser	$user
	)

Definition at line 34 of file Conversation.php.

    {
    }

Member Function Documentation

findByIds()

ILIAS\OnScreenChat\Repository\Conversation::findByIds

(

array

$conversationIds

)

Parameters

string[]

$conversationIds

Returns

ConversationDto[]

Definition at line 42 of file Conversation.php.

                                                     : array
    {
        $conversations = [];
 
        $res = $this->db->query(
            'SELECT * FROM osc_conversation WHERE ' . $this->db->in(
                'id',
                $conversationIds,
                false,
                'text'
            )
        );
 
        while ($row = $this->db->fetchAssoc($res)) {
            $participants = json_decode((string) $row['participants'], true, 512, JSON_THROW_ON_ERROR);
            $participantIds = array_filter(array_map(static function ($user): int {
                if (is_array($user) && isset($user['id'])) {
                    return (int) $user['id'];
                }
 
                return 0;
            }, $participants));
 
            if (!in_array($this->user->getId(), $participantIds, true)) {
                continue;
            }
 
            $conversation = new ConversationDto($row['id']);
            $conversation->setIsGroup((bool) $row['is_group']);
            $conversation->setSubscriberUsrIds($participantIds);
 
            $inParticipants = $this->db->in(
                'osc_messages.user_id',
                $participantIds,
                false,
                'text'
            );
 
            $this->db->setLimit(1, 0);
            $query = "
                SELECT osc_messages.*
                FROM osc_messages
                WHERE osc_messages.conversation_id = %s
                AND $inParticipants
                ORDER BY osc_messages.timestamp DESC
            ";
            $msgRes = $this->db->queryF($query, ['text'], [$conversation->getId()]);
            while ($msgRow = $this->db->fetchAssoc($msgRes)) {
                $message = new MessageDto($msgRow['id'], $conversation);
                $message->setMessage($msgRow['message']);
                $message->setAuthorUsrId((int) $msgRow['user_id']);
                $message->setCreatedTimestamp((int) $msgRow['timestamp']);
                $conversation->setLastMessage($message);
                break;
            }
 
            $conversations[] = $conversation;
        }
 
        return $conversations;
    }

References $message, $res, and ILIAS\Repository\user().

Here is the call graph for this function:

---

The documentation for this class was generated from the following file:

• components/ILIAS/OnScreenChat/classes/Repository/Conversation.php