'UserWatchStats',
'enabled' => true,
'image' => 'plugins/images/homepage/userWatchStats.png',
'category' => 'Media Server',
'settingsArray' => __FUNCTION__
];
if ($infoOnly) {
return $homepageInformation;
}
$homepageSettings = [
'debug' => true,
'settings' => [
'Enable' => [
$this->settingsOption('enable', 'homepageUserWatchStatsEnabled'),
$this->settingsOption('auth', 'homepageUserWatchStatsAuth'),
],
'Connection' => [
$this->settingsOption('select', 'homepageUserWatchStatsService', ['label' => 'Media Server', 'options' => [
['name' => 'Plex (via Tautulli)', 'value' => 'plex'],
['name' => 'Emby', 'value' => 'emby'],
['name' => 'Jellyfin', 'value' => 'jellyfin']
]]),
$this->settingsOption('url', 'homepageUserWatchStatsURL'),
$this->settingsOption('token', 'homepageUserWatchStatsToken'),
$this->settingsOption('disable-cert-check', 'homepageUserWatchStatsDisableCertCheck'),
$this->settingsOption('use-custom-certificate', 'homepageUserWatchStatsUseCustomCertificate'),
],
'Display Options' => [
$this->settingsOption('number', 'homepageUserWatchStatsRefresh', ['label' => 'Auto-refresh Interval (minutes)', 'min' => 1, 'max' => 60]),
$this->settingsOption('number', 'homepageUserWatchStatsDays', ['label' => 'Statistics Period (days)', 'min' => 1, 'max' => 365]),
$this->settingsOption('switch', 'homepageUserWatchStatsCompactView', ['label' => 'Use Compact View']),
$this->settingsOption('switch', 'homepageUserWatchStatsShowTopUsers', ['label' => 'Show Top Users']),
$this->settingsOption('switch', 'homepageUserWatchStatsShowMostWatched', ['label' => 'Show Most Watched']),
$this->settingsOption('switch', 'homepageUserWatchStatsShowRecentActivity', ['label' => 'Show Recent Activity']),
$this->settingsOption('number', 'homepageUserWatchStatsMaxItems', ['label' => 'Maximum Items to Display', 'min' => 5, 'max' => 50]),
],
'Test Connection' => [
$this->settingsOption('blank', null, ['label' => 'Please Save before Testing']),
$this->settingsOption('test', 'userWatchStats'),
]
]
];
return array_merge($homepageInformation, $homepageSettings);
}
public function testConnectionUserWatchStats()
{
if (!$this->homepageItemPermissions($this->userWatchStatsHomepagePermissions('test'), true)) {
return false;
}
$mediaServer = $this->config['homepageUserWatchStatsService'] ?? 'plex';
// Get URL and token from plugin-specific config
$url = $this->config['homepageUserWatchStatsURL'] ?? '';
$token = $this->config['homepageUserWatchStatsToken'] ?? '';
$disableCert = $this->config['homepageUserWatchStatsDisableCertCheck'] ?? false;
$customCert = $this->config['homepageUserWatchStatsUseCustomCertificate'] ?? false;
if (empty($url) || empty($token)) {
$serverName = ucfirst($mediaServer) . ($mediaServer === 'plex' ? ' (Tautulli)' : '');
$this->setAPIResponse('error', $serverName . ' URL or API key not configured', 500);
return false;
}
// Test the connection based on media server type
try {
$options = $this->requestOptions($url, null, $disableCert, $customCert);
switch (strtolower($mediaServer)) {
case 'plex':
// Test Tautulli connection
$testUrl = $this->qualifyURL($url) . '/api/v2?apikey=' . $token . '&cmd=get_server_info';
$response = Requests::get($testUrl, [], $options);
if ($response->success) {
$data = json_decode($response->body, true);
if (isset($data['response']['result']) && $data['response']['result'] === 'success') {
$this->setAPIResponse('success', 'Successfully connected to Tautulli', 200);
return true;
}
}
break;
case 'emby':
// Test Emby connection
$testUrl = $this->qualifyURL($url) . '/emby/System/Info?api_key=' . $token;
$response = Requests::get($testUrl, [], $options);
if ($response->success) {
$data = json_decode($response->body, true);
if (isset($data['ServerName'])) {
$this->setAPIResponse('success', 'Successfully connected to Emby server: ' . $data['ServerName'], 200);
return true;
}
}
break;
case 'jellyfin':
// Test Jellyfin connection
$testUrl = $this->qualifyURL($url) . '/System/Info?api_key=' . $token;
$response = Requests::get($testUrl, [], $options);
if ($response->success) {
$data = json_decode($response->body, true);
if (isset($data['ServerName'])) {
$this->setAPIResponse('success', 'Successfully connected to Jellyfin server: ' . $data['ServerName'], 200);
return true;
}
}
break;
}
$this->setAPIResponse('error', 'Connection test failed - invalid response from server', 500);
return false;
} catch (Exception $e) {
$this->setAPIResponse('error', 'Connection test failed: ' . $e->getMessage(), 500);
return false;
}
}
public function userWatchStatsHomepagePermissions($key = null)
{
$permissions = [
'test' => [
'enabled' => [
'homepageUserWatchStatsEnabled',
],
'auth' => [
'homepageUserWatchStatsAuth',
],
'not_empty' => [
'homepageUserWatchStatsURL',
'homepageUserWatchStatsToken'
]
],
'main' => [
'enabled' => [
'homepageUserWatchStatsEnabled'
],
'auth' => [
'homepageUserWatchStatsAuth'
],
'not_empty' => [
'homepageUserWatchStatsURL',
'homepageUserWatchStatsToken'
]
]
];
return $this->homepageCheckKeyPermissions($key, $permissions);
}
public function homepageOrderUserWatchStats()
{
if ($this->homepageItemPermissions($this->userWatchStatsHomepagePermissions('main'))) {
$refreshInterval = ($this->config['homepageUserWatchStatsRefresh'] ?? 5) * 60000; // Convert minutes to milliseconds
$compactView = ($this->config['homepageUserWatchStatsCompactView'] ?? false) ? 'true' : 'false';
$days = $this->config['homepageUserWatchStatsDays'] ?? 30;
$maxItems = $this->config['homepageUserWatchStatsMaxItems'] ?? 10;
$showTopUsers = ($this->config['homepageUserWatchStatsShowTopUsers'] ?? true) ? 'true' : 'false';
$showMostWatched = ($this->config['homepageUserWatchStatsShowMostWatched'] ?? true) ? 'true' : 'false';
$showRecentActivity = ($this->config['homepageUserWatchStatsShowRecentActivity'] ?? true) ? 'true' : 'false';
return '
';
}
}
/**
* Main function to get watch statistics
*/
public function getUserWatchStats($options = null)
{
if (!$this->homepageItemPermissions($this->userWatchStatsHomepagePermissions('main'), true)) {
$this->setAPIResponse('error', 'User not approved to view this homepage item - check plugin configuration', 401);
return false;
}
try {
$mediaServer = $this->config['homepageUserWatchStatsService'] ?? 'plex';
$days = intval($this->config['homepageUserWatchStatsDays'] ?? 30);
switch (strtolower($mediaServer)) {
case 'plex':
$stats = $this->getPlexWatchStats($days);
break;
case 'emby':
$stats = $this->getEmbyWatchStats($days);
break;
case 'jellyfin':
$stats = $this->getJellyfinWatchStats($days);
break;
default:
$stats = $this->getPlexWatchStats($days);
break;
}
if (isset($stats['error']) && $stats['error']) {
$this->setAPIResponse('error', $stats['message'], 500);
return false;
}
$this->setAPIResponse('success', 'Watch statistics retrieved successfully', 200, $stats);
return true;
} catch (Exception $e) {
$this->setAPIResponse('error', 'Failed to retrieve watch statistics: ' . $e->getMessage(), 500);
return false;
}
}
/**
* Get Emby watch statistics
*/
private function getEmbyWatchStats($days = 30)
{
$embyUrl = $this->config['homepageUserWatchStatsURL'] ?? '';
$embyToken = $this->config['homepageUserWatchStatsToken'] ?? '';
if (empty($embyUrl) || empty($embyToken)) {
return ['error' => true, 'message' => 'Emby URL or API key not configured'];
}
$endDate = date('Y-m-d');
$startDate = date('Y-m-d', strtotime("-{$days} days"));
$stats = [
'period' => "{$days} days",
'start_date' => $startDate,
'end_date' => $endDate,
'most_watched' => $this->getEmbyMostWatched($embyUrl, $embyToken, $days),
'user_stats' => $this->getEmbyUserStats($embyUrl, $embyToken, $days),
'recent_activity' => $this->getEmbyRecentActivity($embyUrl, $embyToken),
];
return $stats;
}
/**
* Get most watched content from Emby
*/
private function getEmbyMostWatched($url, $token, $days)
{
// Try multiple approaches to get accurate play counts
// Approach 1: Try to get activity/playback history if available
$historyStats = $this->getEmbyPlaybackHistory($url, $token, $days);
if (!empty($historyStats)) {
return $historyStats;
}
// Approach 2: Fallback to user aggregation method
return $this->getEmbyFallbackMostWatched($url, $token);
}
/**
* Fallback method - calculate most watched by aggregating play counts across all users
*/
private function getEmbyFallbackMostWatched($url, $token)
{
// Get all users first
$users = $this->getEmbyUserStats($url, $token, 30);
$playCountsByItem = [];
$itemDetails = [];
// For each user, get their watched items
foreach ($users as $user) {
if (isset($user['Policy']['IsDisabled']) && $user['Policy']['IsDisabled']) {
continue; // Skip disabled users
}
$userId = $user['Id'];
$userWatchedItems = $this->getEmbyUserWatchedContent($url, $token, $userId, 30);
// Aggregate play counts - use actual PlayCount if available, otherwise count as 1 per user
foreach ($userWatchedItems as $item) {
$itemId = $item['Id'] ?? $item['title']; // Use ID if available, title as fallback
$userPlayCount = $item['play_count'] ?? 0; // Get actual play count from this user
if ($userPlayCount > 0) {
// Add this user's play count to the total for this item
$playCountsByItem[$itemId] = ($playCountsByItem[$itemId] ?? 0) + $userPlayCount;
// Store item details (only need to do this once per item)
if (!isset($itemDetails[$itemId])) {
$itemDetails[$itemId] = [
'title' => $item['title'] ?? 'Unknown Title',
'runtime' => $item['runtime'] ?? 'Unknown',
'type' => $item['type'] ?? 'Unknown',
'year' => $item['year'] ?? null
];
}
} elseif ($item['is_played'] ?? false) {
// Fallback: if no play count but marked as played, count as 1 for this user
$playCountsByItem[$itemId] = ($playCountsByItem[$itemId] ?? 0) + 1;
// Store item details
if (!isset($itemDetails[$itemId])) {
$itemDetails[$itemId] = [
'title' => $item['title'] ?? 'Unknown Title',
'runtime' => $item['runtime'] ?? 'Unknown',
'type' => $item['type'] ?? 'Unknown',
'year' => $item['year'] ?? null
];
}
}
}
}
// Sort by total play count (descending)
arsort($playCountsByItem);
// Build most watched array
$mostWatched = [];
$count = 0;
foreach ($playCountsByItem as $itemId => $totalPlays) {
if ($count >= 20) break; // Limit to top 20
$details = $itemDetails[$itemId] ?? [
'title' => 'Unknown Title',
'runtime' => 'Unknown',
'type' => 'Unknown',
'year' => null
];
$mostWatched[] = [
'title' => $details['title'],
'total_plays' => $totalPlays,
'runtime' => $details['runtime'],
'type' => $details['type'],
'year' => $details['year']
];
$count++;
}
// If no watched content found, fall back to recent items as last resort
if (empty($mostWatched)) {
return $this->getEmbyRecentItemsFallback($url, $token);
}
return $mostWatched;
}
/**
* Final fallback - recent items when no watch data is available
*/
private function getEmbyRecentItemsFallback($url, $token)
{
$apiURL = rtrim($url, '/') . '/emby/Items?api_key=' . $token .
'&Recursive=true&IncludeItemTypes=Movie,Episode&Fields=Name,RunTimeTicks,ProductionYear,DateCreated' .
'&SortBy=DateCreated&SortOrder=Descending&Limit=10';
try {
$options = $this->requestOptions($url, null, $this->config['homepageUserWatchStatsDisableCertCheck'] ?? false, $this->config['homepageUserWatchStatsUseCustomCertificate'] ?? false);
$response = Requests::get($apiURL, [], $options);
if ($response->success) {
$data = json_decode($response->body, true);
$items = $data['Items'] ?? [];
$recentItems = [];
foreach ($items as $item) {
$recentItems[] = [
'title' => $item['Name'] ?? 'Unknown Title',
'total_plays' => 0, // No play data available
'runtime' => isset($item['RunTimeTicks']) ? $this->formatDuration($item['RunTimeTicks'] / 10000000) : 'Unknown',
'type' => $item['Type'] ?? 'Unknown',
'year' => $item['ProductionYear'] ?? null
];
}
return $recentItems;
}
} catch (Requests_Exception $e) {
// Nothing we can do at this point
}
return [];
}
/**
* Try to get playback history from Emby's activity log
*/
private function getEmbyPlaybackHistory($url, $token, $days)
{
// Try to access Emby's activity log for more accurate play statistics
$apiURL = rtrim($url, '/') . '/emby/System/ActivityLog/Entries?api_key=' . $token . '&Limit=1000&HasUserId=true';
try {
$options = $this->requestOptions($url, null, $this->config['homepageUserWatchStatsDisableCertCheck'] ?? false, $this->config['homepageUserWatchStatsUseCustomCertificate'] ?? false);
$response = Requests::get($apiURL, [], $options);
if ($response->success) {
$data = json_decode($response->body, true);
$activities = $data['Items'] ?? [];
$playCountsByItem = [];
$itemDetails = [];
// Filter for playback activities in the last X days
$cutoffDate = time() - ($days * 24 * 60 * 60);
foreach ($activities as $activity) {
if (isset($activity['Type']) && $activity['Type'] === 'PlaybackStart') {
$activityDate = strtotime($activity['Date']);
if ($activityDate >= $cutoffDate && isset($activity['ItemId'])) {
$itemId = $activity['ItemId'];
$playCountsByItem[$itemId] = ($playCountsByItem[$itemId] ?? 0) + 1;
// Store item name if available
if (isset($activity['Name']) && !isset($itemDetails[$itemId])) {
$itemDetails[$itemId] = [
'title' => $activity['Name'],
'type' => 'Unknown', // Activity log doesn't have type info
'runtime' => 'Unknown',
'year' => null
];
}
}
}
}
if (!empty($playCountsByItem)) {
// Sort by play count and build result
arsort($playCountsByItem);
$mostWatched = [];
$count = 0;
foreach ($playCountsByItem as $itemId => $totalPlays) {
if ($count >= 20) break;
$details = $itemDetails[$itemId] ?? ['title' => 'Unknown Title', 'type' => 'Unknown', 'runtime' => 'Unknown', 'year' => null];
$mostWatched[] = [
'title' => $details['title'],
'total_plays' => $totalPlays,
'runtime' => $details['runtime'],
'type' => $details['type'],
'year' => $details['year']
];
$count++;
}
return $mostWatched;
}
}
} catch (Requests_Exception $e) {
// Fall through to other methods
}
return [];
}
/**
* Get watched content for a specific user with debugging
*/
private function getEmbyUserWatchedContent($url, $token, $userId, $days)
{
// Try to get all items for this user, including play counts
$apiURL = rtrim($url, '/') . '/emby/Users/' . $userId . '/Items?api_key=' . $token .
'&Recursive=true&IncludeItemTypes=Movie,Episode&Limit=200' .
'&Fields=Name,PlayCount,UserData,RunTimeTicks,ProductionYear&SortBy=PlayCount&SortOrder=Descending';
try {
$options = $this->requestOptions($url, null, $this->config['homepageUserWatchStatsDisableCertCheck'] ?? false, $this->config['homepageUserWatchStatsUseCustomCertificate'] ?? false);
$response = Requests::get($apiURL, [], $options);
if ($response->success) {
$data = json_decode($response->body, true);
$items = $data['Items'] ?? [];
$watchedContent = [];
foreach ($items as $item) {
$playCount = $item['UserData']['PlayCount'] ?? 0;
$isPlayed = $item['UserData']['Played'] ?? false;
// Debug: Log some play count data to see what we're getting
// Uncomment these lines temporarily to debug:
// error_log("Emby Item: " . ($item['Name'] ?? 'Unknown') . " - PlayCount: $playCount, Played: " . ($isPlayed ? 'true' : 'false'));
// Include items that have been played OR have a play count > 0
if ($playCount > 0 || $isPlayed) {
$watchedContent[] = [
'Id' => $item['Id'] ?? null,
'title' => $item['Name'] ?? 'Unknown Title',
'play_count' => $playCount, // Use actual play count from UserData
'is_played' => $isPlayed,
'runtime' => $item['RunTimeTicks'] ? $this->formatDuration($item['RunTimeTicks'] / 10000000) : 'Unknown',
'type' => $item['Type'] ?? 'Unknown',
'year' => $item['ProductionYear'] ?? null
];
}
}
return $watchedContent;
}
} catch (Requests_Exception $e) {
// Nothing we can do
}
return [];
}
/**
* Get user statistics from Emby
*/
private function getEmbyUserStats($url, $token, $days)
{
$apiURL = rtrim($url, '/') . '/emby/Users?api_key=' . $token;
try {
$options = $this->requestOptions($url, null, $this->config['homepageUserWatchStatsDisableCertCheck'] ?? false, $this->config['homepageUserWatchStatsUseCustomCertificate'] ?? false);
$response = Requests::get($apiURL, [], $options);
if ($response->success) {
$data = json_decode($response->body, true);
return $data ?? [];
}
} catch (Requests_Exception $e) {
// Nothing we can do
}
return [];
}
/**
* Get recent activity from Emby
*/
private function getEmbyRecentActivity($url, $token)
{
$apiURL = rtrim($url, '/') . '/emby/Items/Latest?api_key=' . $token . '&Limit=10&Recursive=true&IncludeItemTypes=Movie,Episode';
try {
$options = $this->requestOptions($url, null, $this->config['homepageUserWatchStatsDisableCertCheck'] ?? false, $this->config['homepageUserWatchStatsUseCustomCertificate'] ?? false);
$response = Requests::get($apiURL, [], $options);
if ($response->success) {
$data = json_decode($response->body, true);
$recentActivity = [];
foreach ($data as $item) {
$recentActivity[] = [
'title' => $item['Name'] ?? 'Unknown Title',
'type' => $item['Type'] ?? 'Unknown',
'added_at' => $item['DateCreated'] ?? 'Unknown Date',
'year' => $item['ProductionYear'] ?? null
];
}
return $recentActivity;
}
} catch (Requests_Exception $e) {
// Nothing we can do
}
return [];
}
/**
* Format duration for display
*/
private function formatDuration($seconds)
{
if ($seconds < 3600) {
return gmdate('i:s', $seconds);
} else {
return gmdate('H:i:s', $seconds);
}
}
// Stub functions for other media servers
private function getPlexWatchStats($days = 30) { return ['error' => true, 'message' => 'Plex not implemented yet']; }
private function getJellyfinWatchStats($days = 30) { return ['error' => true, 'message' => 'Jellyfin not implemented yet']; }
}