Merge pull request #129 from HyperloopUPV-H8/backend/logger-hotfix

Fix logger file naming and close procedures

Author: jmaralo

backend/pkg/logger/data/logger.go

@@ -106,8 +106,8 @@ func (sublogger *Logger) PushRecord(record abstraction.LoggerRecord) error {
 			val = string(v.Variant())
 		}
 
-		file, exists := sublogger.valueFileSlice[valueName]
-		if !exists {
+		file, ok := sublogger.valueFileSlice[valueName]
+		if !ok {
 			filename := path.Join(
 				"logger/data",
 				fmt.Sprintf("data_%s", loggerHandler.Timestamp.Format(time.RFC3339)),
@@ -147,6 +147,7 @@ func (sublogger *Logger) PushRecord(record abstraction.LoggerRecord) error {
 				Timestamp: time.Now(),
 				Inner:     err,
 			}
+			fmt.Println(writerErr)
 		}
 		writer.Flush()
 	}
@@ -164,18 +165,20 @@ func (sublogger *Logger) Stop() error {
 	}
 
 	closeErr := error(nil)
-	for _, file := range sublogger.valueFileSlice {
+	for value, file := range sublogger.valueFileSlice {
 		err := file.Close()
 		if err != nil {
 			closeErr = loggerHandler.ErrClosingFile{
 				Name:      Name,
 				Timestamp: time.Now(),
 			}
 
-			fmt.Println(closeErr.Error())
+			fmt.Println(value, ": ", closeErr)
 		}
 	}
 
+	sublogger.valueFileSlice = make(map[data.ValueName]io.WriteCloser, len(sublogger.valueFileSlice))
+
 	fmt.Println("Logger stopped")
 	return closeErr
 }

backend/pkg/logger/logger.go

@@ -61,6 +61,8 @@ func (logger *Logger) Start() error {
 		return nil
 	}
 
+	Timestamp = time.Now()
+
 	// Create log folders
 	for subLogger := range logger.subloggers {
 		loggerPath := path.Join("logger", string(subLogger), Timestamp.Format(time.RFC3339))

backend/pkg/logger/protection/logger.go

@@ -158,6 +158,8 @@ func (sublogger *Logger) Stop() error {
 		}
 	}
 
+	sublogger.infoIdMap = make(map[abstraction.BoardId]io.WriteCloser, len(sublogger.infoIdMap))
+
 	fmt.Println("Logger stopped")
 	return closeErr
 }