🐛 Make send notification await
This commit is contained in:
@@ -3,7 +3,6 @@ using CorePush.Firebase;
|
||||
using DysonNetwork.Pusher.Connection;
|
||||
using DysonNetwork.Shared.Cache;
|
||||
using DysonNetwork.Shared.Proto;
|
||||
using EFCore.BulkExtensions;
|
||||
using Microsoft.EntityFrameworkCore;
|
||||
using NodaTime;
|
||||
|
||||
@@ -111,7 +110,7 @@ public class PushService
|
||||
return subscription;
|
||||
}
|
||||
|
||||
public void SendNotification(Account account,
|
||||
public async Task SendNotification(Account account,
|
||||
string topic,
|
||||
string? title = null,
|
||||
string? subtitle = null,
|
||||
@@ -141,7 +140,7 @@ public class PushService
|
||||
if (save)
|
||||
_fbs.Enqueue(notification);
|
||||
|
||||
if (!isSilent) _ = DeliveryNotification(notification);
|
||||
if (!isSilent) await DeliveryNotification(notification);
|
||||
}
|
||||
|
||||
private async Task DeliveryNotification(Notification notification)
|
||||
@@ -337,4 +336,4 @@ public class PushService
|
||||
_logger.LogInformation(
|
||||
$"Successfully pushed notification #{notification.Id} to device {subscription.DeviceId} provider {subscription.Provider}");
|
||||
}
|
||||
}
|
||||
}
|
||||
|
@@ -85,7 +85,7 @@ public class PusherServiceGrpc(
|
||||
ServerCallContext context)
|
||||
{
|
||||
var account = await accountsHelper.GetAccount(Guid.Parse(request.UserId));
|
||||
pushService.SendNotification(
|
||||
await pushService.SendNotification(
|
||||
account,
|
||||
request.Notification.Topic,
|
||||
request.Notification.Title,
|
||||
@@ -141,4 +141,4 @@ public class PusherServiceGrpc(
|
||||
|
||||
return Task.FromResult(new GetWebsocketConnectionStatusResponse { IsConnected = isConnected });
|
||||
}
|
||||
}
|
||||
}
|
||||
|
Reference in New Issue
Block a user