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

feat(connector): fixed several release bugs

Browse source
This commit is contained in:
Alexander 2025-03-13 12:28:23 +01:00
parent fb49c715cb
commit 8acee7d357
2 changed files with 12 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
ee/backend/cmd/connector/main.go
View file

@ -11,6 +11,8 @@ import (
"openreplay/backend/pkg/logger"
"openreplay/backend/pkg/memory"
"openreplay/backend/pkg/messages"
"openreplay/backend/pkg/metrics"
"openreplay/backend/pkg/metrics/database"
"openreplay/backend/pkg/objectstorage/store"
"openreplay/backend/pkg/projects"
"openreplay/backend/pkg/queue"
@ -22,6 +24,9 @@ func main() {
ctx := context.Background()
log := logger.New()
cfg := config.New(log)
// Observability
dbMetrics := database.New("connector")
metrics.New(log, dbMetrics.List())
objStore, err := store.NewStore(&cfg.ObjectsConfig)
if err != nil {
@ -56,7 +61,7 @@ func main() {
defer db.Close()
// Init postgres connection
pgConn, err := pool.New(cfg.Postgres.String())
pgConn, err := pool.New(dbMetrics, cfg.Postgres.String())
if err != nil {
log.Fatal(ctx, "can't init postgres connection: %s", err)
}
@ -69,10 +74,8 @@ func main() {
}
defer redisClient.Close()
projManager := projects.New(log, pgConn, redisClient)
sessManager := sessions.New(log, pgConn, projManager, redisClient)
// Saves messages to Redshift
projManager := projects.New(log, pgConn, redisClient, dbMetrics)
sessManager := sessions.New(log, pgConn, projManager, redisClient, dbMetrics)
dataSaver := saver.New(log, cfg, db, sessManager, projManager)
// Message filter
@ -80,8 +83,7 @@ func main() {
messages.MsgNetworkRequest, messages.MsgIssueEvent, messages.MsgCustomIssue,
messages.MsgSessionStart, messages.MsgSessionEnd, messages.MsgConnectionInformation,
messages.MsgMetadata, messages.MsgPageEvent, messages.MsgPerformanceTrackAggr, messages.MsgUserID,
messages.MsgUserAnonymousID, messages.MsgJSException, messages.MsgJSExceptionDeprecated,
messages.MsgInputEvent, messages.MsgMouseClick, messages.MsgIssueEventDeprecated,
messages.MsgUserAnonymousID, messages.MsgJSException, messages.MsgInputEvent, messages.MsgMouseClick,
// Mobile messages
messages.MsgMobileSessionStart, messages.MsgMobileSessionEnd, messages.MsgMobileUserID, messages.MsgMobileUserAnonymousID,
messages.MsgMobileMetadata, messages.MsgMobileEvent, messages.MsgMobileNetworkCall,

7
ee/backend/pkg/connector/saver.go
View file

@ -269,8 +269,7 @@ func (s *Saver) handleSession(msg messages.Message) {
switch msg.(type) {
case *messages.SessionStart, *messages.SessionEnd, *messages.ConnectionInformation, *messages.Metadata,
*messages.PageEvent, *messages.PerformanceTrackAggr, *messages.UserID, *messages.UserAnonymousID,
*messages.JSException, *messages.JSExceptionDeprecated, *messages.InputEvent, *messages.MouseClick,
*messages.IssueEvent, *messages.IssueEventDeprecated,
*messages.JSException, *messages.InputEvent, *messages.MouseClick, *messages.IssueEvent,
// Mobile messages
*messages.MobileSessionStart, *messages.MobileSessionEnd, *messages.MobileUserID, *messages.MobileUserAnonymousID,
*messages.MobileMetadata:
@ -369,7 +368,7 @@ func (s *Saver) handleSession(msg messages.Message) {
}
case *messages.UserAnonymousID:
sess["user_anonymous_id"] = QUOTES(m.ID)
case *messages.JSException, *messages.JSExceptionDeprecated:
case *messages.JSException:
currExceptionsCount, err := strconv.Atoi(sess["js_exceptions_count"])
if err != nil {
currExceptionsCount = 0
@ -387,7 +386,7 @@ func (s *Saver) handleSession(msg messages.Message) {
currMouseClicksCount = 0
}
sess["clicks_count"] = fmt.Sprintf("%d", currMouseClicksCount+1)
case *messages.IssueEvent, *messages.IssueEventDeprecated:
case *messages.IssueEvent:
currIssuesCount, err := strconv.Atoi(sess["issues_count"])
if err != nil {
currIssuesCount = 0