loopdb: use passed transaction in ExecTx calls

Some calls used external queries instead of the passed one,
bypassing the transaction.

Author: starius

loopdb/sql_store.go

@@ -23,16 +23,16 @@ func (s *BaseDB) FetchLoopOutSwaps(ctx context.Context) ([]*LoopOut,
 
 	var loopOuts []*LoopOut
 
-	err := s.ExecTx(ctx, NewSqlReadOpts(), func(*sqlc.Queries) error {
-		swaps, err := s.Queries.GetLoopOutSwaps(ctx)
+	err := s.ExecTx(ctx, NewSqlReadOpts(), func(tx *sqlc.Queries) error {
+		swaps, err := tx.GetLoopOutSwaps(ctx)
 		if err != nil {
 			return err
 		}
 
 		loopOuts = make([]*LoopOut, len(swaps))
 
 		for i, swap := range swaps {
-			updates, err := s.Queries.GetSwapUpdates(
+			updates, err := tx.GetSwapUpdates(
 				ctx, swap.SwapHash,
 			)
 			if err != nil {
@@ -65,13 +65,13 @@ func (s *BaseDB) FetchLoopOutSwap(ctx context.Context,
 
 	var loopOut *LoopOut
 
-	err := s.ExecTx(ctx, NewSqlReadOpts(), func(*sqlc.Queries) error {
-		swap, err := s.Queries.GetLoopOutSwap(ctx, hash[:])
+	err := s.ExecTx(ctx, NewSqlReadOpts(), func(tx *sqlc.Queries) error {
+		swap, err := tx.GetLoopOutSwap(ctx, hash[:])
 		if err != nil {
 			return err
 		}
 
-		updates, err := s.Queries.GetSwapUpdates(ctx, swap.SwapHash)
+		updates, err := tx.GetSwapUpdates(ctx, swap.SwapHash)
 		if err != nil {
 			return err
 		}
@@ -186,16 +186,16 @@ func (s *BaseDB) FetchLoopInSwaps(ctx context.Context) (
 
 	var loopIns []*LoopIn
 
-	err := s.ExecTx(ctx, NewSqlReadOpts(), func(*sqlc.Queries) error {
-		swaps, err := s.Queries.GetLoopInSwaps(ctx)
+	err := s.ExecTx(ctx, NewSqlReadOpts(), func(tx *sqlc.Queries) error {
+		swaps, err := tx.GetLoopInSwaps(ctx)
 		if err != nil {
 			return err
 		}
 
 		loopIns = make([]*LoopIn, len(swaps))
 
 		for i, swap := range swaps {
-			updates, err := s.Queries.GetSwapUpdates(ctx, swap.SwapHash)
+			updates, err := tx.GetSwapUpdates(ctx, swap.SwapHash)
 			if err != nil {
 				return err
 			}