Skip to content

Commit f3b7128

Browse files
committed
Revert name change and ensure files are cleared between runs
1 parent b4f0798 commit f3b7128

1 file changed

Lines changed: 7 additions & 4 deletions

File tree

backend/pkg/logger/data/logger.go

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -106,8 +106,8 @@ func (sublogger *Logger) PushRecord(record abstraction.LoggerRecord) error {
106106
val = string(v.Variant())
107107
}
108108

109-
file, exists := sublogger.valueFileSlice[valueName]
110-
if !exists {
109+
file, ok := sublogger.valueFileSlice[valueName]
110+
if !ok {
111111
filename := path.Join(
112112
"logger/data",
113113
fmt.Sprintf("data_%s", loggerHandler.Timestamp.Format(time.RFC3339)),
@@ -147,6 +147,7 @@ func (sublogger *Logger) PushRecord(record abstraction.LoggerRecord) error {
147147
Timestamp: time.Now(),
148148
Inner: err,
149149
}
150+
fmt.Println(writerErr)
150151
}
151152
writer.Flush()
152153
}
@@ -164,18 +165,20 @@ func (sublogger *Logger) Stop() error {
164165
}
165166

166167
closeErr := error(nil)
167-
for _, file := range sublogger.valueFileSlice {
168+
for value, file := range sublogger.valueFileSlice {
168169
err := file.Close()
169170
if err != nil {
170171
closeErr = loggerHandler.ErrClosingFile{
171172
Name: Name,
172173
Timestamp: time.Now(),
173174
}
174175

175-
fmt.Println(closeErr.Error())
176+
fmt.Println(value, ": ", closeErr)
176177
}
177178
}
178179

180+
sublogger.valueFileSlice = make(map[data.ValueName]io.WriteCloser, len(sublogger.valueFileSlice))
181+
179182
fmt.Println("Logger stopped")
180183
return closeErr
181184
}

0 commit comments

Comments
 (0)