<?php
/**
*
* @ This file is created by deZender.Net
* @ deZender (PHP5 Decoder for ionCube Loader)
*
* @	Version			:	2.0.0.3
* @	Author			:	DeZender
* @	Release on		:	06.05.2013
* @	Official site	:	http://DeZender.Net
*
*/

function getEvents() {

	global $db;
	global $vars;
	$totalEvents = "0";
	$query = "SELECT * FROM servers WHERE active IS TRUE AND status IS TRUE";
	$serversCount = $db->numRows($query);
	foreach (@$db->getAssoc($query) as $sId => $server)
	{
		$data = "";
		$fp = fopen("http://" . $server["server_ip"] . ":" . $server["server_hitrow_port"] . "/api/events", "r", false, $vars["context"]);
		if ($fp)
		{
			while ($row = @fread($fp, 8192))
			{
				$data .= $row;
				continue;
			}
			$mess .= "Connected to server " . $server["server_host"] . ", reading data
";
		}
		 else
		{
			$mess .= "Can't read data from server " . $server["server_host"] . "\n";
		}
		if (is_array(json_decode($data)))
		{
			foreach (json_decode($data) as $eId => $event)
			{
				$query = "SELECT * FROM logs WHERE message like '%EventID #" . $event->event_id . "#%'";
				if (!("5" <= $event->time_connected))
				{
					continue;
				}
				if (!(trim($event->event_type_id) == "2" && 1000000 <= $event->user_id))
				{
					continue;
				}
				$query = "INSERT INTO logs ( logtype, module, message ) VALUES ( 'INFO', 'EVENTS', 'EventID #" . $event->event_id . "#, Customer <strong>" . $event->user_name . "</strong>, Device " . $event->device_name . ", Channel <strong>" . $event->channel_name . "</strong>, Time " . trim(s2h($event["time_connected"])) . ", Server " . $server["server_name"] . ", ConnID #" . $event->connection_id . "#, ConnIP <strong>" . $event->connection_ip . "' ) ";
				$db->query($query);
				++$totalEvents;
				continue;
			}
		}
		file_get_contents("http://" . $server["server_ip"] . ":" . $server["server_hitrow_port"] . "/api/events?clear=true");
		continue;
	}
	$mess .= "Imported " . $totalEvents . " events from " . $serversCount . " servers.
";
	return $mess;
}

function userDisconnected() {

	$deviceId = $_REQUEST["deviceId"];
	$userId = $_REQUEST["userId"];
	$channelId = $_REQUEST["channelId"];
	$channelName = $_REQUEST["channelName"];
	$clientName = $_REQUEST["clientName"];
	$startTime = $_REQUEST["startTime"];
	$endTime = $_REQUEST["endTime"];
	$currentTime = $_REQUEST["currentTime"];
	$currentCMSTime = @strtotime(date("Y-m-d H:i:s"));
	$timeDiff = $currentCMSTime - $currentTime;
	$rightCurrentTime = $currentTime + $timeDiff;
	$rightStartTime = $startTime + $timeDiff;
	$rightEndTime = $endTime + $timeDiff;
	$duration = $rightEndTime - $rightStartTime;
	$message = "Customer <strong>" . $clientName . "</strong> ( #" . $userId . " ) with device ID <strong>#" . $deviceId . "</strong> watched channel <strong>" . $channelName . "</strong> ( #" . $channelId . " ) for " . trim(s2h($duration)) . " starting " . date("Y-m-d H:i:s", $rightStartTime);
	addLog("INFO", "USERCONN", $message);
	exit("OK");
	return;
}

function updateSorting($sort = null) {

	if (!$sort)
	{
		exit();
	}
	global $db;
	global $vars;
	$query = "SELECT * FROM servers WHERE active IS TRUE";
	foreach ($db->getAssoc($query) as $sId => $server)
	{
		if (!checkServer($sId))
		{
			continue;
		}
		$data = "";
		$fp = fopen("http://" . $server["server_ip"] . ":" . $server["server_hitrow_port"] . "/api/set/playlistOrder?order=" . $sort, "r", false, $vars["context"]);
		continue;
	}
	return;
}

function apiConnect() {

	if (!checkUserType("ADMIN") && !checkUserType("RESELLER"))
	{
		header("Location: " . siteDomain . "profile");
	}
	global $db;
	global $vars;
	$query = "SELECT * FROM servers WHERE active IS TRUE";
	foreach ($db->getAssoc($query) as $sId => $server)
	{
		if (!checkServer($sId))
		{
			continue;
		}
		$data = "";
		$fp = fopen("http://" . $server["server_ip"] . ":" . $server["server_hitrow_port"] . "/api/info", "r", false, $vars["context"]);
		if ($fp)
		{
			while ($row = @fread($fp, 8192))
			{
				$data .= $row;
				continue;
			}
		}
		if (!$data)
		{
			continue;
		}
		$vars["apidata"][$sId] = json_decode($data);
		$vars["apidata"][$sId]->info->cms_time = strtotime(date("Y-m-d H:i:s"));
		$vars["apidata"][$sId]->info->time_diff = $vars["apidata"][$sId]->info->cms_time - $vars["apidata"][$sId]->info->currentDate;
		continue;
	}
	return $vars["apidata"];
}

function processChannels() {

	global $vars;
	global $db;
	if ($vars["apidata"])
	{
		foreach ($vars["apidata"] as $sId => $server)
		{
			if (!$server->channels)
			{
				continue;
			}
			foreach ($server->channels as $cId => $channel)
			{
				if (!(!(isAdmin()) && (@isReseller() || array_search($channel->channelId, $vars["allowed_channels"]))))
				{
					continue;
				}
				if (!(!($channel->transcode) || $channel->stream))
				{
					continue;
				}
				$vars["channels"][$channel->channelId]["channel_name"] = $channel->channelName;
				$vars["channels"][$channel->channelId]["channel_state"] = $channel->channelState;
				$vars["channels"][$channel->channelId]["transcode_server"] = $channel->transcodeServer;
				$vars["channels"][$channel->channelId]["transcode_server_id"] = $channel->transcodeServerID;
				$vars["channels"][$channel->channelId]["stream_server"] = $channel->streamServer;
				$vars["channels"][$channel->channelId]["stream_server_id"] = $channel->streamServerID;
				$up = explode(",", $channel["uptimeData"]);
				if ($channel->transcodeServerID == $sId)
				{
..............................................................
..................................
.............