🐛 Fix pusher service
This commit is contained in:
@@ -5,7 +5,7 @@ using Quartz;
|
|||||||
|
|
||||||
namespace DysonNetwork.Pusher.Notification;
|
namespace DysonNetwork.Pusher.Notification;
|
||||||
|
|
||||||
public class NotificationFlushHandler(AppDatabase db, Logger<NotificationFlushHandler> logger) : IFlushHandler<Notification>
|
public class NotificationFlushHandler(AppDatabase db) : IFlushHandler<Notification>
|
||||||
{
|
{
|
||||||
public async Task FlushAsync(IReadOnlyList<Notification> items)
|
public async Task FlushAsync(IReadOnlyList<Notification> items)
|
||||||
{
|
{
|
||||||
@@ -15,7 +15,6 @@ public class NotificationFlushHandler(AppDatabase db, Logger<NotificationFlushHa
|
|||||||
x.UpdatedAt = x.CreatedAt;
|
x.UpdatedAt = x.CreatedAt;
|
||||||
return x;
|
return x;
|
||||||
}), config => config.ConflictOption = ConflictOption.Ignore);
|
}), config => config.ConflictOption = ConflictOption.Ignore);
|
||||||
logger.LogInformation("Stored {Count} notifications", items.Count);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user