HyperNet/Pusher
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

🔊 Adjusted verbose notify logs

Browse Source
This commit is contained in:
LittleSheep 2024-11-24 21:52:38 +08:00
parent b02e1d805d
commit 02060182d0
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
pkg/internal/provider/caller.go
View File

@ -50,11 +50,6 @@ func PushNotification(in pushkit.NotificationPushRequest) error {
func PushNotificationBatch(in pushkit.NotificationPushBatchRequest) { func PushNotificationBatch(in pushkit.NotificationPushBatchRequest) {
requestId := uuid.NewString() requestId := uuid.NewString()
log.Debug().
Int("count", len(in.Tokens)).
Str("topic", in.Notification.Topic).
Str("request_id", requestId).
Msg("Pushing notification batch...")
var wg sync.WaitGroup var wg sync.WaitGroup
for idx, key := range in.Providers { for idx, key := range in.Providers {
@ -65,6 +60,14 @@ func PushNotificationBatch(in pushkit.NotificationPushBatchRequest) {
go func() { go func() {
wg.Add(1) wg.Add(1)
defer wg.Done() defer wg.Done()
log.Debug().
Str("tk", in.Tokens[0]).
Str("provider", in.Providers[0]).
Str("topic", in.Notification.Topic).
Str("request_id", requestId).
Msg("Pushing notification...")
start := time.Now() start := time.Now()
err := prov.Push(in.Notification, in.Tokens[idx]) err := prov.Push(in.Notification, in.Tokens[idx])
if err != nil { if err != nil {