75 lines
No EOL
1.8 KiB
C#
75 lines
No EOL
1.8 KiB
C#
using Iceshrimp.Frontend.Core.Miscellaneous;
|
|
using Iceshrimp.Frontend.Core.Services;
|
|
using Iceshrimp.Shared.Schemas.Web;
|
|
using Microsoft.AspNetCore.Components;
|
|
|
|
namespace Iceshrimp.Frontend.Components;
|
|
|
|
public partial class NotificationList : IAsyncDisposable
|
|
{
|
|
private string? _minId;
|
|
private State _state = State.Loading;
|
|
[Inject] private StreamingService StreamingService { get; set; } = null!;
|
|
[Inject] private ApiService Api { get; set; } = null!;
|
|
private List<NotificationResponse> Notifications { get; set; } = [];
|
|
|
|
public async ValueTask DisposeAsync()
|
|
{
|
|
StreamingService.Notification -= OnNotification;
|
|
|
|
await StreamingService.DisposeAsync();
|
|
GC.SuppressFinalize(this);
|
|
}
|
|
|
|
private async Task GetNotifications()
|
|
{
|
|
try
|
|
{
|
|
var res = await Api.Notifications.GetNotifications(new PaginationQuery());
|
|
if (res.Count > 0)
|
|
{
|
|
Notifications = res;
|
|
_minId = res.Last().Id;
|
|
}
|
|
|
|
_state = State.Init;
|
|
}
|
|
catch (ApiException)
|
|
{
|
|
_state = State.Error;
|
|
}
|
|
}
|
|
|
|
private async Task LoadMore()
|
|
{
|
|
var pq = new PaginationQuery { MaxId = _minId, Limit = 20 };
|
|
var res = await Api.Notifications.GetNotifications(pq);
|
|
if (res.Count > 0)
|
|
{
|
|
Notifications.AddRange(res);
|
|
_minId = res.Last().Id;
|
|
StateHasChanged();
|
|
}
|
|
}
|
|
|
|
protected override async Task OnInitializedAsync()
|
|
{
|
|
StreamingService.Notification += OnNotification;
|
|
await StreamingService.Connect();
|
|
await GetNotifications();
|
|
StateHasChanged();
|
|
}
|
|
|
|
private void OnNotification(object? _, NotificationResponse notificationResponse)
|
|
{
|
|
Notifications.Insert(0, notificationResponse);
|
|
StateHasChanged();
|
|
}
|
|
|
|
private enum State
|
|
{
|
|
Loading,
|
|
Error,
|
|
Init
|
|
}
|
|
} |