using AIStudio.Settings; using AIStudio.Tools.PluginSystem; using Microsoft.AspNetCore.Components; namespace AIStudio.Components; public abstract class MSGComponentBase : ComponentBase, IDisposable, IMessageBusReceiver, ILang { [Inject] protected SettingsManager SettingsManager { get; init; } = null!; [Inject] protected MessageBus MessageBus { get; init; } = null!; [Inject] private ILogger Logger { get; init; } = null!; private ILanguagePlugin Lang { get; set; } = PluginFactory.BaseLanguage; #region Overrides of ComponentBase protected override async Task OnInitializedAsync() { this.Lang = await this.SettingsManager.GetActiveLanguagePlugin(); this.MessageBus.RegisterComponent(this); await base.OnInitializedAsync(); } #endregion #region Implementation of ILang /// public string T(string fallbackEN) => this.GetText(this.Lang, fallbackEN); #endregion #region Implementation of IMessageBusReceiver public async Task ProcessMessage(ComponentBase? sendingComponent, Event triggeredEvent, T? data) { switch (triggeredEvent) { case Event.COLOR_THEME_CHANGED: this.StateHasChanged(); break; case Event.PLUGINS_RELOADED: this.Lang = await this.SettingsManager.GetActiveLanguagePlugin(); await this.InvokeAsync(this.StateHasChanged); break; } await this.ProcessIncomingMessage(sendingComponent, triggeredEvent, data); } public async Task ProcessMessageWithResult(ComponentBase? sendingComponent, Event triggeredEvent, TPayload? data) { return await this.ProcessIncomingMessageWithResult(sendingComponent, triggeredEvent, data); } #endregion protected virtual Task ProcessIncomingMessage(ComponentBase? sendingComponent, Event triggeredEvent, T? data) { return Task.CompletedTask; } protected virtual Task ProcessIncomingMessageWithResult(ComponentBase? sendingComponent, Event triggeredEvent, TPayload? data) { return Task.FromResult(default); } #region Implementation of IDisposable public void Dispose() { this.MessageBus.Unregister(this); } #endregion protected async Task SendMessage(Event triggeredEvent, T? data = default) { await this.MessageBus.SendMessage(this, triggeredEvent, data); } protected async Task SendMessageWithResult(Event triggeredEvent, TPayload? data) { return await this.MessageBus.SendMessageUseFirstResult(this, triggeredEvent, data); } /// /// Define for which components and events you want to receive messages. /// /// A list of components for which you want to receive messages. Use an empty list to receive messages from all components. /// A list of events for which you want to receive messages. protected void ApplyFilters(ComponentBase[] filterComponents, Event[] events) { // Append the color theme changed event to the list of events: var eventsList = new List(events) { Event.COLOR_THEME_CHANGED, Event.PLUGINS_RELOADED, }; this.MessageBus.ApplyFilters(this, filterComponents, eventsList.ToArray()); } }