throttle PluginsManifest.UpdateManifestAsync

avoid repeatedly fetching manifest data while the user is typing a `pm` query

Author: JohnTheGr8

Flow.Launcher.Core/ExternalPlugins/PluginsManifest.cs

@@ -1,4 +1,4 @@
-using Flow.Launcher.Infrastructure.Logger;
+using Flow.Launcher.Infrastructure.Logger;
 using System;
 using System.Collections.Generic;
 using System.Threading;
@@ -16,6 +16,9 @@ public static class PluginsManifest
 
         private static readonly SemaphoreSlim manifestUpdateLock = new(1);
 
+        private static DateTime lastFetchedAt = DateTime.MinValue;
+        private static TimeSpan fetchTimeout = TimeSpan.FromSeconds(10);
+
         public static List<UserPlugin> UserPlugins { get; private set; }
 
         public static async Task UpdateManifestAsync(CancellationToken token = default)
@@ -24,9 +27,13 @@ public static async Task UpdateManifestAsync(CancellationToken token = default)
             {
                 await manifestUpdateLock.WaitAsync(token).ConfigureAwait(false);
 
-                var results = await mainPluginStore.FetchAsync(token).ConfigureAwait(false);
+                if (UserPlugins == null || DateTime.Now.Subtract(lastFetchedAt) >= fetchTimeout)
+                {
+                    var results = await mainPluginStore.FetchAsync(token).ConfigureAwait(false);
 
-                UserPlugins = results;
+                    UserPlugins = results;
+                    lastFetchedAt = DateTime.Now;
+                }
             }
             catch (Exception e)
             {

Plugins/Flow.Launcher.Plugin.PluginsManager/Main.cs

@@ -1,4 +1,5 @@
-using Flow.Launcher.Plugin.PluginsManager.ViewModels;
+using Flow.Launcher.Core.ExternalPlugins;
+using Flow.Launcher.Plugin.PluginsManager.ViewModels;
 using Flow.Launcher.Plugin.PluginsManager.Views;
 using System.Collections.Generic;
 using System.Linq;
@@ -34,7 +35,7 @@ public async Task InitAsync(PluginInitContext context)
             contextMenu = new ContextMenu(Context);
             pluginManager = new PluginsManager(Context, Settings);
 
-            _ = pluginManager.UpdateManifestAsync();
+            await PluginsManifest.UpdateManifestAsync();
         }
 
         public List<Result> LoadContextMenus(Result selectedResult)

Plugins/Flow.Launcher.Plugin.PluginsManager/PluginsManager.cs

@@ -1,4 +1,4 @@
-using Flow.Launcher.Core.ExternalPlugins;
+using Flow.Launcher.Core.ExternalPlugins;
 using Flow.Launcher.Core.Plugin;
 using Flow.Launcher.Infrastructure;
 using Flow.Launcher.Infrastructure.Http;
@@ -49,26 +49,6 @@ internal PluginsManager(PluginInitContext context, Settings settings)
             Settings = settings;
         }
 
-        private Task _downloadManifestTask = Task.CompletedTask;
-
-        internal Task UpdateManifestAsync(CancellationToken token = default, bool silent = false)
-        {
-            if (_downloadManifestTask.Status == TaskStatus.Running)
-            {
-                return _downloadManifestTask;
-            }
-            else
-            {
-                _downloadManifestTask = PluginsManifest.UpdateManifestAsync(token);
-                if (!silent)
-                    _downloadManifestTask.ContinueWith(_ =>
-                            Context.API.ShowMsg(Context.API.GetTranslation("plugin_pluginsmanager_update_failed_title"),
-                                Context.API.GetTranslation("plugin_pluginsmanager_update_failed_subtitle"), icoPath, false),
-                        TaskContinuationOptions.OnlyOnFaulted);
-                return _downloadManifestTask;
-            }
-        }
-
         internal List<Result> GetDefaultHotKeys()
         {
             return new List<Result>()
@@ -184,7 +164,7 @@ internal async Task InstallOrUpdateAsync(UserPlugin plugin)
 
         internal async ValueTask<List<Result>> RequestUpdateAsync(string search, CancellationToken token)
         {
-            await UpdateManifestAsync(token);
+            await PluginsManifest.UpdateManifestAsync(token);
 
             var resultsForUpdate =
                 from existingPlugin in Context.API.GetAllPlugins()
@@ -359,7 +339,7 @@ private bool InstallSourceKnown(string url)
 
         internal async ValueTask<List<Result>> RequestInstallOrUpdate(string search, CancellationToken token)
         {
-            await UpdateManifestAsync(token);
+            await PluginsManifest.UpdateManifestAsync(token);
 
             if (Uri.IsWellFormedUriString(search, UriKind.Absolute)
                 && search.Split('.').Last() == zip)