From c812fa652a683764db3739f491c950b690cecfde Mon Sep 17 00:00:00 2001
From: EuAndreh <eu@euandre.org>
Date: Thu, 7 Nov 2024 10:59:57 -0300
Subject: src/fiinha.go: Reorder execSerialized() to after inTx()

---
 src/fiinha.go | 64 +++++++++++++++++++++++++++++------------------------------
 1 file changed, 32 insertions(+), 32 deletions(-)

(limited to 'src')

diff --git a/src/fiinha.go b/src/fiinha.go
index 4461462..fe2fa6a 100644
--- a/src/fiinha.go
+++ b/src/fiinha.go
@@ -163,6 +163,38 @@ type IQueue interface{
 
 
 
+func tryRollback(tx *sql.Tx, err error) error {
+	rollbackErr := tx.Rollback()
+	if rollbackErr != nil {
+		return fmt.Errorf(
+			rollbackErrorFmt,
+			rollbackErr,
+			err,
+		)
+	}
+
+	return err
+}
+
+func inTx(db *sql.DB, fn func(*sql.Tx) error) error {
+	tx, err := db.Begin()
+	if err != nil {
+		return err
+	}
+
+	err = fn(tx)
+	if err != nil {
+		return tryRollback(tx, err)
+	}
+
+	err = tx.Commit()
+	if err != nil {
+		return tryRollback(tx, err)
+	}
+
+	return nil
+}
+
 func serialized[A any, B any](callback func(...A) B) (func(...A) B, func()) {
 	in  := make(chan []A)
 	out := make(chan B)
@@ -210,38 +242,6 @@ func execSerialized(query string, db *sql.DB) (func(...any) error, func()) {
 	})
 }
 
-func tryRollback(tx *sql.Tx, err error) error {
-	rollbackErr := tx.Rollback()
-	if rollbackErr != nil {
-		return fmt.Errorf(
-			rollbackErrorFmt,
-			rollbackErr,
-			err,
-		)
-	}
-
-	return err
-}
-
-func inTx(db *sql.DB, fn func(*sql.Tx) error) error {
-	tx, err := db.Begin()
-	if err != nil {
-		return err
-	}
-
-	err = fn(tx)
-	if err != nil {
-		return tryRollback(tx, err)
-	}
-
-	err = tx.Commit()
-	if err != nil {
-		return tryRollback(tx, err)
-	}
-
-	return nil
-}
-
 func createTablesSQL(prefix string) queryT {
 	const tmpl_write = `
 		CREATE TABLE IF NOT EXISTS "%s_payloads" (
-- 
cgit v1.2.3