Update applyUnappliedTxnAdditions to overwrite txn upon unique constraint failure (#1345)

ChrisSchinnerl · web-flow · commit b52e82dde389 · 2024-06-28T17:59:25.000+02:00
diff --git a/stores/wallet.go b/stores/wallet.go
@@ -10,6 +10,7 @@ import (
 	"go.sia.tech/renterd/wallet"
 	"go.sia.tech/siad/modules"
 	"gorm.io/gorm"
+	"gorm.io/gorm/clause"
 )
 
 type (
@@ -329,7 +330,11 @@ func applyUnappliedOutputRemovals(tx *gorm.DB, oid hash256) error {
 }
 
 func applyUnappliedTxnAdditions(tx *gorm.DB, txn dbTransaction) error {
-	return tx.Create(&txn).Error
+	return tx.Clauses(clause.OnConflict{
+		Columns:   []clause.Column{{Name: "transaction_id"}},
+		UpdateAll: true,
+	}).
+		Create(&txn).Error
 }
 
 func applyUnappliedTxnRemovals(tx *gorm.DB, txnID hash256) error {

Original file line number	Diff line number	Diff line change
`@@ -10,6 +10,7 @@ import (`
`10`	`10`	`"go.sia.tech/renterd/wallet"`
`11`	`11`	`"go.sia.tech/siad/modules"`
`12`	`12`	`"gorm.io/gorm"`
	`13`	`+ "gorm.io/gorm/clause"`
`13`	`14`	`)`
`14`	`15`
`15`	`16`	`type (`
`@@ -329,7 +330,11 @@ func applyUnappliedOutputRemovals(tx *gorm.DB, oid hash256) error {`
`329`	`330`	`}`
`330`	`331`
`331`	`332`	`func applyUnappliedTxnAdditions(tx *gorm.DB, txn dbTransaction) error {`
`332`		`- return tx.Create(&txn).Error`
	`333`	`+ return tx.Clauses(clause.OnConflict{`
	`334`	`+ Columns: []clause.Column{{Name: "transaction_id"}},`
	`335`	`+ UpdateAll: true,`
	`336`	`+ }).`
	`337`	`+ Create(&txn).Error`
`333`	`338`	`}`
`334`	`339`
`335`	`340`	`func applyUnappliedTxnRemovals(tx *gorm.DB, txnID hash256) error {`