From 0ec9c4501a0e06c5c86643eca7f9eabfbbdcacd0 Mon Sep 17 00:00:00 2001 From: Marco Kittel Date: Wed, 25 Jun 2025 23:23:38 +0200 Subject: [PATCH] Datewriter um Eliofile geupdated --- go.mod | 2 ++ go.sum | 4 ++++ internal/dataservice/dataservice.go | 7 +++++-- 3 files changed, 11 insertions(+), 2 deletions(-) diff --git a/go.mod b/go.mod index cd66793..f23e302 100644 --- a/go.mod +++ b/go.mod @@ -6,3 +6,5 @@ require ( gittea.marcokittel.de/elio/eliotools/logger v0.0.0-20250624203334-69cf94bf1eef gittea.marcokittel.de/elio/eliotools/tools v0.0.0-20250622182838-d7bc6feff972 ) + +require gittea.marcokittel.de/elio/eliotools/eliofile v0.0.0-20250625211821-d801fbca0baf // indirect diff --git a/go.sum b/go.sum index 0daefe0..cfae0ba 100644 --- a/go.sum +++ b/go.sum @@ -1,3 +1,7 @@ +gittea.marcokittel.de/elio/eliotools/eliofile v0.0.0-20250625210735-e36a0cd13fe6 h1:lM7K/jCZINyCHQpRJR7hMvXRq6mlZlZChn2aBrRpeJE= +gittea.marcokittel.de/elio/eliotools/eliofile v0.0.0-20250625210735-e36a0cd13fe6/go.mod h1:RQlmQsRhpitThSuGT7vl5XwTh1duVGHCmJ0caI+xIoE= +gittea.marcokittel.de/elio/eliotools/eliofile v0.0.0-20250625211821-d801fbca0baf h1:LfjRyNZYKkWpdziHim2MygdvzTkHRusystBifCO0yuo= +gittea.marcokittel.de/elio/eliotools/eliofile v0.0.0-20250625211821-d801fbca0baf/go.mod h1:RQlmQsRhpitThSuGT7vl5XwTh1duVGHCmJ0caI+xIoE= gittea.marcokittel.de/elio/eliotools/logger v0.0.0-20250622173330-32b4c009427c h1:oDEBlixjzptDRNutBddsgcNqls/+dDgfgzWvGGSnQwY= gittea.marcokittel.de/elio/eliotools/logger v0.0.0-20250622173330-32b4c009427c/go.mod h1:WDmnG6o72HhGTSkgwj2kXYcRL2MaNFNsKNBeTh6NIzo= gittea.marcokittel.de/elio/eliotools/logger v0.0.0-20250624203334-69cf94bf1eef h1:EzFzLINpiq712X2/t8ZMTLoWuqA6sRmpH3J0VpFi2Cg= diff --git a/internal/dataservice/dataservice.go b/internal/dataservice/dataservice.go index 54fd423..4c75d17 100644 --- a/internal/dataservice/dataservice.go +++ b/internal/dataservice/dataservice.go @@ -7,12 +7,14 @@ import ( "gittea.marcokittel.de/elio/eliotools/datawriter/internal/dbwriter" "gittea.marcokittel.de/elio/eliotools/datawriter/internal/event" + "gittea.marcokittel.de/elio/eliotools/eliofile" "gittea.marcokittel.de/elio/eliotools/logger" ) type DataService struct { listener []event.EventListener log logger.Logger + ef eliofile.ElioDateiFoo } func (d *DataService) ListenerCount() int { @@ -28,13 +30,14 @@ func (d *DataService) Run(ctx context.Context, wg *sync.WaitGroup) { default: //Hier nach neuen Dateien suchen for _, l := range d.listener { + d.ef.ScanCsv() err := l.HandleData(ctx, dbwriter.MyStruct{A: "dkl", B: 3}) if err != nil { //todo } } d.log.Info("DataService Run") - time.Sleep(time.Second * 2) + time.Sleep(time.Second * 10) } } } @@ -44,6 +47,6 @@ func (d *DataService) AddListener(ev event.EventListener) { } func NewDataService() *DataService { - ds := DataService{listener: make([]event.EventListener, 0), log: logger.NewMarcoLogger()} + ds := DataService{listener: make([]event.EventListener, 0), log: logger.NewMarcoLogger(), ef: *eliofile.NewElioDateiFoo(".")} return &ds }