Conversation.php

Go to the documentation of this file.

<?php
 
declare(strict_types=1);
 
namespace ILIAS\OnScreenChat\Repository;
 
use ilDBInterface;
use ILIAS\OnScreenChat\DTO\ConversationDto;
use ILIAS\OnScreenChat\DTO\MessageDto;
use ilObjUser;
 
class Conversation
{
    private ilDBInterface $db;
    protected ilObjUser $user;
 
    public function __construct(ilDBInterface $db, ilObjUser $user)
    {
        $this->db = $db;
        $this->user = $user;
    }
 
    public function findByIds(array $conversationIds): 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($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;
    }
}