dkforest

commit a071fd75d003bdc1624f7bf116fef27d752a0855
parent 26abc7d66a6cfb927fe968f314face8ea59dcb35
Author: n0tr1v <n0tr1v@protonmail.com>
Date:   Tue, 12 Dec 2023 16:06:25 -0500

txs

Diffstat:
M
pkg/web/handlers/poker/poker.go
 | 
14
+++++++++-----

1 file changed, 9 insertions(+), 5 deletions(-)
diff --git a/pkg/web/handlers/poker/poker.go b/pkg/web/handlers/poker/poker.go
@@ -1183,18 +1183,20 @@ func PokerFoldHandler(c echo.Context) error {
 
 func Refund(db *database.DkfDB) {
 	accounts, _ := db.GetPositivePokerTableAccounts()
+	tx := db.Begin()
 	for _, account := range accounts {
-		if user, err := db.GetUserByID(account.UserID); err == nil {
+		if user, err := tx.GetUserByID(account.UserID); err == nil {
 			account.Amount += account.AmountBet
 			if account.PokerTable.IsTest {
 				user.ChipsTest += int(account.Amount)
 			}
-			user.DoSave(db)
+			user.DoSave(tx)
 			account.Amount = 0
 			account.AmountBet = 0
-			account.DoSave(db)
+			account.DoSave(tx)
 		}
 	}
+	tx.Commit()
 }
 
 func PokerDealHandler(c echo.Context) error {
@@ -1283,8 +1285,10 @@ func PokerSitHandler(c echo.Context) error {
 			PokerPubSub.Pub(roomUserTopic, ErrorMsgEvent{Message: err.Error()})
 			return c.HTML(http.StatusOK, html)
 		}
-		authUser.DoSave(db)
-		tableAccount.DoSave(db)
+		tx := db.Begin()
+		authUser.DoSave(tx)
+		tableAccount.DoSave(tx)
+		tx.Commit()
 		PokerPubSub.Pub(roomTopic, PokerSeatTakenEvent{})
 		newLogEvent(g, roomLogsTopic, fmt.Sprintf("%s sit", authUser.Username.String()))
 	}