using System; using System.Collections.Generic; using System.Diagnostics; using System.Linq; using System.Threading; using System.Threading.Tasks; using System.Windows.Controls; using Flow.Launcher.Infrastructure.Logger; using Flow.Launcher.Infrastructure.Storage; using Flow.Launcher.Plugin.Program.Programs; using Flow.Launcher.Plugin.Program.Views; using Flow.Launcher.Plugin.Program.Views.Models; using Microsoft.Extensions.Caching.Memory; using Stopwatch = Flow.Launcher.Infrastructure.Stopwatch; namespace Flow.Launcher.Plugin.Program { public class Main : ISettingProvider, IAsyncPlugin, IPluginI18n, IContextMenu, ISavable, IAsyncReloadable, IDisposable { internal static Win32[] _win32s { get; set; } internal static UWP.Application[] _uwps { get; set; } internal static Settings _settings { get; set; } internal static PluginInitContext Context { get; private set; } private static BinaryStorage _win32Storage; private static BinaryStorage _uwpStorage; private static readonly List emptyResults = new(); private static readonly MemoryCacheOptions cacheOptions = new() { SizeLimit = 1560 }; private static MemoryCache cache = new(cacheOptions); static Main() { } public void Save() { _win32Storage.Save(_win32s); _uwpStorage.Save(_uwps); } public async Task> QueryAsync(Query query, CancellationToken token) { var result = await cache.GetOrCreateAsync(query.Search, async entry => { var resultList = await Task.Run(() => _win32s.Cast() .Concat(_uwps) .AsParallel() .WithCancellation(token) .Where(p => p.Enabled) .Select(p => p.Result(query.Search, Context.API)) .Where(r => r?.Score > 0) .ToList()); resultList = resultList.Any() ? resultList : emptyResults; entry.SetSize(resultList.Count); entry.SetSlidingExpiration(TimeSpan.FromHours(8)); return resultList; }); return result; } public async Task InitAsync(PluginInitContext context) { Context = context; _settings = context.API.LoadSettingJsonStorage(); Stopwatch.Normal("|Flow.Launcher.Plugin.Program.Main|Preload programs cost", () => { _win32Storage = new BinaryStorage("Win32"); _win32s = _win32Storage.TryLoad(Array.Empty()); _uwpStorage = new BinaryStorage("UWP"); _uwps = _uwpStorage.TryLoad(Array.Empty()); }); Log.Info($"|Flow.Launcher.Plugin.Program.Main|Number of preload win32 programs <{_win32s.Length}>"); Log.Info($"|Flow.Launcher.Plugin.Program.Main|Number of preload uwps <{_uwps.Length}>"); bool cacheEmpty = !_win32s.Any() && !_uwps.Any(); var a = Task.Run(() => { Stopwatch.Normal("|Flow.Launcher.Plugin.Program.Main|Win32Program index cost", IndexWin32Programs); }); var b = Task.Run(() => { Stopwatch.Normal("|Flow.Launcher.Plugin.Program.Main|UWPPRogram index cost", IndexUwpPrograms); }); if (cacheEmpty) await Task.WhenAll(a, b); Win32.WatchProgramUpdate(_settings); UWP.WatchPackageChange(); } public static void IndexWin32Programs() { var win32S = Win32.All(_settings); _win32s = win32S; ResetCache(); } public static void IndexUwpPrograms() { var windows10 = new Version(10, 0); var support = Environment.OSVersion.Version.Major >= windows10.Major; var applications = support ? UWP.All() : Array.Empty(); _uwps = applications; ResetCache(); } public static async Task IndexProgramsAsync() { var a = Task.Run(() => { Stopwatch.Normal("|Flow.Launcher.Plugin.Program.Main|Win32Program index cost", IndexWin32Programs); }); var b = Task.Run(() => { Stopwatch.Normal("|Flow.Launcher.Plugin.Program.Main|UWPProgram index cost", IndexUwpPrograms); }); await Task.WhenAll(a, b).ConfigureAwait(false); _settings.LastIndexTime = DateTime.Today; } internal static void ResetCache() { var oldCache = cache; cache = new MemoryCache(cacheOptions); oldCache.Dispose(); } public Control CreateSettingPanel() { return new ProgramSetting(Context, _settings, _win32s, _uwps); } public string GetTranslatedPluginTitle() { return Context.API.GetTranslation("flowlauncher_plugin_program_plugin_name"); } public string GetTranslatedPluginDescription() { return Context.API.GetTranslation("flowlauncher_plugin_program_plugin_description"); } public List LoadContextMenus(Result selectedResult) { var menuOptions = new List(); var program = selectedResult.ContextData as IProgram; if (program != null) { menuOptions = program.ContextMenus(Context.API); } menuOptions.Add( new Result { Title = Context.API.GetTranslation("flowlauncher_plugin_program_disable_program"), Action = c => { DisableProgram(program); Context.API.ShowMsg( Context.API.GetTranslation("flowlauncher_plugin_program_disable_dlgtitle_success"), Context.API.GetTranslation( "flowlauncher_plugin_program_disable_dlgtitle_success_message")); return false; }, IcoPath = "Images/disable.png", Glyph = new GlyphInfo(FontFamily: "/Resources/#Segoe Fluent Icons", Glyph: "\xece4"), } ); return menuOptions; } private static void DisableProgram(IProgram programToDelete) { if (_settings.DisabledProgramSources.Any(x => x.UniqueIdentifier == programToDelete.UniqueIdentifier)) return; if (_uwps.Any(x => x.UniqueIdentifier == programToDelete.UniqueIdentifier)) { var program = _uwps.First(x => x.UniqueIdentifier == programToDelete.UniqueIdentifier); program.Enabled = false; _settings.DisabledProgramSources.Add(new ProgramSource(program)); _ = Task.Run(() => { IndexUwpPrograms(); _settings.LastIndexTime = DateTime.Today; }); } else if (_win32s.Any(x => x.UniqueIdentifier == programToDelete.UniqueIdentifier)) { var program = _win32s.First(x => x.UniqueIdentifier == programToDelete.UniqueIdentifier); program.Enabled = false; _settings.DisabledProgramSources.Add(new ProgramSource(program)); _ = Task.Run(() => { IndexWin32Programs(); _settings.LastIndexTime = DateTime.Today; }); } } public static void StartProcess(Func runProcess, ProcessStartInfo info) { try { runProcess(info); } catch (Exception) { var name = "Plugin: Program"; var message = $"Unable to start: {info.FileName}"; Context.API.ShowMsg(name, message, string.Empty); } } public async Task ReloadDataAsync() { await IndexProgramsAsync(); } public void Dispose() { Win32.Dispose(); } } }