prehistoric-systems/Flow.Launcher
1
0
Fork 0
mirror of https://github.com/Flow-Launcher/Flow.Launcher.git synced 2026-03-11 08:54:32 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

Add IResultUpdateRegister interface

Browse source
This commit is contained in:
Jack251970 2025-07-21 13:52:11 +08:00
parent aee46e8640
commit f5f256809c
2 changed files with 48 additions and 38 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
Flow.Launcher.Core/Plugin/IResultUpdateRegister.cs Normal file
View file

@ -0,0 +1,12 @@
using Flow.Launcher.Plugin;
namespace Flow.Launcher.Core.Plugin;
public interface IResultUpdateRegister
{
/// <summary>
/// Register a plugin to receive results updated event.
/// </summary>
/// <param name="pair"></param>
void RegisterResultsUpdatedEvent(PluginPair pair);
}

74
Flow.Launcher/ViewModel/MainViewModel.cs
View file

@ -27,7 +27,7 @@ using ModernWpf;
namespace Flow.Launcher.ViewModel
{
public partial class MainViewModel : BaseModel, ISavable, IDisposable
public partial class MainViewModel : BaseModel, ISavable, IDisposable, IResultUpdateRegister
{
#region Private Fields
@ -274,52 +274,50 @@ namespace Flow.Launcher.ViewModel
}
}
public void RegisterResultsUpdatedEvent()
public void RegisterResultsUpdatedEvent(PluginPair pair)
{
foreach (var pair in PluginManager.GetResultUpdatePlugin())
if (pair.Plugin is not IResultUpdated plugin) return;
plugin.ResultsUpdated += (s, e) =>
{
var plugin = (IResultUpdated)pair.Plugin;
plugin.ResultsUpdated += (s, e) =>
if (e.Query.RawQuery != QueryText || e.Token.IsCancellationRequested)
{
if (e.Query.RawQuery != QueryText || e.Token.IsCancellationRequested)
return;
}
var token = e.Token == default ? _updateToken : e.Token;
IReadOnlyList<Result> resultsCopy;
if (e.Results == null)
{
resultsCopy = _emptyResult;
}
else
{
// make a clone to avoid possible issue that plugin will also change the list and items when updating view model
resultsCopy = DeepCloneResults(e.Results, false, token);
}
foreach (var result in resultsCopy)
{
if (string.IsNullOrEmpty(result.BadgeIcoPath))
{
return;
result.BadgeIcoPath = pair.Metadata.IcoPath;
}
}
var token = e.Token == default ? _updateToken : e.Token;
PluginManager.UpdatePluginMetadata(resultsCopy, pair.Metadata, e.Query);
IReadOnlyList<Result> resultsCopy;
if (e.Results == null)
{
resultsCopy = _emptyResult;
}
else
{
// make a clone to avoid possible issue that plugin will also change the list and items when updating view model
resultsCopy = DeepCloneResults(e.Results, false, token);
}
if (token.IsCancellationRequested) return;
foreach (var result in resultsCopy)
{
if (string.IsNullOrEmpty(result.BadgeIcoPath))
{
result.BadgeIcoPath = pair.Metadata.IcoPath;
}
}
App.API.LogDebug(ClassName, $"Update results for plugin <{pair.Metadata.Name}>");
PluginManager.UpdatePluginMetadata(resultsCopy, pair.Metadata, e.Query);
if (token.IsCancellationRequested) return;
App.API.LogDebug(ClassName, $"Update results for plugin <{pair.Metadata.Name}>");
if (!_resultsUpdateChannelWriter.TryWrite(new ResultsForUpdate(resultsCopy, pair.Metadata, e.Query,
token)))
{
App.API.LogError(ClassName, "Unable to add item to Result Update Queue");
}
};
}
if (!_resultsUpdateChannelWriter.TryWrite(new ResultsForUpdate(resultsCopy, pair.Metadata, e.Query,
token)))
{
App.API.LogError(ClassName, "Unable to add item to Result Update Queue");
}
};
}
private async Task RegisterClockAndDateUpdateAsync()