fb_chat.php

<?php
/**
 * @file
 * Class installation to handle ajax request arrived from area Frontend.
 *
 * TODO: use fb_chat_json_encode() to generate output.
 */

require_once("../../class2.php");

if(!e107::isInstalled('fb_chat'))
{
	exit;
}

// Include main fb_chat class.
e107_require_once("classes/fb_chat_main.class.php");

// [PLUGINS]/fb_chat/languages/[LANGUAGE]/[LANGUAGE]_front.php
e107::lan('fb_chat', false, true);

// Start session if required.
if(!session_id())
{
	session_start();
}


/**
 * fb_chat class
 *
 * Handling Ajax Requests arrived from area Frontend.
 */
class fb_chat extends fb_chat_main
{

	protected $plugPrefs = array();

	public function __construct()
	{
		$this->plugPrefs = e107::getPlugConfig('fb_chat')->getPref();

		if(!$this->check_permission())
		{
			exit;
		}

		if(!isset($_SESSION['chatHistory']))
		{
			$_SESSION['chatHistory'] = array();
		}

		if(!isset($_SESSION['openChatBoxes']))
		{
			$_SESSION['openChatBoxes'] = array();
		}

		/**
		 * 1 - startchatsession
		 * 2 - chatheartbeat
		 * 3 - closechat
		 * 4 - sendchat
		 * 5 - get username
		 * 6 - get (normal) menu content
		 * 7 - get (floating) menu content
		 * 8 - Turn chat on
		 * 9 - Turn chat off
		 */
		$action = (int) $_GET['a'];

		switch($action)
		{
			case 1:
				$this->chat_start_session();
				break;
			case 2:
				$this->chat_heartbeat();
				break;
			case 3:
				$this->chat_close();
				break;
			case 4:
				$this->chat_send((int) $_POST['to'], $_POST['message']);
				break;
			case 5:
				$this->get_user_name((int) $_POST['tid']);
				break;
			case 6:
				$this->get_online_list(0);
				break;
			case 7:
				$this->get_online_list(1);
				break;
			case 8:
				$this->turn_chat_on();
				break;
			case 9:
				$this->turn_chat_off();
				break;
			default:
				exit;
		}
	}

	/**
	 * Start Chat Session
	 * - Get opened chat windows from session and push them as json output
	 *   with the current user details.
	 *
	 * @param string $items
	 */
	public function chat_start_session($items = "")
	{
		if(!empty($_SESSION['openChatBoxes']))
		{
			foreach($_SESSION['openChatBoxes'] as $chatbox => $void)
			{
				$items .= $this->chat_box_session($chatbox);
			}
		}

		if(!empty($items))
		{
			$items = substr($items, 0, -1);
		}

		$row = e107::user(USERID);
		$name = $this->get_user_name_by_names($row['user_name'], $row['user_login']);

		header('Content-type: application/json');
		echo '{ "user": { "id": "' . USERID . '", "name": "' . $name . '" }, "items": [' . $items . '] }';
		exit;
	}

	/**
	 * Chat Heartbeat
	 * - Get unread messages from DB and append them to the output string
	 *   and to session history
	 * - Create last message item (after a specified inactivity) and append
	 *   it to the output string and to session history
	 * - Update messages in DB
	 * - Push output string as json
	 *
	 * @param string $items
	 */
	public function chat_heartbeat($items = "")
	{
		$rows = $this->get_new_messages(USERID);
		foreach($rows as $row)
		{
			$fid = $row['fb_chat_from'];
			$fnm = $this->get_user_name_by_names($row['user_name'], $row['user_login']);
			$msg = $this->handle_output($row['fb_chat_msg']);
			$snt = $row['fb_chat_sent'];

			if(!isset($_SESSION['openChatBoxes'][$fid]) && isset($_SESSION['chatHistory'][$fid]))
			{
				$items = $_SESSION['chatHistory'][$fid];
			}

			$items .= '{ "s": "0", "f": { "id": "' . $fid . '", "name": "' . $fnm . '" }, "m": "' . $msg . '" },';

			if(!isset($_SESSION['chatHistory'][$fid]))
			{
				$_SESSION['chatHistory'][$fid] = '';
			}

			$_SESSION['chatHistory'][$fid] .= '{ "s": "0", "f": { "id": "' . $fid . '", "name": "' . $fnm . '" }, "m": "' . $msg . '" },';

			if(isset($_SESSION['tsChatBoxes'][$fid]))
			{
				unset($_SESSION['tsChatBoxes'][$fid]);
			}

			$_SESSION['openChatBoxes'][$fid] = $snt;
		}

		// Last message...
		if(!empty($_SESSION['openChatBoxes']))
		{
			foreach($_SESSION['openChatBoxes'] as $chatbox => $time)
			{
				if(!isset($_SESSION['tsChatBoxes'][$chatbox]))
				{
					$now = time() - $time;

					$gen = e107::getDate();
					$df = vartrue($this->plugPrefs['fb_chat_date_format'], "short");
					$time_s = $gen->convert_date($time, $df);

					$message = LANF_FB_CHAT_03 . " " . $time_s;
					if($now > 180)
					{
						$items .= '{ "s": "2", "f": { "id": "' . $chatbox . '" }, "m": "' . $message . '" },';

						if(!isset($_SESSION['chatHistory'][$chatbox]))
						{
							$_SESSION['chatHistory'][$chatbox] = '';
						}

						$_SESSION['chatHistory'][$chatbox] .= '{ "s": "2", "f": { "id": "' . $chatbox . '" }, "m": "' . $message . '" },';
						$_SESSION['tsChatBoxes'][$chatbox] = 1;
					}
				}
			}
		}

		$update = array(
			'fb_chat_rcd' => 1,
			'WHERE'       => 'fb_chat_to = ' . USERID . ' AND fb_chat_rcd = 0',
		);

		e107::getDb()->update("fb_chat", $update);

		if(!empty($items))
		{
			$items = substr($items, 0, -1);
		}

		header('Content-type: application/json');
		echo '{"items": [' . $items . ']}';
		exit;
	}

