add missing tx

sami-sweng · sami-sweng · commit 588c4c2b3b1e · 2022-11-23T13:26:02.000+01:00
diff --git a/sqlstore.go b/sqlstore.go
@@ -302,7 +302,7 @@ func (store *sqlStore) SaveMessageAndIncrNextSenderMsgSeqNum(seqNum int, msg []b
 	}
 
 	next := store.cache.NextSenderMsgSeqNum()
-	_, err = store.db.Exec(sqlString(`UPDATE sessions SET outgoing_seqnum = ?
+	_, err = tx.Exec(sqlString(`UPDATE sessions SET outgoing_seqnum = ?
 		WHERE beginstring=? AND session_qualifier=?
 		AND sendercompid=? AND sendersubid=? AND senderlocid=?
 		AND targetcompid=? AND targetsubid=? AND targetlocid=?`, store.placeholder),

Original file line number	Diff line number	Diff line change
`@@ -302,7 +302,7 @@ func (store *sqlStore) SaveMessageAndIncrNextSenderMsgSeqNum(seqNum int, msg []b`
`302`	`302`	`}`
`303`	`303`
`304`	`304`	`next := store.cache.NextSenderMsgSeqNum()`
`305`		- _, err = store.db.Exec(sqlString(`UPDATE sessions SET outgoing_seqnum = ?
	`305`	+ _, err = tx.Exec(sqlString(`UPDATE sessions SET outgoing_seqnum = ?
`306`	`306`	`WHERE beginstring=? AND session_qualifier=?`
`307`	`307`	`AND sendercompid=? AND sendersubid=? AND senderlocid=?`
`308`	`308`	AND targetcompid=? AND targetsubid=? AND targetlocid=?`, store.placeholder),