jellyfin/MediaBrowser.Server.Implementations/Session/HttpSessionController.cs

249 lines
7.5 KiB
C#
Raw Normal View History

using MediaBrowser.Common.Net;
2013-12-24 00:00:27 +00:00
using MediaBrowser.Controller.Session;
using MediaBrowser.Model.Entities;
using MediaBrowser.Model.Serialization;
using MediaBrowser.Model.Session;
using MediaBrowser.Model.System;
using System;
using System.Collections.Generic;
2014-06-02 19:32:41 +00:00
using System.Globalization;
using System.Linq;
using System.Net;
2013-12-24 00:00:27 +00:00
using System.Threading;
using System.Threading.Tasks;
2014-05-12 18:04:25 +00:00
namespace MediaBrowser.Server.Implementations.Session
2013-12-24 00:00:27 +00:00
{
public class HttpSessionController : ISessionController, IDisposable
2013-12-24 00:00:27 +00:00
{
private readonly IHttpClient _httpClient;
private readonly IJsonSerializer _json;
private readonly ISessionManager _sessionManager;
2013-12-24 00:00:27 +00:00
public SessionInfo Session { get; private set; }
2014-05-12 18:04:25 +00:00
private readonly string _postUrl;
private Timer _pingTimer;
2014-12-16 05:01:57 +00:00
private DateTime _lastPingTime;
2014-05-18 19:58:42 +00:00
public HttpSessionController(IHttpClient httpClient,
IJsonSerializer json,
SessionInfo session,
string postUrl, ISessionManager sessionManager)
2013-12-24 00:00:27 +00:00
{
_httpClient = httpClient;
_json = json;
Session = session;
2014-05-12 18:04:25 +00:00
_postUrl = postUrl;
_sessionManager = sessionManager;
_pingTimer = new Timer(PingTimerCallback, null, Timeout.Infinite, Timeout.Infinite);
ResetPingTimer();
2013-12-24 00:00:27 +00:00
}
2014-06-04 16:15:44 +00:00
private string PostUrl
{
get
{
return string.Format("http://{0}{1}", Session.RemoteEndPoint, _postUrl);
}
}
2013-12-24 00:00:27 +00:00
public bool IsSessionActive
{
get
{
2014-08-22 15:47:44 +00:00
return (DateTime.UtcNow - Session.LastActivityDate).TotalMinutes <= 20;
2013-12-24 00:00:27 +00:00
}
}
2014-05-17 18:37:40 +00:00
public bool SupportsMediaControl
{
get { return true; }
}
private async void PingTimerCallback(object state)
2014-05-12 18:04:25 +00:00
{
try
{
await SendMessage("Ping", CancellationToken.None).ConfigureAwait(false);
2014-12-16 05:01:57 +00:00
_lastPingTime = DateTime.UtcNow;
}
catch
{
2014-12-16 05:01:57 +00:00
var lastActivityDate = new[] { _lastPingTime, Session.LastActivityDate }
.Max();
var timeSinceLastPing = DateTime.UtcNow - lastActivityDate;
// We don't want to stop the session due to one single request failure
// At the same time, we don't want the timeout to be too long because it will
// be sitting in active sessions available for remote control, when it's not
if (timeSinceLastPing >= TimeSpan.FromMinutes(5))
{
ReportSessionEnded();
}
}
}
2014-05-12 18:04:25 +00:00
private void ReportSessionEnded()
{
try
{
_sessionManager.ReportSessionEnded(Session.Id);
}
catch (Exception ex)
2014-05-12 18:04:25 +00:00
{
}
}
private void ResetPingTimer()
{
2014-05-29 14:19:12 +00:00
if (_pingTimer != null)
{
2014-12-16 05:01:57 +00:00
_lastPingTime = DateTime.UtcNow;
2014-05-29 14:19:12 +00:00
var period = TimeSpan.FromSeconds(60);
2014-05-29 14:19:12 +00:00
_pingTimer.Change(period, period);
}
2014-05-12 18:04:25 +00:00
}
2014-05-18 19:58:42 +00:00
private Task SendMessage(string name, CancellationToken cancellationToken)
{
2014-05-21 00:56:24 +00:00
return SendMessage(name, new Dictionary<string, string>(), cancellationToken);
2014-05-18 19:58:42 +00:00
}
2014-12-16 05:01:57 +00:00
private async Task SendMessage(string name,
Dictionary<string, string> args,
CancellationToken cancellationToken)
2014-05-18 19:58:42 +00:00
{
2014-06-04 16:15:44 +00:00
var url = PostUrl + "/" + name + ToQueryString(args);
2014-05-18 19:58:42 +00:00
await _httpClient.Post(new HttpRequestOptions
2014-05-21 00:56:24 +00:00
{
Url = url,
CancellationToken = cancellationToken
}).ConfigureAwait(false);
ResetPingTimer();
2014-05-18 19:58:42 +00:00
}
2014-04-06 17:53:23 +00:00
public Task SendSessionEndedNotification(SessionInfoDto sessionInfo, CancellationToken cancellationToken)
{
return Task.FromResult(true);
}
public Task SendPlaybackStartNotification(SessionInfoDto sessionInfo, CancellationToken cancellationToken)
{
return Task.FromResult(true);
}
public Task SendPlaybackStoppedNotification(SessionInfoDto sessionInfo, CancellationToken cancellationToken)
{
return Task.FromResult(true);
}
2013-12-24 00:00:27 +00:00
public Task SendPlayCommand(PlayRequest command, CancellationToken cancellationToken)
{
2014-06-02 19:32:41 +00:00
var dict = new Dictionary<string, string>();
dict["ItemIds"] = string.Join(",", command.ItemIds);
if (command.StartPositionTicks.HasValue)
{
dict["StartPositionTicks"] = command.StartPositionTicks.Value.ToString(CultureInfo.InvariantCulture);
}
2013-12-24 00:00:27 +00:00
2014-06-02 19:32:41 +00:00
return SendMessage(command.PlayCommand.ToString(), dict, cancellationToken);
2013-12-24 00:00:27 +00:00
}
public Task SendPlaystateCommand(PlaystateRequest command, CancellationToken cancellationToken)
{
2014-05-18 19:58:42 +00:00
var args = new Dictionary<string, string>();
if (command.Command == PlaystateCommand.Seek)
2013-12-24 00:00:27 +00:00
{
2014-06-02 19:32:41 +00:00
if (!command.SeekPositionTicks.HasValue)
{
throw new ArgumentException("SeekPositionTicks cannot be null");
}
2013-12-24 00:00:27 +00:00
2014-08-27 03:25:39 +00:00
args["SeekPositionTicks"] = command.SeekPositionTicks.Value.ToString(CultureInfo.InvariantCulture);
2014-05-18 19:58:42 +00:00
}
2014-08-27 03:25:39 +00:00
return SendMessage(command.Command.ToString(), args, cancellationToken);
2013-12-24 00:00:27 +00:00
}
public Task SendLibraryUpdateInfo(LibraryUpdateInfo info, CancellationToken cancellationToken)
{
2014-04-06 17:53:23 +00:00
return Task.FromResult(true);
2013-12-24 00:00:27 +00:00
}
2014-05-18 19:58:42 +00:00
public Task SendRestartRequiredNotification(SystemInfo info, CancellationToken cancellationToken)
2013-12-24 00:00:27 +00:00
{
2014-05-18 19:58:42 +00:00
return SendMessage("RestartRequired", cancellationToken);
2013-12-24 00:00:27 +00:00
}
public Task SendUserDataChangeInfo(UserDataChangeInfo info, CancellationToken cancellationToken)
{
2014-04-06 17:53:23 +00:00
return Task.FromResult(true);
2013-12-24 00:00:27 +00:00
}
public Task SendServerShutdownNotification(CancellationToken cancellationToken)
{
2014-05-18 19:58:42 +00:00
return SendMessage("ServerShuttingDown", cancellationToken);
2013-12-24 00:00:27 +00:00
}
public Task SendServerRestartNotification(CancellationToken cancellationToken)
{
2014-05-18 19:58:42 +00:00
return SendMessage("ServerRestarting", cancellationToken);
2013-12-24 00:00:27 +00:00
}
2014-03-31 21:04:22 +00:00
public Task SendGeneralCommand(GeneralCommand command, CancellationToken cancellationToken)
2014-03-28 19:58:18 +00:00
{
2014-05-21 00:56:24 +00:00
return SendMessage(command.Name, command.Arguments, cancellationToken);
2014-03-28 19:58:18 +00:00
}
2014-05-18 19:58:42 +00:00
public Task SendMessage<T>(string name, T data, CancellationToken cancellationToken)
{
// Not supported or needed right now
return Task.FromResult(true);
}
2014-05-18 19:58:42 +00:00
private string ToQueryString(Dictionary<string, string> nvc)
{
var array = (from item in nvc
select string.Format("{0}={1}", WebUtility.UrlEncode(item.Key), WebUtility.UrlEncode(item.Value)))
.ToArray();
2014-05-21 00:56:24 +00:00
var args = string.Join("&", array);
if (string.IsNullOrEmpty(args))
{
return args;
}
return "?" + args;
2014-05-18 19:58:42 +00:00
}
public void Dispose()
{
DisposePingTimer();
}
private void DisposePingTimer()
{
if (_pingTimer != null)
{
_pingTimer.Dispose();
_pingTimer = null;
}
}
2013-12-24 00:00:27 +00:00
}
}