fix directory creation

Author: msanlli

backend/pkg/logger/data/logger.go

@@ -107,8 +107,10 @@ func (sublogger *Logger) PushRecord(record abstraction.LoggerRecord) error {
 
 		file, ok := sublogger.valueFileSlice[valueName]
 		if !ok {
-			filename := fmt.Sprintf("%s_%s.csv", valueName, logger.Timestamp.Format(time.RFC3339))
-			f, err := os.Create(path.Join("logger/data", filename))
+			filename := path.Join("logger/data", fmt.Sprintf("data_%s", logger.Timestamp.Format(time.RFC3339)), fmt.Sprintf("%s.csv", valueName))
+			os.MkdirAll(path.Dir(filename), os.ModePerm)
+
+			f, err := os.Create(path.Join(filename))
 			if err != nil {
 				return &logger.ErrCreatingFile{
 					Name:      Name,

backend/pkg/logger/logger.go

@@ -68,8 +68,8 @@ func (logger *Logger) Start() error {
 	}
 
 	// Create log folders
-	for l := range logger.subloggers {
-		os.MkdirAll(path.Join("logger", fmt.Sprintf("%s_%s", l, time.Now().Format(time.RFC3339))), os.ModePerm)
+	for logger := range logger.subloggers {
+		os.MkdirAll(path.Join("logger", fmt.Sprint(logger), fmt.Sprintf("%s_%s", logger, Timestamp.Format(time.RFC3339))), os.ModePerm)
 	}
 
 	logger.subloggersLock.Lock()

backend/pkg/logger/messages/logger.go

@@ -92,8 +92,9 @@ func (sublogger *Logger) PushRecord(record abstraction.LoggerRecord) error {
 			boardName = fmt.Sprint(boardId)
 		}
 
-		filename := path.Join("logger/messages", fmt.Sprintf(boardName+"_"+logger.Timestamp.Format(time.RFC3339)+".csv"))
+		filename := path.Join("logger/messages", fmt.Sprintf("messages_%s", logger.Timestamp.Format(time.RFC3339)), fmt.Sprintf("%s.csv", boardName))
 		os.MkdirAll(path.Dir(filename), os.ModePerm)
+
 		f, err := os.Create(filename)
 		if err != nil {
 			return &logger.ErrCreatingFile{

backend/pkg/logger/order/logger.go

@@ -38,6 +38,7 @@ func NewLogger() *Logger {
 	return &Logger{
 		running:  &atomic.Bool{},
 		fileLock: &sync.RWMutex{},
+		writer:   nil,
 	}
 }
 
@@ -47,18 +48,6 @@ func (sublogger *Logger) Start() error {
 		return nil
 	}
 
-	filepath := path.Join("logger/order", fmt.Sprint(logger.Timestamp.Format(time.RFC3339)+".csv"))
-	os.MkdirAll(path.Dir(filepath), os.ModePerm)
-	file, err := os.Create(filepath)
-	if err != nil {
-		return &logger.ErrCreatingFile{
-			Name:      Name,
-			Timestamp: time.Now(),
-			Inner:     err,
-		}
-	}
-	sublogger.writer = file
-
 	fmt.Println("Logger started")
 	return nil
 }
@@ -84,10 +73,25 @@ func (sublogger *Logger) PushRecord(record abstraction.LoggerRecord) error {
 	sublogger.fileLock.Lock()
 	defer sublogger.fileLock.Unlock()
 
+	if sublogger.writer == nil {
+		filename := path.Join("logger/order", fmt.Sprintf("order_%s", logger.Timestamp.Format(time.RFC3339)), "order.csv")
+		os.MkdirAll(path.Dir(filename), os.ModePerm)
+
+		file, err := os.Create(filename)
+		if err != nil {
+			return &logger.ErrCreatingFile{
+				Name:      Name,
+				Timestamp: time.Now(),
+				Inner:     err,
+			}
+		}
+		sublogger.writer = file
+	}
+
 	csvWriter := csv.NewWriter(sublogger.writer)
 	defer csvWriter.Flush()
 
-	err := csvWriter.Write([]string{time.Now().Format(time.RFC3339), fmt.Sprint(orderRecord.Packet.GetValues())})
+	err := csvWriter.Write([]string{orderRecord.Packet.Timestamp().Format(time.RFC3339), fmt.Sprint(orderRecord.Packet.GetValues())})
 	if err != nil {
 		return err
 	}

backend/pkg/logger/state/logger.go

@@ -64,8 +64,9 @@ func (sublogger *Logger) PushRecord(record abstraction.LoggerRecord) error {
 		}
 	}
 
-	filepath := fmt.Sprint("logger/state/state_" + logger.Timestamp.Format(time.RFC3339) + ".csv")
+	filepath := path.Join("logger/state", fmt.Sprintf("state_%s", logger.Timestamp.Format(time.RFC3339)), fmt.Sprintf("state_%s.csv", time.Now().Format(time.RFC3339)))
 	os.MkdirAll(path.Dir(filepath), os.ModePerm)
+
 	file, err := os.Create(filepath)
 	if err != nil {
 		return &logger.ErrCreatingFile{