|
|
|
using System;
|
|
|
|
using System.Collections.Generic;
|
|
|
|
using System.Linq;
|
|
|
|
using System.Threading;
|
|
|
|
using System.Threading.Tasks;
|
|
|
|
using MediaBrowser.Common.Configuration;
|
|
|
|
using MediaBrowser.Controller;
|
|
|
|
using MediaBrowser.Controller.Entities;
|
|
|
|
using MediaBrowser.Controller.Library;
|
|
|
|
using MediaBrowser.Controller.LiveTv;
|
|
|
|
using MediaBrowser.Controller.MediaEncoding;
|
|
|
|
using MediaBrowser.Model.Dto;
|
|
|
|
using MediaBrowser.Model.MediaInfo;
|
|
|
|
using MediaBrowser.Model.Serialization;
|
|
|
|
using Microsoft.Extensions.Logging;
|
|
|
|
|
|
|
|
namespace Emby.Server.Implementations.LiveTv
|
|
|
|
{
|
|
|
|
public class LiveTvMediaSourceProvider : IMediaSourceProvider
|
|
|
|
{
|
|
|
|
private readonly ILiveTvManager _liveTvManager;
|
|
|
|
private readonly IJsonSerializer _jsonSerializer;
|
|
|
|
private readonly ILogger _logger;
|
|
|
|
private readonly IMediaSourceManager _mediaSourceManager;
|
|
|
|
private readonly IMediaEncoder _mediaEncoder;
|
|
|
|
private readonly IServerApplicationHost _appHost;
|
|
|
|
private IApplicationPaths _appPaths;
|
|
|
|
|
|
|
|
public LiveTvMediaSourceProvider(ILiveTvManager liveTvManager, IApplicationPaths appPaths, IJsonSerializer jsonSerializer, ILoggerFactory loggerFactory, IMediaSourceManager mediaSourceManager, IMediaEncoder mediaEncoder, IServerApplicationHost appHost)
|
|
|
|
{
|
|
|
|
_liveTvManager = liveTvManager;
|
|
|
|
_jsonSerializer = jsonSerializer;
|
|
|
|
_mediaSourceManager = mediaSourceManager;
|
|
|
|
_mediaEncoder = mediaEncoder;
|
|
|
|
_appHost = appHost;
|
|
|
|
_logger = loggerFactory.CreateLogger(GetType().Name);
|
|
|
|
_appPaths = appPaths;
|
|
|
|
}
|
|
|
|
|
|
|
|
public Task<IEnumerable<MediaSourceInfo>> GetMediaSources(BaseItem item, CancellationToken cancellationToken)
|
|
|
|
{
|
|
|
|
var baseItem = (BaseItem)item;
|
|
|
|
|
|
|
|
if (baseItem.SourceType == SourceType.LiveTV)
|
|
|
|
{
|
|
|
|
var activeRecordingInfo = _liveTvManager.GetActiveRecordingInfo(item.Path);
|
|
|
|
|
|
|
|
if (string.IsNullOrEmpty(baseItem.Path) || activeRecordingInfo != null)
|
|
|
|
{
|
|
|
|
return GetMediaSourcesInternal(item, activeRecordingInfo, cancellationToken);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return Task.FromResult<IEnumerable<MediaSourceInfo>>(Array.Empty<MediaSourceInfo>());
|
|
|
|
}
|
|
|
|
|
|
|
|
// Do not use a pipe here because Roku http requests to the server will fail, without any explicit error message.
|
|
|
|
private const char StreamIdDelimeter = '_';
|
|
|
|
private const string StreamIdDelimeterString = "_";
|
|
|
|
|
|
|
|
private async Task<IEnumerable<MediaSourceInfo>> GetMediaSourcesInternal(BaseItem item, ActiveRecordingInfo activeRecordingInfo, CancellationToken cancellationToken)
|
|
|
|
{
|
|
|
|
IEnumerable<MediaSourceInfo> sources;
|
|
|
|
|
|
|
|
var forceRequireOpening = false;
|
|
|
|
|
|
|
|
try
|
|
|
|
{
|
|
|
|
if (activeRecordingInfo != null)
|
|
|
|
{
|
|
|
|
sources = await EmbyTV.EmbyTV.Current.GetRecordingStreamMediaSources(activeRecordingInfo, cancellationToken)
|
|
|
|
.ConfigureAwait(false);
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
sources = await _liveTvManager.GetChannelMediaSources(item, cancellationToken)
|
|
|
|
.ConfigureAwait(false);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
catch (NotImplementedException)
|
|
|
|
{
|
|
|
|
sources = _mediaSourceManager.GetStaticMediaSources(item, false);
|
|
|
|
|
|
|
|
forceRequireOpening = true;
|
|
|
|
}
|
|
|
|
|
|
|
|
var list = sources.ToList();
|
|
|
|
var serverUrl = await _appHost.GetLocalApiUrl(cancellationToken).ConfigureAwait(false);
|
|
|
|
|
|
|
|
foreach (var source in list)
|
|
|
|
{
|
|
|
|
source.Type = MediaSourceType.Default;
|
|
|
|
source.BufferMs = source.BufferMs ?? 1500;
|
|
|
|
|
|
|
|
if (source.RequiresOpening || forceRequireOpening)
|
|
|
|
{
|
|
|
|
source.RequiresOpening = true;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (source.RequiresOpening)
|
|
|
|
{
|
|
|
|
var openKeys = new List<string>();
|
|
|
|
openKeys.Add(item.GetType().Name);
|
|
|
|
openKeys.Add(item.Id.ToString("N"));
|
|
|
|
openKeys.Add(source.Id ?? string.Empty);
|
|
|
|
source.OpenToken = string.Join(StreamIdDelimeterString, openKeys.ToArray());
|
|
|
|
}
|
|
|
|
|
|
|
|
// Dummy this up so that direct play checks can still run
|
|
|
|
if (string.IsNullOrEmpty(source.Path) && source.Protocol == MediaProtocol.Http)
|
|
|
|
{
|
|
|
|
source.Path = serverUrl;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
_logger.LogDebug("MediaSources: {0}", _jsonSerializer.SerializeToString(list));
|
|
|
|
|
|
|
|
return list;
|
|
|
|
}
|
|
|
|
|
|
|
|
public async Task<ILiveStream> OpenMediaSource(string openToken, List<ILiveStream> currentLiveStreams, CancellationToken cancellationToken)
|
|
|
|
{
|
|
|
|
var keys = openToken.Split(new[] { StreamIdDelimeter }, 3);
|
|
|
|
var mediaSourceId = keys.Length >= 3 ? keys[2] : null;
|
|
|
|
|
|
|
|
var info = await _liveTvManager.GetChannelStream(keys[1], mediaSourceId, currentLiveStreams, cancellationToken).ConfigureAwait(false);
|
|
|
|
var liveStream = info.Item2;
|
|
|
|
|
|
|
|
return liveStream;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|