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

style(backend): rename RawErrorEvent to IntegrationEvent

Browse source
This commit is contained in:
Alex Kaminskii 2022-06-24 16:32:46 +02:00
parent 3259c6667a
commit 4e439354c3
15 changed files with 19 additions and 19 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
backend/cmd/ender/main.go
View file

@ -50,7 +50,7 @@ func main() {
},
func(sessionID uint64, msg messages.Message, meta *types.Meta) {
switch msg.(type) {
case *messages.SessionStart, *messages.SessionEnd, *messages.RawErrorEvent:
case *messages.SessionStart, *messages.SessionEnd:
// Skip several message types
return
}

4
backend/cmd/integrations/main.go
View file

@ -74,7 +74,7 @@ func main() {
log.Printf("Requesting all...\n")
manager.RequestAll()
case event := <-manager.Events:
log.Printf("New integration event: %+v\n", *event.RawErrorEvent)
log.Printf("New integration event: %+v\n", *event.IntegrationEvent)
sessionID := event.SessionID
if sessionID == 0 {
sessData, err := tokenizer.Parse(event.Token)
@ -85,7 +85,7 @@ func main() {
sessionID = sessData.ID
}
// TODO: send to ready-events topic. Otherwise it have to go through the events worker.
producer.Produce(cfg.TopicRawWeb, sessionID, messages.Encode(event.RawErrorEvent))
producer.Produce(cfg.TopicRawWeb, sessionID, messages.Encode(event.IntegrationEvent))
case err := <-manager.Errors:
log.Printf("Integration error: %v\n", err)
case i := <-manager.RequestDataUpdates:

2
backend/internal/db/datasaver/messages.go
View file

@ -66,7 +66,7 @@ func (mi *Saver) InsertMessage(sessionID uint64, msg Message) error {
case *IOSCrash:
return mi.pg.InsertIOSCrash(sessionID, m)
case *RawErrorEvent:
case *IntegrationEvent:
return mi.pg.InsertWebErrorEvent(sessionID, &ErrorEvent{
MessageID: m.Meta().Index, // TODO: is it possible to catch panic here???
Timestamp: m.Timestamp,

2
backend/internal/integrations/integration/bugsnag.go
View file

@ -97,7 +97,7 @@ func (b *bugsnag) Request(c *client) error {
c.evChan <- &SessionErrorEvent{
SessionID: sessionID,
Token: token,
RawErrorEvent: &messages.RawErrorEvent{
IntegrationEvent: &messages.IntegrationEvent{
Source: "bugsnag",
Timestamp: timestamp,
Name: e.Exceptions[0].Message,

2
backend/internal/integrations/integration/client.go
View file

@ -40,7 +40,7 @@ type client struct {
type SessionErrorEvent struct {
SessionID uint64
Token string
*messages.RawErrorEvent
*messages.IntegrationEvent
}
type ClientMap map[string]*client

2
backend/internal/integrations/integration/cloudwatch.go
View file

@ -68,7 +68,7 @@ func (cw *cloudwatch) Request(c *client) error {
c.evChan <- &SessionErrorEvent{
//SessionID: sessionID,
Token: token,
RawErrorEvent: &messages.RawErrorEvent{
IntegrationEvent: &messages.IntegrationEvent{
Source: "cloudwatch",
Timestamp: timestamp, // e.IngestionTime ??
Name: name,

2
backend/internal/integrations/integration/datadog.go
View file

@ -115,7 +115,7 @@ func (d *datadog) Request(c *client) error {
c.evChan <- &SessionErrorEvent{
//SessionID: sessionID,
Token: token,
RawErrorEvent: &messages.RawErrorEvent{
IntegrationEvent: &messages.IntegrationEvent{
Source: "datadog",
Timestamp: timestamp,
Name: ddLog.Content.Attributes.Error.Message,

2
backend/internal/integrations/integration/elasticsearch.go
View file

@ -181,7 +181,7 @@ func (es *elasticsearch) Request(c *client) error {
//SessionID: sessionID,
SessionID: sessionID,
Token: token,
RawErrorEvent: &messages.RawErrorEvent{
IntegrationEvent: &messages.IntegrationEvent{
Source: "elasticsearch",
Timestamp: timestamp,
Name: fmt.Sprintf("%v", docID),

2
backend/internal/integrations/integration/newrelic.go
View file

@ -89,7 +89,7 @@ func (nr *newrelic) Request(c *client) error {
c.setLastMessageTimestamp(e.Timestamp)
c.evChan <- &SessionErrorEvent{
Token: e.OpenReplaySessionToken,
RawErrorEvent: &messages.RawErrorEvent{
IntegrationEvent: &messages.IntegrationEvent{
Source: "newrelic",
Timestamp: e.Timestamp,
Name: e.ErrorClass,

2
backend/internal/integrations/integration/rollbar.go
View file

@ -156,7 +156,7 @@ func (rb *rollbar) Request(c *client) error {
c.setLastMessageTimestamp(timestamp)
c.evChan <- &SessionErrorEvent{
Token: e["body.message.openReplaySessionToken"],
RawErrorEvent: &messages.RawErrorEvent{
IntegrationEvent: &messages.IntegrationEvent{
Source: "rollbar",
Timestamp: timestamp,
Name: e["item.title"],

2
backend/internal/integrations/integration/sentry.go
View file

@ -115,7 +115,7 @@ PageLoop:
c.evChan <- &SessionErrorEvent{
SessionID: sessionID,
Token: token,
RawErrorEvent: &messages.RawErrorEvent{
IntegrationEvent: &messages.IntegrationEvent{
Source: "sentry",
Timestamp: timestamp,
Name: e.Title,

2
backend/internal/integrations/integration/stackdriver.go
View file

@ -89,7 +89,7 @@ func (sd *stackdriver) Request(c *client) error {
c.evChan <- &SessionErrorEvent{
//SessionID: sessionID,
Token: token,
RawErrorEvent: &messages.RawErrorEvent{
IntegrationEvent: &messages.IntegrationEvent{
Source: "stackdriver",
Timestamp: timestamp,
Name: e.InsertID, // not sure about that

2
backend/internal/integrations/integration/sumologic.go
View file

@ -193,7 +193,7 @@ func (sl *sumologic) Request(c *client) error {
c.evChan <- &SessionErrorEvent{
//SessionID: sessionID,
Token: token,
RawErrorEvent: &messages.RawErrorEvent{
IntegrationEvent: &messages.IntegrationEvent{
Source: "sumologic",
Timestamp: e.Timestamp,
Name: name,

8
backend/pkg/messages/messages.go
View file

@ -571,7 +571,7 @@ func (msg *JSException) TypeID() int {
return 25
}
type RawErrorEvent struct {
type IntegrationEvent struct {
message
Timestamp uint64
Source string
@ -580,7 +580,7 @@ type RawErrorEvent struct {
Payload string
}
func (msg *RawErrorEvent) Encode() []byte {
func (msg *IntegrationEvent) Encode() []byte {
buf := make([]byte, 51+len(msg.Source)+len(msg.Name)+len(msg.Message)+len(msg.Payload))
buf[0] = 26
p := 1
@ -592,7 +592,7 @@ func (msg *RawErrorEvent) Encode() []byte {
return buf[:p]
}
func (msg *RawErrorEvent) TypeID() int {
func (msg *IntegrationEvent) TypeID() int {
return 26
}
@ -1396,7 +1396,7 @@ type IssueEvent struct {
Type string
ContextString string
Context string
Payload string // TODO: check, maybe it's better to use empty interface here
Payload string
}
func (msg *IssueEvent) Encode() []byte {

2
backend/pkg/messages/read-message.go
View file

@ -369,7 +369,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 26:
msg := &RawErrorEvent{}
msg := &IntegrationEvent{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}