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

feat(backend): fixed missed session cache layer for some db methods

Browse source
This commit is contained in:
Alexander Zavorotynskiy 2023-01-20 14:43:56 +01:00
parent b620eb5e10
commit 6d557cd053
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
ee/backend/internal/db/datasaver/messages.go
View file

@ -16,7 +16,7 @@ func (mi *Saver) InsertMessage(msg Message) error {
}
return nil
case *IssueEvent:
session, err := mi.pg.GetSession(sessionID)
session, err := mi.pg.Cache.GetSession(sessionID)
if err != nil {
log.Printf("can't get session info for CH: %s", err)
} else {
@ -37,7 +37,7 @@ func (mi *Saver) InsertMessage(msg Message) error {
case *UserAnonymousID:
return mi.pg.InsertWebUserAnonymousID(sessionID, m)
case *CustomEvent:
session, err := mi.pg.GetSession(sessionID)
session, err := mi.pg.Cache.GetSession(sessionID)
if err != nil {
log.Printf("can't get session info for CH: %s", err)
} else {
@ -59,7 +59,7 @@ func (mi *Saver) InsertMessage(msg Message) error {
case *IntegrationEvent:
return mi.pg.InsertWebIntegrationEvent(m)
case *NetworkRequest:
session, err := mi.pg.GetSession(sessionID)
session, err := mi.pg.Cache.GetSession(sessionID)
if err != nil {
log.Printf("can't get session info for CH: %s", err)
} else {
@ -74,7 +74,7 @@ func (mi *Saver) InsertMessage(msg Message) error {
}
return mi.pg.InsertWebNetworkRequest(sessionID, m)
case *GraphQL:
session, err := mi.pg.GetSession(sessionID)
session, err := mi.pg.Cache.GetSession(sessionID)
if err != nil {
log.Printf("can't get session info for CH: %s", err)
} else {