<?


if(!check_perms('site_torrents_notify')) {
	print
		json_encode(
			array(
				'status' => 'failure'
			)
		);
	die();
}

define('NOTIFICATIONS_PER_PAGE', 50);
list($Page,$Limit) = Format::page_limit(NOTIFICATIONS_PER_PAGE);

$Results = $DB->query("SELECT SQL_CALC_FOUND_ROWS unt.TorrentID, unt.UnRead, unt.FilterID, unf.Label, t.GroupID
		FROM users_notify_torrents AS unt
		JOIN torrents AS t ON t.ID = unt.TorrentID
		LEFT JOIN users_notify_filters AS unf ON unf.ID = unt.FilterID
		WHERE unt.UserID=$LoggedUser[ID]".
		((!empty($_GET['filterid']) && is_number($_GET['filterid']))
			? " AND unf.ID='$_GET[filterid]'"
			: "")."
		ORDER BY TorrentID DESC LIMIT $Limit");
$GroupIDs = array_unique($DB->collect('GroupID'));

$DB->query('SELECT FOUND_ROWS()');
list($TorrentCount) = $DB->next_record();

if(count($GroupIDs)) {
	$TorrentGroups = Torrents::get_groups($GroupIDs);
	$TorrentGroups = $TorrentGroups['matches'];

	// Need some extra info that Torrents::get_groups() doesn't return
	$DB->query("SELECT ID, CategoryID FROM torrents_group WHERE ID IN (".implode(',', $GroupIDs).")");
	$GroupCategoryIDs = $DB->to_array('ID', MYSQLI_ASSOC, false);

	$DB->query("UPDATE users_notify_torrents SET UnRead='0' WHERE UserID=".$LoggedUser['ID']);
	$Cache->delete_value('notifications_new_'.$LoggedUser['ID']);
}

$DB->set_query_id($Results);

$JsonNotifications = array();
$NumNew = 0;

$FilterGroups = array();
while($Result = $DB->next_record(MYSQLI_ASSOC)) {
	if(!$Result['FilterID']) {
		$Result['FilterID'] = 0;
	}
	if(!isset($FilterGroups[$Result['FilterID']])) {
		$FilterGroups[$Result['FilterID']] = array();
		$FilterGroups[$Result['FilterID']]['FilterLabel'] = $Result['Label'] ? $Result['Label'] : false;
	}
	array_push($FilterGroups[$Result['FilterID']], $Result);
}
unset($Result);

foreach($FilterGroups as $FilterID => $FilterResults) {
	unset($FilterResults['FilterLabel']);
	foreach($FilterResults as $Result) {
		$TorrentID = $Result['TorrentID'];
		$GroupID = $Result['GroupID'];
		$GroupCategoryID = $GroupCategoryIDs[$GroupID]['CategoryID'];

		$GroupInfo = $TorrentGroups[$Result['GroupID']];
		$TorrentInfo = $GroupInfo['Torrents'][$TorrentID];

		if ($Result['UnRead'] == 1) $NumNew++;
		
		$JsonNotifications[] = array(
			'torrentId' => (int) $TorrentID,
			'groupId' => (int) $GroupID,
			'groupName' => $GroupInfo['Name'],
			'groupCategoryId' => (int) $GroupCategoryID,
			'torrentTags' => $GroupInfo['TagList'],
			'size' => (float) $TorrentInfo['Size'],
			'fileCount' => (int) $TorrentInfo['FileCount'],
			'format' => $TorrentInfo['Format'],
			'encoding' => $TorrentInfo['Encoding'],
			'media' => $TorrentInfo['Media'],
			'scene' => $TorrentInfo['Scene'] == 1,
			'groupYear' => (int) $GroupInfo['Year'],
			'remasterYear' => (int) $TorrentInfo['RemasterYear'],
			'remasterTitle' => $TorrentInfo['RemasterTitle'],
			'snatched' => (int) $TorrentInfo['Snatched'],
			'seeders' => (int) $TorrentInfo['Seeders'],
			'leechers' => (int) $TorrentInfo['Leechers'],
			'notificationTime' => $TorrentInfo['Time'],
			'hasLog' => $TorrentInfo['HasLog'] == 1,
			'hasCue' => $TorrentInfo['HasCue'] == 1,
			'logScore' => (float) $TorrentInfo['LogScore'],
			'freeTorrent' => $TorrentInfo['FreeTorrent'] == 1,
			'logInDb' => $TorrentInfo['HasLog'] == 1,
			'unread' => $Result['UnRead'] == 1
		);
	}
}

print
	json_encode(
		array(
			'status' => 'success',
			'response' => array(
				'currentPages' => intval($Page),
				'pages' => ceil($TorrentCount/NOTIFICATIONS_PER_PAGE),
				'numNew' => $NumNew,
				'results' => $JsonNotifications
			)
		)
	);

?>