jellyfin/MediaBrowser.Api/Dlna/DlnaServerService.cs

222 lines
8.1 KiB
C#
Raw Normal View History

2014-04-20 05:21:08 +00:00
using MediaBrowser.Controller.Dlna;
2014-04-10 15:06:54 +00:00
using ServiceStack;
2014-04-18 05:03:01 +00:00
using ServiceStack.Text.Controller;
2014-04-10 15:06:54 +00:00
using ServiceStack.Web;
2014-04-20 05:21:08 +00:00
using System;
2014-04-10 15:06:54 +00:00
using System.Collections.Generic;
2014-04-20 05:21:08 +00:00
using System.Globalization;
2014-04-10 15:06:54 +00:00
using System.IO;
2014-04-20 05:21:08 +00:00
using System.Linq;
2014-04-10 15:06:54 +00:00
using System.Threading.Tasks;
namespace MediaBrowser.Api.Dlna
{
[Route("/Dlna/{UuId}/description.xml", "GET", Summary = "Gets dlna server info")]
[Route("/Dlna/{UuId}/description", "GET", Summary = "Gets dlna server info")]
public class GetDescriptionXml
{
[ApiMember(Name = "UuId", Description = "Server UuId", IsRequired = false, DataType = "string", ParameterType = "path", Verb = "GET")]
public string UuId { get; set; }
}
2014-04-20 05:21:08 +00:00
[Route("/Dlna/contentdirectory/contentdirectory.xml", "GET", Summary = "Gets dlna content directory xml")]
[Route("/Dlna/contentdirectory/contentdirectory", "GET", Summary = "Gets dlna content directory xml")]
2014-04-10 15:06:54 +00:00
public class GetContentDirectory
{
}
2014-05-21 00:56:24 +00:00
[Route("/Dlna/connectionmanager/connectionmanager.xml", "GET", Summary = "Gets dlna connection manager xml")]
[Route("/Dlna/connectionmanager/connectionmanager", "GET", Summary = "Gets dlna connection manager xml")]
public class GetConnnectionManager
{
}
2014-04-20 05:21:08 +00:00
[Route("/Dlna/contentdirectory/{UuId}/control", "POST", Summary = "Processes a control request")]
2014-05-21 00:56:24 +00:00
public class ProcessContentDirectoryControlRequest : IRequiresRequestStream
{
[ApiMember(Name = "UuId", Description = "Server UuId", IsRequired = false, DataType = "string", ParameterType = "path", Verb = "GET")]
public string UuId { get; set; }
public Stream RequestStream { get; set; }
}
[Route("/Dlna/connectionmanager/{UuId}/control", "POST", Summary = "Processes a control request")]
public class ProcessConnectionManagerControlRequest : IRequiresRequestStream
2014-04-10 15:06:54 +00:00
{
2014-04-18 05:03:01 +00:00
[ApiMember(Name = "UuId", Description = "Server UuId", IsRequired = false, DataType = "string", ParameterType = "path", Verb = "GET")]
public string UuId { get; set; }
2014-04-20 05:21:08 +00:00
2014-04-10 15:06:54 +00:00
public Stream RequestStream { get; set; }
}
2014-04-20 05:21:08 +00:00
[Route("/Dlna/contentdirectory/{UuId}/events", Summary = "Processes an event subscription request")]
2014-05-21 01:15:46 +00:00
public class ProcessContentDirectoryEventRequest
{
[ApiMember(Name = "UuId", Description = "Server UuId", IsRequired = false, DataType = "string", ParameterType = "path", Verb = "GET")]
public string UuId { get; set; }
}
2014-05-21 00:56:24 +00:00
[Route("/Dlna/connectionmanager/{UuId}/events", Summary = "Processes an event subscription request")]
2014-05-21 01:15:46 +00:00
public class ProcessConnectionManagerEventRequest
2014-04-20 05:21:08 +00:00
{
[ApiMember(Name = "UuId", Description = "Server UuId", IsRequired = false, DataType = "string", ParameterType = "path", Verb = "GET")]
public string UuId { get; set; }
}
2014-04-16 05:08:12 +00:00
[Route("/Dlna/icons/{Filename}", "GET", Summary = "Gets a server icon")]
public class GetIcon
{
[ApiMember(Name = "Filename", Description = "The icon filename", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")]
public string Filename { get; set; }
}
2014-04-10 15:06:54 +00:00
public class DlnaServerService : BaseApiService
{
private readonly IDlnaManager _dlnaManager;
2014-04-21 16:02:30 +00:00
private readonly IContentDirectory _contentDirectory;
2014-05-21 00:56:24 +00:00
private readonly IConnectionManager _connectionManager;
2014-04-10 15:06:54 +00:00
2014-05-21 01:15:46 +00:00
public DlnaServerService(IDlnaManager dlnaManager, IContentDirectory contentDirectory, IConnectionManager connectionManager)
2014-04-10 15:06:54 +00:00
{
_dlnaManager = dlnaManager;
2014-04-21 16:02:30 +00:00
_contentDirectory = contentDirectory;
2014-05-21 00:56:24 +00:00
_connectionManager = connectionManager;
2014-04-10 15:06:54 +00:00
}
public object Get(GetDescriptionXml request)
{
var xml = _dlnaManager.GetServerDescriptionXml(GetRequestHeaders(), request.UuId);
return ResultFactory.GetResult(xml, "text/xml");
}
public object Get(GetContentDirectory request)
{
2014-05-21 00:56:24 +00:00
var xml = _contentDirectory.GetServiceXml(GetRequestHeaders());
2014-04-10 15:06:54 +00:00
return ResultFactory.GetResult(xml, "text/xml");
}
2014-05-21 00:56:24 +00:00
public object Get(GetConnnectionManager request)
{
var xml = _connectionManager.GetServiceXml(GetRequestHeaders());
return ResultFactory.GetResult(xml, "text/xml");
}
public object Post(ProcessContentDirectoryControlRequest request)
{
var response = PostAsync(request.RequestStream, _contentDirectory).Result;
return ResultFactory.GetResult(response.Xml, "text/xml");
}
public object Post(ProcessConnectionManagerControlRequest request)
2014-04-10 15:06:54 +00:00
{
2014-05-21 00:56:24 +00:00
var response = PostAsync(request.RequestStream, _connectionManager).Result;
2014-04-10 15:06:54 +00:00
return ResultFactory.GetResult(response.Xml, "text/xml");
}
2014-05-21 00:56:24 +00:00
private async Task<ControlResponse> PostAsync(Stream requestStream, IUpnpService service)
2014-04-10 15:06:54 +00:00
{
2014-04-18 05:03:01 +00:00
var pathInfo = PathInfo.Parse(Request.PathInfo);
2014-04-20 05:21:08 +00:00
var id = pathInfo.GetArgumentValue<string>(2);
2014-05-21 00:56:24 +00:00
using (var reader = new StreamReader(requestStream))
2014-04-10 15:06:54 +00:00
{
2014-05-21 00:56:24 +00:00
return service.ProcessControlRequest(new ControlRequest
2014-04-10 15:06:54 +00:00
{
Headers = GetRequestHeaders(),
2014-04-18 05:03:01 +00:00
InputXml = await reader.ReadToEndAsync().ConfigureAwait(false),
2014-04-25 17:30:41 +00:00
TargetServerUuId = id,
RequestedUrl = Request.AbsoluteUri
2014-04-10 15:06:54 +00:00
});
}
2014-04-16 05:08:12 +00:00
}
2014-04-10 15:06:54 +00:00
private IDictionary<string, string> GetRequestHeaders()
{
var headers = new Dictionary<string, string>();
foreach (var key in Request.Headers.AllKeys)
{
headers[key] = Request.Headers[key];
}
return headers;
}
2014-04-16 05:08:12 +00:00
public object Get(GetIcon request)
{
using (var response = _dlnaManager.GetIcon(request.Filename))
{
using (var ms = new MemoryStream())
{
response.Stream.CopyTo(ms);
ms.Position = 0;
var bytes = ms.ToArray();
return ResultFactory.GetResult(bytes, "image/" + response.Format.ToString().ToLower());
}
}
}
2014-04-20 05:21:08 +00:00
2014-05-21 01:15:46 +00:00
public object Any(ProcessContentDirectoryEventRequest request)
{
return ProcessEventRequest(_contentDirectory);
}
public object Any(ProcessConnectionManagerEventRequest request)
{
return ProcessEventRequest(_connectionManager);
}
private object ProcessEventRequest(IEventManager eventManager)
2014-04-20 05:21:08 +00:00
{
var subscriptionId = GetHeader("SID");
var notificationType = GetHeader("NT");
var callback = GetHeader("CALLBACK");
var timeoutString = GetHeader("TIMEOUT");
2014-04-21 16:02:30 +00:00
var timeout = ParseTimeout(timeoutString);
2014-04-20 05:21:08 +00:00
if (string.Equals(Request.Verb, "SUBSCRIBE", StringComparison.OrdinalIgnoreCase))
{
if (string.IsNullOrEmpty(notificationType))
{
2014-05-21 01:15:46 +00:00
return GetSubscriptionResponse(eventManager.RenewEventSubscription(subscriptionId, timeout));
2014-04-20 05:21:08 +00:00
}
2014-05-21 01:15:46 +00:00
return GetSubscriptionResponse(eventManager.CreateEventSubscription(notificationType, timeout, callback));
2014-04-20 05:21:08 +00:00
}
2014-05-21 01:15:46 +00:00
return GetSubscriptionResponse(eventManager.CancelEventSubscription(subscriptionId));
2014-04-20 05:21:08 +00:00
}
2014-04-21 16:02:30 +00:00
private object GetSubscriptionResponse(EventSubscriptionResponse response)
2014-04-20 05:21:08 +00:00
{
2014-04-21 16:02:30 +00:00
return ResultFactory.GetResult(response.Content, response.ContentType, response.Headers);
2014-04-20 05:21:08 +00:00
}
private readonly CultureInfo _usCulture = new CultureInfo("en-US");
private int? ParseTimeout(string header)
{
if (!string.IsNullOrEmpty(header))
{
// Starts with SECOND-
header = header.Split('-').Last();
int val;
if (int.TryParse(header, NumberStyles.Any, _usCulture, out val))
{
return val;
}
}
return null;
}
2014-04-10 15:06:54 +00:00
}
}