<?php

namespace wcf\data\conversation;

use wcf\data\user\UserProfile;
use wcf\data\user\UserProfileList;
use wcf\system\WCF;

/**
 * Represents a list of conversation participants.
 *
 * @author  Marcel Werk
 * @copyright   2001-2019 WoltLab GmbH
 * @license GNU Lesser General Public License <http://opensource.org/licenses/lgpl-license.php>
 * @package WoltLabSuite\Core\Data\Conversation
 */
class ConversationParticipantList extends UserProfileList
{
    /**
     * conversation id
     * @var integer
     */
    public $conversationID = 0;

    /**
     * @inheritDoc
     */
    public $sqlLimit = 0;

    /**
     * Creates a new ConversationParticipantList object.
     *
     * @param integer $conversationID
     * @param integer $userID
     * @param boolean $isAuthor true if given user is the author of this conversation
     */
    public function __construct($conversationID, $userID = 0, $isAuthor = false)
    {
        parent::__construct();

        $this->conversationID = $conversationID;
        $this->getConditionBuilder()->add('conversation_to_user.conversationID = ?', [$conversationID]);
        if (!$isAuthor) {
            if ($userID) {
                $this->getConditionBuilder()->add(
                    '(conversation_to_user.isInvisible = 0 OR conversation_to_user.participantID = ?)',
                    [$userID]
                );
            } else {
                $this->getConditionBuilder()->add(
                    'conversation_to_user.isInvisible = 0'
                );
            }
        }
        $this->sqlConditionJoins .= " LEFT JOIN wcf" . WCF_N . "_user user_table ON (user_table.userID = conversation_to_user.participantID)";

        if (!empty($this->sqlSelects)) {
            $this->sqlSelects .= ',';
        }
        $this->sqlSelects = 'conversation_to_user.*';
        $this->sqlJoins .= " LEFT JOIN wcf" . WCF_N . "_conversation_to_user conversation_to_user ON (conversation_to_user.participantID = user_table.userID AND conversation_to_user.conversationID = " . $conversationID . ")";
    }

    /**
     * @inheritDoc
     */
    public function countObjects()
    {
        $sql = "SELECT  COUNT(*) AS count
                FROM    wcf" . WCF_N . "_conversation_to_user conversation_to_user
                " . $this->sqlConditionJoins . "
                " . $this->getConditionBuilder()->__toString();
        $statement = WCF::getDB()->prepareStatement($sql);
        $statement->execute($this->getConditionBuilder()->getParameters());
        $row = $statement->fetchArray();

        return $row['count'];
    }

    /**
     * @inheritDoc
     */
    public function readObjectIDs()
    {
        $this->objectIDs = [];
        $sql = "SELECT  conversation_to_user.participantID AS objectID
                FROM    wcf" . WCF_N . "_conversation_to_user conversation_to_user
                " . $this->sqlConditionJoins . "
                " . $this->getConditionBuilder()->__toString() . "
                " . (!empty($this->sqlOrderBy) ? "ORDER BY " . $this->sqlOrderBy : '');
        $statement = WCF::getDB()->prepareStatement($sql, $this->sqlLimit, $this->sqlOffset);
        $statement->execute($this->getConditionBuilder()->getParameters());
        $this->objectIDs = $statement->fetchAll(\PDO::FETCH_COLUMN);
    }

    /**
     * @inheritDoc
     */
    public function readObjects()
    {
        parent::readObjects();

        // check for deleted users
        $sql = "SELECT  username
                FROM    wcf" . WCF_N . "_conversation_to_user
                WHERE   conversationID = ?
                    AND participantID IS NULL";
        $statement = WCF::getDB()->prepareStatement($sql);
        $statement->execute([$this->conversationID]);
        $i = 0;
        while ($row = $statement->fetchArray()) {
            // create fake user profiles
            $this->objects['x' . (++$i)] = UserProfile::getGuestUserProfile($row['username']);
            $this->indexToObject[] = 'x' . $i;
        }
    }
}