aboutsummaryrefslogtreecommitdiff
path: root/MediaBrowser.Server.Implementations/Session/SessionManager.cs
diff options
context:
space:
mode:
authorLuke <luke.pulverenti@gmail.com>2016-08-21 15:39:41 -0400
committerGitHub <noreply@github.com>2016-08-21 15:39:41 -0400
commit3f6b5feffba3aacbbf0387edffad0428f93ad675 (patch)
treef3eaac4c45a827b111ed4813a8c22ad0e57f6885 /MediaBrowser.Server.Implementations/Session/SessionManager.cs
parent30ba965ed2096139d9064b031e338bf81835aba8 (diff)
parent9f7dbec0db461fe416d825b483d475f476c9d42d (diff)
Merge pull request #2087 from MediaBrowser/dev
Dev
Diffstat (limited to 'MediaBrowser.Server.Implementations/Session/SessionManager.cs')
-rw-r--r--MediaBrowser.Server.Implementations/Session/SessionManager.cs11
1 files changed, 9 insertions, 2 deletions
diff --git a/MediaBrowser.Server.Implementations/Session/SessionManager.cs b/MediaBrowser.Server.Implementations/Session/SessionManager.cs
index f495e557a..b21fcddd4 100644
--- a/MediaBrowser.Server.Implementations/Session/SessionManager.cs
+++ b/MediaBrowser.Server.Implementations/Session/SessionManager.cs
@@ -1869,10 +1869,17 @@ namespace MediaBrowser.Server.Implementations.Session
return GetSessionByAuthenticationToken(info, deviceId, remoteEndpoint, null);
}
- public Task SendMessageToUserSessions<T>(string userId, string name, T data,
+ public Task SendMessageToAdminSessions<T>(string name, T data, CancellationToken cancellationToken)
+ {
+ var adminUserIds = _userManager.Users.Where(i => i.Policy.IsAdministrator).Select(i => i.Id.ToString("N")).ToList();
+
+ return SendMessageToUserSessions(adminUserIds, name, data, cancellationToken);
+ }
+
+ public Task SendMessageToUserSessions<T>(List<string> userIds, string name, T data,
CancellationToken cancellationToken)
{
- var sessions = Sessions.Where(i => i.IsActive && i.SessionController != null && i.ContainsUser(userId)).ToList();
+ var sessions = Sessions.Where(i => i.IsActive && i.SessionController != null && userIds.Any(i.ContainsUser)).ToList();
var tasks = sessions.Select(session => Task.Run(async () =>
{