lgladsden/jellyfin-server
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

disable sat/ip host for now

Browse Source
This commit is contained in:
Luke Pulverenti 2016-03-03 01:03:23 -05:00
parent 32204107dd
commit 721e50ce7a
2 changed files with 314 additions and 314 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

378
MediaBrowser.Server.Implementations/LiveTv/TunerHosts/SatIp/SatIpDiscovery.cs
View File

@ -21,225 +21,225 @@ using MediaBrowser.Model.Serialization;
namespace MediaBrowser.Server.Implementations.LiveTv.TunerHosts.SatIp
{
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 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 static SatIpDiscovery Current;
private readonly List<TunerHostInfo> _discoveredHosts = new List<TunerHostInfo>();
// private readonly List<TunerHostInfo> _discoveredHosts = new List<TunerHostInfo>();
public List<TunerHostInfo> DiscoveredHosts
{
get { return _discoveredHosts.ToList(); }
}
// public List<TunerHostInfo> DiscoveredHosts
// {
// get { return _discoveredHosts.ToList(); }
// }
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 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;
}
// 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);
// 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);
// 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
AddDevice(location);
}
}
}
// // Just get the beginning of the url
// AddDevice(location);
// }
// }
// }
private async void AddDevice(string location)
{
await _semaphore.WaitAsync().ConfigureAwait(false);
// private async void AddDevice(string location)
// {
// await _semaphore.WaitAsync().ConfigureAwait(false);
try
{
if (_discoveredHosts.Any(i => string.Equals(i.Type, SatIpHost.DeviceType, StringComparison.OrdinalIgnoreCase) && string.Equals(location, i.Url, StringComparison.OrdinalIgnoreCase)))
{
return;
}
// try
// {
// if (_discoveredHosts.Any(i => string.Equals(i.Type, SatIpHost.DeviceType, StringComparison.OrdinalIgnoreCase) && string.Equals(location, i.Url, StringComparison.OrdinalIgnoreCase)))
// {
// return;
// }
_logger.Debug("Will attempt to add SAT device {0}", location);
var info = await GetInfo(location, CancellationToken.None).ConfigureAwait(false);
// _logger.Debug("Will attempt to add SAT device {0}", location);
// var info = await GetInfo(location, CancellationToken.None).ConfigureAwait(false);
_discoveredHosts.Add(info);
}
catch (OperationCanceledException)
{
// _discoveredHosts.Add(info);
// }
// catch (OperationCanceledException)
// {
}
catch (NotImplementedException)
{
// }
// catch (NotImplementedException)
// {
}
catch (Exception ex)
{
_logger.ErrorException("Error saving device", ex);
}
finally
{
_semaphore.Release();
}
}
// }
// catch (Exception ex)
// {
// _logger.ErrorException("Error saving device", ex);
// }
// finally
// {
// _semaphore.Release();
// }
// }
public void Dispose()
{
}
// 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
};
// 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();
// 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;
}
}
}
}
}
}
// // 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;
// }
// }
// }
// }
// }
// }
if (string.IsNullOrWhiteSpace(result.Id))
{
throw new NotImplementedException();
}
// if (string.IsNullOrWhiteSpace(result.Id))
// {
// throw new NotImplementedException();
// }
// Device hasn't implemented an m3u list
if (string.IsNullOrWhiteSpace(result.M3UUrl))
{
result.IsEnabled = false;
}
// // 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('/');
}
// 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));
// _logger.Debug("SAT device result: {0}", _json.SerializeToString(result));
return result;
}
// return result;
// }
private void FillFromDeviceNode(SatIpTunerHostInfo info, XmlReader reader)
{
reader.MoveToContent();
// private void FillFromDeviceNode(SatIpTunerHostInfo info, XmlReader reader)
// {
// reader.MoveToContent();
while (reader.Read())
{
if (reader.NodeType == XmlNodeType.Element)
{
switch (reader.LocalName)
{
case "UDN":
{
info.Id = reader.ReadElementContentAsString();
break;
}
// while (reader.Read())
// {
// if (reader.NodeType == XmlNodeType.Element)
// {
// switch (reader.LocalName)
// {
// case "UDN":
// {
// info.Id = reader.ReadElementContentAsString();
// break;
// }
case "friendlyName":
{
info.FriendlyName = reader.ReadElementContentAsString();
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;
}
// 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;
}
// 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;
}
// 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;
}
}
}
}
}
// default:
// reader.Skip();
// break;
// }
// }
// }
// }
//}
public class SatIpTunerHostInfo : TunerHostInfo
{

250
MediaBrowser.Server.Implementations/LiveTv/TunerHosts/SatIp/SatIpHost.cs
View File

@ -19,153 +19,153 @@ using MediaBrowser.Model.Serialization;
namespace MediaBrowser.Server.Implementations.LiveTv.TunerHosts.SatIp
{
public class SatIpHost : BaseTunerHost, ITunerHost
{
private readonly IFileSystem _fileSystem;
private readonly IHttpClient _httpClient;
//public class SatIpHost : BaseTunerHost, ITunerHost
//{
// private readonly IFileSystem _fileSystem;
// private readonly IHttpClient _httpClient;
public SatIpHost(IConfigurationManager config, ILogger logger, IJsonSerializer jsonSerializer, IMediaEncoder mediaEncoder, IFileSystem fileSystem, IHttpClient httpClient)
: base(config, logger, jsonSerializer, mediaEncoder)
{
_fileSystem = fileSystem;
_httpClient = httpClient;
}
// public SatIpHost(IConfigurationManager config, ILogger logger, IJsonSerializer jsonSerializer, IMediaEncoder mediaEncoder, IFileSystem fileSystem, IHttpClient httpClient)
// : base(config, logger, jsonSerializer, mediaEncoder)
// {
// _fileSystem = fileSystem;
// _httpClient = httpClient;
// }
private const string ChannelIdPrefix = "sat_";
// private const string ChannelIdPrefix = "sat_";
protected override async Task<IEnumerable<ChannelInfo>> GetChannelsInternal(TunerHostInfo tuner, CancellationToken cancellationToken)
{
var satInfo = (SatIpTunerHostInfo) tuner;
// protected override async Task<IEnumerable<ChannelInfo>> GetChannelsInternal(TunerHostInfo tuner, CancellationToken cancellationToken)
// {
// var satInfo = (SatIpTunerHostInfo) tuner;
return await new M3uParser(Logger, _fileSystem, _httpClient).Parse(satInfo.M3UUrl, ChannelIdPrefix, tuner.Id, cancellationToken).ConfigureAwait(false);
}
// return await new M3uParser(Logger, _fileSystem, _httpClient).Parse(satInfo.M3UUrl, ChannelIdPrefix, tuner.Id, cancellationToken).ConfigureAwait(false);
// }
public static string DeviceType
{
get { return "satip"; }
}
// public static string DeviceType
// {
// get { return "satip"; }
// }
public override string Type
{
get { return DeviceType; }
}
// public override string Type
// {
// get { return DeviceType; }
// }
protected override async Task<List<MediaSourceInfo>> GetChannelStreamMediaSources(TunerHostInfo tuner, string channelId, CancellationToken cancellationToken)
{
var urlHash = tuner.Url.GetMD5().ToString("N");
var prefix = ChannelIdPrefix + urlHash;
if (!channelId.StartsWith(prefix, StringComparison.OrdinalIgnoreCase))
{
return null;
}
// protected override async Task<List<MediaSourceInfo>> GetChannelStreamMediaSources(TunerHostInfo tuner, string channelId, CancellationToken cancellationToken)
// {
// var urlHash = tuner.Url.GetMD5().ToString("N");
// var prefix = ChannelIdPrefix + urlHash;
// if (!channelId.StartsWith(prefix, StringComparison.OrdinalIgnoreCase))
// {
// return null;
// }
var channels = await GetChannels(tuner, true, cancellationToken).ConfigureAwait(false);
var m3uchannels = channels.Cast<M3UChannel>();
var channel = m3uchannels.FirstOrDefault(c => string.Equals(c.Id, channelId, StringComparison.OrdinalIgnoreCase));
if (channel != null)
{
var path = channel.Path;
MediaProtocol protocol = MediaProtocol.File;
if (path.StartsWith("http", StringComparison.OrdinalIgnoreCase))
{
protocol = MediaProtocol.Http;
}
else if (path.StartsWith("rtmp", StringComparison.OrdinalIgnoreCase))
{
protocol = MediaProtocol.Rtmp;
}
else if (path.StartsWith("rtsp", StringComparison.OrdinalIgnoreCase))
{
protocol = MediaProtocol.Rtsp;
}
// var channels = await GetChannels(tuner, true, cancellationToken).ConfigureAwait(false);
// var m3uchannels = channels.Cast<M3UChannel>();
// var channel = m3uchannels.FirstOrDefault(c => string.Equals(c.Id, channelId, StringComparison.OrdinalIgnoreCase));
// if (channel != null)
// {
// var path = channel.Path;
// MediaProtocol protocol = MediaProtocol.File;
// if (path.StartsWith("http", StringComparison.OrdinalIgnoreCase))
// {
// protocol = MediaProtocol.Http;
// }
// else if (path.StartsWith("rtmp", StringComparison.OrdinalIgnoreCase))
// {
// protocol = MediaProtocol.Rtmp;
// }
// else if (path.StartsWith("rtsp", StringComparison.OrdinalIgnoreCase))
// {
// protocol = MediaProtocol.Rtsp;
// }
var mediaSource = new MediaSourceInfo
{
Path = channel.Path,
Protocol = protocol,
MediaStreams = new List<MediaStream>
{
new MediaStream
{
Type = MediaStreamType.Video,
// Set the index to -1 because we don't know the exact index of the video stream within the container
Index = -1,
IsInterlaced = true
},
new MediaStream
{
Type = MediaStreamType.Audio,
// Set the index to -1 because we don't know the exact index of the audio stream within the container
Index = -1
// var mediaSource = new MediaSourceInfo
// {
// Path = channel.Path,
// Protocol = protocol,
// MediaStreams = new List<MediaStream>
// {
// new MediaStream
// {
// Type = MediaStreamType.Video,
// // Set the index to -1 because we don't know the exact index of the video stream within the container
// Index = -1,
// IsInterlaced = true
// },
// new MediaStream
// {
// Type = MediaStreamType.Audio,
// // Set the index to -1 because we don't know the exact index of the audio stream within the container
// Index = -1
}
},
RequiresOpening = false,
RequiresClosing = false
};
// }
// },
// RequiresOpening = false,
// RequiresClosing = false
// };
return new List<MediaSourceInfo> { mediaSource };
}
return new List<MediaSourceInfo> { };
}
// return new List<MediaSourceInfo> { mediaSource };
// }
// return new List<MediaSourceInfo> { };
// }
protected override async Task<MediaSourceInfo> GetChannelStream(TunerHostInfo tuner, string channelId, string streamId, CancellationToken cancellationToken)
{
var sources = await GetChannelStreamMediaSources(tuner, channelId, cancellationToken).ConfigureAwait(false);
// protected override async Task<MediaSourceInfo> GetChannelStream(TunerHostInfo tuner, string channelId, string streamId, CancellationToken cancellationToken)
// {
// var sources = await GetChannelStreamMediaSources(tuner, channelId, cancellationToken).ConfigureAwait(false);
return sources.First();
}
// return sources.First();
// }
protected override async Task<bool> IsAvailableInternal(TunerHostInfo tuner, string channelId, CancellationToken cancellationToken)
{
var updatedInfo = await SatIpDiscovery.Current.GetInfo(tuner.Url, cancellationToken).ConfigureAwait(false);
// protected override async Task<bool> IsAvailableInternal(TunerHostInfo tuner, string channelId, CancellationToken cancellationToken)
// {
// var updatedInfo = await SatIpDiscovery.Current.GetInfo(tuner.Url, cancellationToken).ConfigureAwait(false);
return updatedInfo.TunersAvailable > 0;
}
// return updatedInfo.TunersAvailable > 0;
// }
protected override bool IsValidChannelId(string channelId)
{
return channelId.StartsWith(ChannelIdPrefix, StringComparison.OrdinalIgnoreCase);
}
// protected override bool IsValidChannelId(string channelId)
// {
// return channelId.StartsWith(ChannelIdPrefix, StringComparison.OrdinalIgnoreCase);
// }
protected override List<TunerHostInfo> GetTunerHosts()
{
return SatIpDiscovery.Current.DiscoveredHosts;
}
// protected override List<TunerHostInfo> GetTunerHosts()
// {
// return SatIpDiscovery.Current.DiscoveredHosts;
// }
public string Name
{
get { return "Sat IP"; }
}
// public string Name
// {
// get { return "Sat IP"; }
// }
public Task<List<LiveTvTunerInfo>> GetTunerInfos(CancellationToken cancellationToken)
{
var list = GetTunerHosts()
.SelectMany(i => GetTunerInfos(i, cancellationToken))
.ToList();
// public Task<List<LiveTvTunerInfo>> GetTunerInfos(CancellationToken cancellationToken)
// {
// var list = GetTunerHosts()
// .SelectMany(i => GetTunerInfos(i, cancellationToken))
// .ToList();
return Task.FromResult(list);
}
// return Task.FromResult(list);
// }
public List<LiveTvTunerInfo> GetTunerInfos(TunerHostInfo info, CancellationToken cancellationToken)
{
var satInfo = (SatIpTunerHostInfo) info;
// public List<LiveTvTunerInfo> GetTunerInfos(TunerHostInfo info, CancellationToken cancellationToken)
// {
// var satInfo = (SatIpTunerHostInfo) info;
var list = new List<LiveTvTunerInfo>();
// var list = new List<LiveTvTunerInfo>();
for (var i = 0; i < satInfo.Tuners; i++)
{
list.Add(new LiveTvTunerInfo
{
Name = satInfo.FriendlyName ?? Name,
SourceType = Type,
Status = LiveTvTunerStatus.Available,
Id = info.Url.GetMD5().ToString("N") + i.ToString(CultureInfo.InvariantCulture),
Url = info.Url
});
}
// for (var i = 0; i < satInfo.Tuners; i++)
// {
// list.Add(new LiveTvTunerInfo
// {
// Name = satInfo.FriendlyName ?? Name,
// SourceType = Type,
// Status = LiveTvTunerStatus.Available,
// Id = info.Url.GetMD5().ToString("N") + i.ToString(CultureInfo.InvariantCulture),
// Url = info.Url
// });
// }
return list;
}
}
// return list;
// }
//}
}