2016-02-19 07:20:18 +01:00
|
|
|
|
using System;
|
|
|
|
|
using System.Collections.Generic;
|
2016-12-07 21:03:00 +01:00
|
|
|
|
using System.Globalization;
|
2016-02-19 07:20:18 +01:00
|
|
|
|
using System.IO;
|
2016-08-30 20:17:37 +02:00
|
|
|
|
using System.Linq;
|
2016-02-21 18:22:13 +01:00
|
|
|
|
using System.Text.RegularExpressions;
|
2016-02-19 07:20:18 +01:00
|
|
|
|
using System.Threading;
|
|
|
|
|
using System.Threading.Tasks;
|
2016-10-25 21:02:04 +02:00
|
|
|
|
using MediaBrowser.Model.IO;
|
2016-02-19 07:20:18 +01:00
|
|
|
|
using MediaBrowser.Common.Extensions;
|
2016-10-25 21:02:04 +02:00
|
|
|
|
using MediaBrowser.Common.IO;
|
2016-02-19 07:20:18 +01:00
|
|
|
|
using MediaBrowser.Common.Net;
|
2016-10-18 20:35:27 +02:00
|
|
|
|
using MediaBrowser.Controller;
|
2016-10-25 21:02:04 +02:00
|
|
|
|
using MediaBrowser.Controller.IO;
|
2016-02-19 07:20:18 +01:00
|
|
|
|
using MediaBrowser.Controller.LiveTv;
|
|
|
|
|
using MediaBrowser.Model.Logging;
|
|
|
|
|
|
2016-11-04 00:35:19 +01:00
|
|
|
|
namespace Emby.Server.Implementations.LiveTv.TunerHosts
|
2016-02-19 07:20:18 +01:00
|
|
|
|
{
|
|
|
|
|
public class M3uParser
|
|
|
|
|
{
|
|
|
|
|
private readonly ILogger _logger;
|
|
|
|
|
private readonly IFileSystem _fileSystem;
|
|
|
|
|
private readonly IHttpClient _httpClient;
|
2016-10-18 20:35:27 +02:00
|
|
|
|
private readonly IServerApplicationHost _appHost;
|
2016-02-19 07:20:18 +01:00
|
|
|
|
|
2016-10-18 20:35:27 +02:00
|
|
|
|
public M3uParser(ILogger logger, IFileSystem fileSystem, IHttpClient httpClient, IServerApplicationHost appHost)
|
2016-02-19 07:20:18 +01:00
|
|
|
|
{
|
|
|
|
|
_logger = logger;
|
|
|
|
|
_fileSystem = fileSystem;
|
|
|
|
|
_httpClient = httpClient;
|
2016-10-18 20:35:27 +02:00
|
|
|
|
_appHost = appHost;
|
2016-02-19 07:20:18 +01:00
|
|
|
|
}
|
|
|
|
|
|
2016-02-24 20:06:26 +01:00
|
|
|
|
public async Task<List<M3UChannel>> Parse(string url, string channelIdPrefix, string tunerHostId, CancellationToken cancellationToken)
|
2016-02-19 07:20:18 +01:00
|
|
|
|
{
|
|
|
|
|
var urlHash = url.GetMD5().ToString("N");
|
|
|
|
|
|
|
|
|
|
// Read the file and display it line by line.
|
|
|
|
|
using (var reader = new StreamReader(await GetListingsStream(url, cancellationToken).ConfigureAwait(false)))
|
|
|
|
|
{
|
2016-02-24 20:06:26 +01:00
|
|
|
|
return GetChannels(reader, urlHash, channelIdPrefix, tunerHostId);
|
2016-02-19 07:20:18 +01:00
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public Task<Stream> GetListingsStream(string url, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
if (url.StartsWith("http", StringComparison.OrdinalIgnoreCase))
|
|
|
|
|
{
|
2016-10-18 20:35:27 +02:00
|
|
|
|
return _httpClient.Get(new HttpRequestOptions
|
|
|
|
|
{
|
|
|
|
|
Url = url,
|
|
|
|
|
CancellationToken = cancellationToken,
|
|
|
|
|
// Some data providers will require a user agent
|
|
|
|
|
UserAgent = _appHost.FriendlyName + "/" + _appHost.ApplicationVersion
|
|
|
|
|
});
|
2016-02-19 07:20:18 +01:00
|
|
|
|
}
|
|
|
|
|
return Task.FromResult(_fileSystem.OpenRead(url));
|
|
|
|
|
}
|
|
|
|
|
|
2016-11-27 21:52:24 +01:00
|
|
|
|
const string ExtInfPrefix = "#EXTINF:";
|
2016-02-24 20:06:26 +01:00
|
|
|
|
private List<M3UChannel> GetChannels(StreamReader reader, string urlHash, string channelIdPrefix, string tunerHostId)
|
2016-02-19 07:20:18 +01:00
|
|
|
|
{
|
|
|
|
|
var channels = new List<M3UChannel>();
|
|
|
|
|
string line;
|
2016-02-23 01:48:30 +01:00
|
|
|
|
string extInf = "";
|
2016-11-27 21:52:24 +01:00
|
|
|
|
while ((line = reader.ReadLine()) != null)
|
2016-02-19 07:20:18 +01:00
|
|
|
|
{
|
|
|
|
|
line = line.Trim();
|
|
|
|
|
if (string.IsNullOrWhiteSpace(line))
|
|
|
|
|
{
|
|
|
|
|
continue;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (line.StartsWith("#EXTM3U", StringComparison.OrdinalIgnoreCase))
|
|
|
|
|
{
|
|
|
|
|
continue;
|
|
|
|
|
}
|
|
|
|
|
|
2016-11-27 21:52:24 +01:00
|
|
|
|
if (line.StartsWith(ExtInfPrefix, StringComparison.OrdinalIgnoreCase))
|
2016-02-19 07:20:18 +01:00
|
|
|
|
{
|
2016-11-27 21:52:24 +01:00
|
|
|
|
extInf = line.Substring(ExtInfPrefix.Length).Trim();
|
2016-02-23 01:48:30 +01:00
|
|
|
|
_logger.Info("Found m3u channel: {0}", extInf);
|
2016-02-19 07:20:18 +01:00
|
|
|
|
}
|
2016-03-19 02:40:13 +01:00
|
|
|
|
else if (!string.IsNullOrWhiteSpace(extInf) && !line.StartsWith("#", StringComparison.OrdinalIgnoreCase))
|
2016-02-24 20:06:26 +01:00
|
|
|
|
{
|
2016-08-30 20:17:37 +02:00
|
|
|
|
var channel = GetChannelnfo(extInf, tunerHostId, line);
|
2016-02-23 02:09:08 +01:00
|
|
|
|
channel.Id = channelIdPrefix + urlHash + line.GetMD5().ToString("N");
|
|
|
|
|
channel.Path = line;
|
2016-02-23 01:48:30 +01:00
|
|
|
|
channels.Add(channel);
|
|
|
|
|
extInf = "";
|
2016-02-19 07:20:18 +01:00
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
return channels;
|
|
|
|
|
}
|
2016-11-27 21:52:24 +01:00
|
|
|
|
|
2016-08-30 20:17:37 +02:00
|
|
|
|
private M3UChannel GetChannelnfo(string extInf, string tunerHostId, string mediaUrl)
|
2016-02-23 01:48:30 +01:00
|
|
|
|
{
|
|
|
|
|
var channel = new M3UChannel();
|
2016-02-24 20:06:26 +01:00
|
|
|
|
channel.TunerHostId = tunerHostId;
|
2016-02-23 01:48:30 +01:00
|
|
|
|
|
2016-11-27 21:52:24 +01:00
|
|
|
|
extInf = extInf.Trim();
|
2016-02-23 01:48:30 +01:00
|
|
|
|
|
2016-12-07 21:03:00 +01:00
|
|
|
|
string remaining;
|
|
|
|
|
var attributes = ParseExtInf(extInf, out remaining);
|
|
|
|
|
extInf = remaining;
|
2016-11-27 21:52:24 +01:00
|
|
|
|
|
2016-12-07 21:03:00 +01:00
|
|
|
|
string value;
|
|
|
|
|
if (attributes.TryGetValue("tvg-logo", out value))
|
|
|
|
|
{
|
|
|
|
|
channel.ImageUrl = value;
|
|
|
|
|
}
|
2016-11-27 21:52:24 +01:00
|
|
|
|
|
2016-12-07 21:03:00 +01:00
|
|
|
|
channel.Name = GetChannelName(extInf, attributes);
|
|
|
|
|
channel.Number = GetChannelNumber(extInf, attributes, mediaUrl);
|
2016-11-27 21:52:24 +01:00
|
|
|
|
|
|
|
|
|
return channel;
|
|
|
|
|
}
|
|
|
|
|
|
2016-12-07 21:03:00 +01:00
|
|
|
|
private string GetChannelNumber(string extInf, Dictionary<string, string> attributes, string mediaUrl)
|
2016-11-27 21:52:24 +01:00
|
|
|
|
{
|
|
|
|
|
var nameParts = extInf.Split(new[] { ',' }, StringSplitOptions.RemoveEmptyEntries);
|
|
|
|
|
var nameInExtInf = nameParts.Length > 1 ? nameParts.Last().Trim() : null;
|
|
|
|
|
|
|
|
|
|
var numberString = nameParts[0];
|
|
|
|
|
|
|
|
|
|
//Check for channel number with the format from SatIp
|
|
|
|
|
int number;
|
|
|
|
|
if (!string.IsNullOrWhiteSpace(nameInExtInf))
|
2016-02-23 01:48:30 +01:00
|
|
|
|
{
|
2016-11-27 21:52:24 +01:00
|
|
|
|
var numberIndex = nameInExtInf.IndexOf('.');
|
|
|
|
|
if (numberIndex > 0)
|
2016-02-23 01:48:30 +01:00
|
|
|
|
{
|
2016-11-27 21:52:24 +01:00
|
|
|
|
if (int.TryParse(nameInExtInf.Substring(0, numberIndex), out number))
|
|
|
|
|
{
|
|
|
|
|
numberString = number.ToString();
|
|
|
|
|
}
|
2016-02-23 01:48:30 +01:00
|
|
|
|
}
|
|
|
|
|
}
|
2016-08-30 20:17:37 +02:00
|
|
|
|
|
2016-12-07 21:03:00 +01:00
|
|
|
|
if (!string.IsNullOrWhiteSpace(numberString))
|
|
|
|
|
{
|
|
|
|
|
numberString = numberString.Trim();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (string.IsNullOrWhiteSpace(numberString) ||
|
2016-11-27 21:52:24 +01:00
|
|
|
|
string.Equals(numberString, "-1", StringComparison.OrdinalIgnoreCase) ||
|
|
|
|
|
string.Equals(numberString, "0", StringComparison.OrdinalIgnoreCase))
|
2016-08-30 20:17:37 +02:00
|
|
|
|
{
|
2016-12-07 21:03:00 +01:00
|
|
|
|
string value;
|
|
|
|
|
if (attributes.TryGetValue("tvg-id", out value))
|
|
|
|
|
{
|
|
|
|
|
numberString = value;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (!string.IsNullOrWhiteSpace(numberString))
|
|
|
|
|
{
|
|
|
|
|
numberString = numberString.Trim();
|
2016-08-30 20:17:37 +02:00
|
|
|
|
}
|
|
|
|
|
|
2016-11-27 21:52:24 +01:00
|
|
|
|
if (string.IsNullOrWhiteSpace(numberString) ||
|
|
|
|
|
string.Equals(numberString, "-1", StringComparison.OrdinalIgnoreCase) ||
|
|
|
|
|
string.Equals(numberString, "0", StringComparison.OrdinalIgnoreCase))
|
2016-08-30 20:17:37 +02:00
|
|
|
|
{
|
2016-12-07 21:03:00 +01:00
|
|
|
|
string value;
|
|
|
|
|
if (attributes.TryGetValue("channel-id", out value))
|
|
|
|
|
{
|
|
|
|
|
numberString = value;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (!string.IsNullOrWhiteSpace(numberString))
|
|
|
|
|
{
|
|
|
|
|
numberString = numberString.Trim();
|
2016-08-30 20:17:37 +02:00
|
|
|
|
}
|
|
|
|
|
|
2016-11-27 21:52:24 +01:00
|
|
|
|
if (string.IsNullOrWhiteSpace(numberString) ||
|
|
|
|
|
string.Equals(numberString, "-1", StringComparison.OrdinalIgnoreCase) ||
|
|
|
|
|
string.Equals(numberString, "0", StringComparison.OrdinalIgnoreCase))
|
|
|
|
|
{
|
|
|
|
|
numberString = null;
|
|
|
|
|
}
|
2016-10-18 20:23:41 +02:00
|
|
|
|
|
2016-11-27 21:52:24 +01:00
|
|
|
|
if (string.IsNullOrWhiteSpace(numberString))
|
2016-10-18 20:23:41 +02:00
|
|
|
|
{
|
2016-11-27 21:52:24 +01:00
|
|
|
|
if (string.IsNullOrWhiteSpace(mediaUrl))
|
|
|
|
|
{
|
|
|
|
|
numberString = null;
|
|
|
|
|
}
|
|
|
|
|
else
|
|
|
|
|
{
|
|
|
|
|
numberString = Path.GetFileNameWithoutExtension(mediaUrl.Split('/').Last());
|
2016-12-07 21:03:00 +01:00
|
|
|
|
|
|
|
|
|
double value;
|
|
|
|
|
if (!double.TryParse(numberString, NumberStyles.Any, CultureInfo.InvariantCulture, out value))
|
|
|
|
|
{
|
|
|
|
|
numberString = null;
|
|
|
|
|
}
|
2016-11-27 21:52:24 +01:00
|
|
|
|
}
|
2016-10-18 20:23:41 +02:00
|
|
|
|
}
|
|
|
|
|
|
2016-11-27 21:52:24 +01:00
|
|
|
|
return numberString;
|
|
|
|
|
}
|
2016-10-18 20:23:41 +02:00
|
|
|
|
|
2016-12-07 21:03:00 +01:00
|
|
|
|
private string GetChannelName(string extInf, Dictionary<string, string> attributes)
|
2016-11-27 21:52:24 +01:00
|
|
|
|
{
|
|
|
|
|
var nameParts = extInf.Split(new[] { ',' }, StringSplitOptions.RemoveEmptyEntries);
|
|
|
|
|
var nameInExtInf = nameParts.Length > 1 ? nameParts.Last().Trim() : null;
|
|
|
|
|
|
|
|
|
|
//Check for channel number with the format from SatIp
|
|
|
|
|
int number;
|
|
|
|
|
if (!string.IsNullOrWhiteSpace(nameInExtInf))
|
2016-10-18 20:23:41 +02:00
|
|
|
|
{
|
2016-11-27 21:52:24 +01:00
|
|
|
|
var numberIndex = nameInExtInf.IndexOf('.');
|
|
|
|
|
if (numberIndex > 0)
|
|
|
|
|
{
|
|
|
|
|
if (int.TryParse(nameInExtInf.Substring(0, numberIndex), out number))
|
|
|
|
|
{
|
|
|
|
|
//channel.Number = number.ToString();
|
|
|
|
|
nameInExtInf = nameInExtInf.Substring(numberIndex + 1);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
2016-12-07 21:03:00 +01:00
|
|
|
|
string name;
|
|
|
|
|
attributes.TryGetValue("tvg-name", out name);
|
|
|
|
|
|
2016-11-27 21:52:24 +01:00
|
|
|
|
if (string.IsNullOrWhiteSpace(name))
|
|
|
|
|
{
|
|
|
|
|
name = nameInExtInf;
|
2016-10-18 20:23:41 +02:00
|
|
|
|
}
|
|
|
|
|
|
2016-11-27 21:52:24 +01:00
|
|
|
|
if (string.IsNullOrWhiteSpace(name))
|
2016-10-18 20:23:41 +02:00
|
|
|
|
{
|
2016-12-07 21:03:00 +01:00
|
|
|
|
attributes.TryGetValue("tvg-id", out name);
|
2016-10-18 20:23:41 +02:00
|
|
|
|
}
|
|
|
|
|
|
2016-11-27 21:52:24 +01:00
|
|
|
|
if (string.IsNullOrWhiteSpace(name))
|
|
|
|
|
{
|
|
|
|
|
name = null;
|
|
|
|
|
}
|
2016-02-23 01:48:30 +01:00
|
|
|
|
|
2016-11-27 21:52:24 +01:00
|
|
|
|
return name;
|
2016-02-23 01:48:30 +01:00
|
|
|
|
}
|
2016-11-27 21:52:24 +01:00
|
|
|
|
|
2016-12-07 21:03:00 +01:00
|
|
|
|
private Dictionary<string, string> ParseExtInf(string line, out string remaining)
|
2016-02-21 18:22:13 +01:00
|
|
|
|
{
|
2016-12-07 21:03:00 +01:00
|
|
|
|
var dict = new Dictionary<string, string>(StringComparer.OrdinalIgnoreCase);
|
|
|
|
|
|
2016-02-21 18:22:13 +01:00
|
|
|
|
var reg = new Regex(@"([a-z0-9\-_]+)=\""([^""]+)\""", RegexOptions.IgnoreCase);
|
2016-12-07 21:03:00 +01:00
|
|
|
|
var matches = reg.Matches(line);
|
|
|
|
|
var minIndex = int.MaxValue;
|
2016-02-21 18:22:13 +01:00
|
|
|
|
foreach (Match match in matches)
|
|
|
|
|
{
|
2016-12-07 21:03:00 +01:00
|
|
|
|
dict[match.Groups[1].Value] = match.Groups[2].Value;
|
|
|
|
|
minIndex = Math.Min(minIndex, match.Index);
|
2016-02-21 18:22:13 +01:00
|
|
|
|
}
|
2016-12-07 21:03:00 +01:00
|
|
|
|
|
|
|
|
|
if (minIndex > 0 && minIndex < line.Length)
|
|
|
|
|
{
|
|
|
|
|
line = line.Substring(0, minIndex);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
remaining = line;
|
|
|
|
|
|
|
|
|
|
return dict;
|
2016-02-21 18:22:13 +01:00
|
|
|
|
}
|
2016-02-19 07:20:18 +01:00
|
|
|
|
}
|
|
|
|
|
|
2016-02-21 18:22:13 +01:00
|
|
|
|
|
2016-02-19 07:20:18 +01:00
|
|
|
|
public class M3UChannel : ChannelInfo
|
|
|
|
|
{
|
|
|
|
|
public string Path { get; set; }
|
|
|
|
|
}
|
2016-02-21 18:22:13 +01:00
|
|
|
|
}
|