mirror of
https://github.com/jellyfin/jellyfin.git
synced 2024-09-09 12:58:37 +02:00
169 lines
5.1 KiB
C#
169 lines
5.1 KiB
C#
#pragma warning disable CS1591
|
|
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.IO;
|
|
using System.Linq;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
using MediaBrowser.Controller.Entities;
|
|
using MediaBrowser.Controller.Library;
|
|
using MediaBrowser.Controller.Playlists;
|
|
using MediaBrowser.Controller.Providers;
|
|
using MediaBrowser.Model.IO;
|
|
using Microsoft.Extensions.Logging;
|
|
using PlaylistsNET.Content;
|
|
|
|
namespace MediaBrowser.Providers.Playlists
|
|
{
|
|
public class PlaylistItemsProvider : ICustomMetadataProvider<Playlist>,
|
|
IHasOrder,
|
|
IForcedProvider,
|
|
IPreRefreshProvider,
|
|
IHasItemChangeMonitor
|
|
{
|
|
private readonly ILogger<PlaylistItemsProvider> _logger;
|
|
private IFileSystem _fileSystem;
|
|
|
|
public PlaylistItemsProvider(IFileSystem fileSystem, ILogger<PlaylistItemsProvider> logger)
|
|
{
|
|
_fileSystem = fileSystem;
|
|
_logger = logger;
|
|
}
|
|
|
|
public string Name => "Playlist Reader";
|
|
|
|
public Task<ItemUpdateType> FetchAsync(Playlist item, MetadataRefreshOptions options, CancellationToken cancellationToken)
|
|
{
|
|
var path = item.Path;
|
|
if (!Playlist.IsPlaylistFile(path))
|
|
{
|
|
return Task.FromResult(ItemUpdateType.None);
|
|
}
|
|
|
|
var extension = Path.GetExtension(path);
|
|
if (!Playlist.SupportedExtensions.Contains(extension ?? string.Empty, StringComparer.OrdinalIgnoreCase))
|
|
{
|
|
return Task.FromResult(ItemUpdateType.None);
|
|
}
|
|
|
|
using (var stream = File.OpenRead(path))
|
|
{
|
|
var items = GetItems(stream, extension).ToArray();
|
|
|
|
item.LinkedChildren = items;
|
|
}
|
|
|
|
return Task.FromResult(ItemUpdateType.None);
|
|
}
|
|
|
|
private IEnumerable<LinkedChild> GetItems(Stream stream, string extension)
|
|
{
|
|
if (string.Equals(".wpl", extension, StringComparison.OrdinalIgnoreCase))
|
|
{
|
|
return GetWplItems(stream);
|
|
}
|
|
|
|
if (string.Equals(".zpl", extension, StringComparison.OrdinalIgnoreCase))
|
|
{
|
|
return GetZplItems(stream);
|
|
}
|
|
|
|
if (string.Equals(".m3u", extension, StringComparison.OrdinalIgnoreCase))
|
|
{
|
|
return GetM3uItems(stream);
|
|
}
|
|
|
|
if (string.Equals(".m3u8", extension, StringComparison.OrdinalIgnoreCase))
|
|
{
|
|
return GetM3u8Items(stream);
|
|
}
|
|
|
|
if (string.Equals(".pls", extension, StringComparison.OrdinalIgnoreCase))
|
|
{
|
|
return GetPlsItems(stream);
|
|
}
|
|
|
|
return new List<LinkedChild>();
|
|
}
|
|
|
|
private IEnumerable<LinkedChild> GetPlsItems(Stream stream)
|
|
{
|
|
var content = new PlsContent();
|
|
var playlist = content.GetFromStream(stream);
|
|
|
|
return playlist.PlaylistEntries.Select(i => new LinkedChild
|
|
{
|
|
Path = i.Path,
|
|
Type = LinkedChildType.Manual
|
|
});
|
|
}
|
|
|
|
private IEnumerable<LinkedChild> GetM3u8Items(Stream stream)
|
|
{
|
|
var content = new M3uContent();
|
|
var playlist = content.GetFromStream(stream);
|
|
|
|
return playlist.PlaylistEntries.Select(i => new LinkedChild
|
|
{
|
|
Path = i.Path,
|
|
Type = LinkedChildType.Manual
|
|
});
|
|
}
|
|
|
|
private IEnumerable<LinkedChild> GetM3uItems(Stream stream)
|
|
{
|
|
var content = new M3uContent();
|
|
var playlist = content.GetFromStream(stream);
|
|
|
|
return playlist.PlaylistEntries.Select(i => new LinkedChild
|
|
{
|
|
Path = i.Path,
|
|
Type = LinkedChildType.Manual
|
|
});
|
|
}
|
|
|
|
private IEnumerable<LinkedChild> GetZplItems(Stream stream)
|
|
{
|
|
var content = new ZplContent();
|
|
var playlist = content.GetFromStream(stream);
|
|
|
|
return playlist.PlaylistEntries.Select(i => new LinkedChild
|
|
{
|
|
Path = i.Path,
|
|
Type = LinkedChildType.Manual
|
|
});
|
|
}
|
|
|
|
private IEnumerable<LinkedChild> GetWplItems(Stream stream)
|
|
{
|
|
var content = new WplContent();
|
|
var playlist = content.GetFromStream(stream);
|
|
|
|
return playlist.PlaylistEntries.Select(i => new LinkedChild
|
|
{
|
|
Path = i.Path,
|
|
Type = LinkedChildType.Manual
|
|
});
|
|
}
|
|
|
|
public bool HasChanged(BaseItem item, IDirectoryService directoryService)
|
|
{
|
|
var path = item.Path;
|
|
|
|
if (!string.IsNullOrWhiteSpace(path) && item.IsFileProtocol)
|
|
{
|
|
var file = directoryService.GetFile(path);
|
|
if (file != null && file.LastWriteTimeUtc != item.DateModified)
|
|
{
|
|
_logger.LogDebug("Refreshing {0} due to date modified timestamp change.", path);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
return false;
|
|
}
|
|
// Run last
|
|
public int Order => 100;
|
|
}
|
|
}
|