feat: Log timestamp relative to the start time

Author: JFisica

backend/pkg/logger/data/logger.go

@@ -29,6 +29,8 @@ type Logger struct {
 	saveFiles map[data.ValueName]*file.CSV
 	// allowedVars contains the full names (board/valueName) to be logged
 	allowedVars map[string]struct{}
+	// save the starting time of the logger in Unix microseconds in order to log relative timestamps
+	startTime int64
 }
 
 // Record is a struct that implements the abstraction.LoggerRecord interface
@@ -47,6 +49,7 @@ func NewLogger() *Logger {
 		running:     &atomic.Bool{},
 		fileLock:    &sync.RWMutex{},
 		allowedVars: nil, // no filter by default
+		startTime:   0,
 	}
 
 	logger.running.Store(false)
@@ -68,6 +71,8 @@ func (sublogger *Logger) Start() error {
 		return nil
 	}
 
+	sublogger.startTime = time.Now().UnixMicro() // Update the start time
+
 	fmt.Println("Logger started")
 	return nil
 }
@@ -120,7 +125,7 @@ func (sublogger *Logger) PushRecord(record abstraction.LoggerRecord) error {
 		}
 
 		err = saveFile.Write([]string{
-			fmt.Sprint(dataRecord.Packet.Timestamp().UnixMicro()),
+			fmt.Sprint(dataRecord.Packet.Timestamp().UnixMicro() - sublogger.startTime), // Save the timestamp relative to the start time
 			dataRecord.From,
 			dataRecord.To,
 			valueRepresentation,

backend/pkg/logger/order/logger.go

@@ -21,6 +21,8 @@ type Logger struct {
 	// An atomic boolean is used in order to use CompareAndSwap in the Start and Stop methods
 	running *atomic.Bool
 	writer  *file.CSV
+	// save the starting time of the logger in Unix microseconds in order to log relative timestamps
+	startTime int64
 }
 
 type Record struct {
@@ -36,8 +38,9 @@ func (*Record) Name() abstraction.LoggerName {
 
 func NewLogger() *Logger {
 	return &Logger{
-		running: &atomic.Bool{},
-		writer:  nil,
+		running:   &atomic.Bool{},
+		writer:    nil,
+		startTime: 0,
 	}
 }
 
@@ -51,6 +54,9 @@ func (sublogger *Logger) Start() error {
 	if err != nil {
 		return err
 	}
+
+	sublogger.startTime = time.Now().UnixMicro() // Update the start time
+
 	sublogger.writer = file.NewCSV(fileRaw)
 
 	fmt.Println("Logger started")
@@ -96,7 +102,7 @@ func (sublogger *Logger) PushRecord(record abstraction.LoggerRecord) error {
 	}
 
 	err := sublogger.writer.Write([]string{
-		fmt.Sprint(orderRecord.Packet.Timestamp().UnixMicro()),
+		fmt.Sprint(orderRecord.Packet.Timestamp().UnixMicro() - sublogger.startTime),
 		orderRecord.From,
 		orderRecord.To,
 		fmt.Sprint(orderRecord.Packet.Id()),

backend/pkg/logger/protection/logger.go

@@ -26,6 +26,8 @@ type Logger struct {
 	saveFiles map[abstraction.BoardId]*file.CSV
 	// BoardNames is a map that contains the common name of each board
 	boardNames map[abstraction.BoardId]string
+	// save the starting time of the logger in Unix microseconds in order to log relative timestamps
+	startTime int64
 }
 
 // Record is a struct that implements the abstraction.LoggerRecord interface
@@ -45,6 +47,7 @@ func NewLogger(boardMap map[abstraction.BoardId]string) *Logger {
 		fileLock:   &sync.Mutex{},
 		saveFiles:  make(map[abstraction.BoardId]*file.CSV),
 		boardNames: boardMap,
+		startTime:  0,
 	}
 }
 
@@ -54,6 +57,8 @@ func (sublogger *Logger) Start() error {
 		return nil
 	}
 
+	sublogger.startTime = time.Now().UnixMicro() // Update the start time
+
 	fmt.Println("Logger started")
 	return nil
 }
@@ -82,7 +87,7 @@ func (sublogger *Logger) PushRecord(record abstraction.LoggerRecord) error {
 	}
 
 	err = saveFile.Write([]string{
-		fmt.Sprint(infoRecord.Timestamp.UnixMicro()),
+		fmt.Sprint(infoRecord.Timestamp.UnixMicro() - sublogger.startTime),
 		infoRecord.From,
 		infoRecord.To,
 		fmt.Sprint(infoRecord.Packet.Id()),