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

feat(backend/db): send metadata directly to db (removed from batches) (#544)

Browse source 
Co-authored-by: Alexander Zavorotynskiy <alexander@openreplay.com>
This commit is contained in:
Rajesh Rajendran 2022-06-17 11:03:40 +00:00 • committed by GitHub
parent 449890320e
commit 270e9ca46a
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
backend/pkg/db/postgres/messages-common.go
View file

@ -155,12 +155,11 @@ func (conn *Conn) InsertUserAnonymousID(sessionID uint64, userAnonymousID string
}
func (conn *Conn) InsertMetadata(sessionID uint64, keyNo uint, value string) error {
return conn.batchQueue(sessionID, fmt.Sprintf(`
return conn.exec(fmt.Sprintf(`
UPDATE sessions SET metadata_%v = $1
WHERE session_id = $2`, keyNo),
value, sessionID,
)
// conn.insertAutocompleteValue(sessionID, "METADATA", value)
}
func (conn *Conn) InsertIssueEvent(sessionID uint64, projectID uint32, e *messages.IssueEvent) error {

6
backend/services/db/messages.go
View file

@ -1,6 +1,7 @@
package main
import (
"fmt"
. "openreplay/backend/pkg/messages"
)
@ -8,7 +9,10 @@ func insertMessage(sessionID uint64, msg Message) error {
switch m := msg.(type) {
// Common
case *Metadata:
return pg.InsertMetadata(sessionID, m)
if err := pg.InsertMetadata(sessionID, m); err != nil {
return fmt.Errorf("insert metadata err: %s", err)
}
return nil
case *IssueEvent:
return pg.InsertIssueEvent(sessionID, m)
//TODO: message adapter (transformer) (at the level of pkg/message) for types: