diff --git a/Entity/PushSubscriptionEntity.cs b/Entity/PushSubscriptionEntity.cs index 397c99d..a204ac3 100644 --- a/Entity/PushSubscriptionEntity.cs +++ b/Entity/PushSubscriptionEntity.cs @@ -2,7 +2,7 @@ namespace Entity; -public class PushSubscriptionEntity : BaseEntity +public class PushSubscription : BaseEntity { [Required] public string Endpoint { get; set; } = string.Empty; diff --git a/Repository/PushSubscriptionRepository.cs b/Repository/PushSubscriptionRepository.cs index 8d4f32e..c575e98 100644 --- a/Repository/PushSubscriptionRepository.cs +++ b/Repository/PushSubscriptionRepository.cs @@ -1,15 +1,15 @@ namespace Repository; -public interface IPushSubscriptionRepository : IBaseRepository +public interface IPushSubscriptionRepository : IBaseRepository { - Task GetByEndpointAsync(string endpoint); + Task GetByEndpointAsync(string endpoint); } -public class PushSubscriptionRepository(IFreeSql freeSql) : BaseRepository(freeSql), IPushSubscriptionRepository +public class PushSubscriptionRepository(IFreeSql freeSql) : BaseRepository(freeSql), IPushSubscriptionRepository { - public async Task GetByEndpointAsync(string endpoint) + public async Task GetByEndpointAsync(string endpoint) { - return await FreeSql.Select() + return await FreeSql.Select() .Where(x => x.Endpoint == endpoint) .FirstAsync(); } diff --git a/Service/NotificationService.cs b/Service/NotificationService.cs index 6e54c22..aa30a63 100644 --- a/Service/NotificationService.cs +++ b/Service/NotificationService.cs @@ -5,7 +5,7 @@ namespace Service; public interface INotificationService { Task GetVapidPublicKeyAsync(); - Task SubscribeAsync(PushSubscriptionEntity subscription); + Task SubscribeAsync(Entity.PushSubscription subscription); Task SendNotificationAsync(string message, string? url = null); } @@ -32,7 +32,7 @@ public class NotificationService( return Task.FromResult(GetSettings().PublicKey); } - public async Task SubscribeAsync(PushSubscriptionEntity subscription) + public async Task SubscribeAsync(Entity.PushSubscription subscription) { var existing = await subscriptionRepo.GetByEndpointAsync(subscription.Endpoint); if (existing != null) @@ -73,7 +73,7 @@ public class NotificationService( { try { - var pushSubscription = new PushSubscription(sub.Endpoint, sub.P256DH, sub.Auth); + var pushSubscription = new WebPush.PushSubscription(sub.Endpoint, sub.P256DH, sub.Auth); await webPushClient.SendNotificationAsync(pushSubscription, payload, vapidDetails); } catch (WebPushException ex) diff --git a/WebApi/Controllers/NotificationController.cs b/WebApi/Controllers/NotificationController.cs index a5ff1b7..126e901 100644 --- a/WebApi/Controllers/NotificationController.cs +++ b/WebApi/Controllers/NotificationController.cs @@ -18,7 +18,7 @@ public class NotificationController(INotificationService notificationService) : } } - public async Task Subscribe([FromBody] PushSubscriptionEntity subscription) + public async Task Subscribe([FromBody] PushSubscription subscription) { try {