MindWorkAI/AI-Studio
MindWorkAI/AI-Studio
1
0
Fork 0
mirror of https://github.com/MindWorkAI/AI-Studio.git synced 2026-03-29 13:51:37 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Made event registration resilient against double registrations

Browse Source
This commit is contained in:
Thorsten Sommer 2026-03-23 13:31:34 +01:00
parent e416552467
commit 1436ffd7e0
Signed by untrusted user who does not match committer: tsommer
GPG Key ID: 371BBA77A02C0108
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
app/MindWork AI Studio/Components/MSGComponentBase.cs
View File

@ -100,7 +100,7 @@ public abstract class MSGComponentBase : ComponentBase, IDisposable, IMessageBus
Event.PLUGINS_RELOADED,
};
this.MessageBus.ApplyFilters(this, filterComponents, eventsList.ToArray());
this.MessageBus.ApplyFilters(this, filterComponents, eventsList.ToHashSet());
}
protected virtual void DisposeResources()

4
app/MindWork AI Studio/Tools/MessageBus.cs
View File

@ -33,10 +33,10 @@ public sealed class MessageBus
/// <param name="receiver">That's you, the receiver.</param>
/// <param name="filterComponents">A list of components for which you want to receive messages. Use an empty list to receive messages from all components.</param>
/// <param name="events">A list of events for which you want to receive messages.</param>
public void ApplyFilters(IMessageBusReceiver receiver, ComponentBase[] filterComponents, Event[] events)
public void ApplyFilters(IMessageBusReceiver receiver, ComponentBase[] filterComponents, HashSet<Event> events)
{
this.componentFilters[receiver] = filterComponents;
this.componentEvents[receiver] = events;
this.componentEvents[receiver] = events.ToArray();
}
public void RegisterComponent(IMessageBusReceiver receiver)

2
app/MindWork AI Studio/Tools/MessageBusExtensions.cs
View File

@ -11,6 +11,6 @@ public static class MessageBusExtensions
public static void ApplyFilters(this IMessageBusReceiver component, ComponentBase[] components, Event[] events)
{
MessageBus.INSTANCE.ApplyFilters(component, components, events);
MessageBus.INSTANCE.ApplyFilters(component, components, events.ToHashSet());
}
}