INotificationServiceV2.cs

using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
using Waher.Events;
using Waher.Runtime.Inventory;
 
namespace NeuroAccessMaui.Services.Notification
{
    public interface INotificationServiceV2 : ILoadableService
    {
        Task AddAsync(NotificationIntent Intent, NotificationSource Source, string? RawPayload, CancellationToken CancellationToken);
 
        Task ConsumeAsync(string Id, CancellationToken CancellationToken);
 
        Task MarkConsumedAsync(string Id, CancellationToken CancellationToken);
 
        Task<IReadOnlyList<NotificationRecord>> GetAsync(NotificationQuery Query, CancellationToken CancellationToken);
 
        Task PruneAsync(CancellationToken CancellationToken);
 
        Task<NotificationRecord?> WaitForAsync(Func<NotificationRecord, bool> Predicate, TimeSpan Timeout, CancellationToken CancellationToken);
 
        Task ExpectAsync(Func<NotificationRecord, bool> Predicate, TimeSpan Timeout, CancellationToken CancellationToken);
 
        event EventHandlerAsync<NotificationRecordEventArgs>? OnNotificationAdded;
 
        Task MarkReadAsync(string Id, CancellationToken CancellationToken);
 
        IReadOnlyDictionary<string, int> ChannelCounts { get; }
 
        IDisposable AddIgnoreFilter(Func<NotificationIntent, NotificationFilterDecision> Predicate);
 
        string ComputeId(NotificationIntent Intent, NotificationSource Source);
 
        Task DeleteAsync(IEnumerable<string> Ids, CancellationToken CancellationToken);
 
        Task ProcessPendingAsync(CancellationToken CancellationToken);
    }
}