feat: make the isolation level transaction configurable

Muhammad Luthfi Fahlevi · Muhammad Luthfi Fahlevi · commit 357f88f6823d · 2025-02-07T15:02:24.000+07:00
diff --git a/internal/store/postgres/postgres.go b/internal/store/postgres/postgres.go
@@ -42,7 +42,11 @@ type Client struct {
 }
 
 func (c *Client) RunWithinTx(ctx context.Context, f func(tx *sqlx.Tx) error) error {
-	tx, err := c.db.BeginTxx(ctx, nil)
+	return c.RunWithinTxWithOption(ctx, nil, f)
+}
+
+func (c *Client) RunWithinTxWithOption(ctx context.Context, opts *sql.TxOptions, f func(tx *sqlx.Tx) error) error {
+	tx, err := c.db.BeginTxx(ctx, opts)
 	if err != nil {
 		return fmt.Errorf("starting transaction: %w", err)
 	}

Original file line number	Diff line number	Diff line change
`@@ -42,7 +42,11 @@ type Client struct {`
`42`	`42`	`}`
`43`	`43`
`44`	`44`	`func (c Client) RunWithinTx(ctx context.Context, f func(tx sqlx.Tx) error) error {`
`45`		`- tx, err := c.db.BeginTxx(ctx, nil)`
	`45`	`+ return c.RunWithinTxWithOption(ctx, nil, f)`
	`46`	`+}`
	`47`	`+`
	`48`	`+func (c Client) RunWithinTxWithOption(ctx context.Context, opts sql.TxOptions, f func(tx *sqlx.Tx) error) error {`
	`49`	`+ tx, err := c.db.BeginTxx(ctx, opts)`
`46`	`50`	`if err != nil {`
`47`	`51`	`return fmt.Errorf("starting transaction: %w", err)`
`48`	`52`	`}`