cashless2ecash

commit a201ebe738c30b2dae942ef665612d3ce44a7f80
parent d988b301761fdac010eb657c44b1b07bd645726c
Author: Joel-Haeberli <haebu@rubigen.ch>
Date:   Mon,  3 Jun 2024 17:32:53 +0200

fix: enhance logging

Diffstat:
M
c2ec/proc-transfer.go
 | 
12
+++++++-----

1 file changed, 7 insertions(+), 5 deletions(-)
diff --git a/c2ec/proc-transfer.go b/c2ec/proc-transfer.go
@@ -35,13 +35,17 @@ func RunTransferrer(
 
 	go func() {
 		lastlog := time.Now().Add(time.Minute * -3)
+		lastlog2 := time.Now().Add(time.Minute * -3)
 		for {
 			time.Sleep(REFUND_RETRY_INTERVAL_SECONDS * time.Second)
 			if lastlog.Before(time.Now().Add(time.Second * -30)) {
 				LogInfo("proc-transfer", "transferrer executing transfers")
+				lastlog = time.Now()
+			}
+			executePendingTransfers(errs, lastlog2)
+			if lastlog2.Before(time.Now().Add(time.Second * -30)) {
+				lastlog2 = time.Now()
 			}
-			executePendingTransfers(errs, lastlog)
-			lastlog = time.Now()
 		}
 	}()
 }
@@ -128,9 +132,7 @@ func executePendingTransfers(errs chan error, lastlog time.Time) {
 		return
 	}
 
-	if lastlog.Before(time.Now().Add(time.Second * -30)) {
-		LogInfo("proc-transfer", fmt.Sprintf("found %d pending transfers", len(transfers)))
-	}
+	LogInfo("proc-transfer", fmt.Sprintf("found %d pending transfers", len(transfers)))
 	for _, t := range transfers {
 
 		shouldRetry := ShouldStartRetry(time.Unix(t.TransferTs, 0), int(t.Retries), MAX_TRANSFER_BACKOFF_MS)