From 4c67965b5013954a79cf2860e5d98ec46517a22d Mon Sep 17 00:00:00 2001
From: Jason Dove <jason@jasondove.me>
Date: Thu, 9 Mar 2023 07:59:26 -0600
Subject: [PATCH] fix emby scanning (#1201)

---
 ErsatzTV/Services/EmbyService.cs    | 19 -------------------
 ErsatzTV/Services/ScannerService.cs | 19 +++++++++++++++++++
 2 files changed, 19 insertions(+), 19 deletions(-)

diff --git a/ErsatzTV/Services/EmbyService.cs b/ErsatzTV/Services/EmbyService.cs
index a32b4b888..2d7f40892 100644
--- a/ErsatzTV/Services/EmbyService.cs
+++ b/ErsatzTV/Services/EmbyService.cs
@@ -50,9 +50,6 @@ public class EmbyService : BackgroundService
                         case SynchronizeEmbyMediaSources synchronizeEmbyMediaSources:
                             requestTask = SynchronizeSources(synchronizeEmbyMediaSources, cancellationToken);
                             break;
-                        case SynchronizeEmbyLibraries synchronizeEmbyLibraries:
-                            requestTask = SynchronizeLibraries(synchronizeEmbyLibraries, cancellationToken);
-                            break;
                         default:
                             throw new NotSupportedException($"Unsupported request type: {request.GetType().Name}");
                     }
@@ -105,20 +102,4 @@ public class EmbyService : BackgroundService
                     error.Value);
             });
     }
-
-    private async Task SynchronizeLibraries(SynchronizeEmbyLibraries 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 Emby libraries for source {MediaSourceId}",
-                request.EmbyMediaSourceId),
-            error => _logger.LogWarning(
-                "Unable to synchronize Emby libraries for source {MediaSourceId}: {Error}",
-                request.EmbyMediaSourceId,
-                error.Value));
-    }
 }
diff --git a/ErsatzTV/Services/ScannerService.cs b/ErsatzTV/Services/ScannerService.cs
index 0042f4d5f..efcf56e9e 100644
--- a/ErsatzTV/Services/ScannerService.cs
+++ b/ErsatzTV/Services/ScannerService.cs
@@ -53,6 +53,9 @@ public class ScannerService : BackgroundService
                         case ISynchronizeJellyfinLibraryById synchronizeJellyfinLibraryById:
                             requestTask = SynchronizeJellyfinLibrary(synchronizeJellyfinLibraryById, cancellationToken);
                             break;
+                        case SynchronizeEmbyLibraries synchronizeEmbyLibraries:
+                            requestTask = SynchronizeLibraries(synchronizeEmbyLibraries, cancellationToken);
+                            break;
                         case ISynchronizeEmbyLibraryById synchronizeEmbyLibraryById:
                             requestTask = SynchronizeEmbyLibrary(synchronizeEmbyLibraryById, cancellationToken);
                             break;
@@ -224,6 +227,22 @@ public class ScannerService : BackgroundService
         }
     }
     
+    private async Task SynchronizeLibraries(SynchronizeEmbyLibraries 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 Emby libraries for source {MediaSourceId}",
+                request.EmbyMediaSourceId),
+            error => _logger.LogWarning(
+                "Unable to synchronize Emby libraries for source {MediaSourceId}: {Error}",
+                request.EmbyMediaSourceId,
+                error.Value));
+    }
+    
     private async Task SynchronizeEmbyLibrary(ISynchronizeEmbyLibraryById request, CancellationToken cancellationToken)
     {
         using IServiceScope scope = _serviceScopeFactory.CreateScope();