add jellyfin media source (#185)

* wip * start to add jellyfin tables to db * code cleanup * finish adding jellyfin media source * sync jellyfin libraries * display list of jellyfin libraries * toggle jellyfin library sync * edit jellyfin path replacements * noop jellyfin scanners * get jellyfin admin user id on startup * implement jellyfin disconnect * add jellyfin libraries to list; start to query jellyfin library items * code cleanup * start to project jellyfin movies * save new jellyfin movies to db * basic jellyfin movie update * load jellyfin actor artwork * load jellyfin movie poster and fan art * more jellyfin artwork fixes, sync audio streams * jellyfin playback sort of works * skip jellyfin movies that are inaccessible * use ffprobe for jellyfin movie statistics * code cleanup * store jellyfin operating system * more jellyfin movie updates * update jellyfin movie poster and fan art * add jellyfin tv types * sync jellyfin shows * sync jellyfin seasons * sync jellyfin episodes * remove missing jellyfin television items * delete empty jellyfin seasons and shows * fix jellyfin updates * fix indexing jellyfin movie and show languages
2021-05-15 13:14:17 -05:00
parent 27e0a70d93
commit 4d86250630
132 changed files with 17318 additions and 106 deletions
@@ -0,0 +1,159 @@
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Linq;
+using System.Threading;
+using System.Threading.Channels;
+using System.Threading.Tasks;
+using ErsatzTV.Application;
+using ErsatzTV.Application.Jellyfin.Commands;
+using ErsatzTV.Core;
+using ErsatzTV.Core.Domain;
+using LanguageExt;
+using MediatR;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Hosting;
+using Microsoft.Extensions.Logging;
+using Unit = LanguageExt.Unit;
+
+namespace ErsatzTV.Services
+{
+    public class JellyfinService : BackgroundService
+    {
+        private readonly ChannelReader<IJellyfinBackgroundServiceRequest> _channel;
+        private readonly ILogger<JellyfinService> _logger;
+        private readonly IServiceScopeFactory _serviceScopeFactory;
+
+        public JellyfinService(
+            ChannelReader<IJellyfinBackgroundServiceRequest> channel,
+            IServiceScopeFactory serviceScopeFactory,
+            ILogger<JellyfinService> logger)
+        {
+            _channel = channel;
+            _serviceScopeFactory = serviceScopeFactory;
+            _logger = logger;
+        }
+
+        protected override async Task ExecuteAsync(CancellationToken cancellationToken)
+        {
+            if (!File.Exists(FileSystemLayout.JellyfinSecretsPath))
+            {
+                await File.WriteAllTextAsync(FileSystemLayout.JellyfinSecretsPath, "{}", cancellationToken);
+            }
+
+            _logger.LogInformation(
+                "Jellyfin service started; secrets are at {JellyfinSecretsPath}",
+                FileSystemLayout.JellyfinSecretsPath);
+
+            // synchronize sources on startup
+            await SynchronizeSources(new SynchronizeJellyfinMediaSources(), cancellationToken);
+
+            await foreach (IJellyfinBackgroundServiceRequest request in _channel.ReadAllAsync(cancellationToken))
+            {
+                try
+                {
+                    Task requestTask;
+                    switch (request)
+                    {
+                        case SynchronizeJellyfinMediaSources synchronizeJellyfinMediaSources:
+                            requestTask = SynchronizeSources(synchronizeJellyfinMediaSources, cancellationToken);
+                            break;
+                        case SynchronizeJellyfinAdminUserId synchronizeJellyfinAdminUserId:
+                            requestTask = SynchronizeAdminUserId(synchronizeJellyfinAdminUserId, cancellationToken);
+                            break;
+                        case SynchronizeJellyfinLibraries synchronizeJellyfinLibraries:
+                            requestTask = SynchronizeLibraries(synchronizeJellyfinLibraries, cancellationToken);
+                            break;
+                        case ISynchronizeJellyfinLibraryById synchronizeJellyfinLibraryById:
+                            requestTask = SynchronizeJellyfinLibrary(synchronizeJellyfinLibraryById, cancellationToken);
+                            break;
+                        default:
+                            throw new NotSupportedException($"Unsupported request type: {request.GetType().Name}");
+                    }
+
+                    await requestTask;
+                }
+                catch (Exception ex)
+                {
+                    _logger.LogWarning(ex, "Failed to process Jellyfin background service request");
+                }
+            }
+        }
+
+        private async Task SynchronizeSources(
+            SynchronizeJellyfinMediaSources request,
+            CancellationToken cancellationToken)
+        {
+            using IServiceScope scope = _serviceScopeFactory.CreateScope();
+            IMediator mediator = scope.ServiceProvider.GetRequiredService<IMediator>();
+
+            Either<BaseError, List<JellyfinMediaSource>> result = await mediator.Send(request, cancellationToken);
+            result.Match(
+                sources =>
+                {
+                    if (sources.Any())
+                    {
+                        _logger.LogInformation("Successfully synchronized jellyfin media sources");
+                    }
+                },
+                error =>
+                {
+                    _logger.LogWarning(
+                        "Unable to synchronize jellyfin media sources: {Error}",
+                        error.Value);
+                });
+        }
+
+        private async Task SynchronizeLibraries(
+            SynchronizeJellyfinLibraries request,
+            CancellationToken cancellationToken)
+        {
+            using IServiceScope scope = _serviceScopeFactory.CreateScope();
+            IMediator mediator = scope.ServiceProvider.GetRequiredService<IMediator>();
+
+            Either<BaseError, Unit> result = await mediator.Send(request, cancellationToken);
+            result.BiIter(
+                _ => _logger.LogInformation(
+                    "Successfully synchronized Jellyfin libraries for source {MediaSourceId}",
+                    request.JellyfinMediaSourceId),
+                error => _logger.LogWarning(
+                    "Unable to synchronize Jellyfin libraries for source {MediaSourceId}: {Error}",
+                    request.JellyfinMediaSourceId,
+                    error.Value));
+        }
+
+        private async Task SynchronizeAdminUserId(
+            SynchronizeJellyfinAdminUserId request,
+            CancellationToken cancellationToken)
+        {
+            using IServiceScope scope = _serviceScopeFactory.CreateScope();
+            IMediator mediator = scope.ServiceProvider.GetRequiredService<IMediator>();
+
+            Either<BaseError, Unit> result = await mediator.Send(request, cancellationToken);
+            result.BiIter(
+                _ => _logger.LogInformation(
+                    "Successfully synchronized Jellyfin admin user id for source {MediaSourceId}",
+                    request.JellyfinMediaSourceId),
+                error => _logger.LogWarning(
+                    "Unable to synchronize Jellyfin admin user id for source {MediaSourceId}: {Error}",
+                    request.JellyfinMediaSourceId,
+                    error.Value));
+        }
+
+        private async Task SynchronizeJellyfinLibrary(
+            ISynchronizeJellyfinLibraryById request,
+            CancellationToken cancellationToken)
+        {
+            using IServiceScope scope = _serviceScopeFactory.CreateScope();
+            IMediator mediator = scope.ServiceProvider.GetRequiredService<IMediator>();
+
+            Either<BaseError, string> result = await mediator.Send(request, cancellationToken);
+            result.BiIter(
+                name => _logger.LogDebug("Done synchronizing jellyfin library {Name}", name),
+                error => _logger.LogWarning(
+                    "Unable to synchronize jellyfin library {LibraryId}: {Error}",
+                    request.JellyfinLibraryId,
+                    error.Value));
+        }
+    }
+}