commit 4f4038f0a32bc07567c647e23a643822081b6141
parent 527b1bd20a7cb52a74c6ebe878914d17f1d344ff
Author: Joel-Haeberli <haebu@rubigen.ch>
Date: Sat, 18 May 2024 14:02:16 +0200
fix: retrier
Diffstat:
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/c2ec/db-postgres.go b/c2ec/db-postgres.go
@@ -30,8 +30,7 @@ const PS_REGISTER_WITHDRAWAL_PARAMS = "UPDATE " + WITHDRAWAL_TABLE_NAME + " SET
" WHERE " + WITHDRAWAL_FIELD_NAME_WOPID + "=$4"
const PS_GET_UNCONFIRMED_WITHDRAWALS = "SELECT * FROM " + WITHDRAWAL_TABLE_NAME +
- " WHERE " + WITHDRAWAL_FIELD_NAME_TRANSACTION_ID + " IS NOT NULL" +
- " AND " + WITHDRAWAL_FIELD_NAME_STATUS + " = '" + string(SELECTED) + "'"
+ " WHERE " + WITHDRAWAL_FIELD_NAME_STATUS + " = '" + string(SELECTED) + "'"
const PS_PAYMENT_NOTIFICATION = "UPDATE " + WITHDRAWAL_TABLE_NAME + " SET (" +
WITHDRAWAL_FIELD_NAME_FEES + "," + WITHDRAWAL_FIELD_NAME_TRANSACTION_ID + "," +
diff --git a/c2ec/proc-retrier.go b/c2ec/proc-retrier.go
@@ -23,6 +23,7 @@ func RunRetrier(ctx context.Context, errs chan error) {
go func() {
for {
time.Sleep(time.Duration(CONFIG.Server.RetryDelayMs) * time.Millisecond)
+ LogInfo("proc-retrier", "attesting selected withdrawals...")
withdrawals, err := DB.GetAttestableWithdrawals()
if err != nil {
LogError("proc-retrier", err)