Sirherobrine23/Jellyfin_Xtream
1
0
Fork 0
Code Issues 26 Pull Requests 6 Actions Releases Wiki Activity

Remove the old Live Channel, as Live TV integration has matured. #34

Merged
Kevinjil merged 1 commits from remove/issue-28 into master 2022-07-04 20:47:52 +00:00
Conversation 0 Commits 1 Files Changed 1 -189
1 changed files with 0 additions and 189 deletions
Download Patch File Download Diff File Expand all files Collapse all files

189
Jellyfin.Xtream/LiveChannel.cs
View File

@@ -1,189 +0,0 @@
// Copyright (C) 2022 Kevin Jilissen
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
// You should have received a copy of the GNU General Public License
// along with this program. If not, see <https://www.gnu.org/licenses/>.
using System;
using System.Collections.Generic;
using System.Globalization;
using System.Threading;
using System.Threading.Tasks;
using Jellyfin.Xtream.Client;
using Jellyfin.Xtream.Client.Models;
using Jellyfin.Xtream.Service;
using MediaBrowser.Controller.Channels;
using MediaBrowser.Controller.Providers;
using MediaBrowser.Model.Channels;
using MediaBrowser.Model.Dto;
using MediaBrowser.Model.Entities;
using Microsoft.Extensions.Logging;
namespace Jellyfin.Xtream
{
/// <summary>
/// The Xtream Codes API channel.
/// </summary>
public class LiveChannel : IChannel
{
private readonly ILogger<LiveChannel> logger;
/// <summary>
/// Initializes a new instance of the <see cref="LiveChannel"/> class.
/// </summary>
/// <param name="logger">Instance of the <see cref="ILogger"/> interface.</param>
public LiveChannel(ILogger<LiveChannel> logger)
{
this.logger = logger;
}
/// <inheritdoc />
public string? Name => "Xtream Live";
/// <inheritdoc />
public string? Description => "Live IPTV streamed from the Xtream-compatible server.";
/// <inheritdoc />
public string DataVersion => Plugin.Instance.Creds.ToString();
/// <inheritdoc />
public string HomePageUrl => string.Empty;
/// <inheritdoc />
public ChannelParentalRating ParentalRating => ChannelParentalRating.GeneralAudience;
/// <inheritdoc />
public InternalChannelFeatures GetChannelFeatures()
{
return new InternalChannelFeatures
{
ContentTypes = new List<ChannelMediaContentType>
{
ChannelMediaContentType.TvExtra,
},
MediaTypes = new List<ChannelMediaType>
{
ChannelMediaType.Video
},
};
}
/// <inheritdoc />
public Task<DynamicImageResponse> GetChannelImage(ImageType type, CancellationToken cancellationToken)
{
switch (type)
{
default:
throw new ArgumentException("Unsupported image type: " + type);
}
}
/// <inheritdoc />
public IEnumerable<ImageType> GetSupportedChannelImages()
{
return new List<ImageType>
{
// ImageType.Primary
};
}
/// <inheritdoc />
public async Task<ChannelItemResult> GetChannelItems(InternalChannelItemQuery query, CancellationToken cancellationToken)
{
if (string.IsNullOrEmpty(query.FolderId))
{
return await GetCategories(cancellationToken).ConfigureAwait(false);
}
int categoryId = int.Parse(query.FolderId, CultureInfo.InvariantCulture);
return await GetVideos(categoryId, cancellationToken).ConfigureAwait(false);
}
private async Task<ChannelItemResult> GetCategories(CancellationToken cancellationToken)
{
Plugin plugin = Plugin.Instance;
using (XtreamClient client = new XtreamClient())
{
List<Category> categories = await client.GetLiveCategoryAsync(plugin.Creds, cancellationToken).ConfigureAwait(false);
List<ChannelItemInfo> items = new List<ChannelItemInfo>();
foreach (Category category in categories)
{
ParsedName parsedName = plugin.StreamService.ParseName(category.CategoryName);
items.Add(new ChannelItemInfo()
{
Id = category.CategoryId.ToString(System.Globalization.CultureInfo.InvariantCulture),
Name = category.CategoryName,
Tags = new List<string>(parsedName.Tags),
Type = ChannelItemType.Folder,
});
}
ChannelItemResult result = new ChannelItemResult()
{
Items = items,
TotalRecordCount = items.Count
};
return result;
}
}
private async Task<ChannelItemResult> GetVideos(int categoryId, CancellationToken cancellationToken)
{
Plugin plugin = Plugin.Instance;
using (XtreamClient client = new XtreamClient())
{
IEnumerable<StreamInfo> channels = await client.GetLiveStreamsByCategoryAsync(plugin.Creds, categoryId, cancellationToken).ConfigureAwait(false);
List<ChannelItemInfo> items = new List<ChannelItemInfo>();
foreach (StreamInfo channel in channels)
{
long added = long.Parse(channel.Added, System.Globalization.CultureInfo.InvariantCulture);
ParsedName parsedName = plugin.StreamService.ParseName(channel.Name);
List<MediaSourceInfo> sources = new List<MediaSourceInfo>()
{
plugin.StreamService.GetMediaSourceInfo(StreamType.Live, channel.StreamId)
};
items.Add(new ChannelItemInfo()
{
ContentType = ChannelMediaContentType.TvExtra,
DateCreated = DateTimeOffset.FromUnixTimeSeconds(added).DateTime,
FolderType = ChannelFolderType.Container,
Id = channel.StreamId.ToString(CultureInfo.InvariantCulture),
ImageUrl = channel.StreamIcon,
IsLiveStream = true,
MediaSources = sources,
MediaType = ChannelMediaType.Video,
Name = parsedName.Title,
Tags = new List<string>(parsedName.Tags),
Type = ChannelItemType.Media,
});
}
ChannelItemResult result = new ChannelItemResult()
{
Items = items,
TotalRecordCount = items.Count
};
return result;
}
}
/// <inheritdoc />
public bool IsEnabledFor(string userId)
{
return true;
}
}
}