MachineVariablesViewModel.cs

using CommunityToolkit.Mvvm.ComponentModel;
using NeuroAccessMaui.Services;
using System.Collections.ObjectModel;
using System.Diagnostics.CodeAnalysis;
using Waher.Script;
 
namespace NeuroAccessMaui.UI.Pages.Wallet.MachineVariables
{
    public partial class MachineVariablesViewModel : BaseViewModel
    {
        public MachineVariablesViewModel(MachineVariablesNavigationArgs? Args)
            : base()
        {
            this.Variables = [];
 
            if (Args is not null)
            {
                this.Running = Args.Running;
                this.Ended = Args.Ended;
                this.CurrentState = Args.CurrentState;
 
                if (Args.Variables is not null)
                {
                    foreach (Variable Variable in Args.Variables)
                        this.Variables.Add(new VariableModel(Variable.Name, Variable.ValueObject));
                }
            }
        }
 
        public override async Task OnInitializeAsync()
        {
            await base.OnInitializeAsync();
 
            ServiceRef.XmppService.NeuroFeatureVariablesUpdated += this.Wallet_VariablesUpdated;
            ServiceRef.XmppService.NeuroFeatureStateUpdated += this.Wallet_StateUpdated;
        }
 
        public override Task OnDisposeAsync()
        {
            ServiceRef.XmppService.NeuroFeatureVariablesUpdated -= this.Wallet_VariablesUpdated;
            ServiceRef.XmppService.NeuroFeatureStateUpdated -= this.Wallet_StateUpdated;
 
            return base.OnDisposeAsync();
        }
 
        private Task Wallet_StateUpdated(object? Sender, NeuroFeatures.EventArguments.NewStateEventArgs e)
        {
            MainThread.BeginInvokeOnMainThread(() =>
            {
                this.CurrentState = e.NewState;
                this.Ended = string.IsNullOrEmpty(e.NewState);
                this.Running = !this.Ended;
            });
 
            return Task.CompletedTask;
        }
 
        private Task Wallet_VariablesUpdated(object? Sender, NeuroFeatures.EventArguments.VariablesUpdatedEventArgs e)
        {
            MainThread.BeginInvokeOnMainThread(() =>
            {
                foreach (Variable Variable in e.Variables)
                {
                    if (this.TryGetVariableMode(Variable.Name, out VariableModel? Model))
                        Model.UpdateValue(Variable.ValueObject);
                    else
                        this.Variables.Add(new VariableModel(Variable.Name, Variable.ValueObject));
                }
            });
 
            return Task.CompletedTask;
        }
 
        private bool TryGetVariableMode(string Name, [NotNullWhen(true)] out VariableModel? Result)
        {
            foreach (VariableModel Model in this.Variables)
            {
                if (Model.Name == Name)
                {
                    Result = Model;
                    return true;
                }
            }
 
            Result = null;
            return false;
        }
 
        #region Properties
 
        public ObservableCollection<VariableModel> Variables { get; }
 
        [ObservableProperty]
        private bool running;
 
        [ObservableProperty]
        private bool ended;
 
        [ObservableProperty]
        private string? currentState;
 
        #endregion
 
    }
}