From 24628f4ebb061c717e91510693efbe61ec84a355 Mon Sep 17 00:00:00 2001 From: Bel LaPointe <153096461+breel-render@users.noreply.github.com> Date: Fri, 12 Apr 2024 09:21:36 -0600 Subject: [PATCH] Config has a .storage, .queue, .driiver --- config.go | 8 ++++++++ main.go | 1 + 2 files changed, 9 insertions(+) diff --git a/config.go b/config.go index 27ee69d..b667f61 100644 --- a/config.go +++ b/config.go @@ -16,6 +16,9 @@ type Config struct { InitializeSlack bool SlackToken string SlackChannels string + storage Storage + queue Queue + driver Driver } func newConfig() (Config, error) { @@ -73,5 +76,10 @@ func newConfigFromEnv(getEnv func(string) string) (Config, error) { } else if err := json.Unmarshal(b, &result); err != nil { return Config{}, err } + + result.driver = NewRAM() + result.storage = NewStorage(result.driver) + result.queue = NewQueue(result.driver) + return result, nil } diff --git a/main.go b/main.go index a996087..8b3782c 100644 --- a/main.go +++ b/main.go @@ -23,6 +23,7 @@ func main() { if err != nil { panic(err) } + defer cfg.driver.Close() if err := run(ctx, cfg); err != nil && ctx.Err() == nil { panic(err)