	/**
	 * Send chat message to a user
	 * - Parse the message with toDB method
	 * - Insert the message into DB
	 * - Create output HTML from parsed message
	 * - Append message details to session and push output as json
	 *
	 * @param int $to
	 *  User ID addressed to.
	 * @param string $msg
	 *  The message that will be sent.
	 * @param int $from (optional)
	 *  User ID of the sender
	 */
	public function chat_send($to = 0, $msg = "", $from = USERID)
	{
		if((int) $to === 0 || (int) $from === 0)
		{
			exit;
		}

		// Parse input string
		$msg = e107::getParser()->toDB($msg);

		// Insert parsed message into DB.
		$arg = array(
			"fb_chat_from" => (int) $from,
			"fb_chat_to"   => $to,
			"fb_chat_msg"  => $msg,
			"fb_chat_sent" => time(),
		);
		e107::getDb()->insert('fb_chat', $arg);

		// Create output HTML message
		$message = $this->handle_output($msg);

		// Get display name of the sender
		$row = e107::user((int) $from);
		$name = $this->get_user_name_by_names($row['user_name'], $row['user_login']);

		$_SESSION['openChatBoxes'][$to] = time();
		if(!isset($_SESSION['chatHistory'][$to]))
		{
			$_SESSION['chatHistory'][$to] = '';
		}

		$_SESSION['chatHistory'][$to] .= '{ "s": "1", "f": { "id": "' . $to . '", "name": "' . $name . '" } , "m": "' . $message . '" },';
		unset($_SESSION['tsChatBoxes'][$to]);

		header('Content-type: application/json');
		echo '{ "f": "' . $name . '", "m": "' . $message . '" }';
		exit;
	}

	/**
	 * Close chat session
	 */
	public function chat_close()
	{
		unset($_SESSION['openChatBoxes'][$_POST['chatbox']]);
		echo "1";
		exit;
	}

	/**
	 * Get chat history from session
	 *
	 * @param int $chatbox
	 *  Chat partner (User ID) of the current user.
	 * @param string $items
	 *  Chat history, json formatted string
	 * @return string $items
	 *  Chat history, json formatted string
	 */
	public function chat_box_session($chatbox, $items = "")
	{
		if(isset($_SESSION['chatHistory'][$chatbox]))
		{
			$items = $_SESSION['chatHistory'][$chatbox];
		}
		return $items;
	}

	/**
	 * Get the user display name (user_name or user_login)
	 *
	 * @param int $uid
	 *  User ID
	 */
	public function get_user_name($uid = 0)
	{
		if((int) $uid === 0)
		{
			exit;
		}

		$link = vartrue($this->plugPrefs['fb_chat_title_link'], 1);
		$row = e107::user(intval($uid));
		$name = $this->get_user_name_by_names($row['user_name'], $row['user_login']);

		if((boolean) $link)
		{
			$name = "<a href='" . SITEURL . "user.php?id." . (int) $uid . "' target='_self'>" . $name . "</a>";
		}

		header('Content-type: application/json');
		echo '{"name": "' . $name . '"}';
		exit;
	}

	/**
	 * Get a HTML list with online users
	 * - Get online user from DB
	 * - Create HTML list
	 * - Push output HTML
	 */
	public function get_online_list($mode = 0)
	{
		$template = e107::getTemplate('fb_chat');
		$sc = e107::getScBatch('fb_chat', true);
		$tp = e107::getParser();

		$users = $this->get_online_users();
		$menu = "";

		if(!empty($users))
		{
			if((int) $mode === 0)
			{
				$menu .= $tp->parseTemplate($template['MENU_START']);
				foreach($users as $user)
				{
					$sc->setVars($user);
					$menu .= $tp->parseTemplate($template['MENU_ITEM'], true, $sc);
				}
				$menu .= $tp->parseTemplate($template['MENU_END']);
			}

			if((int) $mode === 1)
			{
				$menu .= $tp->parseTemplate($template['FLOAT_MENU_START']);
				foreach($users as $user)
				{
					$sc->setVars($user);
					$menu .= $tp->parseTemplate($template['FLOAT_MENU_ITEM'], true, $sc);
				}
				$menu .= $tp->parseTemplate($template['FLOAT_MENU_END']);
			}
		}

		header('Content-Type: text/html; charset=utf-8');
		echo $menu;
		exit;
	}

	/**
	 * Turn on chat by current user.
	 * Delete record from "turned off" table.
	 */
	public function turn_chat_on()
	{
		e107::getDb()
			->delete("fb_chat_turnedoff", "fb_chat_turnedoff_uid = " . USERID);
	}

	/**
	 * Turn off chat by crrent user.
	 * Insert row into "turned off" table.
	 */
	public function turn_chat_off()
	{
		$arg = array("fb_chat_turnedoff_uid" => USERID);
		e107::getDb()->insert('fb_chat_turnedoff', $arg);
	}

}


// Class installation.
new fb_chat;