Skip to content

Commit 2018f91

Browse files
committed
Create timestamp format constant
1 parent d847ffd commit 2018f91

5 files changed

Lines changed: 11 additions & 26 deletions

File tree

backend/pkg/logger/data/logger.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -109,8 +109,8 @@ func (sublogger *Logger) PushRecord(record abstraction.LoggerRecord) error {
109109
file, ok := sublogger.valueFileSlice[valueName]
110110
if !ok {
111111
filename := path.Join(
112-
"logger/data",
113-
fmt.Sprintf("data_%s", timestamp.Format("2006_01_02_15_04_05")),
112+
"logger", "data",
113+
loggerHandler.Timestamp.Format(loggerHandler.TimestampFormat),
114114
fmt.Sprintf("%s.csv", valueName),
115115
)
116116
err := os.MkdirAll(path.Dir(filename), os.ModePerm)

backend/pkg/logger/logger.go

Lines changed: 2 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,6 @@
11
package logger
22

33
import (
4-
"os"
5-
"path"
64
"sync"
75
"sync/atomic"
86
"time"
@@ -16,6 +14,8 @@ const (
1614
HandlerName = "logger"
1715
)
1816

17+
const TimestampFormat = "01-Jan-2006_15-04-05.000"
18+
1919
// Logger is a struct that implements the abstraction.Logger interface
2020
type Logger struct {
2121
// An atomic boolean is used in order to use CompareAndSwap in the Start and Stop methods
@@ -63,21 +63,6 @@ func (logger *Logger) Start() error {
6363

6464
Timestamp = time.Now()
6565

66-
// Create log folders
67-
for subLogger := range logger.subloggers {
68-
loggerPath := path.Join("logger", string(subLogger), Timestamp.Format(time.RFC3339))
69-
logger.trace.Debug().Str("subLogger", string(subLogger)).Str("path", loggerPath).Msg("creating folder")
70-
err := os.MkdirAll(loggerPath, os.ModePerm)
71-
if err != nil {
72-
logger.trace.Error().Stack().Err(err).Msg("creating folder")
73-
return ErrCreatingAllDir{
74-
Name: Name,
75-
Timestamp: time.Now(),
76-
Path: loggerPath,
77-
}
78-
}
79-
}
80-
8166
logger.subloggersLock.Lock()
8267
defer logger.subloggersLock.Unlock()
8368

backend/pkg/logger/order/logger.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -52,8 +52,8 @@ func (sublogger *Logger) Start() error {
5252
}
5353

5454
filename := path.Join(
55-
"logger/order",
56-
fmt.Sprintf("order_%s", logger.Timestamp.Format("2006_01_02_15_04_05")),
55+
"logger", "order",
56+
logger.Timestamp.Format(logger.TimestampFormat),
5757
"order.csv",
5858
)
5959
err := os.MkdirAll(path.Dir(filename), os.ModePerm)

backend/pkg/logger/protection/logger.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -91,8 +91,8 @@ func (sublogger *Logger) PushRecord(record abstraction.LoggerRecord) error {
9191
}
9292

9393
filename := path.Join(
94-
"logger/protections",
95-
fmt.Sprintf("protection_%s", logger.Timestamp.Format("2006_01_02_15_04_05")),
94+
"logger", "protections",
95+
logger.Timestamp.Format(logger.TimestampFormat),
9696
fmt.Sprintf("%s.csv", boardName),
9797
)
9898
err := os.MkdirAll(path.Dir(filename), os.ModePerm)

backend/pkg/logger/state/logger.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -68,9 +68,9 @@ func (sublogger *Logger) PushRecord(record abstraction.LoggerRecord) error {
6868
}
6969

7070
filename := path.Join(
71-
"logger/state",
72-
fmt.Sprintf("data_%s", logger.Timestamp.Format("2006_01_02_15_04_05")),
73-
fmt.Sprintf("state_%s.csv", time.Now().Format("2006_01_02_15_04_05")),
71+
"logger", "state",
72+
logger.Timestamp.Format(logger.TimestampFormat),
73+
fmt.Sprintf("%s.csv", time.Now().Format(logger.TimestampFormat)),
7474
)
7575
err := os.MkdirAll(path.Dir(filename), os.ModePerm)
7676
if err != nil {

0 commit comments

Comments
 (0)