tie csv engine to meteo domain
This commit is contained in:
@@ -12,10 +12,14 @@ import (
|
|||||||
"time"
|
"time"
|
||||||
)
|
)
|
||||||
|
|
||||||
type Handler struct{}
|
type Handler struct {
|
||||||
|
csv *CSV
|
||||||
|
}
|
||||||
|
|
||||||
func NewHandler() *Handler {
|
func NewHandler() *Handler {
|
||||||
return &Handler{}
|
return &Handler{
|
||||||
|
csv: &CSV{},
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (h *Handler) IngestCSV(w http.ResponseWriter, r *http.Request) {
|
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()
|
start := time.Now()
|
||||||
|
|
||||||
csvParser := &CSV{}
|
inserted, rejected, err := h.csv.Parse(bytes.NewReader(content), fileStats)
|
||||||
inserted, rejected, err := csvParser.Parse(bytes.NewReader(content), fileStats)
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
slog.Error(ErrCannotParseFile.Error(),
|
slog.Error(ErrCannotParseFile.Error(),
|
||||||
"filename", header.Filename,
|
"filename", header.Filename,
|
||||||
|
|||||||
Reference in New Issue
Block a user