"user", $kind_agent => "agent", $kind_info => "inf", $kind_conn => "conn", $kind_events => "event" ); function next_token() { return rand(99999,99999999); } function next_revision($link) { perform_query("update chatrevision set id=LAST_INSERT_ID(id+1)",$link); $val = mysql_insert_id($link); return $val; } function post_message($threadid,$kind,$message,$from=null) { $link = connect(); $query = sprintf( "insert into chatmessage (threadid,ikind,tmessage,tname,dtmcreated) values (%s, %s,'%s',%s,CURRENT_TIMESTAMP)", $threadid, $kind, mysql_real_escape_string($message), $from ? "'".mysql_real_escape_string($from)."'" : "null" ); perform_query($query,$link); mysql_close($link); } function prepare_html_message($text) { $escaped_text = htmlspecialchars($text); $text_w_links = preg_replace('/(http|ftp):\/\/\S*/','$0',$escaped_text); $multiline = str_replace("\n","
",$text_w_links); return $multiline; } function message_to_html($msg) { global $kind_to_string; $message = "".date("H:i:s",$msg['created'])." "; $kind = $kind_to_string{$msg['ikind']}; if( $msg['tname'] ) $message.= "".htmlspecialchars($msg['tname']).": "; $message.= "".prepare_html_message($msg['tmessage'])."
"; return $message; } function message_to_text($msg) { global $kind_user, $kind_agent, $kind_info; $time = date("H:i:s ",$msg['created']); if($msg['ikind'] == $kind_user || $msg['ikind'] == $kind_agent) { if( $msg['tname'] ) return $time.$msg['tname'].": ".$msg['tmessage']."\n"; else return $time.$msg['tmessage']."\n"; } else if($msg['ikind'] == $kind_info ) { return $time.$msg['tmessage']."\n"; } else { return $time."[".$msg['tmessage']."]\n"; } } function get_messages($threadid,$meth,&$lastid) { $link = connect(); $query = sprintf( "select messageid,ikind,unix_timestamp(dtmcreated) as created,tname,tmessage from chatmessage ". "where threadid = %s and messageid > %s order by messageid", $threadid, $lastid ); $messages = array(); $result = mysql_query($query,$link) or die(' Query failed: ' .mysql_error().": ".$query); while ($msg = mysql_fetch_array($result, MYSQL_ASSOC)) { $message = ($meth == 'text') ? message_to_text($msg) : message_to_html($msg); $messages[] = $message; if( $msg['messageid'] > $lastid ) $lastid = $msg['messageid']; } mysql_free_result($result); mysql_close($link); return $messages; } function print_thread_mesages($threadid, $token, $lastid, $isuser,$format) { global $webim_encoding, $webimroot; $output = get_messages( $threadid, "html", $lastid ); if( $format == "xml" ) { start_xml_output(); print(""); foreach( $output as $msg ) { print "".myiconv($webim_encoding,"utf-8",escape_with_cdata($msg))."\n"; } print(""); } else if( $format == "html" ) { start_html_output(); $url = "$webimroot/thread.php?act=refresh&thread=$threadid&token=$token&html=on&user=".($isuser?"true":"false"); print("\n". "\n". "\n". "\n". "". "". "

" ); foreach( $output as $msg ) { print $msg; } print( "

". "" ); } } function setup_chatview_for_user($thread,$level) { global $page, $webimroot; $page = array(); $page['agent'] = false; $page['user'] = true; $page['canpost'] = true; $nameisset = getstring("chat.default.username") != $thread['userName']; $page['displ1'] = $nameisset ? "none" : "inline"; $page['displ2'] = $nameisset ? "inline" : "none"; $page['level'] = $level; $page['ct.chatThreadId'] = $thread['threadid']; $page['ct.token'] = $thread['ltoken']; $page['ct.user.name'] = $thread['userName']; $page['ct.company.name'] = "Test company"; // TODO $page['ct.company.chatLogoURL'] = ""; // TODO $params = "thread=".$thread['threadid']."&token=".$thread['ltoken']; $page['selfLink'] = "$webimroot/client.php?".$params."&level=".$level; } function setup_chatview_for_operator($thread) { global $page; $page = array(); $page['agent'] = true; $page['user'] = false; $page['canpost'] = true; $page['ct.chatThreadId'] = $thread['threadid']; $page['ct.token'] = $thread['ltoken']; $page['ct.user.name'] = $thread['userName']; $page['ct.company.name'] = "Test company"; $page['ct.company.chatLogoURL'] = ""; } function is_ajax_browser($name,$ver,$useragent) { if( $name == "opera" ) return $ver >= 8.02; if( $name == "safari" ) return $ver >= 125; if( $name == "msie" ) return $ver >= 5.5 && !strstr($useragent, "powerpc"); if( $name == "netscape" ) return $ver >= 7.1; if( $name == "mozilla") return $ver >= 1.4; if( $name == "firefox") return $ver >= 1.0; return false; } function is_old_browser($name,$ver) { if( $name == "opera" ) return $ver < 7.0; if( $name == "msie" ) return $ver < 5.0; return false; } $knownAgents = array("opera","msie","safari","firefox","netscape","mozilla"); function get_remote_level($useragent) { global $knownAgents; $useragent = strtolower($useragent); foreach( $knownAgents as $agent ) { if( strstr($useragent,$agent) ) { if( preg_match( "/".$agent."[\\s\/]?(\\d+(\\.\\d+)?)/", $useragent, $matches ) ) { $ver = $matches[1]; if( is_ajax_browser($agent,$ver,$useragent) ) return "ajaxed"; else if( is_old_browser($agent,$ver) ) return "old"; return "simple"; } } } return "simple"; } function ping_thread($thread, $isuser) { $link = connect(); $query = sprintf( "update chatthread set %s = CURRENT_TIMESTAMP where threadid = %s", $isuser ? "lastpinguser" : "lastpingagent", $thread['threadid']); perform_query($query,$link); mysql_close($link); } function commit_thread($threadid,$params,$link) { $query = "update chatthread set lrevision = ".next_revision($link); foreach( $params as $k => $v ) { $query .= ", ".$k."=".$v; } $query .= " where threadid = ".$threadid; perform_query($query,$link); } function rename_user($thread, $newname) { global $kind_events; $link = connect(); commit_thread( $thread['threadid'], array('userName' => "'".mysql_real_escape_string($newname)."'"), $link); mysql_close($link); if( $thread['userName'] != $newname ) { post_message($thread['threadid'],$kind_events, getstring2_("chat.status.user.changedname",array($thread['userName'], $newname), $thread['locale'])); } } function close_thread($thread,$isuser) { global $state_closed, $kind_events; if( $thread['istate'] != $state_closed ) { $link = connect(); commit_thread( $thread['threadid'], array('istate' => $state_closed), $link); mysql_close($link); } $message = $isuser ? getstring2_("chat.status.user.left", array($thread['userName']), $thread['locale']) : getstring2_("chat.status.operator.left", array($thread['agentName']), $thread['locale']); post_message($thread['threadid'], $kind_events, $message); } function create_thread($username,$remote,$referer,$lang) { $link = connect(); $query = sprintf( "insert into chatthread (userName,ltoken,remote,referer,lrevision,locale,dtmcreated,dtmmodified) values ('%s',%s,'%s','%s',%s,'%s',CURRENT_TIMESTAMP,CURRENT_TIMESTAMP)", mysql_real_escape_string($username), next_token(), mysql_real_escape_string($remote), mysql_real_escape_string($referer), next_revision($link), mysql_real_escape_string($lang) ); perform_query($query,$link); $id = mysql_insert_id($link); $newthread = select_one_row("select * from chatthread where threadid = ". $id, $link ); mysql_close($link); return $newthread; } function do_take_thread($threadid,$operator) { global $state_chatting; $link = connect(); commit_thread( $threadid, array("istate" => $state_chatting, "agentName" => "'".mysql_real_escape_string($operator)."'"), $link); mysql_close($link); } function reopen_thread($threadid) { global $state_queue,$state_waiting,$state_chatting,$kind_events; $thread = thread_by_id($threadid); if( !$thread ) return FALSE; if( $thread['istate'] != $state_chatting && $thread['istate'] != $state_queue ) { $link = connect(); commit_thread( $threadid, array("istate" => $state_waiting), $link); mysql_close($link); } post_message($thread['threadid'], $kind_events, getstring_("chat.status.user.reopenedthread", $thread['locale'])); return $thread; } function take_thread($thread,$operator) { global $state_queue, $state_waiting, $state_chatting, $kind_events; $state = $thread['istate']; $threadid = $thread['threadid']; $message_to_post = ""; if( $state == $state_queue || $state == $state_waiting) { do_take_thread($threadid, $operator); $message_to_post = getstring2_("chat.status.operator.joined", array($operator), $thread['locale']); } else if( $state == $state_chatting ) { if( $operator != $thread['agentName'] ) { do_take_thread($threadid, $operator); $message_to_post = getstring2_("chat.status.operator.changed", array($operator, $thread['agentName']), $thread['locale']); } } else { die("cannot take thread"); } if( $message_to_post ) post_message($threadid,$kind_events,$message_to_post); } function thread_by_id($id) { $link = connect(); $thread = select_one_row("select * from chatthread where threadid = ". $id, $link ); mysql_close($link); return $thread; } ?>