jellyfin/MediaBrowser.Server.Implementations/LiveTv/TunerHosts/SatIp/SatIpDiscovery.cs

306 lines
11 KiB
C#
Raw Normal View History

2016-01-25 21:33:36 +00:00
using System;
using System.Collections.Generic;
2016-02-21 17:37:57 +00:00
using System.Globalization;
2016-02-19 06:20:18 +00:00
using System.IO;
2016-01-25 21:33:36 +00:00
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
2016-02-19 06:20:18 +00:00
using System.Xml;
2016-01-25 21:33:36 +00:00
using MediaBrowser.Common.Configuration;
2016-02-19 06:20:18 +00:00
using MediaBrowser.Common.Extensions;
2016-01-25 21:33:36 +00:00
using MediaBrowser.Common.Net;
using MediaBrowser.Controller.Configuration;
using MediaBrowser.Controller.Dlna;
using MediaBrowser.Controller.LiveTv;
using MediaBrowser.Controller.Plugins;
using MediaBrowser.Model.LiveTv;
using MediaBrowser.Model.Logging;
2016-02-19 06:20:18 +00:00
using MediaBrowser.Model.Serialization;
2016-03-16 21:39:49 +00:00
using MediaBrowser.Model.Extensions;
2016-01-25 21:33:36 +00:00
namespace MediaBrowser.Server.Implementations.LiveTv.TunerHosts.SatIp
{
2016-03-05 18:29:14 +00:00
public class SatIpDiscovery : IServerEntryPoint
{
private readonly IDeviceDiscovery _deviceDiscovery;
private readonly IServerConfigurationManager _config;
private readonly ILogger _logger;
private readonly ILiveTvManager _liveTvManager;
private readonly SemaphoreSlim _semaphore = new SemaphoreSlim(1, 1);
private readonly IHttpClient _httpClient;
private readonly IJsonSerializer _json;
public static SatIpDiscovery Current;
public SatIpDiscovery(IDeviceDiscovery deviceDiscovery, IServerConfigurationManager config, ILogger logger, ILiveTvManager liveTvManager, IHttpClient httpClient, IJsonSerializer json)
{
_deviceDiscovery = deviceDiscovery;
_config = config;
_logger = logger;
_liveTvManager = liveTvManager;
_httpClient = httpClient;
_json = json;
Current = this;
}
public void Run()
{
_deviceDiscovery.DeviceDiscovered += _deviceDiscovery_DeviceDiscovered;
}
void _deviceDiscovery_DeviceDiscovered(object sender, SsdpMessageEventArgs e)
{
string st = null;
string nt = null;
e.Headers.TryGetValue("ST", out st);
e.Headers.TryGetValue("NT", out nt);
if (string.Equals(st, "urn:ses-com:device:SatIPServer:1", StringComparison.OrdinalIgnoreCase) ||
string.Equals(nt, "urn:ses-com:device:SatIPServer:1", StringComparison.OrdinalIgnoreCase))
{
string location;
if (e.Headers.TryGetValue("Location", out location) && !string.IsNullOrWhiteSpace(location))
{
_logger.Debug("SAT IP found at {0}", location);
// Just get the beginning of the url
2016-03-16 21:39:49 +00:00
Uri uri;
if (Uri.TryCreate(location, UriKind.Absolute, out uri))
{
var apiUrl = location.Replace(uri.LocalPath, String.Empty, StringComparison.OrdinalIgnoreCase)
.TrimEnd('/');
AddDevice(apiUrl, location);
}
2016-03-05 18:29:14 +00:00
}
}
}
2016-03-16 21:39:49 +00:00
private async void AddDevice(string deviceUrl, string infoUrl)
2016-03-05 18:29:14 +00:00
{
await _semaphore.WaitAsync().ConfigureAwait(false);
try
{
2016-03-13 07:34:17 +00:00
var options = GetConfiguration();
2016-03-16 21:39:49 +00:00
if (options.TunerHosts.Any(i => string.Equals(i.Type, SatIpHost.DeviceType, StringComparison.OrdinalIgnoreCase) && UriEquals(i.Url, deviceUrl)))
2016-03-05 18:29:14 +00:00
{
return;
}
2016-03-16 21:39:49 +00:00
_logger.Debug("Will attempt to add SAT device {0}", deviceUrl);
var info = await GetInfo(infoUrl, CancellationToken.None).ConfigureAwait(false);
2016-03-05 18:29:14 +00:00
2016-03-13 07:34:17 +00:00
var existing = GetConfiguration().TunerHosts
.FirstOrDefault(i => string.Equals(i.Type, SatIpHost.DeviceType, StringComparison.OrdinalIgnoreCase) && string.Equals(i.DeviceId, info.DeviceId, StringComparison.OrdinalIgnoreCase));
if (existing == null)
{
2016-03-14 03:32:03 +00:00
if (string.IsNullOrWhiteSpace(info.M3UUrl))
{
2016-03-25 17:06:36 +00:00
return;
2016-03-14 03:32:03 +00:00
}
2016-03-13 07:34:17 +00:00
await _liveTvManager.SaveTunerHost(new TunerHostInfo
{
Type = SatIpHost.DeviceType,
2016-03-16 21:39:49 +00:00
Url = deviceUrl,
InfoUrl = infoUrl,
2016-03-13 07:34:17 +00:00
DataVersion = 1,
DeviceId = info.DeviceId,
FriendlyName = info.FriendlyName,
2016-03-14 03:32:03 +00:00
Tuners = info.Tuners,
M3UUrl = info.M3UUrl,
IsEnabled = true
2016-03-13 07:34:17 +00:00
}).ConfigureAwait(false);
}
else
{
2016-03-16 21:39:49 +00:00
existing.Url = deviceUrl;
existing.InfoUrl = infoUrl;
existing.M3UUrl = info.M3UUrl;
existing.FriendlyName = info.FriendlyName;
existing.Tuners = info.Tuners;
await _liveTvManager.SaveTunerHost(existing).ConfigureAwait(false);
2016-03-13 07:34:17 +00:00
}
2016-03-05 18:29:14 +00:00
}
catch (OperationCanceledException)
{
}
catch (NotImplementedException)
{
}
catch (Exception ex)
{
_logger.ErrorException("Error saving device", ex);
}
finally
{
_semaphore.Release();
}
}
2016-03-13 07:34:17 +00:00
private bool UriEquals(string savedUri, string location)
{
return string.Equals(NormalizeUrl(location), NormalizeUrl(savedUri), StringComparison.OrdinalIgnoreCase);
}
private string NormalizeUrl(string url)
{
if (!url.StartsWith("http", StringComparison.OrdinalIgnoreCase))
{
url = "http://" + url;
}
url = url.TrimEnd('/');
// Strip off the port
return new Uri(url).GetComponents(UriComponents.AbsoluteUri & ~UriComponents.Port, UriFormat.UriEscaped);
}
private LiveTvOptions GetConfiguration()
{
return _config.GetConfiguration<LiveTvOptions>("livetv");
}
2016-03-05 18:29:14 +00:00
public void Dispose()
{
}
public async Task<SatIpTunerHostInfo> GetInfo(string url, CancellationToken cancellationToken)
{
var result = new SatIpTunerHostInfo
{
Url = url,
IsEnabled = true,
Type = SatIpHost.DeviceType,
Tuners = 1,
TunersAvailable = 1
};
using (var stream = await _httpClient.Get(url, cancellationToken).ConfigureAwait(false))
{
using (var streamReader = new StreamReader(stream))
{
// Use XmlReader for best performance
using (var reader = XmlReader.Create(streamReader))
{
reader.MoveToContent();
// Loop through each element
while (reader.Read())
{
if (reader.NodeType == XmlNodeType.Element)
{
switch (reader.Name)
{
case "device":
using (var subtree = reader.ReadSubtree())
{
FillFromDeviceNode(result, subtree);
}
break;
default:
reader.Skip();
break;
}
}
}
}
}
}
2016-03-13 07:34:17 +00:00
if (string.IsNullOrWhiteSpace(result.DeviceId))
2016-03-05 18:29:14 +00:00
{
throw new NotImplementedException();
}
// Device hasn't implemented an m3u list
if (string.IsNullOrWhiteSpace(result.M3UUrl))
{
result.IsEnabled = false;
}
else if (!result.M3UUrl.StartsWith("http", StringComparison.OrdinalIgnoreCase))
{
var fullM3uUrl = url.Substring(0, url.LastIndexOf('/'));
result.M3UUrl = fullM3uUrl + "/" + result.M3UUrl.TrimStart('/');
}
_logger.Debug("SAT device result: {0}", _json.SerializeToString(result));
return result;
}
private void FillFromDeviceNode(SatIpTunerHostInfo info, XmlReader reader)
{
reader.MoveToContent();
while (reader.Read())
{
if (reader.NodeType == XmlNodeType.Element)
{
switch (reader.LocalName)
{
case "UDN":
{
2016-03-13 07:34:17 +00:00
info.DeviceId = reader.ReadElementContentAsString();
2016-03-05 18:29:14 +00:00
break;
}
case "friendlyName":
{
info.FriendlyName = reader.ReadElementContentAsString();
break;
}
case "satip:X_SATIPCAP":
case "X_SATIPCAP":
{
// <satip:X_SATIPCAP xmlns:satip="urn:ses-com:satip">DVBS2-2</satip:X_SATIPCAP>
var value = reader.ReadElementContentAsString() ?? string.Empty;
var parts = value.Split(new[] { '-' }, StringSplitOptions.RemoveEmptyEntries);
if (parts.Length == 2)
{
int intValue;
if (int.TryParse(parts[1], NumberStyles.Any, CultureInfo.InvariantCulture, out intValue))
{
info.TunersAvailable = intValue;
}
if (int.TryParse(parts[0].Substring(parts[0].Length - 1), NumberStyles.Any, CultureInfo.InvariantCulture, out intValue))
{
info.Tuners = intValue;
}
}
break;
}
case "satip:X_SATIPM3U":
case "X_SATIPM3U":
{
// <satip:X_SATIPM3U xmlns:satip="urn:ses-com:satip">/channellist.lua?select=m3u</satip:X_SATIPM3U>
info.M3UUrl = reader.ReadElementContentAsString();
break;
}
default:
reader.Skip();
break;
}
}
}
}
}
2016-02-19 06:20:18 +00:00
public class SatIpTunerHostInfo : TunerHostInfo
{
public int TunersAvailable { get; set; }
}
2016-01-25 21:33:36 +00:00
}