jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(backend/db): fixed loss of sessions

Browse source
This commit is contained in:
Alexander Zavorotynskiy 2022-06-07 13:44:20 +02:00
parent 4f8c4358f8
commit 7678e9d056
1 changed files with 8 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
backend/cmd/db/main.go
View file

@ -51,15 +51,6 @@ func main() {
handler := func(sessionID uint64, msg messages.Message, meta *types.Meta) {
statsLogger.Collect(sessionID, meta)
// Check if session in db and get session info for the following stats insertion (actually for CH case only)
session, err := pg.GetSession(sessionID)
if session == nil {
if err != nil {
log.Printf("Error on session retrieving from cache: %v, SessionID: %v, Message: %v", err, sessionID, msg)
}
return
}
// Just save session data into db without additional checks
if err := saver.InsertMessage(sessionID, msg); err != nil {
if !postgres.IsPkeyViolation(err) {
@ -68,6 +59,14 @@ func main() {
return
}
session, err := pg.GetSession(sessionID)
if session == nil {
if err != nil {
log.Printf("Error on session retrieving from cache: %v, SessionID: %v, Message: %v", err, sessionID, msg)
}
return
}
// Save statistics to db
err = saver.InsertStats(session, msg)
if err != nil {