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

fix(backend): fixed bug in db saver (ee)

Browse source
This commit is contained in:
Alexander Zavorotynskiy 2022-09-01 08:40:01 +02:00
parent 6a956da100
commit 1ff51c44cb
2 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
ee/backend/internal/db/datasaver/saver.go
View file

@ -3,13 +3,15 @@ package datasaver
import (
"openreplay/backend/pkg/db/cache"
"openreplay/backend/pkg/db/clickhouse"
"openreplay/backend/pkg/queue/types"
)
type Saver struct {
pg *cache.PGCache
ch clickhouse.Connector
pg *cache.PGCache
ch clickhouse.Connector
producer types.Producer
}
func New(pg *cache.PGCache) *Saver {
return &Saver{pg: pg}
func New(pg *cache.PGCache, producer types.Producer) *Saver {
return &Saver{pg: pg, producer: producer}
}

2
ee/backend/internal/db/datasaver/stats.go
View file

@ -25,10 +25,8 @@ func (si *Saver) InsertStats(session *types.Session, msg messages.Message) error
switch m := msg.(type) {
// Web
case *messages.SessionEnd:
// TODO: get issue_types and base_referrer before session end
return si.ch.InsertWebSession(session)
case *messages.PerformanceTrackAggr:
// TODO: page_path
return si.ch.InsertWebPerformanceTrackAggr(session, m)
case *messages.ClickEvent:
return si.ch.InsertWebClickEvent(session, m)