Solar/Swarm
2
2
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

🔊 Add more logging to push notification

Browse Source
This commit is contained in:
LittleSheep
2025-08-14 17:25:06 +08:00
parent 27e6dde7c4
commit 8c01ec364c
1 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
DysonNetwork.Pusher/Notification/PushService.cs
View File

@@ -156,8 +156,8 @@ public class PushService
// Pushing the notification // Pushing the notification
var subscribers = await _db.PushSubscriptions var subscribers = await _db.PushSubscriptions
.Where(s => s.AccountId == notification.AccountId) .Where(s => s.AccountId == notification.AccountId)
.AsNoTracking()
.ToListAsync(); .ToListAsync();
await _PushNotification(notification, subscribers); await _PushNotification(notification, subscribers);
} }
@@ -208,6 +208,7 @@ public class PushService
var subscribers = await _db.PushSubscriptions var subscribers = await _db.PushSubscriptions
.Where(s => accounts.Contains(s.AccountId)) .Where(s => accounts.Contains(s.AccountId))
.AsNoTracking()
.ToListAsync(); .ToListAsync();
await _PushNotification(notification, subscribers); await _PushNotification(notification, subscribers);
} }
@@ -245,7 +246,7 @@ public class PushService
notification.Content ?? string.Empty).Trim(); notification.Content ?? string.Empty).Trim();
} }
await _fcm.SendAsync(new Dictionary<string, object> var fcmResult = await _fcm.SendAsync(new Dictionary<string, object>
{ {
["message"] = new Dictionary<string, object> ["message"] = new Dictionary<string, object>
{ {
@@ -263,6 +264,9 @@ public class PushService
} }
} }
}); });
if (fcmResult.Error != null)
throw new Exception($"Notification pushed failed ({fcmResult.StatusCode}) {fcmResult.Error}");
break; break;
case PushProvider.Apple: case PushProvider.Apple:
@@ -290,13 +294,16 @@ public class PushService
["meta"] = notification.Meta ["meta"] = notification.Meta
}; };
await _apns.SendAsync( var apnResult = await _apns.SendAsync(
payload, payload,
deviceToken: subscription.DeviceToken, deviceToken: subscription.DeviceToken,
apnsId: notification.Id.ToString(), apnsId: notification.Id.ToString(),
apnsPriority: notification.Priority, apnsPriority: notification.Priority,
apnPushType: ApnPushType.Alert apnPushType: ApnPushType.Alert
); );
if (apnResult.Error != null)
throw new Exception($"Notification pushed failed ({apnResult.StatusCode}) {apnResult.Error}");
break; break;
default: default: