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,