mirror of
https://github.com/Mibew/i18n.git
synced 2025-01-24 06:10:28 +03:00
319 lines
10 KiB
PHP
319 lines
10 KiB
PHP
<?php
|
|
/*
|
|
* Copyright 2005-2013 the original author or authors.
|
|
*
|
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
* you may not use this file except in compliance with the License.
|
|
* You may obtain a copy of the License at
|
|
*
|
|
* http://www.apache.org/licenses/LICENSE-2.0
|
|
*
|
|
* Unless required by applicable law or agreed to in writing, software
|
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
* See the License for the specific language governing permissions and
|
|
* limitations under the License.
|
|
*/
|
|
|
|
require_once('../libs/init.php');
|
|
require_once('../libs/chat.php');
|
|
require_once('../libs/userinfo.php');
|
|
require_once('../libs/operator.php');
|
|
require_once('../libs/groups.php');
|
|
require_once('../libs/track.php');
|
|
require_once('../libs/classes/thread.php');
|
|
|
|
$operator = get_logged_in();
|
|
if (!$operator) {
|
|
start_xml_output();
|
|
echo "<error><descr>" . myiconv($webim_encoding, "utf-8", escape_with_cdata(getstring("agent.not_logged_in"))) . "</descr></error>";
|
|
exit;
|
|
}
|
|
|
|
$threadstate_to_string = array(
|
|
Thread::STATE_QUEUE => "wait",
|
|
Thread::STATE_WAITING => "prio",
|
|
Thread::STATE_CHATTING => "chat",
|
|
Thread::STATE_CLOSED => "closed",
|
|
Thread::STATE_LOADING => "wait",
|
|
Thread::STATE_LEFT => "closed"
|
|
);
|
|
|
|
$threadstate_key = array(
|
|
Thread::STATE_QUEUE => "chat.thread.state_wait",
|
|
Thread::STATE_WAITING => "chat.thread.state_wait_for_another_agent",
|
|
Thread::STATE_CHATTING => "chat.thread.state_chatting_with_agent",
|
|
Thread::STATE_CLOSED => "chat.thread.state_closed",
|
|
Thread::STATE_LOADING => "chat.thread.state_loading"
|
|
);
|
|
|
|
function thread_to_xml($thread_info)
|
|
{
|
|
global $threadstate_to_string, $threadstate_key,
|
|
$webim_encoding, $operator, $can_viewthreads, $can_takeover;
|
|
|
|
$thread = $thread_info['thread'];
|
|
|
|
$state = $threadstate_to_string[$thread->state];
|
|
$result = "<thread id=\"" . $thread->id . "\" stateid=\"$state\"";
|
|
if ($state == "closed")
|
|
return $result . "/>";
|
|
|
|
$state = getstring($threadstate_key[$thread->state]);
|
|
$nextagent = $thread->nextAgent != 0 ? operator_by_id($thread->nextAgent) : null;
|
|
$threadoperator = $nextagent ? get_operator_name($nextagent)
|
|
: ($thread->agentName ? $thread->agentName : "-");
|
|
|
|
if ($threadoperator == "-" && $thread_info['groupname']) {
|
|
$threadoperator = "- " . $thread_info['groupname'] . " -";
|
|
}
|
|
|
|
if (!($thread->state == Thread::STATE_CHATTING && $thread->agentId != $operator['operatorid'] && !is_capable($can_takeover, $operator))) {
|
|
$result .= " canopen=\"true\"";
|
|
}
|
|
if ($thread->agentId != $operator['operatorid'] && $thread->nextAgent != $operator['operatorid']
|
|
&& is_capable($can_viewthreads, $operator)) {
|
|
$result .= " canview=\"true\"";
|
|
}
|
|
if (Settings::get('enableban') == "1") {
|
|
$result .= " canban=\"true\"";
|
|
}
|
|
|
|
$banForThread = Settings::get('enableban') == "1" ? ban_for_addr($thread->remote) : false;
|
|
if ($banForThread) {
|
|
$result .= " ban=\"blocked\" banid=\"" . $banForThread['banid'] . "\"";
|
|
}
|
|
|
|
$result .= " state=\"$state\" typing=\"" . $thread->userTyping . "\">";
|
|
$result .= "<name>";
|
|
if ($banForThread) {
|
|
$result .= htmlspecialchars(getstring('chat.client.spam.prefix'));
|
|
}
|
|
$result .= htmlspecialchars(
|
|
htmlspecialchars(get_user_name($thread->userName, $thread->remote, $thread->userId))
|
|
) . "</name>";
|
|
$result .= "<addr>" . htmlspecialchars(get_user_addr($thread->remote)) . "</addr>";
|
|
$result .= "<agent>" . htmlspecialchars(htmlspecialchars($threadoperator)) . "</agent>";
|
|
$result .= "<time>" . $thread->created . "000</time>";
|
|
$result .= "<modified>" . $thread->modified . "000</modified>";
|
|
|
|
if ($banForThread) {
|
|
$result .= "<reason>" . $banForThread['comment'] . "</reason>";
|
|
}
|
|
|
|
$userAgent = get_useragent_version($thread->userAgent);
|
|
$result .= "<useragent>" . $userAgent . "</useragent>";
|
|
if ($thread->shownMessageId != 0) {
|
|
$db = Database::getInstance();
|
|
$line = $db->query(
|
|
"select tmessage from {chatmessage} where messageid = ?",
|
|
array($thread->shownMessageId),
|
|
array('return_rows' => Database::RETURN_ONE_ROW)
|
|
);
|
|
if ($line) {
|
|
$message = preg_replace("/[\r\n\t]+/", " ", $line["tmessage"]);
|
|
$result .= "<message>" . htmlspecialchars(htmlspecialchars($message)) . "</message>";
|
|
}
|
|
}
|
|
$result .= "</thread>";
|
|
return $result;
|
|
}
|
|
|
|
function print_pending_threads($groupids, $since)
|
|
{
|
|
global $webim_encoding;
|
|
$db = Database::getInstance();
|
|
|
|
$revision = $since;
|
|
$query = "select {chatthread}.*, " .
|
|
"(select vclocalname from {chatgroup} where {chatgroup}.groupid = {chatthread}.groupid) as groupname " .
|
|
"from {chatthread} where lrevision > :since " .
|
|
($since <= 0
|
|
? "AND istate <> " . Thread::STATE_CLOSED . " AND istate <> " . Thread::STATE_LEFT . " "
|
|
: "") .
|
|
(Settings::get('enablegroups') == '1'
|
|
? "AND (groupid is NULL" . ($groupids
|
|
? " OR groupid IN ($groupids) OR groupid IN (SELECT parent FROM {chatgroup} WHERE groupid IN ($groupids)) "
|
|
: "") .
|
|
") "
|
|
: "") .
|
|
"ORDER BY threadid";
|
|
$rows = $db->query(
|
|
$query,
|
|
array(':since' => $since),
|
|
array('return_rows' => Database::RETURN_ALL_ROWS)
|
|
);
|
|
|
|
$output = array();
|
|
foreach ($rows as $row) {
|
|
$thread = Thread::createFromDbInfo($row);
|
|
$thread_info = array(
|
|
'thread' => $thread,
|
|
'groupName' => $row['groupname']
|
|
);
|
|
$thread_as_xml = thread_to_xml($thread_info);
|
|
$output[] = $thread_as_xml;
|
|
if ($thread->lastRevision > $revision) {
|
|
$revision = $thread->lastRevision;
|
|
}
|
|
}
|
|
|
|
echo "<threads revision=\"$revision\" time=\"" . time() . "000\">";
|
|
foreach ($output as $thr) {
|
|
print myiconv($webim_encoding, "utf-8", $thr);
|
|
}
|
|
echo "</threads>";
|
|
}
|
|
|
|
function print_operators($operator)
|
|
{
|
|
global $webim_encoding;
|
|
echo "<operators>";
|
|
|
|
$list_options = in_isolation($operator)?array('isolated_operator_id' => $operator['operatorid']):array();
|
|
$operators = get_operators_list($list_options);
|
|
|
|
foreach ($operators as $operator) {
|
|
if (!operator_is_online($operator))
|
|
continue;
|
|
|
|
$name = myiconv($webim_encoding, "utf-8", htmlspecialchars(htmlspecialchars($operator['vclocalename'])));
|
|
$away = operator_is_away($operator) ? " away=\"1\"" : "";
|
|
|
|
echo "<operator name=\"$name\"$away/>";
|
|
}
|
|
echo "</operators>";
|
|
}
|
|
|
|
function visitor_to_xml($visitor)
|
|
{
|
|
$result = "<visitor id=\"" . $visitor['visitorid'] . "\">";
|
|
|
|
// $result .= "<userid>" . htmlspecialchars($visitor['userid']) . "</userid>";
|
|
$result .= "<username>" . htmlspecialchars($visitor['username']) . "</username>";
|
|
|
|
$result .= "<time>" . $visitor['firsttime'] . "000</time>";
|
|
$result .= "<modified>" . $visitor['lasttime'] . "000</modified>";
|
|
// $result .= "<entry>" . htmlspecialchars($visitor['entry']) . "</entry>";
|
|
|
|
// $result .= "<path>";
|
|
// $path = track_retrieve_path($visitor);
|
|
// ksort($path);
|
|
// foreach ($path as $k => $v) {
|
|
// $result .= "<url visited=\"" . $k . "000\">" . htmlspecialchars($v) . "</url>";
|
|
// }
|
|
// $result .= "</path>";
|
|
|
|
$details = track_retrieve_details($visitor);
|
|
$userAgent = get_useragent_version($details['user_agent']);
|
|
$result .= "<useragent>" . $userAgent . "</useragent>";
|
|
$result .= "<addr>" . htmlspecialchars(get_user_addr($details['remote_host'])) . "</addr>";
|
|
|
|
$result .= "<invitations>" . $visitor['invitations'] . "</invitations>";
|
|
$result .= "<chats>" . $visitor['chats'] . "</chats>";
|
|
|
|
$result .= "<invitation>";
|
|
if ($visitor['invited']) {
|
|
$result .= "<invitationtime>" . $visitor['invitationtime'] . "000</invitationtime>";
|
|
$operator = get_operator_name(operator_by_id($visitor['invitedby']));
|
|
$result .= "<operator>" . htmlspecialchars(htmlspecialchars($operator)) . "</operator>";
|
|
}
|
|
$result .= "</invitation>";
|
|
|
|
$result .= "</visitor>";
|
|
return $result;
|
|
}
|
|
|
|
function print_visitors()
|
|
{
|
|
global $webim_encoding;
|
|
|
|
$db = Database::getInstance();
|
|
|
|
// Remove old visitors
|
|
$db->query(
|
|
"DELETE FROM {chatsitevisitor} " .
|
|
"WHERE (:now - lasttime) > :lifetime ".
|
|
"AND (threadid IS NULL OR " .
|
|
"(SELECT count(*) FROM {chatthread} WHERE threadid = {chatsitevisitor}.threadid " .
|
|
"AND istate <> " . Thread::STATE_CLOSED . " AND istate <> " . Thread::STATE_LEFT . ") = 0)",
|
|
array(
|
|
':lifetime' => Settings::get('tracking_lifetime'),
|
|
':now' => time()
|
|
)
|
|
);
|
|
|
|
// Remove old invitations
|
|
$db->query(
|
|
"UPDATE {chatsitevisitor} SET invited = 0, invitationtime = NULL, invitedby = NULL".
|
|
" WHERE threadid IS NULL AND (:now - invitationtime) > :lifetime",
|
|
array(
|
|
':lifetime' => Settings::get('invitation_lifetime'),
|
|
':now' => time()
|
|
)
|
|
);
|
|
|
|
// Remove associations of visitors with closed threads
|
|
$db->query(
|
|
"UPDATE {chatsitevisitor} SET threadid = NULL WHERE threadid IS NOT NULL AND" .
|
|
" (SELECT count(*) FROM {chatthread} WHERE threadid = {chatsitevisitor}.threadid" .
|
|
" AND istate <> " . Thread::STATE_CLOSED . " AND istate <> " . Thread::STATE_LEFT . ") = 0"
|
|
);
|
|
|
|
// Remove old visitors' tracks
|
|
$db->query(
|
|
"DELETE FROM {visitedpage} WHERE (:now - visittime) > :lifetime " .
|
|
" AND visitorid NOT IN (SELECT visitorid FROM {chatsitevisitor})",
|
|
array(
|
|
':lifetime' => Settings::get('tracking_lifetime'),
|
|
':now' => time()
|
|
)
|
|
);
|
|
|
|
$query = "SELECT visitorid, userid, username, firsttime, lasttime, " .
|
|
"entry, details, invited, invitationtime, invitedby, invitations, chats " .
|
|
"FROM {chatsitevisitor} " .
|
|
"WHERE threadid IS NULL " .
|
|
"ORDER BY invited, lasttime DESC, invitations";
|
|
$query .= (Settings::get('visitors_limit') == '0') ? "" : " LIMIT " . Settings::get('visitors_limit');
|
|
|
|
$rows = $db->query($query, NULL, array('return_rows' => Database::RETURN_ALL_ROWS));
|
|
|
|
$output = array();
|
|
foreach ($rows as $row) {
|
|
$visitor = visitor_to_xml($row);
|
|
$output[] = $visitor;
|
|
}
|
|
|
|
echo "<visitors>";
|
|
foreach ($output as $thr) {
|
|
print myiconv($webim_encoding, "utf-8", $thr);
|
|
}
|
|
echo "</visitors>";
|
|
}
|
|
|
|
$since = verifyparam("since", "/^\d{1,9}$/", 0);
|
|
$status = verifyparam("status", "/^\d{1,2}$/", 0);
|
|
$showonline = verifyparam("showonline", "/^1$/", 0);
|
|
$showvisitors = verifyparam("showvisitors", "/^1$/", 0);
|
|
|
|
if (!isset($_SESSION["${mysqlprefix}operatorgroups"])) {
|
|
$_SESSION["${mysqlprefix}operatorgroups"] = get_operator_groupslist($operator['operatorid']);
|
|
}
|
|
Thread::closeOldThreads();
|
|
$groupids = $_SESSION["${mysqlprefix}operatorgroups"];
|
|
|
|
start_xml_output();
|
|
echo '<update>';
|
|
if ($showonline) {
|
|
print_operators($operator);
|
|
}
|
|
print_pending_threads($groupids, $since);
|
|
if ($showvisitors) {
|
|
print_visitors();
|
|
}
|
|
echo '</update>';
|
|
notify_operator_alive($operator['operatorid'], $status);
|
|
exit;
|
|
|
|
?>
|