From 2dc8af998cb97944bca1507eb9095b13dbf5c1e4 Mon Sep 17 00:00:00 2001 From: Alexander Zavorotynskiy Date: Wed, 30 Nov 2022 17:44:35 +0100 Subject: [PATCH] feat(backend/ender): remove from memory sessions with wrong duration --- backend/cmd/ender/main.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/backend/cmd/ender/main.go b/backend/cmd/ender/main.go index beb69bd42..2ebf15fc4 100644 --- a/backend/cmd/ender/main.go +++ b/backend/cmd/ender/main.go @@ -5,6 +5,7 @@ import ( "openreplay/backend/internal/storage" "os" "os/signal" + "strings" "syscall" "time" @@ -72,6 +73,10 @@ func main() { newDuration, err := pg.InsertSessionEnd(sessionID, msg.Timestamp) if err != nil { log.Printf("can't save sessionEnd to database, sessID: %d, err: %s", sessionID, err) + if strings.Contains(err.Error(), "integer out of range") { + // Skip message with broken duration + return true + } return false } if currDuration == newDuration {