// Copyright (c) Microsoft Corporation // The Microsoft Corporation licenses this file to you under the MIT license. // See the LICENSE file in the project root for more information. using System; using System.Collections.Generic; using System.Diagnostics; using System.Linq; using System.Threading.Tasks; using Microsoft.Plugin.Program.Programs; using Microsoft.Plugin.Program.Storage; using Wox.Infrastructure.Logger; using Wox.Infrastructure.Storage; using Wox.Plugin; using Stopwatch = Wox.Infrastructure.Stopwatch; namespace Microsoft.Plugin.Program { public class Main : IPlugin, IPluginI18n, IContextMenu, ISavable, IReloadable, IDisposable { internal static ProgramPluginSettings Settings { get; set; } private static PluginInitContext _context; private readonly PluginJsonStorage _settingsStorage; private bool _disposed; private PackageRepository _packageRepository = new PackageRepository(new PackageCatalogWrapper(), new BinaryStorage>("UWP")); private static Win32ProgramFileSystemWatchers _win32ProgramRepositoryHelper; private static Win32ProgramRepository _win32ProgramRepository; public Main() { _settingsStorage = new PluginJsonStorage(); Settings = _settingsStorage.Load(); // This helper class initializes the file system watchers based on the locations to watch _win32ProgramRepositoryHelper = new Win32ProgramFileSystemWatchers(); // Initialize the Win32ProgramRepository with the settings object _win32ProgramRepository = new Win32ProgramRepository(_win32ProgramRepositoryHelper.FileSystemWatchers.Cast().ToList(), new BinaryStorage>("Win32"), Settings, _win32ProgramRepositoryHelper.PathsToWatch); var a = Task.Run(() => { Stopwatch.Normal("|Microsoft.Plugin.Program.Main|Win32Program index cost", _win32ProgramRepository.IndexPrograms); }); var b = Task.Run(() => { Stopwatch.Normal("|Microsoft.Plugin.Program.Main|Win32Program index cost", _packageRepository.IndexPrograms); }); Task.WaitAll(a, b); Settings.LastIndexTime = DateTime.Today; } public void Save() { _settingsStorage.Save(); } public List Query(Query query) { var results1 = _win32ProgramRepository.AsParallel() .Where(p => p.Enabled) .Select(p => p.Result(query.Search, _context.API)); var results2 = _packageRepository.AsParallel() .Where(p => p.Enabled) .Select(p => p.Result(query.Search, _context.API)); var result = results1.Concat(results2).Where(r => r != null && r.Score > 0); if (result.Any()) { var maxScore = result.Max(x => x.Score); result = result.Where(x => x.Score > Settings.MinScoreThreshold * maxScore); } return result.ToList(); } public void Init(PluginInitContext context) { _context = context ?? throw new ArgumentNullException(nameof(context)); _context.API.ThemeChanged += OnThemeChanged; UpdateUWPIconPath(_context.API.GetCurrentTheme()); } public void OnThemeChanged(Theme currentTheme, Theme newTheme) { UpdateUWPIconPath(newTheme); } public void UpdateUWPIconPath(Theme theme) { foreach (UWPApplication app in _packageRepository) { app.UpdatePath(theme); } } public void IndexPrograms() { var t1 = Task.Run(() => _win32ProgramRepository.IndexPrograms()); var t2 = Task.Run(() => _packageRepository.IndexPrograms()); Task.WaitAll(t1, t2); Settings.LastIndexTime = DateTime.Today; } public string GetTranslatedPluginTitle() { return Properties.Resources.wox_plugin_program_plugin_name; } public string GetTranslatedPluginDescription() { return Properties.Resources.wox_plugin_program_plugin_description; } public List LoadContextMenus(Result selectedResult) { if (selectedResult == null) { throw new ArgumentNullException(nameof(selectedResult)); } var menuOptions = new List(); if (selectedResult.ContextData is Programs.IProgram program) { menuOptions = program.ContextMenus(_context.API); } return menuOptions; } [System.Diagnostics.CodeAnalysis.SuppressMessage("Design", "CA1031:Do not catch general exception types", Justification = "We want to keep the process alive and show the user a warning message")] public static void StartProcess(Func runProcess, ProcessStartInfo info) { try { if (runProcess == null) { throw new ArgumentNullException(nameof(runProcess)); } if (info == null) { throw new ArgumentNullException(nameof(info)); } runProcess(info); } catch (Exception) { var name = "Plugin: Program"; var message = $"Unable to start: {info?.FileName}"; _context.API.ShowMsg(name, message, string.Empty); } } public void ReloadData() { IndexPrograms(); } public void Dispose() { Dispose(disposing: true); GC.SuppressFinalize(this); } protected virtual void Dispose(bool disposing) { if (!_disposed) { if (disposing) { _context.API.ThemeChanged -= OnThemeChanged; _win32ProgramRepositoryHelper.Dispose(); _disposed = true; } } } } }