|
|
|
|
using MediaBrowser.Common.Extensions;
|
|
|
|
|
using MediaBrowser.Common.IO;
|
|
|
|
|
using MediaBrowser.Controller;
|
|
|
|
|
using MediaBrowser.Controller.Drawing;
|
|
|
|
|
using MediaBrowser.Controller.Dto;
|
|
|
|
|
using MediaBrowser.Controller.Entities;
|
|
|
|
|
using MediaBrowser.Controller.Library;
|
|
|
|
|
using MediaBrowser.Controller.LiveTv;
|
|
|
|
|
using MediaBrowser.Controller.Localization;
|
|
|
|
|
using MediaBrowser.Controller.Persistence;
|
|
|
|
|
using MediaBrowser.Model.LiveTv;
|
|
|
|
|
using MediaBrowser.Model.Logging;
|
|
|
|
|
using MediaBrowser.Model.Querying;
|
|
|
|
|
using System;
|
|
|
|
|
using System.Collections.Generic;
|
|
|
|
|
using System.IO;
|
|
|
|
|
using System.Linq;
|
|
|
|
|
using System.Threading;
|
|
|
|
|
using System.Threading.Tasks;
|
|
|
|
|
|
|
|
|
|
namespace MediaBrowser.Server.Implementations.LiveTv
|
|
|
|
|
{
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// Class LiveTvManager
|
|
|
|
|
/// </summary>
|
|
|
|
|
public class LiveTvManager : ILiveTvManager
|
|
|
|
|
{
|
|
|
|
|
private readonly IServerApplicationPaths _appPaths;
|
|
|
|
|
private readonly IFileSystem _fileSystem;
|
|
|
|
|
private readonly ILogger _logger;
|
|
|
|
|
private readonly IItemRepository _itemRepo;
|
|
|
|
|
private readonly IUserManager _userManager;
|
|
|
|
|
|
|
|
|
|
private readonly ILocalizationManager _localization;
|
|
|
|
|
private readonly LiveTvDtoService _tvDtoService;
|
|
|
|
|
|
|
|
|
|
private readonly List<ILiveTvService> _services = new List<ILiveTvService>();
|
|
|
|
|
|
|
|
|
|
private Dictionary<Guid, LiveTvChannel> _channels = new Dictionary<Guid, LiveTvChannel>();
|
|
|
|
|
private Dictionary<Guid, LiveTvProgram> _programs = new Dictionary<Guid, LiveTvProgram>();
|
|
|
|
|
|
|
|
|
|
public LiveTvManager(IServerApplicationPaths appPaths, IFileSystem fileSystem, ILogger logger, IItemRepository itemRepo, IImageProcessor imageProcessor, ILocalizationManager localization, IUserDataManager userDataManager, IDtoService dtoService, IUserManager userManager)
|
|
|
|
|
{
|
|
|
|
|
_appPaths = appPaths;
|
|
|
|
|
_fileSystem = fileSystem;
|
|
|
|
|
_logger = logger;
|
|
|
|
|
_itemRepo = itemRepo;
|
|
|
|
|
_localization = localization;
|
|
|
|
|
_userManager = userManager;
|
|
|
|
|
|
|
|
|
|
_tvDtoService = new LiveTvDtoService(dtoService, userDataManager, imageProcessor, logger);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// Gets the services.
|
|
|
|
|
/// </summary>
|
|
|
|
|
/// <value>The services.</value>
|
|
|
|
|
public IReadOnlyList<ILiveTvService> Services
|
|
|
|
|
{
|
|
|
|
|
get { return _services; }
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public ILiveTvService ActiveService { get; private set; }
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// Adds the parts.
|
|
|
|
|
/// </summary>
|
|
|
|
|
/// <param name="services">The services.</param>
|
|
|
|
|
public void AddParts(IEnumerable<ILiveTvService> services)
|
|
|
|
|
{
|
|
|
|
|
_services.AddRange(services);
|
|
|
|
|
|
|
|
|
|
ActiveService = _services.FirstOrDefault();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public Task<QueryResult<ChannelInfoDto>> GetChannels(ChannelQuery query, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
var user = string.IsNullOrEmpty(query.UserId) ? null : _userManager.GetUserById(new Guid(query.UserId));
|
|
|
|
|
|
|
|
|
|
IEnumerable<LiveTvChannel> channels = _channels.Values;
|
|
|
|
|
|
|
|
|
|
if (user != null)
|
|
|
|
|
{
|
|
|
|
|
channels = channels
|
|
|
|
|
.Where(i => i.IsParentalAllowed(user, _localization))
|
|
|
|
|
.OrderBy(i =>
|
|
|
|
|
{
|
|
|
|
|
double number = 0;
|
|
|
|
|
|
|
|
|
|
if (!string.IsNullOrEmpty(i.ChannelInfo.Number))
|
|
|
|
|
{
|
|
|
|
|
double.TryParse(i.ChannelInfo.Number, out number);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return number;
|
|
|
|
|
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
var returnChannels = channels.OrderBy(i =>
|
|
|
|
|
{
|
|
|
|
|
double number = 0;
|
|
|
|
|
|
|
|
|
|
if (!string.IsNullOrEmpty(i.ChannelInfo.Number))
|
|
|
|
|
{
|
|
|
|
|
double.TryParse(i.ChannelInfo.Number, out number);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return number;
|
|
|
|
|
|
|
|
|
|
}).ThenBy(i => i.Name)
|
|
|
|
|
.Select(i => _tvDtoService.GetChannelInfoDto(i, user))
|
|
|
|
|
.ToArray();
|
|
|
|
|
|
|
|
|
|
var result = new QueryResult<ChannelInfoDto>
|
|
|
|
|
{
|
|
|
|
|
Items = returnChannels,
|
|
|
|
|
TotalRecordCount = returnChannels.Length
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
return Task.FromResult(result);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public LiveTvChannel GetInternalChannel(string id)
|
|
|
|
|
{
|
|
|
|
|
var guid = new Guid(id);
|
|
|
|
|
|
|
|
|
|
LiveTvChannel channel = null;
|
|
|
|
|
|
|
|
|
|
_channels.TryGetValue(guid, out channel);
|
|
|
|
|
return channel;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public LiveTvProgram GetInternalProgram(string id)
|
|
|
|
|
{
|
|
|
|
|
var guid = new Guid(id);
|
|
|
|
|
|
|
|
|
|
LiveTvProgram obj = null;
|
|
|
|
|
|
|
|
|
|
_programs.TryGetValue(guid, out obj);
|
|
|
|
|
return obj;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public async Task<LiveTvRecording> GetInternalRecording(string id, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
var service = ActiveService;
|
|
|
|
|
|
|
|
|
|
var recordings = await service.GetRecordingsAsync(cancellationToken).ConfigureAwait(false);
|
|
|
|
|
|
|
|
|
|
var recording = recordings.FirstOrDefault(i => _tvDtoService.GetInternalRecordingId(service.Name, i.Id) == new Guid(id));
|
|
|
|
|
|
|
|
|
|
return await GetRecording(recording, service.Name, cancellationToken).ConfigureAwait(false);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public async Task<StreamResponseInfo> GetRecordingStream(string id, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
var service = ActiveService;
|
|
|
|
|
|
|
|
|
|
var recordings = await service.GetRecordingsAsync(cancellationToken).ConfigureAwait(false);
|
|
|
|
|
|
|
|
|
|
var recording = recordings.FirstOrDefault(i => _tvDtoService.GetInternalRecordingId(service.Name, i.Id) == new Guid(id));
|
|
|
|
|
|
|
|
|
|
return await service.GetRecordingStream(recording.Id, cancellationToken).ConfigureAwait(false);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private async Task<LiveTvChannel> GetChannel(ChannelInfo channelInfo, string serviceName, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
var path = Path.Combine(_appPaths.ItemsByNamePath, "channels", _fileSystem.GetValidFilename(serviceName), _fileSystem.GetValidFilename(channelInfo.Name));
|
|
|
|
|
|
|
|
|
|
var fileInfo = new DirectoryInfo(path);
|
|
|
|
|
|
|
|
|
|
var isNew = false;
|
|
|
|
|
|
|
|
|
|
if (!fileInfo.Exists)
|
|
|
|
|
{
|
|
|
|
|
Directory.CreateDirectory(path);
|
|
|
|
|
fileInfo = new DirectoryInfo(path);
|
|
|
|
|
|
|
|
|
|
if (!fileInfo.Exists)
|
|
|
|
|
{
|
|
|
|
|
throw new IOException("Path not created: " + path);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
isNew = true;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
var id = _tvDtoService.GetInternalChannelId(serviceName, channelInfo.Id, channelInfo.Name);
|
|
|
|
|
|
|
|
|
|
var item = _itemRepo.RetrieveItem(id) as LiveTvChannel;
|
|
|
|
|
|
|
|
|
|
if (item == null)
|
|
|
|
|
{
|
|
|
|
|
item = new LiveTvChannel
|
|
|
|
|
{
|
|
|
|
|
Name = channelInfo.Name,
|
|
|
|
|
Id = id,
|
|
|
|
|
DateCreated = _fileSystem.GetCreationTimeUtc(fileInfo),
|
|
|
|
|
DateModified = _fileSystem.GetLastWriteTimeUtc(fileInfo),
|
|
|
|
|
Path = path
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
isNew = true;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
item.ChannelInfo = channelInfo;
|
|
|
|
|
item.ServiceName = serviceName;
|
|
|
|
|
|
|
|
|
|
// Set this now so we don't cause additional file system access during provider executions
|
|
|
|
|
item.ResetResolveArgs(fileInfo);
|
|
|
|
|
|
|
|
|
|
await item.RefreshMetadata(cancellationToken, forceSave: isNew, resetResolveArgs: false);
|
|
|
|
|
|
|
|
|
|
return item;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private async Task<LiveTvProgram> GetProgram(ProgramInfo info, ChannelType channelType, string serviceName, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
var isNew = false;
|
|
|
|
|
|
|
|
|
|
var id = _tvDtoService.GetInternalProgramId(serviceName, info.Id);
|
|
|
|
|
|
|
|
|
|
var item = _itemRepo.RetrieveItem(id) as LiveTvProgram;
|
|
|
|
|
|
|
|
|
|
if (item == null)
|
|
|
|
|
{
|
|
|
|
|
item = new LiveTvProgram
|
|
|
|
|
{
|
|
|
|
|
Name = info.Name,
|
|
|
|
|
Id = id,
|
|
|
|
|
DateCreated = DateTime.UtcNow,
|
|
|
|
|
DateModified = DateTime.UtcNow
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
isNew = true;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
item.ChannelType = channelType;
|
|
|
|
|
item.ProgramInfo = info;
|
|
|
|
|
item.ServiceName = serviceName;
|
|
|
|
|
|
|
|
|
|
await item.RefreshMetadata(cancellationToken, forceSave: isNew, resetResolveArgs: false);
|
|
|
|
|
|
|
|
|
|
return item;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private async Task<LiveTvRecording> GetRecording(RecordingInfo info, string serviceName, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
var isNew = false;
|
|
|
|
|
|
|
|
|
|
var id = _tvDtoService.GetInternalRecordingId(serviceName, info.Id);
|
|
|
|
|
|
|
|
|
|
var item = _itemRepo.RetrieveItem(id) as LiveTvRecording;
|
|
|
|
|
|
|
|
|
|
if (item == null)
|
|
|
|
|
{
|
|
|
|
|
item = new LiveTvRecording
|
|
|
|
|
{
|
|
|
|
|
Name = info.Name,
|
|
|
|
|
Id = id,
|
|
|
|
|
DateCreated = DateTime.UtcNow,
|
|
|
|
|
DateModified = DateTime.UtcNow
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
isNew = true;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
item.RecordingInfo = info;
|
|
|
|
|
item.ServiceName = serviceName;
|
|
|
|
|
|
|
|
|
|
await item.RefreshMetadata(cancellationToken, forceSave: isNew, resetResolveArgs: false);
|
|
|
|
|
|
|
|
|
|
return item;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public async Task<ProgramInfoDto> GetProgram(string id, CancellationToken cancellationToken, User user = null)
|
|
|
|
|
{
|
|
|
|
|
var program = GetInternalProgram(id);
|
|
|
|
|
|
|
|
|
|
var dto = _tvDtoService.GetProgramInfoDto(program, user);
|
|
|
|
|
|
|
|
|
|
await AddRecordingInfo(new[] { dto }, cancellationToken).ConfigureAwait(false);
|
|
|
|
|
|
|
|
|
|
return dto;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public async Task<QueryResult<ProgramInfoDto>> GetPrograms(ProgramQuery query, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
IEnumerable<LiveTvProgram> programs = _programs.Values;
|
|
|
|
|
|
|
|
|
|
if (query.ChannelIdList.Length > 0)
|
|
|
|
|
{
|
|
|
|
|
var guids = query.ChannelIdList.Select(i => new Guid(i)).ToList();
|
|
|
|
|
var serviceName = ActiveService.Name;
|
|
|
|
|
|
|
|
|
|
programs = programs.Where(i =>
|
|
|
|
|
{
|
|
|
|
|
var programChannelId = i.ProgramInfo.ChannelId;
|
|
|
|
|
|
|
|
|
|
var internalProgramChannelId = _tvDtoService.GetInternalChannelId(serviceName, programChannelId, i.ProgramInfo.ChannelName);
|
|
|
|
|
|
|
|
|
|
return guids.Contains(internalProgramChannelId);
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
var user = string.IsNullOrEmpty(query.UserId) ? null : _userManager.GetUserById(new Guid(query.UserId));
|
|
|
|
|
|
|
|
|
|
if (user != null)
|
|
|
|
|
{
|
|
|
|
|
programs = programs.Where(i => i.IsParentalAllowed(user, _localization));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
var returnArray = programs
|
|
|
|
|
.OrderBy(i => i.ProgramInfo.StartDate)
|
|
|
|
|
.Select(i => _tvDtoService.GetProgramInfoDto(i, user))
|
|
|
|
|
.ToArray();
|
|
|
|
|
|
|
|
|
|
await AddRecordingInfo(returnArray, cancellationToken).ConfigureAwait(false);
|
|
|
|
|
|
|
|
|
|
var result = new QueryResult<ProgramInfoDto>
|
|
|
|
|
{
|
|
|
|
|
Items = returnArray,
|
|
|
|
|
TotalRecordCount = returnArray.Length
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
return result;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private async Task AddRecordingInfo(IEnumerable<ProgramInfoDto> programs, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
var timers = await ActiveService.GetTimersAsync(cancellationToken).ConfigureAwait(false);
|
|
|
|
|
var timerList = timers.ToList();
|
|
|
|
|
|
|
|
|
|
foreach (var program in programs)
|
|
|
|
|
{
|
|
|
|
|
var timer = timerList.FirstOrDefault(i => string.Equals(i.ProgramId, program.ExternalId, StringComparison.OrdinalIgnoreCase));
|
|
|
|
|
|
|
|
|
|
if (timer != null)
|
|
|
|
|
{
|
|
|
|
|
program.TimerId = _tvDtoService.GetInternalTimerId(program.ServiceName, timer.Id)
|
|
|
|
|
.ToString("N");
|
|
|
|
|
|
|
|
|
|
if (!string.IsNullOrEmpty(timer.SeriesTimerId))
|
|
|
|
|
{
|
|
|
|
|
program.SeriesTimerId = _tvDtoService.GetInternalSeriesTimerId(program.ServiceName, timer.SeriesTimerId)
|
|
|
|
|
.ToString("N");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
internal async Task RefreshChannels(IProgress<double> progress, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
// Avoid implicitly captured closure
|
|
|
|
|
var service = ActiveService;
|
|
|
|
|
|
|
|
|
|
if (service == null)
|
|
|
|
|
{
|
|
|
|
|
progress.Report(100);
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
progress.Report(10);
|
|
|
|
|
|
|
|
|
|
var allChannels = await GetChannels(service, cancellationToken).ConfigureAwait(false);
|
|
|
|
|
var allChannelsList = allChannels.ToList();
|
|
|
|
|
|
|
|
|
|
var list = new List<LiveTvChannel>();
|
|
|
|
|
var programs = new List<LiveTvProgram>();
|
|
|
|
|
|
|
|
|
|
var numComplete = 0;
|
|
|
|
|
|
|
|
|
|
foreach (var channelInfo in allChannelsList)
|
|
|
|
|
{
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
var item = await GetChannel(channelInfo.Item2, channelInfo.Item1, cancellationToken).ConfigureAwait(false);
|
|
|
|
|
|
|
|
|
|
var channelPrograms = await service.GetProgramsAsync(channelInfo.Item2.Id, cancellationToken).ConfigureAwait(false);
|
|
|
|
|
|
|
|
|
|
var programTasks = channelPrograms.Select(program => GetProgram(program, item.ChannelInfo.ChannelType, service.Name, cancellationToken));
|
|
|
|
|
var programEntities = await Task.WhenAll(programTasks).ConfigureAwait(false);
|
|
|
|
|
|
|
|
|
|
programs.AddRange(programEntities);
|
|
|
|
|
|
|
|
|
|
list.Add(item);
|
|
|
|
|
}
|
|
|
|
|
catch (OperationCanceledException)
|
|
|
|
|
{
|
|
|
|
|
throw;
|
|
|
|
|
}
|
|
|
|
|
catch (Exception ex)
|
|
|
|
|
{
|
|
|
|
|
_logger.ErrorException("Error getting channel information for {0}", ex, channelInfo.Item2.Name);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
numComplete++;
|
|
|
|
|
double percent = numComplete;
|
|
|
|
|
percent /= allChannelsList.Count;
|
|
|
|
|
|
|
|
|
|
progress.Report(90 * percent + 10);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
_programs = programs.ToDictionary(i => i.Id);
|
|
|
|
|
_channels = list.ToDictionary(i => i.Id);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private async Task<IEnumerable<Tuple<string, ChannelInfo>>> GetChannels(ILiveTvService service, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
var channels = await service.GetChannelsAsync(cancellationToken).ConfigureAwait(false);
|
|
|
|
|
|
|
|
|
|
return channels.Select(i => new Tuple<string, ChannelInfo>(service.Name, i));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public async Task<QueryResult<RecordingInfoDto>> GetRecordings(RecordingQuery query, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
var service = ActiveService;
|
|
|
|
|
|
|
|
|
|
var user = string.IsNullOrEmpty(query.UserId) ? null : _userManager.GetUserById(new Guid(query.UserId));
|
|
|
|
|
|
|
|
|
|
var list = new List<RecordingInfo>();
|
|
|
|
|
|
|
|
|
|
var recordings = await service.GetRecordingsAsync(cancellationToken).ConfigureAwait(false);
|
|
|
|
|
list.AddRange(recordings);
|
|
|
|
|
|
|
|
|
|
if (!string.IsNullOrEmpty(query.ChannelId))
|
|
|
|
|
{
|
|
|
|
|
list = list
|
|
|
|
|
.Where(i => _tvDtoService.GetInternalChannelId(service.Name, i.ChannelId, i.ChannelName) == new Guid(query.ChannelId))
|
|
|
|
|
.ToList();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (!string.IsNullOrEmpty(query.Id))
|
|
|
|
|
{
|
|
|
|
|
list = list
|
|
|
|
|
.Where(i => _tvDtoService.GetInternalRecordingId(service.Name, i.Id) == new Guid(query.Id))
|
|
|
|
|
.ToList();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
var entities = await GetEntities(list, service.Name, cancellationToken).ConfigureAwait(false);
|
|
|
|
|
|
|
|
|
|
if (user != null)
|
|
|
|
|
{
|
|
|
|
|
entities = entities.Where(i => i.IsParentalAllowed(user, _localization)).ToArray();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
var returnArray = entities
|
|
|
|
|
.Select(i => _tvDtoService.GetRecordingInfoDto(i, service, user))
|
|
|
|
|
.OrderByDescending(i => i.StartDate)
|
|
|
|
|
.ToArray();
|
|
|
|
|
|
|
|
|
|
return new QueryResult<RecordingInfoDto>
|
|
|
|
|
{
|
|
|
|
|
Items = returnArray,
|
|
|
|
|
TotalRecordCount = returnArray.Length
|
|
|
|
|
};
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private Task<LiveTvRecording[]> GetEntities(IEnumerable<RecordingInfo> recordings, string serviceName, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
var tasks = recordings.Select(i => GetRecording(i, serviceName, cancellationToken));
|
|
|
|
|
|
|
|
|
|
return Task.WhenAll(tasks);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private IEnumerable<ILiveTvService> GetServices(string serviceName, string channelId)
|
|
|
|
|
{
|
|
|
|
|
IEnumerable<ILiveTvService> services = _services;
|
|
|
|
|
|
|
|
|
|
if (string.IsNullOrEmpty(serviceName) && !string.IsNullOrEmpty(channelId))
|
|
|
|
|
{
|
|
|
|
|
var channel = GetInternalChannel(channelId);
|
|
|
|
|
|
|
|
|
|
if (channel != null)
|
|
|
|
|
{
|
|
|
|
|
serviceName = channel.ServiceName;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (!string.IsNullOrEmpty(serviceName))
|
|
|
|
|
{
|
|
|
|
|
services = services.Where(i => string.Equals(i.Name, serviceName, StringComparison.OrdinalIgnoreCase));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return services;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public async Task<QueryResult<TimerInfoDto>> GetTimers(TimerQuery query, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
var service = ActiveService;
|
|
|
|
|
var timers = await service.GetTimersAsync(cancellationToken).ConfigureAwait(false);
|
|
|
|
|
|
|
|
|
|
if (!string.IsNullOrEmpty(query.ChannelId))
|
|
|
|
|
{
|
|
|
|
|
var guid = new Guid(query.ChannelId);
|
|
|
|
|
timers = timers.Where(i => guid == _tvDtoService.GetInternalChannelId(service.Name, i.ChannelId, i.ChannelName));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
var returnArray = timers
|
|
|
|
|
.Select(i =>
|
|
|
|
|
{
|
|
|
|
|
var program = string.IsNullOrEmpty(i.ProgramId) ? null : GetInternalProgram(_tvDtoService.GetInternalProgramId(service.Name, i.ProgramId).ToString("N"));
|
|
|
|
|
|
|
|
|
|
return _tvDtoService.GetTimerInfoDto(i, service, program);
|
|
|
|
|
})
|
|
|
|
|
.OrderBy(i => i.StartDate)
|
|
|
|
|
.ToArray();
|
|
|
|
|
|
|
|
|
|
return new QueryResult<TimerInfoDto>
|
|
|
|
|
{
|
|
|
|
|
Items = returnArray,
|
|
|
|
|
TotalRecordCount = returnArray.Length
|
|
|
|
|
};
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public async Task DeleteRecording(string recordingId)
|
|
|
|
|
{
|
|
|
|
|
var recording = await GetRecording(recordingId, CancellationToken.None).ConfigureAwait(false);
|
|
|
|
|
|
|
|
|
|
if (recording == null)
|
|
|
|
|
{
|
|
|
|
|
throw new ResourceNotFoundException(string.Format("Recording with Id {0} not found", recordingId));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
var service = GetServices(recording.ServiceName, null)
|
|
|
|
|
.First();
|
|
|
|
|
|
|
|
|
|
await service.DeleteRecordingAsync(recording.ExternalId, CancellationToken.None).ConfigureAwait(false);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public async Task CancelTimer(string id)
|
|
|
|
|
{
|
|
|
|
|
var timer = await GetTimer(id, CancellationToken.None).ConfigureAwait(false);
|
|
|
|
|
|
|
|
|
|
if (timer == null)
|
|
|
|
|
{
|
|
|
|
|
throw new ResourceNotFoundException(string.Format("Timer with Id {0} not found", id));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
var service = GetServices(timer.ServiceName, null)
|
|
|
|
|
.First();
|
|
|
|
|
|
|
|
|
|
await service.CancelTimerAsync(timer.ExternalId, CancellationToken.None).ConfigureAwait(false);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public async Task CancelSeriesTimer(string id)
|
|
|
|
|
{
|
|
|
|
|
var timer = await GetSeriesTimer(id, CancellationToken.None).ConfigureAwait(false);
|
|
|
|
|
|
|
|
|
|
if (timer == null)
|
|
|
|
|
{
|
|
|
|
|
throw new ResourceNotFoundException(string.Format("Timer with Id {0} not found", id));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
var service = GetServices(timer.ServiceName, null)
|
|
|
|
|
.First();
|
|
|
|
|
|
|
|
|
|
await service.CancelSeriesTimerAsync(timer.ExternalId, CancellationToken.None).ConfigureAwait(false);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public async Task<RecordingInfoDto> GetRecording(string id, CancellationToken cancellationToken, User user = null)
|
|
|
|
|
{
|
|
|
|
|
var results = await GetRecordings(new RecordingQuery
|
|
|
|
|
{
|
|
|
|
|
UserId = user == null ? null : user.Id.ToString("N"),
|
|
|
|
|
Id = id
|
|
|
|
|
|
|
|
|
|
}, cancellationToken).ConfigureAwait(false);
|
|
|
|
|
|
|
|
|
|
return results.Items.FirstOrDefault();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public async Task<TimerInfoDto> GetTimer(string id, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
var results = await GetTimers(new TimerQuery(), cancellationToken).ConfigureAwait(false);
|
|
|
|
|
|
|
|
|
|
return results.Items.FirstOrDefault(i => string.Equals(i.Id, id, StringComparison.CurrentCulture));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public async Task<SeriesTimerInfoDto> GetSeriesTimer(string id, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
var results = await GetSeriesTimers(new SeriesTimerQuery(), cancellationToken).ConfigureAwait(false);
|
|
|
|
|
|
|
|
|
|
return results.Items.FirstOrDefault(i => string.Equals(i.Id, id, StringComparison.CurrentCulture));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public async Task<QueryResult<SeriesTimerInfoDto>> GetSeriesTimers(SeriesTimerQuery query, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
var service = ActiveService;
|
|
|
|
|
|
|
|
|
|
var timers = await service.GetSeriesTimersAsync(cancellationToken).ConfigureAwait(false);
|
|
|
|
|
|
|
|
|
|
var returnArray = timers
|
|
|
|
|
.Select(i => _tvDtoService.GetSeriesTimerInfoDto(i, service))
|
|
|
|
|
.OrderByDescending(i => i.StartDate)
|
|
|
|
|
.ToArray();
|
|
|
|
|
|
|
|
|
|
return new QueryResult<SeriesTimerInfoDto>
|
|
|
|
|
{
|
|
|
|
|
Items = returnArray,
|
|
|
|
|
TotalRecordCount = returnArray.Length
|
|
|
|
|
};
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public Task<ChannelInfoDto> GetChannel(string id, CancellationToken cancellationToken, User user = null)
|
|
|
|
|
{
|
|
|
|
|
var channel = GetInternalChannel(id);
|
|
|
|
|
|
|
|
|
|
var dto = _tvDtoService.GetChannelInfoDto(channel, user);
|
|
|
|
|
|
|
|
|
|
return Task.FromResult(dto);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public async Task<SeriesTimerInfoDto> GetNewTimerDefaults(CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
var service = ActiveService;
|
|
|
|
|
|
|
|
|
|
var info = await service.GetNewTimerDefaultsAsync(cancellationToken).ConfigureAwait(false);
|
|
|
|
|
|
|
|
|
|
var obj = _tvDtoService.GetSeriesTimerInfoDto(info, service);
|
|
|
|
|
|
|
|
|
|
obj.Id = obj.ExternalId = string.Empty;
|
|
|
|
|
|
|
|
|
|
return obj;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public async Task<SeriesTimerInfoDto> GetNewTimerDefaults(string programId, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
var info = await GetNewTimerDefaults(cancellationToken).ConfigureAwait(false);
|
|
|
|
|
|
|
|
|
|
var program = await GetProgram(programId, cancellationToken).ConfigureAwait(false);
|
|
|
|
|
|
|
|
|
|
info.Days = new List<DayOfWeek>
|
|
|
|
|
{
|
|
|
|
|
program.StartDate.ToLocalTime().DayOfWeek
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
info.DayPattern = _tvDtoService.GetDayPattern(info.Days);
|
|
|
|
|
|
|
|
|
|
info.Name = program.Name;
|
|
|
|
|
info.ChannelId = program.ChannelId;
|
|
|
|
|
info.ChannelName = program.ChannelName;
|
|
|
|
|
info.EndDate = program.EndDate;
|
|
|
|
|
info.StartDate = program.StartDate;
|
|
|
|
|
info.Name = program.Name;
|
|
|
|
|
info.Overview = program.Overview;
|
|
|
|
|
info.ProgramId = program.Id;
|
|
|
|
|
info.ExternalProgramId = program.ExternalId;
|
|
|
|
|
|
|
|
|
|
return info;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public async Task CreateTimer(TimerInfoDto timer, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
var service = string.IsNullOrEmpty(timer.ServiceName) ? ActiveService : GetServices(timer.ServiceName, null).First();
|
|
|
|
|
|
|
|
|
|
var info = await _tvDtoService.GetTimerInfo(timer, true, this, cancellationToken).ConfigureAwait(false);
|
|
|
|
|
|
|
|
|
|
// Set priority from default values
|
|
|
|
|
var defaultValues = await service.GetNewTimerDefaultsAsync(cancellationToken).ConfigureAwait(false);
|
|
|
|
|
info.Priority = defaultValues.Priority;
|
|
|
|
|
|
|
|
|
|
await service.CreateTimerAsync(info, cancellationToken).ConfigureAwait(false);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public async Task CreateSeriesTimer(SeriesTimerInfoDto timer, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
var service = string.IsNullOrEmpty(timer.ServiceName) ? ActiveService : GetServices(timer.ServiceName, null).First();
|
|
|
|
|
|
|
|
|
|
var info = await _tvDtoService.GetSeriesTimerInfo(timer, true, this, cancellationToken).ConfigureAwait(false);
|
|
|
|
|
|
|
|
|
|
// Set priority from default values
|
|
|
|
|
var defaultValues = await service.GetNewTimerDefaultsAsync(cancellationToken).ConfigureAwait(false);
|
|
|
|
|
info.Priority = defaultValues.Priority;
|
|
|
|
|
|
|
|
|
|
await service.CreateSeriesTimerAsync(info, cancellationToken).ConfigureAwait(false);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public async Task UpdateTimer(TimerInfoDto timer, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
var info = await _tvDtoService.GetTimerInfo(timer, false, this, cancellationToken).ConfigureAwait(false);
|
|
|
|
|
|
|
|
|
|
var service = string.IsNullOrEmpty(timer.ServiceName) ? ActiveService : GetServices(timer.ServiceName, null).First();
|
|
|
|
|
|
|
|
|
|
await service.UpdateTimerAsync(info, cancellationToken).ConfigureAwait(false);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public async Task UpdateSeriesTimer(SeriesTimerInfoDto timer, CancellationToken cancellationToken)
|
|
|
|
|
{
|
|
|
|
|
var info = await _tvDtoService.GetSeriesTimerInfo(timer, false, this, cancellationToken).ConfigureAwait(false);
|
|
|
|
|
|
|
|
|
|
var service = string.IsNullOrEmpty(timer.ServiceName) ? ActiveService : GetServices(timer.ServiceName, null).First();
|
|
|
|
|
|
|
|
|
|
await service.UpdateSeriesTimerAsync(info, cancellationToken).ConfigureAwait(false);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|