refactor: Add status to callbacker logs (#683)

bitcoin-sv · Dec 2, 2024 · 5de1703 · 5de1703
1 parent 22fd0dc
commit 5de1703
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/internal/callbacker/sender.go b/internal/callbacker/sender.go
@@ -111,6 +111,7 @@ func (p *CallbackSender) Send(url, token string, dto *Callback) (ok bool) {
 			slog.String("url", url),
 			slog.String("token", token),
 			slog.String("hash", dto.TxID),
+			slog.String("status", dto.TxStatus),
 			slog.String("err", err.Error()))
 		return false
 	}
@@ -122,6 +123,7 @@ func (p *CallbackSender) Send(url, token string, dto *Callback) (ok bool) {
 			slog.String("url", url),
 			slog.String("token", token),
 			slog.String("hash", dto.TxID),
+			slog.String("status", dto.TxStatus),
 			slog.Int("retries", retries))
 
 		p.updateSuccessStats(dto.TxStatus)
@@ -132,7 +134,8 @@ func (p *CallbackSender) Send(url, token string, dto *Callback) (ok bool) {
 		slog.String("url", url),
 		slog.String("token", token),
 		slog.String("hash", dto.TxID),
-		slog.Int("retries", p.retries))
+		slog.String("status", dto.TxStatus),
+		slog.Int("retries", retries))
 
 	p.stats.callbackFailedCount.Inc()
 	return
@@ -163,6 +166,7 @@ func (p *CallbackSender) SendBatch(url, token string, dtos []*Callback) (ok bool
 				slog.String("url", url),
 				slog.String("token", token),
 				slog.String("hash", c.TxID),
+				slog.String("status", c.TxStatus),
 				slog.Int("retries", retries))
 
 			p.updateSuccessStats(c.TxStatus)
@@ -174,7 +178,7 @@ func (p *CallbackSender) SendBatch(url, token string, dtos []*Callback) (ok bool
 		slog.String("url", url),
 		slog.String("token", token),
 		slog.Bool("batch", true),
-		slog.Int("retries", p.retries))
+		slog.Int("retries", retries))
 
 	p.stats.callbackFailedCount.Inc()
 	return