flash/flash.moe
flash/flash.moe
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity
flash.moe/public/chat/lib/class/AJAXChat.php

3491 lines
99 KiB
PHP
Raw Normal View History

import live siht
2020-08-20 00:02:37 +00:00
<?php
/*
* @package AJAX_Chat
* @author Sebastian Tschan
* @copyright (c) Sebastian Tschan
* @license GNU Affero General Public License
* @link https://blueimp.net/ajax/
*/
// Ajax Chat backend logic:
class AJAXChat {
var $db;
var $_config;
var $_requestVars;
var $_infoMessages;
var $_channels;
var $_allChannels;
var $_view;
var $_lang;
var $_invitations;
var $_customVars;
var $_sessionNew;
var $_onlineUsersData;
var $_bannedUsersData;
function __construct() {
// Initialize configuration settings:
$this->initConfig();
// Initialize the DataBase connection:
$this->initDataBaseConnection();
// Initialize request variables:
$this->initRequestVars();
// Initialize the chat session:
$this->initSession();
// Handle the browser request and send the response content:
$this->handleRequest();
}
function initConfig() {
$config = null;
if(!include(AJAX_CHAT_PATH.'lib/config.php')) {
print('<strong>Error:</strong> Configuration file could not be loaded.');
exit;
}
$this->_config = &$config;
// Initialize custom configuration settings:
$this->initCustomConfig();
}
function initRequestVars() {
$this->_requestVars = array();
$this->_requestVars['ajax'] = isset($_REQUEST['ajax']) ? true : false;
$this->_requestVars['userID'] = isset($_REQUEST['userID']) ? (int)$_REQUEST['userID'] : null;
$this->_requestVars['userName'] = isset($_REQUEST['userName']) ? $_REQUEST['userName'] : null;
$this->_requestVars['channelID'] = isset($_REQUEST['channelID']) ? (int)$_REQUEST['channelID'] : null;
$this->_requestVars['channelName'] = isset($_REQUEST['channelName']) ? $_REQUEST['channelName'] : null;
$this->_requestVars['text'] = isset($_POST['text']) ? $_POST['text'] : null;
$this->_requestVars['lastID'] = isset($_REQUEST['lastID']) ? (int)$_REQUEST['lastID'] : 0;
$this->_requestVars['login'] = isset($_REQUEST['login']) ? true : false;
$this->_requestVars['logout'] = isset($_POST['logout']) ? true : false;
$this->_requestVars['password'] = isset($_REQUEST['password']) ? $_REQUEST['password'] : null;
$this->_requestVars['view'] = isset($_REQUEST['view']) ? $_REQUEST['view'] : null;
$this->_requestVars['year'] = isset($_REQUEST['year']) ? (int)$_REQUEST['year'] : null;
$this->_requestVars['month'] = isset($_REQUEST['month']) ? (int)$_REQUEST['month'] : null;
$this->_requestVars['day'] = isset($_REQUEST['day']) ? (int)$_REQUEST['day'] : null;
$this->_requestVars['hour'] = isset($_REQUEST['hour']) ? (int)$_REQUEST['hour'] : null;
$this->_requestVars['search'] = isset($_REQUEST['search']) ? $_REQUEST['search'] : null;
$this->_requestVars['shoutbox'] = isset($_REQUEST['shoutbox']) ? true : false;
$this->_requestVars['getInfos'] = isset($_REQUEST['getInfos']) ? $_REQUEST['getInfos'] : null;
$this->_requestVars['lang'] = isset($_REQUEST['lang']) ? $_REQUEST['lang'] : null;
$this->_requestVars['delete'] = isset($_REQUEST['delete']) ? (int)$_REQUEST['delete'] : null;
// Initialize custom request variables:
$this->initCustomRequestVars();
// Remove slashes which have been added to user input strings if magic_quotes_gpc is On:
/*if(get_magic_quotes_gpc()) {
// It is safe to remove the slashes as we escape user data ourself
array_walk(
$this->_requestVars,
create_function(
'&$value, $key',
'if(is_string($value)) $value = stripslashes($value);'
)
);
}*/
}
function initDataBaseConnection() {
// Create a new database object:
$this->db = new AJAXChatDataBase(
$this->_config['dbConnection']
);
// Use a new database connection if no existing is given:
if(!$this->_config['dbConnection']['link']) {
// Connect to the database server:
$this->db->connect($this->_config['dbConnection']);
if($this->db->error()) {
echo $this->db->getError();
die();
}
// Select the database:
$this->db->select($this->_config['dbConnection']['name']);
if($this->db->error()) {
echo $this->db->getError();
die();
}
}
// Unset the dbConnection array for safety purposes:
unset($this->_config['dbConnection']);
}
function getDataBaseTable($table) {
return ($this->db->getName() ? $this->db->getName().'.'.$this->getConfig('dbTableNames',$table) : $this->getConfig('dbTableNames',$table));
}
function initSession() {
// Start the PHP session (if not already started):
$this->startSession();
if($this->isLoggedIn()) {
// Logout if we receive a logout request, the chat has been closed or the userID could not be revalidated:
if($this->getRequestVar('logout') || !$this->isChatOpen() || !$this->revalidateUserID()) {
$this->logout();
return;
}
// Logout if the Session IP is not the same when logged in and ipCheck is enabled:
if($this->getConfig('ipCheck') && ($this->getSessionIP() === null || $this->getSessionIP() != $_SERVER['REMOTE_ADDR'])) {
$this->logout('IP');
return;
}
} else if(
// Login if auto-login enabled or a login, userName or shoutbox parameter is given:
$this->getConfig('forceAutoLogin') ||
$this->getRequestVar('login') ||
$this->getRequestVar('userName') ||
$this->getRequestVar('shoutbox')
) {
$this->login();
}
// Initialize the view:
$this->initView();
if($this->getView() == 'chat') {
$this->initChatViewSession();
} else if($this->getView() == 'logs') {
$this->initLogsViewSession();
}
if(!$this->getRequestVar('ajax') && !headers_sent()) {
// Set style cookie:
$this->setStyle();
// Set langCode cookie:
$this->setLangCodeCookie();
}
$this->initCustomSession();
}
function initLogsViewSession() {
if($this->getConfig('socketServerEnabled')) {
if(!$this->getSessionVar('logsViewSocketAuthenticated')) {
$this->updateLogsViewSocketAuthentication();
$this->setSessionVar('logsViewSocketAuthenticated', true);
}
}
}
function updateLogsViewSocketAuthentication() {
if($this->getUserRole() != AJAX_CHAT_ADMIN) {
$channels = array();
foreach($this->getChannels() as $channel) {
if($this->getConfig('logsUserAccessChannelList') && !in_array($channel, $this->getConfig('logsUserAccessChannelList'))) {
continue;
}
array_push($channels, $channel);
}
array_push($channels, $this->getPrivateMessageID());
array_push($channels, $this->getPrivateChannelID());
} else {
// The channelID "ALL" authenticates for all channels:
$channels = array('ALL');
}
$this->updateSocketAuthentication(
$this->getUserID(),
$this->getSocketRegistrationID(),
$channels
);
}
function initChatViewSession() {
// If channel is not null we are logged in to the chat view:
if($this->getChannel() !== null) {
// Check if the current user has been logged out due to inactivity:
if(!$this->isUserOnline()) {
$this->logout();
return;
}
if($this->getRequestVar('ajax')) {
$this->initChannel();
$this->updateOnlineStatus();
$this->checkAndRemoveInactive();
}
} else {
if($this->getRequestVar('ajax')) {
// Set channel, insert login messages and add to online list on first ajax request in chat view:
$this->chatViewLogin();
}
}
}
function isChatOpen() {
if($this->getUserRole() == AJAX_CHAT_ADMIN)
return true;
if($this->getConfig('chatClosed'))
return false;
$time = time();
if($this->getConfig('timeZoneOffset') !== null) {
// Subtract the server timezone offset and add the config timezone offset:
$time -= date('Z', $time);
$time += $this->getConfig('timeZoneOffset');
}
// Check the opening hours:
if($this->getConfig('openingHour') < $this->getConfig('closingHour'))
{
if(($this->getConfig('openingHour') > date('G', $time)) || ($this->getConfig('closingHour') <= date('G', $time)))
return false;
}
else
{
if(($this->getConfig('openingHour') > date('G', $time)) && ($this->getConfig('closingHour') <= date('G', $time)))
return false;
}
// Check the opening weekdays:
if(!in_array(date('w', $time), $this->getConfig('openingWeekDays')))
return false;
return true;
}
function handleRequest() {
if($this->getRequestVar('ajax')) {
if($this->isLoggedIn()) {
// Parse info requests (for current userName, etc.):
$this->parseInfoRequests();
// Parse command requests (e.g. message deletion):
$this->parseCommandRequests();
// Parse message requests:
$this->initMessageHandling();
}
// Send chat messages and online user list in XML format:
$this->sendXMLMessages();
} else {
// Display XHTML content for non-ajax requests:
$this->sendXHTMLContent();
}
}
function parseCommandRequests() {
if($this->getRequestVar('delete') !== null) {
$this->deleteMessage($this->getRequestVar('delete'));
}
}
function parseInfoRequests() {
if($this->getRequestVar('getInfos')) {
$infoRequests = explode(',', $this->getRequestVar('getInfos'));
foreach($infoRequests as $infoRequest) {
$this->parseInfoRequest($infoRequest);
}
}
}
function parseInfoRequest($infoRequest) {
switch($infoRequest) {
case 'userID':
$this->addInfoMessage($this->getUserID(), 'userID');
break;
case 'userName':
$this->addInfoMessage($this->getUserName(), 'userName');
break;
case 'userRole':
$this->addInfoMessage($this->getUserRole(), 'userRole');
break;
case 'channelID':
$this->addInfoMessage($this->getChannel(), 'channelID');
break;
case 'channelName':
$this->addInfoMessage($this->getChannelName(), 'channelName');
break;
case 'socketRegistrationID':
$this->addInfoMessage($this->getSocketRegistrationID(), 'socketRegistrationID');
break;
default:
$this->parseCustomInfoRequest($infoRequest);
}
}
function sendXHTMLContent() {
$httpHeader = new AJAXChatHTTPHeader($this->getConfig('contentEncoding'), $this->getConfig('contentType'));
$template = new AJAXChatTemplate($this, $this->getTemplateFileName(), $httpHeader->getContentType());
// Send HTTP header:
$httpHeader->send();
// Send parsed template content:
echo $template->getParsedContent();
}
function getTemplateFileName() {
switch($this->getView()) {
case 'chat':
return AJAX_CHAT_PATH.'lib/template/loggedIn.html';
case 'logs':
return AJAX_CHAT_PATH.'lib/template/logs.html';
case 'mobile':
return AJAX_CHAT_PATH.'lib/template/mobile.html';
case 'legacy':
return AJAX_CHAT_PATH.'lib/template/legacyLogin.html';
case 'banned':
return AJAX_CHAT_PATH.'lib/template/banned.html';
case 'legacy1':
return AJAX_CHAT_PATH.'lib/template/~loggedOut.html';
case 'legacy2':
return AJAX_CHAT_PATH.'lib/template/loggedOut~.html';
case 'legacy3':
return AJAX_CHAT_PATH.'lib/template/loggedOutFA.html';
default:
return AJAX_CHAT_PATH.'lib/template/loggedOut.html';
}
}
function initView() {
$this->_view = null;
// "chat" is the default view:
$view = ($this->getRequestVar('view') === null) ? 'chat' : $this->getRequestVar('view');
if($this->hasAccessTo($view)) {
$this->_view = $view;
}
}
function getView() {
return $this->_view;
}
function hasAccessTo($view) {
if(substr($view, 0, 6) === 'legacy')
return !$this->isLoggedIn();
switch($view) {
case 'legacy':
if($this->isLoggedIn()) {
return false;
}
return true;
case 'banned':
return true;
case 'chat':
case 'mobile':
case 'teaser':
if($this->isLoggedIn()) {
return true;
}
return false;
case 'logs':
if($this->isLoggedIn() && ($this->getUserRole() == AJAX_CHAT_ADMIN || $this->getUserRole() == CMOD || $this->getUserRole() == AJAX_CHAT_MODERATOR || $this->getUserRole() == PURPLE || $this->getUserRole() == DONATOR ||
($this->getConfig('logsUserAccess') &&
($this->getUserRole() == AJAX_CHAT_USER))
)) {
return true;
}
return false;
default:
return false;
}
}
function login() {
// Retrieve valid login user data (from request variables or session data):
$userData = $this->getValidLoginUserData();
if(!$userData) {
$this->addInfoMessage('errorInvalidUser');
return false;
}
// If the chat is closed, only the admin may login:
if(!$this->isChatOpen() && $userData['userRole'] != AJAX_CHAT_ADMIN) {
$this->addInfoMessage('errorChatClosed');
return false;
}
if(!$this->getConfig('allowGuestLogins') && $userData['userRole'] == AJAX_CHAT_GUEST) {
return false;
}
// Check if userID or userName are already listed online:
if($this->isUserOnline($userData['userID']) || $this->isUserNameInUse($userData['userName'])) {
// Set the registered user inactive and remove the inactive users so the user can be logged in again:
$this->setInactive($userData['userID'], $userData['userName']);
$this->removeInactive();
}
// Check if user is banned:
if($userData['userRole'] != AJAX_CHAT_ADMIN && $this->isUserBanned($userData['userName'], $userData['userID'], $_SERVER['REMOTE_ADDR'])) {
$this->addInfoMessage('errorBanned');
return false;
}
// Check if the max number of users is logged in (not affecting moderators or admins):
if(!($userData['userRole'] == AJAX_CHAT_MODERATOR || $userData['userRole'] == PURPLE || $userData['userRole'] == AJAX_CHAT_ADMIN) && $this->isMaxUsersLoggedIn()) {
$this->addInfoMessage('errorMaxUsersLoggedIn');
return false;
}
// Use a new session id (if session has been started by the chat):
$this->regenerateSessionID();
// Log in:
$this->setUserID($userData['userID']);
$this->setUserName($userData['userName']);
$this->setLoginUserName($userData['userName']);
$this->setUserRole($userData['userRole']);
$this->setLoggedIn(true);
$this->setLoginTimeStamp(time());
// IP Security check variable:
$this->setSessionIP($_SERVER['REMOTE_ADDR']);
// The client authenticates to the socket server using a socketRegistrationID:
if($this->getConfig('socketServerEnabled')) {
$this->setSocketRegistrationID(
md5(uniqid(rand(), true))
);
}
// Add userID, userName and userRole to info messages:
$this->addInfoMessage($this->getUserID(), 'userID');
$this->addInfoMessage($this->getUserName(), 'userName');
$this->addInfoMessage($this->getUserRole(), 'userRole');
// Purge logs:
if($this->getConfig('logsPurgeLogs')) {
$this->purgeLogs();
}
// Report login to Satori:
don't
2020-11-15 01:24:13 +01:00
/*$boatcom = @fsockopen('marie.railgun.sh', 9064, $errno, $errstr, 5);
import live siht
2020-08-20 00:02:37 +00:00
if($boatcom) {
$message = sprintf('{sock}[i][url=https://flashii.net/profile.php?u=%d][b]%s[/b][/url] logged into [url=https://flash.moe/chat/]Flashii Chat Legacy[/url].[/i]', $userData['userID'], $userData['userName']);
$message = chr(0xF) . hash_hmac('sha256', $message, '13a77e7b38126647486cc0ef0b0e5f8f') . $message . chr(0xF);
fwrite($boatcom, $message);
fflush($boatcom);
fclose($boatcom);
don't
2020-11-15 01:24:13 +01:00
}*/
import live siht
2020-08-20 00:02:37 +00:00
return true;
}
function chatViewLogin() {
$this->setChannel($this->getValidRequestChannelID());
$this->addToOnlineList();
// Add channelID and channelName to info messages:
$this->addInfoMessage($this->getChannel(), 'channelID');
$this->addInfoMessage($this->getChannelName(), 'channelName');
// Login message:
$text = '/login '.$this->getUserName();
$this->insertChatBotMessage(
$this->getChannel(),
$text,
null,
1
);
}
function getValidRequestChannelID() {
$channelID = $this->getRequestVar('channelID');
$channelName = $this->getRequestVar('channelName');
// Check the given channelID, or get channelID from channelName:
if($channelID === null) {
if($channelName !== null) {
$channelID = $this->getChannelIDFromChannelName($channelName);
// channelName might need encoding conversion:
if($channelID === null) {
$channelID = $this->getChannelIDFromChannelName(
$this->trimChannelName($channelName, $this->getConfig('contentEncoding'))
);
}
}
}
// Validate the resulting channelID:
if(!$this->validateChannel($channelID)) {
if($this->getChannel() !== null) {
return $this->getChannel();
}
return $this->getConfig('defaultChannelID');
}
return $channelID;
}
function initChannel() {
$channelID = $this->getRequestVar('channelID');
$channelName = $this->getRequestVar('channelName');
if($channelID !== null) {
$this->switchChannel($this->getChannelNameFromChannelID($channelID));
} else if($channelName !== null) {
if($this->getChannelIDFromChannelName($channelName) === null) {
// channelName might need encoding conversion:
$channelName = $this->trimChannelName($channelName, $this->getConfig('contentEncoding'));
}
$this->switchChannel($channelName);
}
}
function logout($type=null) {
// Update the socket server authentication for the user:
if($this->getConfig('socketServerEnabled')) {
$this->updateSocketAuthentication($this->getUserID());
}
if($this->isUserOnline()) {
$this->chatViewLogout($type);
}
$this->setLoggedIn(false);
$this->destroySession();
// Re-initialize the view:
$this->initView();
}
function chatViewLogout($type) {
$this->removeFromOnlineList();
if($type !== null) {
$type = ' '.$type;
}
// Logout message
$text = '/logout '.$this->getUserName().$type;
$this->insertChatBotMessage(
$this->getChannel(),
$text,
null,
1
);
}
function switchChannel($channelName) {
$channelID = $this->getChannelIDFromChannelName($channelName);
if($channelID !== null && $this->getChannel() == $channelID) {
// User is already in the given channel, return:
return;
}
// Check if we have a valid channel:
if(!$this->validateChannel($channelID)) {
// Invalid channel:
$text = '/error InvalidChannelName '.$channelName;
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
$text
);
return;
}
$oldChannel = $this->getChannel();
$this->setChannel($channelID);
$this->updateOnlineList();
// Channel leave message
$text = '/channelLeave '.$this->getUserName();
$this->insertChatBotMessage(
$oldChannel,
$text,
null,
1
);
// Channel enter message
$text = '/channelEnter '.$this->getUserName();
$this->insertChatBotMessage(
$this->getChannel(),
$text,
null,
1
);
$this->addInfoMessage($channelName, 'channelSwitch');
$this->addInfoMessage($channelID, 'channelID');
$this->_requestVars['lastID'] = 0;
}
function addToOnlineList() {
$sql = 'INSERT INTO '.$this->getDataBaseTable('online').'(
userID,
userName,
userRole,
channel,
dateTime,
ip
)
VALUES (
'.$this->db->makeSafe($this->getUserID()).',
'.$this->db->makeSafe($this->getUserName()).',
'.$this->db->makeSafe($this->getUserRole()).',
'.$this->db->makeSafe($this->getChannel()).',
NOW(),
'.$this->db->makeSafe($this->ipToStorageFormat($_SERVER['REMOTE_ADDR'])).'
);';
// Create a new SQL query:
$result = $this->db->sqlQuery($sql);
// Stop if an error occurs:
if($result->error()) {
echo $result->getError();
die();
}
$this->resetOnlineUsersData();
}
function removeFromOnlineList() {
$sql = 'DELETE FROM
'.$this->getDataBaseTable('online').'
WHERE
userID = '.$this->db->makeSafe($this->getUserID()).';';
// Create a new SQL query:
$result = $this->db->sqlQuery($sql);
// Stop if an error occurs:
if($result->error()) {
echo $result->getError();
die();
}
$this->removeUserFromOnlineUsersData();
}
function updateOnlineList() {
$sql = 'UPDATE
'.$this->getDataBaseTable('online').'
SET
userName = '.$this->db->makeSafe($this->getUserName()).',
channel = '.$this->db->makeSafe($this->getChannel()).',
dateTime = NOW(),
ip = '.$this->db->makeSafe($this->ipToStorageFormat($_SERVER['REMOTE_ADDR'])).'
WHERE
userID = '.$this->db->makeSafe($this->getUserID()).';';
// Create a new SQL query:
$result = $this->db->sqlQuery($sql);
// Stop if an error occurs:
if($result->error()) {
echo $result->getError();
die();
}
$this->resetOnlineUsersData();
}
function initMessageHandling() {
// Don't handle messages if we are not in chat view:
if($this->getView() != 'chat') {
return;
}
// Check if we have been uninvited from a private or restricted channel:
if(!$this->validateChannel($this->getChannel())) {
// Switch to the default channel:
$this->switchChannel($this->getChannelNameFromChannelID($this->getConfig('defaultChannelID')));
return;
}
if($this->getRequestVar('text') !== null) {
$this->insertMessage($this->getRequestVar('text'));
}
}
function insertParsedMessage($text) {
// Replace Unicode character
$text = preg_replace("/\xEF\xBF\xBF/im", " ", $text);
/*
$gtParse = preg_replace('/\\[(?:\\/)?(\\w+)(?:=([^<>]*?))?\\]/ms', '', $text);
// Auto greentext
if(preg_match("/>(.*?)$/im", $gtParse)) {
$text = preg_replace("/>(.*?)$/im", "[color=Green]>$1[/color]", $gtParse);
}
if(preg_match("/(.*?)<$/im", $gtParse)) {
$text = preg_replace("/(.*?)<$/im", "[color=Red]$1<[/color]", $gtParse);
}*/
// Emoticon Limiting
$emoticons = array(':happy:', ':lmao:', ':angry:', ':angrier:', ':evil:', ':glare:', ':eat:', ':lol:', ':dizzy:', ':yay:', ':wtf:', ':sigh:', ':omg:', ':ouch:', ':tired:', ':kiss:', ':love:', ':sweat:', ':suspicious:', ':crying:', ':blank:', ':puke:', ':ruse:', ':meow:');
$emoticonCount = 0;
foreach($emoticons as $emoticon) {
// Increase Emoticon count
$emoticonCount += substr_count($text, $emoticon);
// If higher than 10 replace then
if($emoticonCount > 10)
$text = str_replace($emoticon, '', $text);
}
if($this->getQueryUserName() !== null && strpos($text, '/') !== 0) {
// If a queryUserName is set, sent all messages as private messages to this userName:
$text = '/msg '.$this->getQueryUserName().' '.$text;
}
if(strpos($text, '/') === 0) {
// Parse IRC-style commands:
$textParts = explode(' ', $text);
switch($textParts[0]) {
// Channel switch:
case '/join':
$this->insertParsedMessageJoin($textParts);
break;
// Logout:
case '/quit':
case '/suicide':
$this->logout();
break;
// Private message:
case '/msg':
case '/describe':
$this->insertParsedMessagePrivMsg($textParts);
break;
// Invitation:
case '/invite':
$this->insertParsedMessageInvite($textParts);
break;
// Uninvitation:
case '/uninvite':
$this->insertParsedMessageUninvite($textParts);
break;
// Private messaging:
case '/query':
$this->insertParsedMessageQuery($textParts);
break;
// Kicking offending users from the chat:
case '/kick':
$this->insertParsedMessageKick($textParts);
break;
// Listing banned users:
case '/bans':
$this->insertParsedMessageBans($textParts);
break;
// Unban user (remove from ban list):
case '/unban':
$this->insertParsedMessageUnban($textParts);
break;
// Describing actions:
case '/me':
case '/action':
$this->insertParsedMessageAction($textParts);
break;
// Listing online Users:
case '/who':
$this->insertParsedMessageWho($textParts);
break;
// Listing available channels:
case '/list':
$this->insertParsedMessageList($textParts);
break;
// Retrieving the channel of a User:
case '/whereis':
$this->insertParsedMessageWhereis($textParts);
break;
// Listing information about a User:
case '/whois':
$this->insertParsedMessageWhois($textParts);
break;
// Rolling dice:
case '/roll':
$this->insertParsedMessageRoll($textParts);
break;
// Switching userName:
case '/nick':
$this->insertParsedMessageNick($textParts);
break;
// Switching userName:
case '/saibatekuisagoodsite':
$this->insertParsedMessageChangeNick($textParts);
break;
// Custom or unknown command:
default:
if(!$this->parseCustomCommands($text, $textParts)) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error UnknownCommand '.$textParts[0]
);
}
}
} else {
// No command found, just insert the plain message:
$this->insertCustomMessage(
$this->getUserID(),
$this->getUserName(),
$this->getUserRole(),
$this->getChannel(),
$text
);
}
include_once 'satori.php';
}
function insertParsedMessageJoin($textParts) {
if(count($textParts) == 1) {
// join with no arguments is the own private channel, if allowed:
if($this->isAllowedToCreatePrivateChannel()) {
// Private channels are identified by square brackets:
$this->switchChannel($this->getChannelNameFromChannelID($this->getPrivateChannelID()));
} else {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error MissingChannelName'
);
}
} else {
$this->switchChannel($textParts[1]);
}
}
function insertParsedMessagePrivMsg($textParts) {
if($this->isAllowedToSendPrivateMessage()) {
if(count($textParts) < 3) {
if(count($textParts) == 2) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error MissingText'
);
} else {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error MissingUserName'
);
}
} else {
// Get UserID from UserName:
$toUserID = $this->getIDFromName($textParts[1]);
if($toUserID === null) {
if($this->getQueryUserName() !== null) {
// Close the current query:
$this->insertMessage('/query');
} else {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error UserNameNotFound '.$textParts[1]
);
}
} else {
// Insert /privaction command if /describe is used:
$command = ($textParts[0] == '/describe') ? '/privaction' : '/privmsg';
// Copy of private message to current User:
$this->insertCustomMessage(
$this->getUserID(),
$this->getUserName(),
$this->getUserRole(),
$this->getPrivateMessageID(),
$command.'to '.$textParts[1].' '.implode(' ', array_slice($textParts, 2))
);
// Private message to requested User:
$this->insertCustomMessage(
$this->getUserID(),
$this->getUserName(),
$this->getUserRole(),
$this->getPrivateMessageID($toUserID),
$command.' '.implode(' ', array_slice($textParts, 2))
);
}
}
} else {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error PrivateMessageNotAllowed'
);
}
}
function insertParsedMessageInvite($textParts) {
if($this->getChannel() == $this->getPrivateChannelID() || in_array($this->getChannel(), $this->getChannels())) {
if(count($textParts) == 1) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error MissingUserName'
);
} else {
$toUserID = $this->getIDFromName($textParts[1]);
if($toUserID === null) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error UserNameNotFound '.$textParts[1]
);
} else {
// Add the invitation to the database:
$this->addInvitation($toUserID);
$invitationChannelName = $this->getChannelNameFromChannelID($this->getChannel());
// Copy of invitation to current User:
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/inviteto '.$textParts[1].' '.$invitationChannelName
);
// Invitation to requested User:
$this->insertChatBotMessage(
$this->getPrivateMessageID($toUserID),
'/invite '.$this->getUserName().' '.$invitationChannelName
);
}
}
} else {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error InviteNotAllowed'
);
}
}
function insertParsedMessageUninvite($textParts) {
if($this->getChannel() == $this->getPrivateChannelID() || in_array($this->getChannel(), $this->getChannels())) {
if(count($textParts) == 1) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error MissingUserName'
);
} else {
$toUserID = $this->getIDFromName($textParts[1]);
if($toUserID === null) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error UserNameNotFound '.$textParts[1]
);
} else {
// Remove the invitation from the database:
$this->removeInvitation($toUserID);
$invitationChannelName = $this->getChannelNameFromChannelID($this->getChannel());
// Copy of uninvitation to current User:
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/uninviteto '.$textParts[1].' '.$invitationChannelName
);
// Uninvitation to requested User:
$this->insertChatBotMessage(
$this->getPrivateMessageID($toUserID),
'/uninvite '.$this->getUserName().' '.$invitationChannelName
);
}
}
} else {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error UninviteNotAllowed'
);
}
}
function insertParsedMessageQuery($textParts) {
if($this->isAllowedToSendPrivateMessage()) {
if(count($textParts) == 1) {
if($this->getQueryUserName() !== null) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/queryClose '.$this->getQueryUserName()
);
// Close the current query:
$this->setQueryUserName(null);
} else {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error NoOpenQuery'
);
}
} else {
if($this->getIDFromName($textParts[1]) === null) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error UserNameNotFound '.$textParts[1]
);
} else {
if($this->getQueryUserName() !== null) {
// Close the current query:
$this->insertMessage('/query');
}
// Open a query to the requested user:
$this->setQueryUserName($textParts[1]);
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/queryOpen '.$textParts[1]
);
}
}
} else {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error PrivateMessageNotAllowed'
);
}
}
function insertParsedMessageKick($textParts) {
// Only moderators/admins may kick users:
if($this->getUserRole() == AJAX_CHAT_ADMIN || $this->getUserRole() == AJAX_CHAT_MODERATOR || $this->getUserRole() == CMOD || $this->getUserID() == 11) {
if(count($textParts) == 1) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error MissingUserName'
);
} else {
// Get UserID from UserName:
$kickUserID = $this->getIDFromName($textParts[1]);
if($kickUserID === null) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error UserNameNotFound '.$textParts[1]
);
} else {
// Check the role of the user to kick:
$kickUserRole = $this->getRoleFromID($kickUserID);
if(
$kickUserRole == AJAX_CHAT_ADMIN ||
(
(
$kickUserID == 11
&&
$this->getUserRole() != AJAX_CHAT_ADMIN
&&
$this->getUserID() != 11
)
||
(
$kickUserRole == CMOD
&&
$this->getUserRole() != AJAX_CHAT_MODERATOR
&&
$this->getUserRole() != PURPLE
&&
$this->getUserRole() != AJAX_CHAT_ADMIN
&&
$this->getUserID() != 11
)
||
(
$kickUserRole == AJAX_CHAT_MODERATOR
&&
$this->getUserRole() != PURPLE
&&
$this->getUserRole() != AJAX_CHAT_ADMIN
&&
$this->getUserID() != 11
)
)
) {
// Admins and moderators may not be kicked:
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error KickNotAllowed '.$textParts[1]
);
} else {
// Kick user and insert message:
$channel = $this->getChannelFromID($kickUserID);
$banMinutes = (count($textParts) > 2) ? $textParts[2] : null;
$this->kickUser($textParts[1], $banMinutes, $kickUserID);
// If no channel found, user logged out before he could be kicked
if($channel !== null) {
$this->insertChatBotMessage(
$channel,
'/kick '.$textParts[1],
null,
1
);
// Send a copy of the message to the current user, if not in the channel:
if($channel != $this->getChannel()) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/kick '.$textParts[1],
null,
1
);
}
}
}
}
}
} else {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error CommandNotAllowed '.$textParts[0]
);
}
}
function insertParsedMessageBans($textParts) {
// Only moderators/admins may see the list of banned users:
if($this->getUserRole() == AJAX_CHAT_ADMIN || $this->getUserRole() == AJAX_CHAT_MODERATOR || $this->getUserRole() == CMOD) {
$this->removeExpiredBans();
$bannedUsers = $this->getBannedUsers();
if(count($bannedUsers) > 0) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/bans '.implode(' ', $bannedUsers)
);
} else {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/bansEmpty -'
);
}
} else {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error CommandNotAllowed '.$textParts[0]
);
}
}
function insertParsedMessageUnban($textParts) {
// Only moderators/admins may unban users:
if($this->getUserRole() == AJAX_CHAT_ADMIN || $this->getUserRole() == AJAX_CHAT_MODERATOR || $this->getUserRole() == CMOD) {
$this->removeExpiredBans();
if(count($textParts) == 1) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error MissingUserName'
);
} else {
if(!in_array($textParts[1], $this->getBannedUsers())) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error UserNameNotFound '.$textParts[1]
);
} else {
// Unban user and insert message:
$this->unbanUser($textParts[1]);
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/unban '.$textParts[1]
);
}
}
} else {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error CommandNotAllowed '.$textParts[0]
);
}
}
function insertParsedMessageAction($textParts) {
if(count($textParts) == 1) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error MissingText'
);
} else {
if($this->getQueryUserName() !== null) {
// If we are in query mode, sent the action to the query user:
$this->insertMessage('/describe '.$this->getQueryUserName().' '.implode(' ', array_slice($textParts, 1)));
} else {
$this->insertCustomMessage(
$this->getUserID(),
$this->getUserName(),
$this->getUserRole(),
$this->getChannel(),
implode(' ', $textParts)
);
}
}
}
function insertParsedMessageWho($textParts) {
if(count($textParts) == 1) {
if($this->isAllowedToListHiddenUsers()) {
// List online users from any channel:
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/who '.implode(' ', $this->getOnlineUsers())
);
} else {
// Get online users for all accessible channels:
$channels = $this->getChannels();
// Add the own private channel if allowed:
if($this->isAllowedToCreatePrivateChannel()) {
array_push($channels, $this->getPrivateChannelID());
}
// Add the invitation channels:
foreach($this->getInvitations() as $channelID) {
if(!in_array($channelID, $channels)) {
array_push($channels, $channelID);
}
}
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/who '.implode(' ', $this->getOnlineUsers($channels))
);
}
} else {
$channelName = $textParts[1];
$channelID = $this->getChannelIDFromChannelName($channelName);
if(!$this->validateChannel($channelID)) {
// Invalid channel:
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error InvalidChannelName '.$channelName
);
} else {
// Get online users for the given channel:
$onlineUsers = $this->getOnlineUsers(array($channelID));
if(count($onlineUsers) > 0) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/whoChannel '.$channelName.' '.implode(' ', $onlineUsers)
);
} else {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/whoEmpty -'
);
}
}
}
}
function insertParsedMessageList($textParts) {
// Get the names of all accessible channels:
$channelNames = $this->getChannelNames();
// Add the own private channel, if allowed:
if($this->isAllowedToCreatePrivateChannel()) {
array_push($channelNames, $this->getPrivateChannelName());
}
// Add the invitation channels:
foreach($this->getInvitations() as $channelID) {
$channelName = $this->getChannelNameFromChannelID($channelID);
if($channelName !== null && !in_array($channelName, $channelNames)) {
array_push($channelNames, $channelName);
}
}
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/list '.implode(' ', $channelNames)
);
}
function insertParsedMessageWhereis($textParts) {
if(count($textParts) == 1) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error MissingUserName'
);
} else {
// Get UserID from UserName:
$whereisUserID = $this->getIDFromName($textParts[1]);
if($whereisUserID === null) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error UserNameNotFound '.$textParts[1]
);
} else {
$channelID = $this->getChannelFromID($whereisUserID);
if($this->validateChannel($channelID)) {
$channelName = $this->getChannelNameFromChannelID($channelID);
} else {
$channelName = null;
}
if($channelName === null) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error UserNameNotFound '.$textParts[1]
);
} else {
// List user information:
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/whereis '.$textParts[1].' '.$channelName
);
}
}
}
}
function insertParsedMessageWhois($textParts) {
// Only moderators/admins:
if($this->getUserRole() == AJAX_CHAT_ADMIN || $this->getUserRole() == AJAX_CHAT_MODERATOR || $this->getUserRole() == PURPLE || $this->getUserRole() == CMOD) {
// if($this->getUserRole() == AJAX_CHAT_ADMIN) {
if(count($textParts) == 1) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error MissingUserName'
);
} else {
// Get UserID from UserName:
$whoisUserID = $this->getIDFromName($textParts[1]);
if($whoisUserID === null) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error UserNameNotFound '.$textParts[1]
);
} else {
// List user information:
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/whois '.$textParts[1].' '.$this->getIPFromID($whoisUserID)
);
}
}
} else {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error CommandNotAllowed '.$textParts[0]
);
}
}
function insertParsedMessageRoll($textParts) {
if(count($textParts) == 1) {
// default is one d6:
$text = '/roll '.$this->getUserName().' 1d6 '.$this->rollDice(6);
} else {
$diceParts = explode('d', $textParts[1]);
if(count($diceParts) == 2) {
$number = (int)$diceParts[0];
$sides = (int)$diceParts[1];
// Dice number must be an integer between 1 and 100, else roll only one:
$number = ($number > -1 && $number < 100) ? $number : 1;
// Sides must be an integer between 1 and 100, else take 6:
$sides = ($sides > -1 && $sides < 100) ? $sides : 6;
$text = '/roll '.$this->getUserName().' '.$number.'d'.$sides.' ';
for($i=0; $i<$number; $i++) {
if($i != 0)
$text .= ',';
switch($this->getUserID()) { // snowflake
case 3://303:
$text .= str_shuffle('bird');
break;
case 0://230:
$text .= str_shuffle('portugal');
break;
case 15://21:
$text .= str_shuffle('divorce');
break;
case 2://8:
$text .= str_shuffle('mewow');
break;
default:
$text .= $this->rollDice($sides);
}
}
} else {
// if dice syntax is invalid, roll one d6:
$text = '/roll '.$this->getUserName().' 1d6 '.$this->rollDice(6);
}
}
$this->insertChatBotMessage(
$this->getChannel(),
$text
);
}
function insertParsedMessageNick($textParts) {
if($this->getUserRole() == AJAX_CHAT_ADMIN || $this->getUserRole() == AJAX_CHAT_MODERATOR || $this->getUserRole() == PURPLE || $this->getUserRole() == CMOD || $this->getUserRole() == BOTS || $this->getUserRole() == DONATOR) {
if(!$this->getConfig('allowNickChange') ||
(!$this->getConfig('allowGuestUserName') && $this->getUserRole() == AJAX_CHAT_GUEST)) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error CommandNotAllowed '.$textParts[0]
);
} elseif(count($textParts) == 1) {
$oldUserName = $this->getUserName();
$newUserName = $this->getLoginUserName();
if($oldUserName != $newUserName) {
$this->setUserName($newUserName);
$this->updateOnlineList();
// Add info message to update the client-side stored userName:
$this->addInfoMessage($this->getUserName(), 'userName');
$this->insertChatBotMessage(
$this->getChannel(),
'/nick '.$oldUserName.' '.$newUserName,
null,
2
);
} else {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error MissingUserName'
);
}
} else {
$newUserName = implode(' ', array_slice($textParts, 1));
if($newUserName == $this->getLoginUserName()) {
// Allow the user to regain the original login userName:
$prefix = '';
$suffix = '';
} else if($this->getUserRole() == AJAX_CHAT_GUEST) {
$prefix = $this->getConfig('guestUserPrefix');
$suffix = $this->getConfig('guestUserSuffix');
} else {
$prefix = $this->getConfig('changedNickPrefix');
$suffix = $this->getConfig('changedNickSuffix');
}
$maxLength = $this->getConfig('userNameMaxLength')
- $this->stringLength($prefix)
- $this->stringLength($suffix);
$newUserName = $this->trimString($newUserName, 'UTF-8', $maxLength, true);
if(!$newUserName) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error InvalidUserName'
);
} else {
$newUserName = $prefix.$newUserName.$suffix;
if($this->isUserNameInUse($newUserName)) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error UserNameInUse'
);
} else {
$oldUserName = $this->getUserName();
$this->setUserName($newUserName);
$this->updateOnlineList();
// Add info message to update the client-side stored userName:
$this->addInfoMessage($this->getUserName(), 'userName');
$this->insertChatBotMessage(
$this->getChannel(),
'/nick '.$oldUserName.' '.$newUserName,
null,
2
);
}
}
}
} else {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error CommandNotAllowed '.$textParts[0]
);
}
}
function insertParsedMessageChangeNick($textParts) {
if($this->getUserRole() == AJAX_CHAT_ADMIN || $this->getUserRole() == AJAX_CHAT_MODERATOR) {
if(count($textParts) == 1) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error MissingUserName'
);
} else {
$newUserName = implode(' ', array_slice($textParts, 1));
$oldUserName = $this->getUserName();
$this->setUserName($newUserName);
$this->updateOnlineList();
$this->addInfoMessage($this->getUserName(), 'userName');
}
}
}
function insertMessage($text) {
if(!$this->isAllowedToWriteMessage())
return;
if(!$this->floodControl())
return;
$text = $this->trimMessageText($text);
if($text == '')
return;
if(!$this->onNewMessage($text))
return;
$text = $this->replaceCustomText($text);
$this->insertParsedMessage($text);
}
function deleteMessage($messageID) {
// Retrieve the channel of the given message:
$sql = 'SELECT
channel
FROM
'.$this->getDataBaseTable('messages').'
WHERE
id='.$this->db->makeSafe($messageID).';';
// Create a new SQL query:
$result = $this->db->sqlQuery($sql);
// Stop if an error occurs:
if($result->error()) {
echo $result->getError();
die();
}
$row = $result->fetch();
if($row['channel'] !== null) {
$channel = $row['channel'];
if($this->getUserRole() == AJAX_CHAT_ADMIN) {
$condition = '';
} else if($this->getUserRole() == CMOD || $this->getUserRole() == PURPLE) {
$condition = ' AND
NOT (userRole='.$this->db->makeSafe(AJAX_CHAT_MODERATOR).')
AND
NOT (userRole='.$this->db->makeSafe(AJAX_CHAT_ADMIN).')
AND
NOT (userRole='.$this->db->makeSafe(AJAX_CHAT_CHATBOT).')';
} else if($this->getUserRole() == AJAX_CHAT_MODERATOR) {
$condition = ' AND
NOT (userRole='.$this->db->makeSafe(AJAX_CHAT_ADMIN).')
AND
NOT (userRole='.$this->db->makeSafe(AJAX_CHAT_CHATBOT).')';
} else if($this->getUserRole() == AJAX_CHAT_USER && $this->getConfig('allowUserMessageDelete')) {
$condition = 'AND
(
userID='.$this->db->makeSafe($this->getUserID()).'
OR
(
channel = '.$this->db->makeSafe($this->getPrivateMessageID()).'
OR
channel = '.$this->db->makeSafe($this->getPrivateChannelID()).'
)
AND
NOT (userRole='.$this->db->makeSafe(AJAX_CHAT_ADMIN).')
AND
NOT (userRole='.$this->db->makeSafe(AJAX_CHAT_CHATBOT).')
)';
} else {
return false;
}
// Remove given message from the database:
$sql = 'DELETE FROM
'.$this->getDataBaseTable('messages').'
WHERE
id='.$this->db->makeSafe($messageID).'
'.$condition.';';
// Create a new SQL query:
$result = $this->db->sqlQuery($sql);
// Stop if an error occurs:
if($result->error()) {
echo $result->getError();
die();
}
if($result->affectedRows() == 1) {
// Insert a deletion command to remove the message from the clients chatlists:
$this->insertChatBotMessage($channel, '/delete '.$messageID);
return true;
}
}
return false;
}
function floodControl() {
// Admins can do whatever the fuck they want:
if($this->getUserRole() == AJAX_CHAT_ADMIN || $this->getUserRole() == AJAX_CHAT_MODERATOR || $this->getUserID() == 11) {
return true;
}
$time = time();
// Check the time of the last inserted message:
if($this->getInsertedMessagesRateTimeStamp()+60 < $time) {
$this->setInsertedMessagesRateTimeStamp($time);
$this->setInsertedMessagesRate(1);
} else {
// Increase the inserted messages rate:
$rate = $this->getInsertedMessagesRate()+1;
$this->setInsertedMessagesRate($rate);
// Check if message rate is too high:
if($rate > $this->getConfig('maxMessageRate')) {
$this->insertChatBotMessage(
$this->getPrivateMessageID(),
'/error MaxMessageRate'
);
$this->kickUser($this->getUserName(), 10, $this->getUserID());
$this->insertChatBotMessage($this->getChannel(), "[i][b]".$this->getUsername()."[/b] exceeded the message limit and will now be kicked for 10 minutes.[/i]");
$this->insertChatBotMessage($this->getChannel(), "/kick ". $this->getUsername());
// Return false so the message is not inserted:
return false;
}
}
return true;
}
function isAllowedToWriteMessage() {
if($this->getUserRole() != AJAX_CHAT_GUEST)
return true;
if($this->getConfig('allowGuestWrite'))
return true;
return false;
}
function insertChatBotMessage($channelID, $messageText, $ip=null, $mode=0) {
$this->insertCustomMessage(
$this->getConfig('chatBotID'),
$this->getConfig('chatBotName'),
AJAX_CHAT_CHATBOT,
$channelID,
$messageText,
$ip,
$mode
);
}
function insertCustomMessage($userID, $userName, $userRole, $channelID, $text, $ip=null, $mode=0) {
// The $mode parameter is used for socket updates:
// 0 = normal messages
// 1 = channel messages (e.g. login/logout, channel enter/leave, kick)
// 2 = messages with online user updates (nick)
$ip = $ip ? $ip : $_SERVER['REMOTE_ADDR'];
$sql = 'INSERT INTO '.$this->getDataBaseTable('messages').'(
userID,
userName,
userRole,
channel,
dateTime,
ip,
text
)
VALUES (
'.$this->db->makeSafe($userID).',
'.$this->db->makeSafe($userName).',
'.$this->db->makeSafe($userRole).',
'.$this->db->makeSafe($channelID).',
NOW(),
'.$this->db->makeSafe($this->ipToStorageFormat($ip)).',
'.$this->db->makeSafe($text).'
);';
// Create a new SQL query:
$result = $this->db->sqlQuery($sql);
// Stop if an error occurs:
if($result->error()) {
echo $result->getError();
die();
}
if($this->getConfig('socketServerEnabled')) {
$this->sendSocketMessage(
$this->getSocketBroadcastMessage(
$this->db->getLastInsertedID(),
time(),
$userID,
$userName,
$userRole,
$channelID,
$text,
$mode
)
);
}
}
function getSocketBroadcastMessage(
$messageID,
$timeStamp,
$userID,
$userName,
$userRole,
$channelID,
$text,
$mode
) {
// The $mode parameter:
// 0 = normal messages
// 1 = channel messages (e.g. login/logout, channel enter/leave, kick)
// 2 = messages with online user updates (nick)
// Get the message XML content:
$xml = '<root chatID="'.$this->getConfig('socketServerChatID').'" channelID="'.$channelID.'" mode="'.$mode.'">';
if($mode) {
// Add the list of online users if the user list has been updated ($mode > 0):
$xml .= $this->getChatViewOnlineUsersXML(array($channelID));
}
if($mode != 1 || $this->getConfig('showChannelMessages')) {
$xml .= '<messages>';
$xml .= $this->getChatViewMessageXML(
$messageID,
$timeStamp,
$userID,
$userName,
$userRole,
$channelID,
$text
);
$xml .= '</messages>';
}
$xml .= '</root>';
return $xml;
}
function sendSocketMessage($message) {
// Open a TCP socket connection to the socket server:
if($socket = @socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) {
if(@socket_connect($socket, $this->getConfig('socketServerIP'), $this->getConfig('socketServerPort'))) {
// Append a null-byte to the string as EOL (End Of Line) character
// which is required by Flash XML socket communication:
$message .= "\0";
@socket_write(
$socket,
$message,
strlen($message) // Using strlen to count the bytes instead of the number of UTF-8 characters
);
}
@socket_close($socket);
}
}
function updateSocketAuthentication($userID, $socketRegistrationID=null, $channels=null) {
// If no $socketRegistrationID or no $channels are given the authentication is removed for the given user:
$authentication = '<authenticate chatID="'.$this->getConfig('socketServerChatID').'" userID="'.$userID.'" regID="'.$socketRegistrationID.'">';
if($channels) {
foreach($channels as $channelID) {
$authentication .= '<channel id="'.$channelID.'"/>';
}
}
$authentication .= '</authenticate>';
$this->sendSocketMessage($authentication);
}
function setSocketRegistrationID($value) {
$this->setSessionVar('SocketRegistrationID', $value);
}
function getSocketRegistrationID() {
return $this->getSessionVar('SocketRegistrationID');
}
function rollDice($sides) {
// seed with microseconds since last "whole" second:
//mt_srand((double)microtime()*1000000);
return mt_rand(1, $sides);
}
function kickUser($userName, $banMinutes=null, $userID=null) {
if($userID === null) {
$userID = $this->getIDFromName($userName);
}
if($userID === null) {
return;
}
$banMinutes = ($banMinutes !== null) ? $banMinutes : $this->getConfig('defaultBanTime');
if($banMinutes) {
// Ban User for the given time in minutes:
$this->banUser($userName, $banMinutes, $userID);
}
// Remove given User from online list:
$sql = 'DELETE FROM
'.$this->getDataBaseTable('online').'
WHERE
userID = '.$this->db->makeSafe($userID).';';
// Create a new SQL query:
$result = $this->db->sqlQuery($sql);
// Stop if an error occurs:
if($result->error()) {
echo $result->getError();
die();
}
// Update the socket server authentication for the kicked user:
if($this->getConfig('socketServerEnabled')) {
$this->updateSocketAuthentication($userID);
}
$this->removeUserFromOnlineUsersData($userID);
}
function getBannedUsersData($key=null, $value=null) {
if($this->_bannedUsersData === null) {
$this->_bannedUsersData = array();
$sql = 'SELECT
userID,
userName,
ip
FROM
'.$this->getDataBaseTable('bans').'
WHERE
NOW() < dateTime;';
// Create a new SQL query:
$result = $this->db->sqlQuery($sql);
// Stop if an error occurs:
if($result->error()) {
echo $result->getError();
die();
}
while($row = $result->fetch()) {
$row['ip'] = $this->ipFromStorageFormat($row['ip']);
array_push($this->_bannedUsersData, $row);
}
$result->free();
}
if($key) {
$bannedUsersData = array();
foreach($this->_bannedUsersData as $bannedUserData) {
if(!isset($bannedUserData[$key])) {
return $bannedUsersData;
}
if($value) {
if($bannedUserData[$key] == $value) {
array_push($bannedUsersData, $bannedUserData);
} else {
continue;
}
} else {
array_push($bannedUsersData, $bannedUserData[$key]);
}
}
return $bannedUsersData;
}
return $this->_bannedUsersData;
}
function getBannedUsers() {
return $this->getBannedUsersData('userName');
}
function banUser($userName, $banMinutes=null, $userID=null) {
if($userID === null) {
$userID = $this->getIDFromName($userName);
}
$ip = $this->getIPFromID($userID);
if(!$ip || $userID === null) {
return;
}
// Remove expired bans:
$this->removeExpiredBans();
$banMinutes = (int)$banMinutes;
if(!$banMinutes) {
// If banMinutes is not a valid integer, use the defaultBanTime:
$banMinutes = $this->getConfig('defaultBanTime');
}
$sql = 'INSERT INTO '.$this->getDataBaseTable('bans').'(
userID,
userName,
dateTime,
ip
)
VALUES (
'.$this->db->makeSafe($userID).',
'.$this->db->makeSafe($userName).',
DATE_ADD(NOW(), interval '.$this->db->makeSafe($banMinutes).' MINUTE),
'.$this->db->makeSafe($this->ipToStorageFormat($ip)).'
);';
// Create a new SQL query:
$result = $this->db->sqlQuery($sql);
// Stop if an error occurs:
if($result->error()) {
echo $result->getError();
die();
}
}
function unbanUser($userName) {
$sql = 'DELETE FROM
'.$this->getDataBaseTable('bans').'
WHERE
userName = '.$this->db->makeSafe($userName).';';
// Create a new SQL query:
$result = $this->db->sqlQuery($sql);
// Stop if an error occurs:
if($result->error()) {
echo $result->getError();
die();
}
}
function removeExpiredBans() {
$sql = 'DELETE FROM
'.$this->getDataBaseTable('bans').'
WHERE
dateTime < NOW();';
// Create a new SQL query:
$result = $this->db->sqlQuery($sql);
// Stop if an error occurs:
if($result->error()) {
echo $result->getError();
die();
}
}
function setInactive($userID, $userName=null) {
$condition = 'userID='.$this->db->makeSafe($userID);
if($userName !== null) {
$condition .= ' OR userName='.$this->db->makeSafe($userName);
}
$sql = 'UPDATE
'.$this->getDataBaseTable('online').'
SET
dateTime = DATE_SUB(NOW(), interval '.(intval($this->getConfig('inactiveTimeout'))+1).' MINUTE)
WHERE
'.$condition.';';
// Create a new SQL query:
$result = $this->db->sqlQuery($sql);
// Stop if an error occurs:
if($result->error()) {
echo $result->getError();
die();
}
$this->resetOnlineUsersData();
}
function removeInactive() {
$sql = 'SELECT
userID,
userName,
channel
FROM
'.$this->getDataBaseTable('online').'
WHERE
NOW() > DATE_ADD(dateTime, interval '.$this->getConfig('inactiveTimeout').' MINUTE);';
// Create a new SQL query:
$result = $this->db->sqlQuery($sql);
// Stop if an error occurs:
if($result->error()) {
echo $result->getError();
die();
}
if($result->numRows() > 0) {
$condition = '';
while($row = $result->fetch()) {
if(!empty($condition))
$condition .= ' OR ';
// Add userID to condition for removal:
$condition .= 'userID='.$this->db->makeSafe($row['userID']);
// Update the socket server authentication for the kicked user:
if($this->getConfig('socketServerEnabled')) {
$this->updateSocketAuthentication($row['userID']);
}
$this->removeUserFromOnlineUsersData($row['userID']);
// Insert logout timeout message:
$text = '/logout '.$row['userName'].' Timeout';
$this->insertChatBotMessage(
$row['channel'],
$text,
null,
1
);
}
$result->free();
$sql = 'DELETE FROM
'.$this->getDataBaseTable('online').'
WHERE
'.$condition.';';
// Create a new SQL query:
$result = $this->db->sqlQuery($sql);
// Stop if an error occurs:
if($result->error()) {
echo $result->getError();
die();
}
}
}
function updateOnlineStatus() {
// Update online status every 50 seconds (this allows update requests to be in time):
if(!$this->getStatusUpdateTimeStamp() || ((time() - $this->getStatusUpdateTimeStamp()) > 50)) {
$this->updateOnlineList();
$this->setStatusUpdateTimeStamp(time());
}
}
function checkAndRemoveInactive() {
// Remove inactive users every inactiveCheckInterval:
if(!$this->getInactiveCheckTimeStamp() || ((time() - $this->getInactiveCheckTimeStamp()) > $this->getConfig('inactiveCheckInterval')*60)) {
$this->removeInactive();
$this->setInactiveCheckTimeStamp(time());
}
}
function sendXMLMessages() {
$httpHeader = new AJAXChatHTTPHeader('UTF-8', 'text/xml');
// Send HTTP header:
$httpHeader->send();
// Output XML messages:
echo $this->getXMLMessages();
}
function getXMLMessages() {
switch($this->getView()) {
case 'chat':
return $this->getChatViewXMLMessages();
case 'teaser':
return $this->getTeaserViewXMLMessages();
case 'logs':
return $this->getLogsViewXMLMessages();
default:
return $this->getLogoutXMLMessage();
}
}
function getMessageCondition() {
$condition = 'id > '.$this->db->makeSafe($this->getRequestVar('lastID')).'
AND (
channel = '.$this->db->makeSafe($this->getChannel()).'
OR
channel = '.$this->db->makeSafe($this->getPrivateMessageID()).'
)
AND
';
if($this->getConfig('requestMessagesPriorChannelEnter') ||
($this->getConfig('requestMessagesPriorChannelEnterList') && in_array($this->getChannel(), $this->getConfig('requestMessagesPriorChannelEnterList')))) {
$condition .= 'NOW() < DATE_ADD(dateTime, interval '.$this->getConfig('requestMessagesTimeDiff').' HOUR)';
} else {
$condition .= 'dateTime >= \''.date('Y-m-d H:i:s', $this->getChannelEnterTimeStamp()).'\'';
}
return $condition;
}
function getMessageFilter() {
$filterChannelMessages = '';
if(!$this->getConfig('showChannelMessages') || $this->getRequestVar('shoutbox')) {
$filterChannelMessages = ' AND NOT (
text LIKE (\'/login%\')
OR
text LIKE (\'/logout%\')
OR
text LIKE (\'/channelEnter%\')
OR
text LIKE (\'/channelLeave%\')
OR
text LIKE (\'/kick%\')
)';
}
return $filterChannelMessages;
}
function getInfoMessagesXML() {
$xml = '<infos>';
// Go through the info messages:
foreach($this->getInfoMessages() as $type=>$infoArray) {
foreach($infoArray as $info) {
$xml .= '<info type="'.$type.'">';
$xml .= '<![CDATA['.$this->encodeSpecialChars($info).']]>';
$xml .= '</info>';
}
}
$xml .= '</infos>';
return $xml;
}
function getChatViewOnlineUsersXML($channelIDs) {
// Get the online users for the given channels:
$onlineUsersData = $this->getOnlineUsersData($channelIDs);
$xml = '<users>';
foreach($onlineUsersData as $onlineUserData) {
$xml .= '<user';
$xml .= ' userID="'.$onlineUserData['userID'].'"';
$xml .= ' userRole="'.$onlineUserData['userRole'].'"';
$xml .= ' channelID="'.$onlineUserData['channel'].'"';
$xml .= '>';
$xml .= '<![CDATA['.$this->encodeSpecialChars($onlineUserData['userName']).']]>';
$xml .= '</user>';
}
$xml .= '</users>';
return $xml;
}
function getLogoutXMLMessage() {
$xml = '<?xml version="1.0" encoding="UTF-8"?>';
$xml .= '<root>';
$xml .= '<infos>';
$xml .= '<info type="logout">';
$xml .= '<![CDATA['.$this->encodeSpecialChars($this->getConfig('logoutData')).']]>';
$xml .= '</info>';
$xml .= '</infos>';
$xml .= '</root>';
return $xml;
}
function getChatViewMessageXML(
$messageID,
$timeStamp,
$userID,
$userName,
$userRole,
$channelID,
$text
) {
$message = '<message';
$message .= ' id="'.$messageID.'"';
$message .= ' dateTime="'.date('r', $timeStamp).'"';
$message .= ' userID="'.$userID.'"';
$message .= ' userRole="'.$userRole.'"';
$message .= ' channelID="'.$channelID.'"';
$message .= '>';
$message .= '<username><![CDATA['.$this->encodeSpecialChars($userName).']]></username>';
$message .= '<text><![CDATA['.$this->encodeSpecialChars($text).']]></text>';
$message .= '</message>';
return $message;
}
function getChatViewMessagesXML() {
// Get the last messages in descending order (this optimises the LIMIT usage):
$sql = 'SELECT
id,
userID,
userName,
userRole,
channel AS channelID,
UNIX_TIMESTAMP(dateTime) AS timeStamp,
text
FROM
'.$this->getDataBaseTable('messages').'
WHERE
'.$this->getMessageCondition().'
'.$this->getMessageFilter().'
ORDER BY
id
DESC
LIMIT '.$this->getConfig('requestMessagesLimit').';';
// Create a new SQL query:
$result = $this->db->sqlQuery($sql);
// Stop if an error occurs:
if($result->error()) {
echo $result->getError();
die();
}
$messages = '';
// Add the messages in reverse order so it is ascending again:
while($row = $result->fetch()) {
$message = $this->getChatViewMessageXML(
$row['id'],
$row['timeStamp'],
$row['userID'],
$row['userName'],
$row['userRole'],
$row['channelID'],
$row['text']
);
$messages = $message.$messages;
}
$result->free();
$messages = '<messages>'.$messages.'</messages>';
return $messages;
}
function getChatViewXMLMessages() {
$xml = '<?xml version="1.0" encoding="UTF-8"?>';
$xml .= '<root>';
$xml .= $this->getInfoMessagesXML();
$xml .= $this->getChatViewOnlineUsersXML(array($this->getChannel()));
$xml .= $this->getChatViewMessagesXML();
$xml .= '</root>';
return $xml;
}
function getTeaserMessageCondition() {
$channelID = $this->getValidRequestChannelID();
$condition = 'channel = '.$this->db->makeSafe($channelID).'
AND
';
if($this->getConfig('requestMessagesPriorChannelEnter') ||
($this->getConfig('requestMessagesPriorChannelEnterList') && in_array($channelID, $this->getConfig('requestMessagesPriorChannelEnterList')))) {
$condition .= 'NOW() < DATE_ADD(dateTime, interval '.$this->getConfig('requestMessagesTimeDiff').' HOUR)';
} else {
// Teaser content may not be shown for this channel:
$condition .= '0 = 1';
}
return $condition;
}
function getTeaserViewMessagesXML() {
// Get the last messages in descending order (this optimises the LIMIT usage):
$sql = 'SELECT
id,
userID,
userName,
userRole,
channel AS channelID,
UNIX_TIMESTAMP(dateTime) AS timeStamp,
text
FROM
'.$this->getDataBaseTable('messages').'
WHERE
'.$this->getTeaserMessageCondition().'
'.$this->getMessageFilter().'
ORDER BY
id
DESC
LIMIT '.$this->getConfig('requestMessagesLimit').';';
// Create a new SQL query:
$result = $this->db->sqlQuery($sql);
// Stop if an error occurs:
if($result->error()) {
echo $result->getError();
die();
}
$messages = '';
// Add the messages in reverse order so it is ascending again:
while($row = $result->fetch()) {
$message = '';
$message .= '<message';
$message .= ' id="'.$row['id'].'"';
$message .= ' dateTime="'.date('r', $row['timeStamp']).'"';
$message .= ' userID="'.$row['userID'].'"';
$message .= ' userRole="'.$row['userRole'].'"';
$message .= ' channelID="'.$row['channelID'].'"';
$message .= '>';
$message .= '<username><![CDATA['.$this->encodeSpecialChars($row['userName']).']]></username>';
$message .= '<text><![CDATA['.$this->encodeSpecialChars($row['text']).']]></text>';
$message .= '</message>';
$messages = $message.$messages;
}
$result->free();
$messages = '<messages>'.$messages.'</messages>';
return $messages;
}
function getTeaserViewXMLMessages() {
$xml = '<?xml version="1.0" encoding="UTF-8"?>';
$xml .= '<root>';
$xml .= $this->getInfoMessagesXML();
$xml .= $this->getTeaserViewMessagesXML();
$xml .= '</root>';
return $xml;
}
function getLogsViewCondition() {
$condition = 'id > '.$this->db->makeSafe($this->getRequestVar('lastID'));
// Check the channel condition:
switch($this->getRequestVar('channelID')) {
case '-3':
// Just display messages from all accessible channels
if($this->getUserRole() != AJAX_CHAT_ADMIN) {
$condition .= ' AND (channel = '.$this->db->makeSafe($this->getPrivateMessageID());
$condition .= ' OR channel = '.$this->db->makeSafe($this->getPrivateChannelID());
foreach($this->getChannels() as $channel) {
if($this->getConfig('logsUserAccessChannelList') && !in_array($channel, $this->getConfig('logsUserAccessChannelList'))) {
continue;
}
$condition .= ' OR channel = '.$this->db->makeSafe($channel);
}
$condition .= ')';
}
break;
case '-2':
if($this->getUserRole() != AJAX_CHAT_ADMIN) {
$condition .= ' AND channel = '.($this->getPrivateMessageID());
} else {
$condition .= ' AND channel > '.($this->getConfig('privateMessageDiff')-1);
}
break;
case '-1':
if($this->getUserRole() != AJAX_CHAT_ADMIN) {
$condition .= ' AND channel = '.($this->getPrivateChannelID());
} else {
$condition .= ' AND (channel > '.($this->getConfig('privateChannelDiff')-1).' AND channel < '.($this->getConfig('privateMessageDiff')).')';
}
break;
default:
if(($this->getUserRole() == AJAX_CHAT_ADMIN || !$this->getConfig('logsUserAccessChannelList') || in_array($this->getRequestVar('channelID'), $this->getConfig('logsUserAccessChannelList')))
&& $this->validateChannel($this->getRequestVar('channelID'))) {
$condition .= ' AND channel = '.$this->db->makeSafe($this->getRequestVar('channelID'));
} else {
// No valid channel:
$condition .= ' AND 0 = 1';
}
}
// Check the period condition:
$hour = ($this->getRequestVar('hour') === null || $this->getRequestVar('hour') > 23 || $this->getRequestVar('hour') < 0) ? null : $this->getRequestVar('hour');
$day = ($this->getRequestVar('day') === null || $this->getRequestVar('day') > 31 || $this->getRequestVar('day') < 1) ? null : $this->getRequestVar('day');
$month = ($this->getRequestVar('month') === null || $this->getRequestVar('month') > 12 || $this->getRequestVar('month') < 1) ? null : $this->getRequestVar('month');
$year = ($this->getRequestVar('year') === null || $this->getRequestVar('year') > date('Y') || $this->getRequestVar('year') < $this->getConfig('logsFirstYear')) ? null : $this->getRequestVar('year');
// If a time (hour) is given but no date (year, month, day), use the current date:
if($hour !== null) {
if($day === null)
$day = date('j');
if($month === null)
$month = date('n');
if($year === null)
$year = date('Y');
}
if($year === null) {
// No year given, so no period condition
} else if($month === null) {
// Define the given year as period:
$periodStart = mktime(0, 0, 0, 1, 1, $year);
// The last day in a month can be expressed by using 0 for the day of the next month:
$periodEnd = mktime(23, 59, 59, 13, 0, $year);
} else if($day === null) {
// Define the given month as period:
$periodStart = mktime(0, 0, 0, $month, 1, $year);
// The last day in a month can be expressed by using 0 for the day of the next month:
$periodEnd = mktime(23, 59, 59, $month+1, 0, $year);
} else if($hour === null){
// Define the given day as period:
$periodStart = mktime(0, 0, 0, $month, $day, $year);
$periodEnd = mktime(23, 59, 59, $month, $day, $year);
} else {
// Define the given hour as period:
$periodStart = mktime($hour, 0, 0, $month, $day, $year);
$periodEnd = mktime($hour, 59, 59, $month, $day, $year);
}
if(isset($periodStart))
$condition .= ' AND dateTime > \''.date('Y-m-d H:i:s', $periodStart).'\' AND dateTime <= \''.date('Y-m-d H:i:s', $periodEnd).'\'';
// Check the search condition:
if($this->getRequestVar('search')) {
if(($this->getUserRole() == AJAX_CHAT_ADMIN || $this->getUserRole() == AJAX_CHAT_MODERATOR || $this->getUserRole() == PURPLE || $this->getUserRole() == CMOD) && strpos($this->getRequestVar('search'), 'ip=') === 0) {
// Search for messages with the given IP:
$ip = substr($this->getRequestVar('search'), 3);
$condition .= ' AND (ip = '.$this->db->makeSafe($this->ipToStorageFormat($ip)).')';
} else if(strpos($this->getRequestVar('search'), 'userID=') === 0) {
// Search for messages with the given userID:
$userID = substr($this->getRequestVar('search'), 7);
$condition .= ' AND (userID = '.$this->db->makeSafe($userID).')';
} else {
// Use the search value as regular expression on message text and username:
$condition .= ' AND (userName REGEXP '.$this->db->makeSafe($this->getRequestVar('search')).' OR text REGEXP '.$this->db->makeSafe($this->getRequestVar('search')).')';
}
}
// If no period or search condition is given, just monitor the last messages on the given channel:
if(!isset($periodStart) && !$this->getRequestVar('search')) {
$condition .= ' AND NOW() < DATE_ADD(dateTime, interval '.$this->getConfig('logsRequestMessagesTimeDiff').' HOUR)';
}
return $condition;
}
function getLogsViewMessagesXML() {
$sql = 'SELECT
id,
userID,
userName,
userRole,
channel AS channelID,
UNIX_TIMESTAMP(dateTime) AS timeStamp,
ip,
text
FROM
'.$this->getDataBaseTable('messages').'
WHERE
'.$this->getLogsViewCondition().'
ORDER BY
id
LIMIT '.$this->getConfig('logsRequestMessagesLimit').';';
// Create a new SQL query:
$result = $this->db->sqlQuery($sql);
// Stop if an error occurs:
if($result->error()) {
echo $result->getError();
die();
}
$xml = '<messages>';
while($row = $result->fetch()) {
$xml .= '<message';
$xml .= ' id="'.$row['id'].'"';
$xml .= ' dateTime="'.date('r', $row['timeStamp']).'"';
$xml .= ' userID="'.$row['userID'].'"';
$xml .= ' userRole="'.$row['userRole'].'"';
$xml .= ' channelID="'.$row['channelID'].'"';
if($this->getUserRole() == AJAX_CHAT_ADMIN || $this->getUserRole() == AJAX_CHAT_MODERATOR || $this->getUserRole() == PURPLE) {
$xml .= ' ip="'.$this->ipFromStorageFormat($row['ip']).'"';
}
$xml .= '>';
$xml .= '<username><![CDATA['.$this->encodeSpecialChars($row['userName']).']]></username>';
$xml .= '<text><![CDATA['.$this->encodeSpecialChars($row['text']).']]></text>';
$xml .= '</message>';
}
$result->free();
$xml .= '</messages>';
return $xml;
}
function getLogsViewXMLMessages() {
$xml = '<?xml version="1.0" encoding="UTF-8"?>';
$xml .= '<root>';
$xml .= $this->getInfoMessagesXML();
$xml .= $this->getLogsViewMessagesXML();
$xml .= '</root>';
return $xml;
}
function purgeLogs() {
$sql = 'DELETE FROM
'.$this->getDataBaseTable('messages').'
WHERE
dateTime < DATE_SUB(NOW(), interval '.$this->getConfig('logsPurgeTimeDiff').' DAY);';
// Create a new SQL query:
$result = $this->db->sqlQuery($sql);
// Stop if an error occurs:
if($result->error()) {
echo $result->getError();
die();
}
}
function getInfoMessages($type=null) {
if(!isset($this->_infoMessages)) {
$this->_infoMessages = array();
}
if($type) {
if(!isset($this->_infoMessages[$type])) {
$this->_infoMessages[$type] = array();
}
return $this->_infoMessages[$type];
} else {
return $this->_infoMessages;
}
}
function addInfoMessage($info, $type='error') {
if(!isset($this->_infoMessages)) {
$this->_infoMessages = array();
}
if(!isset($this->_infoMessages[$type])) {
$this->_infoMessages[$type] = array();
}
if(!in_array($info, $this->_infoMessages[$type])) {
array_push($this->_infoMessages[$type], $info);
}
}
function getRequestVars() {
return $this->_requestVars;
}
function getRequestVar($key) {
if($this->_requestVars && isset($this->_requestVars[$key])) {
return $this->_requestVars[$key];
}
return null;
}
function setRequestVar($key, $value) {
if(!$this->_requestVars) {
$this->_requestVars = array();
}
$this->_requestVars[$key] = $value;
}
function getOnlineUsersData($channelIDs=null, $key=null, $value=null) {
if($this->_onlineUsersData === null) {
$this->_onlineUsersData = array();
$sql = 'SELECT
userID,
userName,
userRole,
channel,
UNIX_TIMESTAMP(dateTime) AS timeStamp,
ip
FROM
'.$this->getDataBaseTable('online').'
ORDER BY
userName;';
// Create a new SQL query:
$result = $this->db->sqlQuery($sql);
// Stop if an error occurs:
if($result->error()) {
echo $result->getError();
die();
}
while($row = $result->fetch()) {
$row['ip'] = $this->ipFromStorageFormat($row['ip']);
array_push($this->_onlineUsersData, $row);
}
$result->free();
}
if($channelIDs || $key) {
$onlineUsersData = array();
foreach($this->_onlineUsersData as $userData) {
if($channelIDs && !in_array($userData['channel'], $channelIDs)) {
continue;
}
if($key) {
if(!isset($userData[$key])) {
return $onlineUsersData;
}
if($value !== null) {
if($userData[$key] == $value) {
array_push($onlineUsersData, $userData);
} else {
continue;
}
} else {
array_push($onlineUsersData, $userData[$key]);
}
} else {
array_push($onlineUsersData, $userData);
}
}
return $onlineUsersData;
}
return $this->_onlineUsersData;
}
function removeUserFromOnlineUsersData($userID=null) {
if(!$this->_onlineUsersData) {
return;
}
$userID = ($userID === null) ? $this->getUserID() : $userID;
for($i=0; $i<count($this->_onlineUsersData); $i++) {
if($this->_onlineUsersData[$i]['userID'] == $userID) {
array_splice($this->_onlineUsersData, $i, 1);
break;
}
}
}
function resetOnlineUsersData() {
$this->_onlineUsersData = null;
}
function getOnlineUsers($channelIDs=null) {
return $this->getOnlineUsersData($channelIDs, 'userName');
}
function getOnlineUserIDs($channelIDs=null) {
return $this->getOnlineUsersData($channelIDs, 'userID');
}
function startSession() {
if(!session_id()) {
// Set the session name:
session_name($this->getConfig('sessionName'));
// Set session cookie parameters:
session_set_cookie_params(
0, // The session is destroyed on logout anyway, so no use to set this
$this->getConfig('sessionCookiePath'),
$this->getConfig('sessionCookieDomain'),
$this->getConfig('sessionCookieSecure')
);
// Start the session:
session_start();
// We started a new session:
$this->_sessionNew = true;
}
}
function destroySession() {
if($this->_sessionNew) {
// Delete all session variables:
$_SESSION = array();
// Delete the session cookie:
if (isset($_COOKIE[session_name()])) {
setcookie(
session_name(),
'',
time()-42000,
$this->getConfig('sessionCookiePath'),
$this->getConfig('sessionCookieDomain'),
$this->getConfig('sessionCookieSecure')
);
}
// Destroy the session:
session_destroy();
} else {
// Unset all session variables starting with the sessionKeyPrefix:
foreach($_SESSION as $key=>$value) {
if(strpos($key, $this->getConfig('sessionKeyPrefix')) === 0) {
unset($_SESSION[$key]);
}
}
}
}
function regenerateSessionID() {
if($this->_sessionNew) {
// Regenerate session id:
@session_regenerate_id(true);
}
}
function getSessionVar($key, $prefix=null) {
if($prefix === null)
$prefix = $this->getConfig('sessionKeyPrefix');
// Return the session value if existing:
if(isset($_SESSION[$prefix.$key]))
return $_SESSION[$prefix.$key];
else
return null;
}
function setSessionVar($key, $value, $prefix=null) {
if($prefix === null)
$prefix = $this->getConfig('sessionKeyPrefix');
// Set the session value:
$_SESSION[$prefix.$key] = $value;
}
function getSessionIP() {
return $this->getSessionVar('IP');
}
function setSessionIP($ip) {
$this->setSessionVar('IP', $ip);
}
function getQueryUserName() {
return $this->getSessionVar('QueryUserName');
}
function setQueryUserName($userName) {
$this->setSessionVar('QueryUserName', $userName);
}
function getInvitations() {
if($this->_invitations === null) {
$this->_invitations = array();
$sql = 'SELECT
channel
FROM
'.$this->getDataBaseTable('invitations').'
WHERE
userID='.$this->db->makeSafe($this->getUserID()).'
AND
DATE_SUB(NOW(), interval 1 DAY) < dateTime;';
// Create a new SQL query:
$result = $this->db->sqlQuery($sql);
// Stop if an error occurs:
if($result->error()) {
echo $result->getError();
die();
}
while($row = $result->fetch()) {
array_push($this->_invitations, $row['channel']);
}
$result->free();
}
return $this->_invitations;
}
function removeExpiredInvitations() {
$sql = 'DELETE FROM
'.$this->getDataBaseTable('invitations').'
WHERE
DATE_SUB(NOW(), interval 1 DAY) > dateTime;';
// Create a new SQL query:
$result = $this->db->sqlQuery($sql);
// Stop if an error occurs:
if($result->error()) {
echo $result->getError();
die();
}
}
function addInvitation($userID, $channelID=null) {
$this->removeExpiredInvitations();
$channelID = ($channelID === null) ? $this->getChannel() : $channelID;
$sql = 'INSERT INTO '.$this->getDataBaseTable('invitations').'(
userID,
channel,
dateTime
)
VALUES (
'.$this->db->makeSafe($userID).',
'.$this->db->makeSafe($channelID).',
NOW()
);';
// Create a new SQL query:
$result = $this->db->sqlQuery($sql);
// Stop if an error occurs:
if($result->error()) {
echo $result->getError();
die();
}
}
function removeInvitation($userID, $channelID=null) {
$channelID = ($channelID === null) ? $this->getChannel() : $channelID;
$sql = 'DELETE FROM
'.$this->getDataBaseTable('invitations').'
WHERE
userID='.$this->db->makeSafe($userID).'
AND
channel='.$this->db->makeSafe($channelID).';';
// Create a new SQL query:
$result = $this->db->sqlQuery($sql);
// Stop if an error occurs:
if($result->error()) {
echo $result->getError();
die();
}
}
function getUserID() {
return $this->getSessionVar('UserID');
}
function setUserID($id) {
$this->setSessionVar('UserID', $id);
}
function getUserName() {
return $this->getSessionVar('UserName');
}
function setUserName($name) {
$this->setSessionVar('UserName', $name);
}
function getLoginUserName() {
return $this->getSessionVar('LoginUserName');
}
function setLoginUserName($name) {
$this->setSessionVar('LoginUserName', $name);
}
function getUserRole() {
$userRole = $this->getSessionVar('UserRole');
if($userRole === null)
return AJAX_CHAT_GUEST;
return $userRole;
}
function setUserRole($role) {
$this->setSessionVar('UserRole', $role);
}
function getChannel() {
return $this->getSessionVar('Channel');
}
function setChannel($channel) {
$this->setSessionVar('Channel', $channel);
// Save the channel enter timestamp:
$this->setChannelEnterTimeStamp(time());
// Update the channel authentication for the socket server:
if($this->getConfig('socketServerEnabled')) {
$this->updateSocketAuthentication(
$this->getUserID(),
$this->getSocketRegistrationID(),
array($channel,$this->getPrivateMessageID())
);
}
// Reset the logs view socket authentication session var:
if($this->getSessionVar('logsViewSocketAuthenticated')) {
$this->setSessionVar('logsViewSocketAuthenticated', false);
}
}
function isLoggedIn() {
return (bool)$this->getSessionVar('LoggedIn');
}
function setLoggedIn($bool) {
$this->setSessionVar('LoggedIn', $bool);
}
function getLoginTimeStamp() {
return $this->getSessionVar('LoginTimeStamp');
}
function setLoginTimeStamp($time) {
$this->setSessionVar('LoginTimeStamp', $time);
}
function getChannelEnterTimeStamp() {
return $this->getSessionVar('ChannelEnterTimeStamp');
}
function setChannelEnterTimeStamp($time) {
$this->setSessionVar('ChannelEnterTimeStamp', $time);
}
function getStatusUpdateTimeStamp() {
return $this->getSessionVar('StatusUpdateTimeStamp');
}
function setStatusUpdateTimeStamp($time) {
$this->setSessionVar('StatusUpdateTimeStamp', $time);
}
function getInactiveCheckTimeStamp() {
return $this->getSessionVar('InactiveCheckTimeStamp');
}
function setInactiveCheckTimeStamp($time) {
$this->setSessionVar('InactiveCheckTimeStamp', $time);
}
function getInsertedMessagesRate() {
return $this->getSessionVar('InsertedMessagesRate');
}
function setInsertedMessagesRate($rate) {
$this->setSessionVar('InsertedMessagesRate', $rate);
}
function getInsertedMessagesRateTimeStamp() {
return $this->getSessionVar('InsertedMessagesRateTimeStamp');
}
function setInsertedMessagesRateTimeStamp($time) {
$this->setSessionVar('InsertedMessagesRateTimeStamp', $time);
}
function getLangCode() {
// Get the langCode from request or cookie:
$langCodeCookie = isset($_COOKIE[$this->getConfig('sessionName').'_lang']) ? $_COOKIE[$this->getConfig('sessionName').'_lang'] : null;
$langCode = $this->getRequestVar('lang') ? $this->getRequestVar('lang') : $langCodeCookie;
// Check if the langCode is valid:
if(!in_array($langCode, $this->getConfig('langAvailable'))) {
// Determine the user language:
$language = new AJAXChatLanguage($this->getConfig('langAvailable'), $this->getConfig('langDefault'));
$langCode = $language->getLangCode();
}
return $langCode;
}
function setLangCodeCookie() {
setcookie(
$this->getConfig('sessionName').'_lang',
$this->getLangCode(),
time()+60*60*24*$this->getConfig('sessionCookieLifeTime'),
$this->getConfig('sessionCookiePath'),
$this->getConfig('sessionCookieDomain'),
$this->getConfig('sessionCookieSecure')
);
}
function removeUnsafeCharacters($str) {
// Remove NO-WS-CTL, non-whitespace control characters (RFC 2822), decimal 1–8, 11–12, 14–31, and 127:
return AJAXChatEncoding::removeUnsafeCharacters($str);
}
function subString($str, $start=0, $length=null, $encoding='UTF-8') {
return AJAXChatString::subString($str, $start, $length, $encoding);
}
function stringLength($str, $encoding='UTF-8') {
return AJAXChatString::stringLength($str, $encoding);
}
function trimMessageText($text) {
return $this->trimString($text, 'UTF-8', $this->getConfig('messageTextMaxLength'));
}
function trimUserName($userName) {
return $this->trimString($userName, null, $this->getConfig('userNameMaxLength'), true, true);
}
function trimChannelName($channelName) {
return $this->trimString($channelName, null, null, true, true);
}
function trimString($str, $sourceEncoding=null, $maxLength=null, $replaceWhitespace=false, $decodeEntities=false, $htmlEntitiesMap=null) {
// Make sure the string contains valid unicode:
$str = $this->convertToUnicode($str, $sourceEncoding);
// Make sure the string contains no unsafe characters:
$str = $this->removeUnsafeCharacters($str);
// Strip whitespace from the beginning and end of the string:
$str = trim($str);
if($replaceWhitespace) {
// Replace any whitespace in the userName with the underscore "_":
$str = preg_replace('/\s/u', '_', $str);
}
if($decodeEntities) {
// Decode entities:
$str = $this->decodeEntities($str, 'UTF-8', $htmlEntitiesMap);
}
if($maxLength) {
// Cut the string to the allowed length:
$str = $this->subString($str, 0, $maxLength);
}
return $str;
}
function convertToUnicode($str, $sourceEncoding=null) {
if($sourceEncoding === null) {
$sourceEncoding = $this->getConfig('sourceEncoding');
}
return $this->convertEncoding($str, $sourceEncoding, 'UTF-8');
}
function convertFromUnicode($str, $contentEncoding=null) {
if($contentEncoding === null) {
$contentEncoding = $this->getConfig('contentEncoding');
}
return $this->convertEncoding($str, 'UTF-8', $contentEncoding);
}
function convertEncoding($str, $charsetFrom, $charsetTo) {
return AJAXChatEncoding::convertEncoding($str, $charsetFrom, $charsetTo);
}
function encodeEntities($str, $encoding='UTF-8', $convmap=null) {
return AJAXChatEncoding::encodeEntities($str, $encoding, $convmap);
}
function decodeEntities($str, $encoding='UTF-8', $htmlEntitiesMap=null) {
return AJAXChatEncoding::decodeEntities($str, $encoding, $htmlEntitiesMap);
}
function htmlEncode($str) {
return AJAXChatEncoding::htmlEncode($str, $this->getConfig('contentEncoding'));
}
function encodeSpecialChars($str) {
return AJAXChatEncoding::encodeSpecialChars($str);
}
function decodeSpecialChars($str) {
return AJAXChatEncoding::decodeSpecialChars($str);
}
function ipToStorageFormat($ip) {
if(function_exists('inet_pton')) {
// ipv4 & ipv6:
return @inet_pton($ip);
}
// Only ipv4:
return @pack('N',@ip2long($ip));
}
function ipFromStorageFormat($ip) {
if(function_exists('inet_ntop')) {
// ipv4 & ipv6:
return @inet_ntop($ip);
}
// Only ipv4:
$unpacked = @unpack('Nlong',$ip);
if(isset($unpacked['long'])) {
return @long2ip($unpacked['long']);
}
return null;
}
function getConfig($key, $subkey=null) {
if($subkey)
return $this->_config[$key][$subkey];
else
return $this->_config[$key];
}
function setConfig($key, $subkey, $value) {
if($subkey) {
if(!isset($this->_config[$key])) {
$this->_config[$key] = array();
}
$this->_config[$key][$subkey] = $value;
} else {
$this->_config[$key] = $value;
}
}
function getLang($key=null) {
if(!$this->_lang) {
// Include the language file:
$lang = null;
require(AJAX_CHAT_PATH.'lib/lang/'.$this->getLangCode().'.php');
$this->_lang = &$lang;
}
if($key === null)
return $this->_lang;
if(isset($this->_lang[$key]))
return $this->_lang[$key];
return null;
}
function getChatURL() {
if(defined('AJAX_CHAT_URL')) {
return AJAX_CHAT_URL;
}
return
(isset($_SERVER['HTTPS']) ? 'https://' : 'http://').
(isset($_SERVER['REMOTE_USER']) ? $_SERVER['REMOTE_USER'].'@' : '').
(isset($_SERVER['HTTP_HOST']) ? $_SERVER['HTTP_HOST'] : ($_SERVER['SERVER_NAME'].
(isset($_SERVER['HTTPS']) && $_SERVER['SERVER_PORT'] == 443 || $_SERVER['SERVER_PORT'] == 80 ? '' : ':'.$_SERVER['SERVER_PORT']))).
substr($_SERVER['SCRIPT_NAME'],0, strrpos($_SERVER['SCRIPT_NAME'], '/')+1);
}
function getIDFromName($userName) {
$userDataArray = $this->getOnlineUsersData(null,'userName',$userName);
if($userDataArray && isset($userDataArray[0])) {
return $userDataArray[0]['userID'];
}
return null;
}
function getNameFromID($userID) {
$userDataArray = $this->getOnlineUsersData(null,'userID',$userID);
if($userDataArray && isset($userDataArray[0])) {
return $userDataArray[0]['userName'];
}
return null;
}
function getChannelFromID($userID) {
$userDataArray = $this->getOnlineUsersData(null,'userID',$userID);
if($userDataArray && isset($userDataArray[0])) {
return $userDataArray[0]['channel'];
}
return null;
}
function getIPFromID($userID) {
$userDataArray = $this->getOnlineUsersData(null,'userID',$userID);
if($userDataArray && isset($userDataArray[0])) {
return $userDataArray[0]['ip'];
}
return null;
}
function getRoleFromID($userID) {
$userDataArray = $this->getOnlineUsersData(null,'userID',$userID);
if($userDataArray && isset($userDataArray[0])) {
return $userDataArray[0]['userRole'];
}
return null;
}
function getChannelNames() {
return array_flip($this->getChannels());
}
function getChannelIDFromChannelName($channelName) {
if(!$channelName)
return null;
$channels = $this->getAllChannels();
if(array_key_exists($channelName,$channels)) {
return $channels[$channelName];
}
$channelID = null;
// Check if the requested channel is the own private channel:
if($channelName == $this->getPrivateChannelName()) {
return $this->getPrivateChannelID();
}
// Try to retrieve a private room ID:
$strlenChannelName = $this->stringLength($channelName);
$strlenPrefix = $this->stringLength($this->getConfig('privateChannelPrefix'));
$strlenSuffix = $this->stringLength($this->getConfig('privateChannelSuffix'));
if($this->subString($channelName,0,$strlenPrefix) == $this->getConfig('privateChannelPrefix')
&& $this->subString($channelName,$strlenChannelName-$strlenSuffix) == $this->getConfig('privateChannelSuffix')) {
$userName = $this->subString(
$channelName,
$strlenPrefix,
$strlenChannelName-($strlenPrefix+$strlenSuffix)
);
$userID = $this->getIDFromName($userName);
if($userID !== null) {
$channelID = $this->getPrivateChannelID($userID);
}
}
return $channelID;
}
function getChannelNameFromChannelID($channelID) {
foreach($this->getAllChannels() as $key=>$value) {
if($value == $channelID) {
return $key;
}
}
// Try to retrieve a private room name:
if($channelID == $this->getPrivateChannelID()) {
return $this->getPrivateChannelName();
}
$userName = $this->getNameFromID($channelID-$this->getConfig('privateChannelDiff'));
if($userName === null) {
return null;
}
return $this->getPrivateChannelName($userName);
}
function getChannelName() {
return $this->getChannelNameFromChannelID($this->getChannel());
}
function getPrivateChannelName($userName=null) {
if($userName === null) {
$userName = $this->getUserName();
}
return $this->getConfig('privateChannelPrefix').$userName.$this->getConfig('privateChannelSuffix');
}
function getPrivateChannelID($userID=null) {
if($userID === null) {
$userID = $this->getUserID();
}
return $userID + $this->getConfig('privateChannelDiff');
}
function getPrivateMessageID($userID=null) {
if($userID === null) {
$userID = $this->getUserID();
}
return $userID + $this->getConfig('privateMessageDiff');
}
function isAllowedToSendPrivateMessage() {
if($this->getConfig('allowPrivateMessages') || $this->getUserRole() == AJAX_CHAT_ADMIN) {
return true;
}
return false;
}
function isAllowedToCreatePrivateChannel() {
if($this->getConfig('allowPrivateChannels')) {
switch($this->getUserRole()) {
case DONATOR:
return true;
case BOTS:
return true;
case PURPLE:
return true;
case CMOD:
return true;
case AJAX_CHAT_MODERATOR:
return true;
case AJAX_CHAT_ADMIN:
return true;
default:
return false;
}
}
return false;
}
function isAllowedToListHiddenUsers() {
// Hidden users are users within private or restricted channels:
switch($this->getUserRole()) {
case CMOD:
return true;
case PURPLE:
return true;
case AJAX_CHAT_MODERATOR:
return true;
case AJAX_CHAT_ADMIN:
return true;
default:
return false;
}
}
function isUserOnline($userID=null) {
$userID = ($userID === null) ? $this->getUserID() : $userID;
$userDataArray = $this->getOnlineUsersData(null,'userID',$userID);
if($userDataArray && count($userDataArray) > 0) {
return true;
}
return false;
}
function isUserNameInUse($userName=null) {
$userName = ($userName === null) ? $this->getUserName() : $userName;
$userDataArray = $this->getOnlineUsersData(null,'userName',$userName);
if($userDataArray && count($userDataArray) > 0) {
return true;
}
return false;
}
function isUserBanned($userName, $userID=null, $ip=null) {
if($userID !== null) {
$bannedUserDataArray = $this->getBannedUsersData('userID',$userID);
if($bannedUserDataArray && isset($bannedUserDataArray[0])) {
return true;
}
}
if($ip !== null) {
$bannedUserDataArray = $this->getBannedUsersData('ip',$ip);
if($bannedUserDataArray && isset($bannedUserDataArray[0])) {
return true;
}
}
$bannedUserDataArray = $this->getBannedUsersData('userName',$userName);
if($bannedUserDataArray && isset($bannedUserDataArray[0])) {
return true;
}
return false;
}
function isMaxUsersLoggedIn() {
if(count($this->getOnlineUsersData()) >= $this->getConfig('maxUsersLoggedIn')) {
return true;
}
return false;
}
function validateChannel($channelID) {
if($channelID === null) {
return false;
}
// Return true for normal channels the user has acces to:
if(in_array($channelID, $this->getChannels())) {
return true;
}
// Return true if the user is allowed to join his own private channel:
if($channelID == $this->getPrivateChannelID() && $this->isAllowedToCreatePrivateChannel()) {
return true;
}
// Return true if the user has been invited to a restricted or private channel:
if(in_array($channelID, $this->getInvitations())) {
return true;
}
// No valid channel, return false:
return false;
}
function createGuestUserName() {
$maxLength = $this->getConfig('userNameMaxLength')
- $this->stringLength($this->getConfig('guestUserPrefix'))
- $this->stringLength($this->getConfig('guestUserSuffix'));
// seed with microseconds since last "whole" second:
mt_srand((double)microtime()*1000000);
// Create a random userName using numbers between 100000 and 999999:
$userName = substr(mt_rand(100000, 999999), 0, $maxLength);
return $this->getConfig('guestUserPrefix').$userName.$this->getConfig('guestUserSuffix');
}
// Guest userIDs must not interfere with existing userIDs and must be lower than privateChannelDiff:
function createGuestUserID() {
// seed with microseconds since last "whole" second:
mt_srand((double)microtime()*1000000);
return mt_rand($this->getConfig('minGuestUserID'), $this->getConfig('privateChannelDiff')-1);
}
function getGuestUser() {
if(!$this->getConfig('allowGuestLogins'))
return null;
if($this->getConfig('allowGuestUserName')) {
$maxLength = $this->getConfig('userNameMaxLength')
- $this->stringLength($this->getConfig('guestUserPrefix'))
- $this->stringLength($this->getConfig('guestUserSuffix'));
// Trim guest userName:
$userName = $this->trimString($this->getRequestVar('userName'), null, $maxLength, true, true);
// If given userName is invalid, create one:
if(!$userName) {
$userName = $this->createGuestUserName();
} else {
// Add the guest users prefix and suffix to the given userName:
$userName = $this->getConfig('guestUserPrefix').$userName.$this->getConfig('guestUserSuffix');
}
} else {
$userName = $this->createGuestUserName();
}
$userData = array();
$userData['userID'] = $this->createGuestUserID();
$userData['userName'] = $userName;
$userData['userRole'] = AJAX_CHAT_GUEST;
return $userData;
}
function getCustomVar($key) {
if(!isset($this->_customVars))
$this->_customVars = array();
if(!isset($this->_customVars[$key]))
return null;
return $this->_customVars[$key];
}
function setCustomVar($key, $value) {
if(!isset($this->_customVars))
$this->_customVars = array();
$this->_customVars[$key] = $value;
}
// Override to replace custom template tags:
// Return the replacement for the given tag (and given tagContent)
function replaceCustomTemplateTags($tag, $tagContent) {
return null;
}
// Override to initialize custom configuration settings:
function initCustomConfig() {
}
// Override to add custom request variables:
// Add values to the request variables array: $this->_requestVars['customVariable'] = null;
function initCustomRequestVars() {
}
// Override to add custom session code right after the session has been started:
function initCustomSession() {
}
// Override, to parse custom info requests:
// $infoRequest contains the current info request
// Add info responses using the method addInfoMessage($info, $type)
function parseCustomInfoRequest($infoRequest) {
}
// Override to replace custom text:
// Return replaced text
// $text contains the whole message
function replaceCustomText(&$text) {
return $text;
}
// Override to add custom commands:
// Return true if a custom command has been successfully parsed, else false
// $text contains the whole message, $textParts the message split up as words array
function parseCustomCommands($text, $textParts) {
return false;
}
// Override to perform custom actions on new messages:
// Return true if message may be inserted, else false
// $text contains the whole message
function onNewMessage($text) {
return true;
}
// Override to perform custom actions on new messages:
// Method to set the style cookie depending on user data
function setStyle() {
}
// Override:
// Returns true if the userID of the logged in user is identical to the userID of the authentication system
// or the user is authenticated as guest in the chat and the authentication system
function revalidateUserID() {
return true;
}
// Override:
// Returns an associative array containing userName, userID and userRole
// Returns null if login is invalid
function getValidLoginUserData() {
// Check if we have a valid registered user:
if(false) {
// Here is the place to check user authentication
} else {
// Guest users:
return $this->getGuestUser();
}
}
// Override:
// Store the channels the current user has access to
// Make sure channel names don't contain any whitespace
function &getChannels() {
if($this->_channels === null) {
$this->_channels = $this->getAllChannels();
}
return $this->_channels;
}
// Override:
// Store all existing channels
// Make sure channel names don't contain any whitespace
function &getAllChannels() {
if($this->_allChannels === null) {
$this->_allChannels = array();
// Default channel, public to everyone:
$this->_allChannels[$this->trimChannelName($this->getConfig('defaultChannelName'))] = $this->getConfig('defaultChannelID');
}
return $this->_allChannels;
}
}
Reference in a new issue Copy permalink