add missing error check

pashagolub · pashagolub · commit cc3e8d88d261 · 2022-05-25T16:48:06.000+02:00
diff --git a/internal/pgengine/transaction.go b/internal/pgengine/transaction.go
@@ -39,6 +39,9 @@ func (pge *PgEngine) StartTransaction(ctx context.Context, chainID int) (tx pgx.
 		return
 	}
 	err = pgxscan.Get(ctx, tx, &txid, "SELECT txid_current()")
+	if err != nil {
+		return
+	}
 	_, err = tx.Exec(ctx, `SELECT set_config('pg_timetable.current_chain_id', $1, true)`, strconv.Itoa(chainID))
 	return
 }

Original file line number	Diff line number	Diff line change
`@@ -39,6 +39,9 @@ func (pge *PgEngine) StartTransaction(ctx context.Context, chainID int) (tx pgx.`
`39`	`39`	`return`
`40`	`40`	`}`
`41`	`41`	`err = pgxscan.Get(ctx, tx, &txid, "SELECT txid_current()")`
	`42`	`+ if err != nil {`
	`43`	`+ return`
	`44`	`+ }`
`42`	`45`	_, err = tx.Exec(ctx, `SELECT set_config('pg_timetable.current_chain_id', $1, true)`, strconv.Itoa(chainID))
`43`	`46`	`return`
`44`	`47`	`}`