aljaz/lspd
1
0
Fork 0
mirror of https://github.com/aljazceru/lspd.git synced 2025-12-24 01:04:21 +01:00
Code Issues Packages Projects Releases Wiki Activity

call notification webhooks simultaneously

Browse Source
This commit is contained in:
Jesse de Wit
2023-11-16 12:26:50 +01:00
parent 23628628fe
commit 6d307179f1
1 changed files with 41 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

63
notifications/notification_service.go
View File

@@ -78,40 +78,59 @@ func (s *NotificationService) Notify(
},
}
var mtx sync.Mutex
var wg sync.WaitGroup
wg.Add(len(registrations))
notified := false
ctx, cancel := context.WithTimeout(context.Background(), time.Second*7)
for _, r := range registrations {
var buf bytes.Buffer
err = json.NewEncoder(&buf).Encode(req)
if err != nil {
log.Printf("Failed to encode payment notification for %s: %v", pubkey, err)
return false, err
}
resp, err := http.DefaultClient.Post(r, "application/json", &buf)
if err != nil {
log.Printf("Failed to send payment notification for %s to %s: %v", pubkey, r, err)
// TODO: Remove subscription?
continue
}
if resp.StatusCode != 200 {
log.Printf("Got non 200 status code (%s) for payment notification for %s to %s: %v", resp.Status, pubkey, r, err)
// TODO: Remove subscription?
continue
}
notified = true
go func(r string) {
currentNotified := s.notifyOnce(ctx, req, pubkey, r)
if currentNotified {
mtx.Lock()
notified = true
mtx.Unlock()
}
wg.Done()
}(r)
}
wg.Wait()
cancel()
if notified {
s.mtx.Lock()
s.recentNotifications[paymentIdentifier(pubkey, paymenthash)] = time.Now()
s.mtx.Unlock()
}
return notified, nil
}
func (s *NotificationService) notifyOnce(ctx context.Context, req *PaymentReceivedPayload, pubkey string, url string) bool {
var buf bytes.Buffer
err := json.NewEncoder(&buf).Encode(req)
if err != nil {
log.Printf("Failed to encode payment notification for %s: %v", pubkey, err)
return false
}
resp, err := http.DefaultClient.Post(url, "application/json", &buf)
if err != nil {
log.Printf("Failed to send payment notification for %s to %s: %v", pubkey, url, err)
// TODO: Remove subscription?
return false
}
if resp.StatusCode != 200 {
log.Printf("Got non 200 status code (%s) for payment notification for %s to %s: %v", resp.Status, pubkey, url, err)
// TODO: Remove subscription?
return false
}
return true
}
func paymentIdentifier(pubkey string, paymentHash string) string {
return pubkey + "|" + paymentHash
}