using Oqtane.Models; using System.Threading.Tasks; using System.Net.Http; using Microsoft.AspNetCore.Components; using Oqtane.Shared; using System.Collections.Generic; using System.Linq; namespace Oqtane.Services { public class NotificationService : ServiceBase, INotificationService { private readonly HttpClient _http; private readonly SiteState _siteState; private readonly NavigationManager _navigationManager; public NotificationService(HttpClient http, SiteState sitestate, NavigationManager NavigationManager) { _http = http; _siteState = sitestate; _navigationManager = NavigationManager; } private string apiurl { get { return CreateApiUrl(_siteState.Alias, _navigationManager.Uri, "Notification"); } } public async Task> GetNotificationsAsync(int SiteId, string Direction, int UserId) { string querystring = "?siteid=" + SiteId.ToString() + "&direction=" + Direction.ToLower() + "&userid=" + UserId.ToString(); List Notifications = await _http.GetJsonAsync>(apiurl + querystring); return Notifications.OrderByDescending(item => item.CreatedOn).ToList(); } public async Task GetNotificationAsync(int NotificationId) { return await _http.GetJsonAsync(apiurl + "/" + NotificationId.ToString()); } public async Task AddNotificationAsync(Notification Notification) { return await _http.PostJsonAsync(apiurl, Notification); } public async Task UpdateNotificationAsync(Notification Notification) { return await _http.PutJsonAsync(apiurl + "/" + Notification.NotificationId.ToString(), Notification); } public async Task DeleteNotificationAsync(int NotificationId) { await _http.DeleteAsync(apiurl + "/" + NotificationId.ToString()); } } }