From 6c24eed54141aebd484522d9ccfbe2a4335b1b4e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Pedro=20P=C3=A9rez?= Date: Thu, 23 Oct 2025 03:52:19 +0200 Subject: [PATCH] tie csv engine to meteo domain --- service_a/internal/domains/meteo/handlers.go | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/service_a/internal/domains/meteo/handlers.go b/service_a/internal/domains/meteo/handlers.go index 1400be3..769306e 100644 --- a/service_a/internal/domains/meteo/handlers.go +++ b/service_a/internal/domains/meteo/handlers.go @@ -12,10 +12,14 @@ import ( "time" ) -type Handler struct{} +type Handler struct { + csv *CSV +} func NewHandler() *Handler { - return &Handler{} + return &Handler{ + csv: &CSV{}, + } } func (h *Handler) IngestCSV(w http.ResponseWriter, r *http.Request) { @@ -47,8 +51,7 @@ func (h *Handler) IngestCSV(w http.ResponseWriter, r *http.Request) { start := time.Now() - csvParser := &CSV{} - inserted, rejected, err := csvParser.Parse(bytes.NewReader(content), fileStats) + inserted, rejected, err := h.csv.Parse(bytes.NewReader(content), fileStats) if err != nil { slog.Error(ErrCannotParseFile.Error(), "filename", header.Filename,