Skip to content
Snippets Groups Projects
Commit 9363ce22972f authored by Christophe de Vienne's avatar Christophe de Vienne
Browse files

Better error handling + tools

parent 86f7892ca412
No related branches found
No related tags found
No related merge requests found
Pipeline #7011 passed
...@@ -129,8 +129,8 @@ ...@@ -129,8 +129,8 @@
} }
// Close the lock connection, then the database // Close the lock connection, then the database
func (db *TestDB) Close() error { func (db *TestDB) Close() {
if err := db.lockConn.Close(); err != nil { if err := db.lockConn.Close(); err != nil {
db.tb.Error("lockConn.Close() failed", err) db.tb.Error("lockConn.Close() failed", err)
} }
...@@ -133,6 +133,8 @@ ...@@ -133,6 +133,8 @@
if err := db.lockConn.Close(); err != nil { if err := db.lockConn.Close(); err != nil {
db.tb.Error("lockConn.Close() failed", err) db.tb.Error("lockConn.Close() failed", err)
} }
return db.DB.Close() if err := db.DB.Close(); err != nil {
db.tb.Error("db.Close() failed", err)
}
} }
...@@ -61,7 +61,9 @@ ...@@ -61,7 +61,9 @@
parser.NamespaceDelimiter = "-" parser.NamespaceDelimiter = "-"
parser.EnvNamespaceDelimiter = "_" parser.EnvNamespaceDelimiter = "_"
parser.EnvNamespace = "CARNET" parser.EnvNamespace = "CARNET"
parser.AddGroup("Configuration", "Configuration file", ConfigFileOption) if _, err := parser.AddGroup("Configuration", "Configuration file", ConfigFileOption); err != nil {
panic(err)
}
g, err := parser.AddGroup("Logging", "Logging options", LoggingOptions) g, err := parser.AddGroup("Logging", "Logging options", LoggingOptions)
if err != nil { if err != nil {
panic(err) panic(err)
...@@ -83,8 +85,10 @@ ...@@ -83,8 +85,10 @@
g.Namespace="sentry" g.Namespace="sentry"
g.EnvNamespace="SENTRY" g.EnvNamespace="SENTRY"
parser.AddCommand("generate-config", "Generate a configuration file", "", orusapi.NewGenerateConfigCmd(parser)) if _, err := parser.AddCommand("generate-config", "Generate a configuration file", "", orusapi.NewGenerateConfigCmd(parser)); err != nil {
panic(err)
}
bootstrapParser.NamespaceDelimiter = "-" bootstrapParser.NamespaceDelimiter = "-"
bootstrapParser.EnvNamespaceDelimiter = "_" bootstrapParser.EnvNamespaceDelimiter = "_"
bootstrapParser.EnvNamespace = "CARNET" bootstrapParser.EnvNamespace = "CARNET"
...@@ -87,8 +91,10 @@ ...@@ -87,8 +91,10 @@
bootstrapParser.NamespaceDelimiter = "-" bootstrapParser.NamespaceDelimiter = "-"
bootstrapParser.EnvNamespaceDelimiter = "_" bootstrapParser.EnvNamespaceDelimiter = "_"
bootstrapParser.EnvNamespace = "CARNET" bootstrapParser.EnvNamespace = "CARNET"
bootstrapParser.AddGroup("Configuration", "Configuration file", ConfigFileOption) if _, err := bootstrapParser.AddGroup("Configuration", "Configuration file", ConfigFileOption); err != nil {
panic(err)
}
g, err = bootstrapParser.AddGroup("Logging", "Logging options", LoggingOptions) g, err = bootstrapParser.AddGroup("Logging", "Logging options", LoggingOptions)
if err != nil { if err != nil {
panic(err) panic(err)
......
...@@ -3,4 +3,6 @@ ...@@ -3,4 +3,6 @@
package cmd package cmd
import ( import (
"github.com/golang-migrate/migrate/v4"
"github.com/rs/zerolog"
"orus.io/orus-io/go-orusapi/database" "orus.io/orus-io/go-orusapi/database"
...@@ -6,6 +8,4 @@ ...@@ -6,6 +8,4 @@
"orus.io/orus-io/go-orusapi/database" "orus.io/orus-io/go-orusapi/database"
"github.com/golang-migrate/migrate/v4/source"
bindata "github.com/golang-migrate/migrate/v4/source/go_bindata"
"{{ joinFilePath .TargetImportPath "migration" }}" "{{ joinFilePath .TargetImportPath "migration" }}"
) )
...@@ -32,7 +32,16 @@ ...@@ -32,7 +32,16 @@
if err != nil { if err != nil {
return fmt.Errorf("failed to init migration engine: %s", err) return fmt.Errorf("failed to init migration engine: %s", err)
} }
defer m.Close() defer func() {
if sourceErr, databaseErr := m.Close(); sourceErr != nil || databaseErr != nil {
if sourceErr != nil {
log.Err(err).Msg("error closing Migrate source")
}
if databaseErr != nil {
log.Err(err).Msg("error closing Migrate database")
}
}
}()
if err := m.Up(); err != nil { if err := m.Up(); err != nil {
if err == migrate.ErrNoChange { if err == migrate.ErrNoChange {
......
package testutils
import (
"testing"
"github.com/stretchr/testify/assert"
)
// DeferedErrCheck ...
func DeferedErrCheck(tb testing.TB, cb func() error) {
assert.NoError(tb, cb())
}
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment