Add ntfy config settings

internal/config/defaults.go

@@ -1,13 +1,19 @@
 package config
 
+import "strconv"
+
 const (
-	KeyUploadMaxFileSizeBytes   = "upload.max_file_size_bytes"
-	KeyUploadMultiMaxFiles      = "upload.multi.max_files"
-	KeyUploadMaxHours           = "upload.max_hours"
-	KeyRateLimitLoginPerMinute  = "ratelimit.login.per_minute"
-	KeyRateLimitApiPerMinute    = "ratelimit.api.per_minute"
-	KeyRateLimitApiBurst        = "ratelimit.api.burst"
-	KeyRateLimitLoginBurst      = "ratelimit.login.burst"
+	KeyUploadMaxFileSizeBytes  = "upload.max_file_size_bytes"
+	KeyUploadMultiMaxFiles     = "upload.multi.max_files"
+	KeyUploadMaxHours          = "upload.max_hours"
+	KeyRateLimitLoginPerMinute = "ratelimit.login.per_minute"
+	KeyRateLimitApiPerMinute   = "ratelimit.api.per_minute"
+	KeyRateLimitApiBurst       = "ratelimit.api.burst"
+	KeyRateLimitLoginBurst     = "ratelimit.login.burst"
+
+	KeyUseNtfy   = "use_ntfy"
+	KeyNtfyUrl   = "ntfy.url"
+	KeyNtfyTopic = "ntfy.topic"
 )
 
 // Defaults (used when DB does not have an override)
@@ -20,4 +26,27 @@ const (
 	DefaultRateLimitLoginBurst     = 10
 	DefaultRateLimitApiPerMinute   = 60
 	DefaultRateLimitApiBurst       = 30
+
+	DefaultUseNtfy   = 0
+	DefaultNtfyUrl   = ""
+	DefaultNtfyTopic = ""
 )
+
+// DefaultKeyValues returns a map of config keys to their default string values, for use when initializing the database.
+// Code duplication be dammed
+func DefaultKeyValues() map[string]string {
+	return map[string]string{
+		KeyUploadMaxFileSizeBytes: strconv.FormatInt(DefaultUploadMaxFileSizeBytes, 10),
+		KeyUploadMultiMaxFiles:    strconv.Itoa(DefaultUploadMultiMaxFiles),
+		KeyUploadMaxHours:         strconv.Itoa(DefaultUploadMaxHours),
+
+		KeyRateLimitLoginPerMinute: strconv.Itoa(DefaultRateLimitLoginPerMinute),
+		KeyRateLimitLoginBurst:     strconv.Itoa(DefaultRateLimitLoginBurst),
+		KeyRateLimitApiPerMinute:   strconv.Itoa(DefaultRateLimitApiPerMinute),
+		KeyRateLimitApiBurst:       strconv.Itoa(DefaultRateLimitApiBurst),
+
+		KeyUseNtfy:   strconv.Itoa(DefaultUseNtfy),
+		KeyNtfyUrl:   DefaultNtfyUrl,
+		KeyNtfyTopic: DefaultNtfyTopic,
+	}
+}

internal/config/repository.go

@@ -1,6 +1,10 @@
 package config
 
-import "gorm.io/gorm"
+import (
+	"errors"
+
+	"gorm.io/gorm"
+)
 
 type Repository struct {
 	db *gorm.DB
@@ -37,3 +41,15 @@ func (r *Repository) List() ([]ConfigEntry, error) {
 	}
 	return entries, nil
 }
+
+func (r *Repository) CreateIfMissing(key, value string) error {
+	var e ConfigEntry
+	err := r.db.First(&e, "key = ?", key).Error
+	if err == nil {
+		return nil
+	}
+	if errors.Is(err, gorm.ErrRecordNotFound) {
+		return r.db.Create(&ConfigEntry{Key: key, Value: value}).Error
+	}
+	return err
+}

internal/config/service.go

@@ -22,6 +22,15 @@ func NewService(r *Repository) *Service {
 	return &Service{repo: r, cache: make(map[string]string)}
 }
 
+func (s *Service) EnsureDefaults() error {
+	for k, v := range DefaultKeyValues() {
+		if err := s.repo.CreateIfMissing(k, v); err != nil {
+			return err
+		}
+	}
+	return nil
+}
+
 func (s *Service) List() ([]ConfigEntry, error) {
 	entries, err := s.repo.List()
 	if err != nil {