mirror of
https://github.com/sysadminsmedia/homebox.git
synced 2025-12-21 21:33:02 +01:00
23cecfb2a5
* Refactor main file, add support for postgres certificate authentication * Fix potential issues. * Remove legacy linting ignore comment * Minor cleanup, documentation update
94 lines
3.7 KiB
Go
94 lines
3.7 KiB
Go
package main
|
|
|
|
import (
|
|
"bytes"
|
|
"fmt"
|
|
"os"
|
|
"path/filepath"
|
|
"strings"
|
|
|
|
"github.com/rs/zerolog/log"
|
|
"github.com/sysadminsmedia/homebox/backend/internal/core/currencies"
|
|
"github.com/sysadminsmedia/homebox/backend/internal/sys/config"
|
|
)
|
|
|
|
// setupStorageDir handles the creation and validation of the storage directory.
|
|
func setupStorageDir(cfg *config.Config) {
|
|
if strings.HasPrefix(cfg.Storage.ConnString, "file:///./") {
|
|
raw := strings.TrimPrefix(cfg.Storage.ConnString, "file:///./")
|
|
clean := filepath.Clean(raw)
|
|
absBase, err := filepath.Abs(clean)
|
|
if err != nil {
|
|
log.Fatal().Err(err).Msg("failed to get absolute path for storage connection string")
|
|
}
|
|
storageDir := filepath.Join(absBase, cfg.Storage.PrefixPath)
|
|
storageDir = strings.ReplaceAll(storageDir, "\\", "/")
|
|
if !strings.HasPrefix(storageDir, absBase+"/") && storageDir != absBase {
|
|
log.Fatal().Str("path", storageDir).Msg("invalid storage path: you tried to use a prefix that is not a subdirectory of the base path")
|
|
}
|
|
if err := os.MkdirAll(storageDir, 0o750); err != nil {
|
|
log.Fatal().Err(err).Msg("failed to create data directory")
|
|
}
|
|
}
|
|
}
|
|
|
|
// setupDatabaseURL returns the database URL and ensures any required directories exist.
|
|
func setupDatabaseURL(cfg *config.Config) string {
|
|
databaseURL := ""
|
|
switch strings.ToLower(cfg.Database.Driver) {
|
|
case "sqlite3":
|
|
databaseURL = cfg.Database.SqlitePath
|
|
dbFilePath := strings.Split(cfg.Database.SqlitePath, "?")[0]
|
|
dbDir := filepath.Dir(dbFilePath)
|
|
if err := os.MkdirAll(dbDir, 0o755); err != nil {
|
|
log.Fatal().Err(err).Str("path", dbDir).Msg("failed to create SQLite database directory")
|
|
}
|
|
case "postgres":
|
|
databaseURL = fmt.Sprintf("host=%s port=%s dbname=%s sslmode=%s", cfg.Database.Host, cfg.Database.Port, cfg.Database.Database, cfg.Database.SslMode)
|
|
if cfg.Database.Username != "" {
|
|
databaseURL += fmt.Sprintf(" user=%s", cfg.Database.Username)
|
|
}
|
|
if cfg.Database.Password != "" {
|
|
databaseURL += fmt.Sprintf(" password=%s", cfg.Database.Password)
|
|
}
|
|
if cfg.Database.SslRootCert != "" {
|
|
if _, err := os.Stat(cfg.Database.SslRootCert); err != nil || !os.IsNotExist(err) {
|
|
log.Fatal().Err(err).Str("path", cfg.Database.SslRootCert).Msg("SSL root certificate file does not accessible")
|
|
}
|
|
databaseURL += fmt.Sprintf(" sslrootcert=%s", cfg.Database.SslRootCert)
|
|
}
|
|
if cfg.Database.SslCert != "" {
|
|
if _, err := os.Stat(cfg.Database.SslCert); err != nil || !os.IsNotExist(err) {
|
|
log.Fatal().Err(err).Str("path", cfg.Database.SslCert).Msg("SSL certificate file does not accessible")
|
|
}
|
|
databaseURL += fmt.Sprintf(" sslcert=%s", cfg.Database.SslCert)
|
|
}
|
|
if cfg.Database.SslKey != "" {
|
|
if _, err := os.Stat(cfg.Database.SslKey); err != nil || !os.IsNotExist(err) {
|
|
log.Fatal().Err(err).Str("path", cfg.Database.SslKey).Msg("SSL key file does not accessible")
|
|
}
|
|
databaseURL += fmt.Sprintf(" sslkey=%s", cfg.Database.SslKey)
|
|
}
|
|
default:
|
|
log.Fatal().Str("driver", cfg.Database.Driver).Msg("unsupported database driver")
|
|
}
|
|
return databaseURL
|
|
}
|
|
|
|
// loadCurrencies loads currency data from config if provided.
|
|
func loadCurrencies(cfg *config.Config) ([]currencies.CollectorFunc, error) {
|
|
collectFuncs := []currencies.CollectorFunc{
|
|
currencies.CollectDefaults(),
|
|
}
|
|
if cfg.Options.CurrencyConfig != "" {
|
|
log.Info().Str("path", cfg.Options.CurrencyConfig).Msg("loading currency config file")
|
|
content, err := os.ReadFile(cfg.Options.CurrencyConfig)
|
|
if err != nil {
|
|
log.Error().Err(err).Str("path", cfg.Options.CurrencyConfig).Msg("failed to read currency config file")
|
|
return nil, err
|
|
}
|
|
collectFuncs = append(collectFuncs, currencies.CollectJSON(bytes.NewReader(content)))
|
|
}
|
|
return collectFuncs, nil
|
|
}
|