aboutsummaryrefslogtreecommitdiff
path: root/Emby.Server.Implementations/LiveTv
diff options
context:
space:
mode:
authorLuke Pulverenti <luke.pulverenti@gmail.com>2017-09-25 01:06:15 -0400
committerLuke Pulverenti <luke.pulverenti@gmail.com>2017-09-25 01:06:15 -0400
commit978eedbcb7a778248acd03b7f924260db70cd406 (patch)
tree034fcf627081d6b0f5b60c62e5147127de438371 /Emby.Server.Implementations/LiveTv
parent768f20b1bbc16c9f0eb013a486d472dc7d2684a2 (diff)
improve support for compressed xmltv
Diffstat (limited to 'Emby.Server.Implementations/LiveTv')
-rw-r--r--Emby.Server.Implementations/LiveTv/Listings/XmlTvListingsProvider.cs42
1 files changed, 22 insertions, 20 deletions
diff --git a/Emby.Server.Implementations/LiveTv/Listings/XmlTvListingsProvider.cs b/Emby.Server.Implementations/LiveTv/Listings/XmlTvListingsProvider.cs
index fb8308cda..55500df6e 100644
--- a/Emby.Server.Implementations/LiveTv/Listings/XmlTvListingsProvider.cs
+++ b/Emby.Server.Implementations/LiveTv/Listings/XmlTvListingsProvider.cs
@@ -65,14 +65,15 @@ namespace Emby.Server.Implementations.LiveTv.Listings
if (!path.StartsWith("http", StringComparison.OrdinalIgnoreCase))
{
- return path;
+ return UnzipIfNeeded(path, path);
}
var cacheFilename = DateTime.UtcNow.DayOfYear.ToString(CultureInfo.InvariantCulture) + "-" + DateTime.UtcNow.Hour.ToString(CultureInfo.InvariantCulture) + ".xml";
var cacheFile = Path.Combine(_config.ApplicationPaths.CachePath, "xmltv", cacheFilename);
if (_fileSystem.FileExists(cacheFile))
{
- return UnzipIfNeeded(path, cacheFile);
+ //return UnzipIfNeeded(path, cacheFile);
+ return cacheFile;
}
_logger.Info("Downloading xmltv listings from {0}", path);
@@ -112,28 +113,29 @@ namespace Emby.Server.Implementations.LiveTv.Listings
}
_logger.Debug("Returning xmltv path {0}", cacheFile);
- return UnzipIfNeeded(path, cacheFile);
+ return cacheFile;
+ //return UnzipIfNeeded(path, cacheFile);
}
private string UnzipIfNeeded(string originalUrl, string file)
{
- //var ext = Path.GetExtension(originalUrl);
-
- //if (string.Equals(ext, ".gz", StringComparison.OrdinalIgnoreCase))
- //{
- // using (var stream = _fileSystem.OpenRead(file))
- // {
- // var tempFolder = Path.Combine(_config.ApplicationPaths.TempDirectory, Guid.NewGuid().ToString());
- // _fileSystem.CreateDirectory(tempFolder);
-
- // _zipClient.ExtractAllFromZip(stream, tempFolder, true);
-
- // return _fileSystem.GetFiles(tempFolder, true)
- // .Where(i => string.Equals(i.Extension, ".xml", StringComparison.OrdinalIgnoreCase))
- // .Select(i => i.FullName)
- // .FirstOrDefault();
- // }
- //}
+ var ext = Path.GetExtension(originalUrl.Split('?')[0]);
+
+ if (string.Equals(ext, ".gz", StringComparison.OrdinalIgnoreCase))
+ {
+ using (var stream = _fileSystem.OpenRead(file))
+ {
+ var tempFolder = Path.Combine(_config.ApplicationPaths.TempDirectory, Guid.NewGuid().ToString());
+ _fileSystem.CreateDirectory(tempFolder);
+
+ _zipClient.ExtractAllFromGz(stream, tempFolder, true);
+
+ return _fileSystem.GetFiles(tempFolder, true)
+ .Where(i => string.Equals(i.Extension, ".xml", StringComparison.OrdinalIgnoreCase))
+ .Select(i => i.FullName)
+ .FirstOrDefault();
+ }
+ }
return file;
}