From 43e9b2b993de1c24b2ac58f1035d1204ad3a9886 Mon Sep 17 00:00:00 2001 From: Zsolt Tasnadi Date: Tue, 20 Jan 2026 00:31:54 +0100 Subject: [PATCH] tweaks --- lib/runner.go | 31 ++++++++++++++++--------------- lib/sender.discord.go | 6 ++++++ 2 files changed, 22 insertions(+), 15 deletions(-) diff --git a/lib/runner.go b/lib/runner.go index 0d2b824..7f76acb 100644 --- a/lib/runner.go +++ b/lib/runner.go @@ -56,31 +56,32 @@ func getDiscordSender(config Config) DiscordSender { return DiscordSender{Config: config} } -func Runner() { +func getMessages(fetchers []Fetcher) []string { + messages := []string{} + for _, fetcher := range fetchers { + fetcher_messages := fetcher.Fetch() + messages = append(messages, fetcher_messages...) + } + return messages +} + +func loadEnv() { if err := godotenv.Load(); err != nil { log.Println("Warning: .env file not found, using environment variables") } +} + +func Runner() { + loadEnv() config := getConfig() cache := getCache() discord_sender := getDiscordSender(config) fetchers := getFetchers(config, &cache) - messages := []string{} for { log.Println("Run updater...") - - messages = []string{} // Clear messages for the current iteration - for _, fetcher := range fetchers { - fetcher_messages := fetcher.Fetch() - messages = append(messages, fetcher_messages...) - } - - for _, message := range messages { - log.Println("Send message: ", message) - discord_sender.Send(message) - } - + messages := getMessages(fetchers) + discord_sender.SendBatch(messages) cache.Save() - time.Sleep(config.Interval) } } diff --git a/lib/sender.discord.go b/lib/sender.discord.go index d46d8e9..0b8ec89 100644 --- a/lib/sender.discord.go +++ b/lib/sender.discord.go @@ -17,3 +17,9 @@ func (d DiscordSender) Send(msg string) { } http.Post(d.Config.DiscordWebhook, "application/json", bytes.NewBuffer(b)) } + +func (d DiscordSender) SendBatch(msgs []string) { + for _, msg := range msgs { + d.Send(msg) + } +}