From 288092e4b4193195052a703f96d5b85017218428 Mon Sep 17 00:00:00 2001 From: KS Jannette Date: Sat, 28 Mar 2026 10:31:14 -0400 Subject: [PATCH] More --- backend/README.md | 5 +++-- backend/cmd/poller/main.go | 1 - backend/internal/services/evaluator.go | 14 +------------- 3 files changed, 4 insertions(+), 16 deletions(-) diff --git a/backend/README.md b/backend/README.md index d579bf4..5b4adac 100644 --- a/backend/README.md +++ b/backend/README.md @@ -1,4 +1,4 @@ -Start DB: +Backend startup quickstarat: ## 1. brew services start postgresql@15 @@ -19,7 +19,8 @@ Start DB: make dev — Runs the API server with auto-reload via air (falls back to go run if air isn't installed). ## 5. Terminal 2 (Poller): - cd /Users/kjannette/workspace/koin_ping_0.2.0/backend go run ./cmd/poller + cd /Users/kjannette/workspace/koin_ping_0.2.0/backend + go run ./cmd/poller make poller — Builds and runs the poller. make poller-dev — Runs the poller with auto-reload. diff --git a/backend/cmd/poller/main.go b/backend/cmd/poller/main.go index 05dc523..f7b0cbe 100644 --- a/backend/cmd/poller/main.go +++ b/backend/cmd/poller/main.go @@ -60,7 +60,6 @@ func main() { observer := services.NewObserverService(eth, addressModel, checkpointModel) evaluator := services.NewEvaluatorService( eth, alertRuleModel, alertEventModel, addressModel, notifConfigModel, - cfg.ResendAPIKey, cfg.EmailFrom, ) digestSvc := services.NewEmailDigestService(cfg.ResendAPIKey, cfg.EmailFrom, alertEventModel, notifConfigModel) diff --git a/backend/internal/services/evaluator.go b/backend/internal/services/evaluator.go index f3d6740..e664df7 100644 --- a/backend/internal/services/evaluator.go +++ b/backend/internal/services/evaluator.go @@ -29,8 +29,6 @@ type EvaluatorService struct { alertEvents *models.AlertEventModel addresses *models.AddressModel notifConfigs *models.NotificationConfigModel - resendAPIKey string - emailFrom string notifSem *semaphore.Weighted notifWg sync.WaitGroup } @@ -41,8 +39,6 @@ func NewEvaluatorService( alertEvents *models.AlertEventModel, addresses *models.AddressModel, notifConfigs *models.NotificationConfigModel, - resendAPIKey string, - emailFrom string, ) *EvaluatorService { return &EvaluatorService{ eth: eth, @@ -50,8 +46,6 @@ func NewEvaluatorService( alertEvents: alertEvents, addresses: addresses, notifConfigs: notifConfigs, - resendAPIKey: resendAPIKey, - emailFrom: emailFrom, notifSem: semaphore.NewWeighted(maxConcurrentNotifications), } } @@ -273,13 +267,7 @@ func (s *EvaluatorService) buildNotifiers(cfg *domain.NotificationConfig) []noti notifiers = append(notifiers, ¬ifications.SlackNotifier{WebhookURL: *cfg.SlackWebhookURL}) } - if cfg.Email != nil && *cfg.Email != "" { - notifiers = append(notifiers, ¬ifications.EmailNotifier{ - APIKey: s.resendAPIKey, - From: s.emailFrom, - To: *cfg.Email, - }) - } + // Email is delivered exclusively via the daily digest service, never real-time. return notifiers }