package services import ( "fmt" "log/slog" "github.com/labstack/echo/v4" _ "github.com/mattn/go-sqlite3" "github.com/mikestefanello/backlite" "git.grosinger.net/tgrosinger/saasitone/config" "git.grosinger.net/tgrosinger/saasitone/pkg/funcmap" "git.grosinger.net/tgrosinger/saasitone/pkg/log" ) // Container contains all services used by the application and provides an easy way to handle dependency // injection including within tests type Container struct { // Validator stores a validator Validator *Validator // Web stores the web framework Web *echo.Echo // Config stores the application configuration Config *config.Config // Cache contains the cache client Cache *CacheClient // DB is the connection to the database and models for interacting with it DB *DBClient // Mail stores an email sending client Mail *MailClient // Auth stores an authentication client Auth *AuthClient // TemplateRenderer stores a service to easily render and cache templates TemplateRenderer *TemplateRenderer // Tasks stores the task client Tasks *backlite.Client } // NewContainer creates and initializes a new Container func NewContainer() *Container { c := new(Container) c.initConfig() c.initValidator() c.initWeb() c.initCache() c.initDatabase() c.initAuth() c.initTemplateRenderer() c.initMail() c.initTasks() return c } // Shutdown shuts the Container down and disconnects all connections. // If the task runner was started, cancel the context to shut it down prior to calling this. func (c *Container) Shutdown() error { if err := c.DB.Close(); err != nil { return err } c.Cache.Close() return nil } // initConfig initializes configuration func (c *Container) initConfig() { cfg, err := config.GetConfig() if err != nil { panic(fmt.Sprintf("failed to load config: %v", err)) } c.Config = &cfg // Configure logging switch cfg.App.Environment { case config.EnvProduction: slog.SetLogLoggerLevel(slog.LevelInfo) default: slog.SetLogLoggerLevel(slog.LevelDebug) } } // initValidator initializes the validator func (c *Container) initValidator() { c.Validator = NewValidator() } // initWeb initializes the web framework func (c *Container) initWeb() { c.Web = echo.New() c.Web.HideBanner = true c.Web.Validator = c.Validator } // initCache initializes the cache func (c *Container) initCache() { store, err := newInMemoryCache(c.Config.Cache.Capacity) if err != nil { panic(err) } c.Cache = NewCacheClient(store) } // initDatabase initializes the database func (c *Container) initDatabase() { client, err := NewDBClient(c.Config) if err != nil { panic(err) } c.DB = client } // initAuth initializes the authentication client func (c *Container) initAuth() { c.Auth = NewAuthClient(c.Config, c.DB) } // initTemplateRenderer initializes the template renderer func (c *Container) initTemplateRenderer() { c.TemplateRenderer = NewTemplateRenderer(c.Config, c.Cache, funcmap.NewFuncMap(c.Web)) } // initMail initialize the mail client func (c *Container) initMail() { var err error c.Mail, err = NewMailClient(c.Config, c.TemplateRenderer) if err != nil { panic(fmt.Sprintf("failed to create mail client: %v", err)) } } // initTasks initializes the task client func (c *Container) initTasks() { var err error // You could use a separate database for tasks, if you'd like. but using one // makes transaction support easier c.Tasks, err = backlite.NewClient(backlite.ClientConfig{ DB: c.DB.DB(), Logger: log.Default(), NumWorkers: c.Config.Tasks.Goroutines, ReleaseAfter: c.Config.Tasks.ReleaseAfter, CleanupInterval: c.Config.Tasks.CleanupInterval, }) if err != nil { panic(fmt.Sprintf("failed to create task client: %v", err)) } if err = c.Tasks.Install(); err != nil { panic(fmt.Sprintf("failed to install task schema: %v", err)) } }