clean cache folder on startup (move channel logos, delete everything else)

ErsatzTV.Application/Images/Queries/GetImageContentsHandler.cs

@@ -42,7 +42,7 @@ namespace ErsatzTV.Application.Images.Queries
                             ArtworkKind.Poster => Path.Combine(FileSystemLayout.PosterCacheFolder, subfolder),
                             ArtworkKind.Thumbnail => Path.Combine(FileSystemLayout.ThumbnailCacheFolder, subfolder),
                             ArtworkKind.Logo => Path.Combine(FileSystemLayout.LogoCacheFolder, subfolder),
-                            _ => FileSystemLayout.ImageCacheFolder
+                            _ => FileSystemLayout.LegacyImageCacheFolder
                         };
 
                         string fileName = Path.Combine(baseFolder, request.FileName);

ErsatzTV.Core/FileSystemLayout.cs

@@ -15,7 +15,7 @@ namespace ErsatzTV.Core
 
         public static readonly string LogDatabasePath = Path.Combine(AppDataFolder, "logs.sqlite3");
 
-        public static readonly string ImageCacheFolder = Path.Combine(AppDataFolder, "cache", "images");
+        public static readonly string LegacyImageCacheFolder = Path.Combine(AppDataFolder, "cache", "images");
 
         public static readonly string PlexSecretsPath = Path.Combine(AppDataFolder, "plex-secrets.json");
 

ErsatzTV.Infrastructure/Images/ImageCache.cs

@@ -56,7 +56,7 @@ namespace ErsatzTV.Infrastructure.Images
                     ArtworkKind.Poster => Path.Combine(FileSystemLayout.PosterCacheFolder, subfolder),
                     ArtworkKind.Thumbnail => Path.Combine(FileSystemLayout.ThumbnailCacheFolder, subfolder),
                     ArtworkKind.Logo => Path.Combine(FileSystemLayout.LogoCacheFolder, subfolder),
-                    _ => FileSystemLayout.ImageCacheFolder
+                    _ => FileSystemLayout.LegacyImageCacheFolder
                 };
                 string target = Path.Combine(baseFolder, hex);
 
@@ -85,7 +85,7 @@ namespace ErsatzTV.Infrastructure.Images
                 ArtworkKind.Poster => Path.Combine(FileSystemLayout.PosterCacheFolder, subfolder),
                 ArtworkKind.Thumbnail => Path.Combine(FileSystemLayout.ThumbnailCacheFolder, subfolder),
                 ArtworkKind.Logo => Path.Combine(FileSystemLayout.LogoCacheFolder, subfolder),
-                _ => FileSystemLayout.ImageCacheFolder
+                _ => FileSystemLayout.LegacyImageCacheFolder
             };
             string target = Path.Combine(baseFolder, hex);
             _localFileSystem.CopyFile(path, target);

ErsatzTV/Extensions/HostExtensions.cs

@@ -1,4 +1,8 @@
 using System;
+using System.IO;
+using System.Linq;
+using ErsatzTV.Core;
+using ErsatzTV.Core.Domain;
 using ErsatzTV.Infrastructure.Data;
 using LanguageExt;
 using Microsoft.EntityFrameworkCore;
@@ -17,12 +21,24 @@ namespace ErsatzTV.Extensions
             return host;
         }
 
+        public static IHost CleanCacheFolder(this IHost host)
+        {
+            Unit _ = use(() => host.Services.CreateScope(), CleanCache);
+            return host;
+        }
+
         private static Unit Seed(IServiceScope scope) =>
             Try(() => scope.ServiceProvider)
                 .Bind(services => Try(GetDbContext(services)))
                 .Bind(ctx => Try(Migrate(ctx)))
                 .Bind(ctx => Try(InitializeDb(ctx)))
-                .IfFail(ex => LogException(ex, scope.ServiceProvider));
+                .IfFail(ex => LogException(ex, "Error occured while seeding database", scope.ServiceProvider));
+
+        private static Unit CleanCache(IServiceScope scope) =>
+            Try(() => scope.ServiceProvider)
+                .Bind(services => Try(GetDbContext(services)))
+                .Bind(ctx => Try(CleanCache(ctx, scope.ServiceProvider)))
+                .IfFail(ex => LogException(ex, "Error occured while cleaning cache", scope.ServiceProvider));
 
         private static TvContext GetDbContext(IServiceProvider provider) =>
             provider.GetRequiredService<TvContext>();
@@ -36,10 +52,40 @@ namespace ErsatzTV.Extensions
         private static Unit InitializeDb(TvContext context) =>
             DbInitializer.Initialize(context);
 
-        private static Unit LogException(Exception ex, IServiceProvider provider)
+        private static Unit CleanCache(TvContext context, IServiceProvider provider)
+        {
+            if (Directory.Exists(FileSystemLayout.LegacyImageCacheFolder))
+            {
+                ILogger<Program> logger = provider.GetRequiredService<ILogger<Program>>();
+                logger.LogInformation("Migrating channel logos from legacy image cache folder");
+
+                var logos = context.Channels
+                    .SelectMany(c => c.Artwork)
+                    .Where(a => a.ArtworkKind == ArtworkKind.Logo)
+                    .Map(a => a.Path)
+                    .ToList();
+
+                foreach (string logo in logos)
+                {
+                    string legacyPath = Path.Combine(FileSystemLayout.LegacyImageCacheFolder, logo);
+                    if (File.Exists(legacyPath))
+                    {
+                        string subfolder = logo.Substring(0, 2);
+                        string newPath = Path.Combine(FileSystemLayout.LogoCacheFolder, subfolder, logo);
+                        File.Copy(legacyPath, newPath, true);
+                    }
+                }
+
+                logger.LogInformation("Deleting legacy image cache folder");
+                Directory.Delete(FileSystemLayout.LegacyImageCacheFolder, true);
+            }
+
+            return Unit.Default;
+        }
+
+        private static Unit LogException(Exception ex, string message, IServiceProvider provider)
         {
-            provider.GetRequiredService<ILogger<Program>>()
-                .LogError(ex, "Error occured while seeding database");
+            provider.GetRequiredService<ILogger<Program>>().LogError(ex, message);
             return unit;
         }
     }

ErsatzTV/Program.cs

@@ -34,6 +34,7 @@ namespace ErsatzTV
                 await CreateHostBuilder(args)
                     .Build()
                     .SeedDatabase()
+                    .CleanCacheFolder()
                     .RunAsync();
                 return 0;
             }