Skip to content

Commit

Permalink
Don't parse YAML config twice & drop superfluous code
Browse files Browse the repository at this point in the history
  • Loading branch information
yhabteab committed Jul 24, 2024
1 parent e74208b commit 8cef88a
Show file tree
Hide file tree
Showing 5 changed files with 5 additions and 130 deletions.
8 changes: 2 additions & 6 deletions cmd/icinga-kubernetes/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -66,20 +66,16 @@ func main() {
klog.Fatal(errors.Wrap(err, "can't create configuration"))
}

d, err := database.FromYAMLFile(configLocation)
if err != nil {
klog.Fatal(err)
}
dbLog := log.WithName("database")
db, err := database.NewFromConfig(d, dbLog)
db, err := database.NewFromConfig(&cfg.Database, dbLog)
if err != nil {
klog.Fatal(err)
}
if !db.Connect() {
return
}

hasSchema, err := dbHasSchema(db, d.Database)
hasSchema, err := dbHasSchema(db, cfg.Database.Database)
if err != nil {
klog.Fatal(err)
}
Expand Down
43 changes: 0 additions & 43 deletions pkg/database/config.go

This file was deleted.

6 changes: 3 additions & 3 deletions pkg/database/database.go
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ var registerDriversOnce sync.Once
type Database struct {
*sqlx.DB

Options Options
Options database.Options

log logr.Logger

Expand All @@ -46,7 +46,7 @@ type Database struct {
}

// NewFromConfig returns a new Database connection from the given Config.
func NewFromConfig(c *Config, log logr.Logger) (*Database, error) {
func NewFromConfig(c *database.Config, log logr.Logger) (*Database, error) {
registerDriversOnce.Do(func() {
RegisterDrivers(log)
})
Expand Down Expand Up @@ -99,7 +99,7 @@ func NewFromConfig(c *Config, log logr.Logger) (*Database, error) {
uri.RawQuery = query.Encode()
dsn = uri.String()
default:
return nil, unknownDbType(c.Type)
return nil, errors.Errorf(`unknown database type %q, must be one of: "mysql", "pgsql"`, c.Type)
}

db, err := sqlx.Open("icinga-"+c.Type, dsn)
Expand Down
35 changes: 0 additions & 35 deletions pkg/database/db.go

This file was deleted.

43 changes: 0 additions & 43 deletions pkg/database/options.go

This file was deleted.

0 comments on commit 8cef88a

Please sign in to comment.