1
0
mirror of https://github.com/wbbaddons/Tims-Chat.git synced 2024-11-16 16:30:09 +00:00
Tims-Chat/files/lib/data/user/User.class.php
2022-03-10 18:56:18 +01:00

122 lines
3.0 KiB
PHP
Raw Blame History

This file contains ambiguous Unicode characters

This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.

<?php
/*
* Copyright (c) 2010-2022 Tim Düsterhus.
*
* Use of this software is governed by the Business Source License
* included in the LICENSE file.
*
* Change Date: 2026-03-10
*
* On the date above, in accordance with the Business Source
* License, use of this software will be governed by version 2
* or later of the General Public License.
*/
namespace chat\data\user;
use chat\data\room\Room;
use chat\data\room\RoomCache;
use wcf\data\DatabaseObjectDecorator;
use wcf\system\WCF;
/**
* Decorates the User object to make it useful in context of Tims Chat.
*/
class User extends DatabaseObjectDecorator implements \JsonSerializable
{
/**
* @inheritDoc
*/
protected static $baseClass = \wcf\data\user\User::class;
/**
* array of room_to_user rows
*
* @var int[][]
*/
protected $roomToUser;
/**
* Returns an array of the room_to_user arrays for this user.
*
* @return mixed[]
*/
public function getRoomAssociations($skipCache = false)
{
if ($this->roomToUser === null || $skipCache) {
$sql = "SELECT *
FROM chat1_room_to_user
WHERE userID = ?";
$statement = WCF::getDB()->prepare($sql);
$statement->execute([ $this->userID ]);
$this->roomToUser = [ ];
while (($row = $statement->fetchArray())) {
$this->roomToUser[$row['roomID']] = $row;
}
}
return $this->roomToUser;
}
/**
* Returns an array of Rooms this user is part of.
*
* @return \chat\data\room\Room[]
*/
public function getRooms($skipCache = false)
{
return \array_map(static function ($assoc) {
return RoomCache::getInstance()->getRoom($assoc['roomID']);
}, \array_filter($this->getRoomAssociations($skipCache), static function ($assoc) {
return $assoc['active'] === 1;
}));
}
/**
* Returns whether the user is in the given room.
*/
public function isInRoom(Room $room, $skipCache = false): bool
{
$assoc = $this->getRoomAssociations($skipCache);
if (!isset($assoc[$room->roomID])) {
return false;
}
return $assoc[$room->roomID]['active'] === 1;
}
/**
* Returns (userID, roomID, sessionID) triples where the client died.
*
* @return mixed[][]
*/
public static function getDeadSessions()
{
$sql = "SELECT userID,
roomID,
sessionID
FROM chat1_session
WHERE lastRequest < ?";
$statement = WCF::getDB()->prepare($sql);
$statement->execute([
TIME_NOW - 60 * 3,
]);
return $statement->fetchAll(\PDO::FETCH_ASSOC);
}
/**
* @inheritDoc
*/
public function jsonSerialize()
{
return [
'userID' => $this->userID,
'username' => $this->username,
'link' => $this->getLink(),
];
}
}