need to select FOR UPDATE to lock row (#245)

hemilabs · Sep 5, 2024 · dcd150d · dcd150d
1 parent daa09d9
commit dcd150d
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/database/bfgd/postgres/postgres.go b/database/bfgd/postgres/postgres.go
@@ -1092,6 +1092,7 @@ func (p *pgdb) BtcTransactionBroadcastRequestGetNext(ctx context.Context, onlyNe
 			AND broadcast_at IS NULL
 			AND created_at > NOW() - INTERVAL '30 minutes'
 			%s
+			FOR UPDATE
 			LIMIT 1
 		)
 		RETURNING serialized_tx