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

refactor(backend-messages):predefined TypeID() on message type

Browse source
This commit is contained in:
Alex Kaminskii 2022-05-07 23:19:49 +02:00
parent e4d45e88f9
commit 71d50e5a44
6 changed files with 547 additions and 203 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
backend/pkg/messages/filters.go
View file

@ -1,10 +1,10 @@
// Auto-generated, do not edit
package messages
func IsReplayerType(id uint64) bool {
func IsReplayerType(id int) bool {
return 0 == id || 2 == id || 4 == id || 5 == id || 6 == id || 7 == id || 8 == id || 9 == id || 10 == id || 11 == id || 12 == id || 13 == id || 14 == id || 15 == id || 16 == id || 18 == id || 19 == id || 20 == id || 22 == id || 37 == id || 38 == id || 39 == id || 40 == id || 41 == id || 44 == id || 45 == id || 46 == id || 47 == id || 48 == id || 49 == id || 54 == id || 55 == id || 59 == id || 69 == id || 70 == id || 90 == id || 93 == id || 96 == id || 100 == id || 102 == id || 103 == id || 105 == id
}
func IsIOSType(id uint64) bool {
func IsIOSType(id int) bool {
return 107 == id || 90 == id || 91 == id || 92 == id || 93 == id || 94 == id || 95 == id || 96 == id || 97 == id || 98 == id || 99 == id || 100 == id || 101 == id || 102 == id || 103 == id || 104 == id || 105 == id || 110 == id || 111 == id
}

3
backend/pkg/messages/legacy-message-transform.go
View file

@ -3,10 +3,7 @@ package messages
func transformDeprecated(msg Message) Message {
switch m := msg.(type) {
case *MouseClickDepricated:
meta := m.Meta()
meta.TypeID = 33
return &MouseClick{
meta: meta,
ID: m.ID,
HesitationTime: m.HesitationTime,
Label: m.Label,

16
backend/pkg/messages/message.go Normal file
View file

@ -0,0 +1,16 @@
package messages
type message struct {
Timestamp int64
Index uint64
}
func (m *message) Meta() *message {
return m
}
type Message interface {
Encode() []byte
TypeID() int
Meta() *message
}

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

File diff suppressed because it is too large Load diff

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

@ -14,7 +14,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
switch t {
case 80:
msg := &BatchMeta{meta: &meta{TypeID: 80}}
msg := &BatchMeta{}
if msg.PageNo, err = ReadUint(reader); err != nil {
return nil, err
}
@ -27,14 +27,14 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 0:
msg := &Timestamp{meta: &meta{TypeID: 0}}
msg := &Timestamp{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}
return msg, nil
case 1:
msg := &SessionStart{meta: &meta{TypeID: 1}}
msg := &SessionStart{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}
@ -86,21 +86,21 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 2:
msg := &SessionDisconnect{meta: &meta{TypeID: 2}}
msg := &SessionDisconnect{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}
return msg, nil
case 3:
msg := &SessionEnd{meta: &meta{TypeID: 3}}
msg := &SessionEnd{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}
return msg, nil
case 4:
msg := &SetPageLocation{meta: &meta{TypeID: 4}}
msg := &SetPageLocation{}
if msg.URL, err = ReadString(reader); err != nil {
return nil, err
}
@ -113,7 +113,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 5:
msg := &SetViewportSize{meta: &meta{TypeID: 5}}
msg := &SetViewportSize{}
if msg.Width, err = ReadUint(reader); err != nil {
return nil, err
}
@ -123,7 +123,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 6:
msg := &SetViewportScroll{meta: &meta{TypeID: 6}}
msg := &SetViewportScroll{}
if msg.X, err = ReadInt(reader); err != nil {
return nil, err
}
@ -133,12 +133,12 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 7:
msg := &CreateDocument{meta: &meta{TypeID: 7}}
msg := &CreateDocument{}
return msg, nil
case 8:
msg := &CreateElementNode{meta: &meta{TypeID: 8}}
msg := &CreateElementNode{}
if msg.ID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -157,7 +157,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 9:
msg := &CreateTextNode{meta: &meta{TypeID: 9}}
msg := &CreateTextNode{}
if msg.ID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -170,7 +170,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 10:
msg := &MoveNode{meta: &meta{TypeID: 10}}
msg := &MoveNode{}
if msg.ID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -183,14 +183,14 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 11:
msg := &RemoveNode{meta: &meta{TypeID: 11}}
msg := &RemoveNode{}
if msg.ID, err = ReadUint(reader); err != nil {
return nil, err
}
return msg, nil
case 12:
msg := &SetNodeAttribute{meta: &meta{TypeID: 12}}
msg := &SetNodeAttribute{}
if msg.ID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -203,7 +203,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 13:
msg := &RemoveNodeAttribute{meta: &meta{TypeID: 13}}
msg := &RemoveNodeAttribute{}
if msg.ID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -213,7 +213,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 14:
msg := &SetNodeData{meta: &meta{TypeID: 14}}
msg := &SetNodeData{}
if msg.ID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -223,7 +223,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 15:
msg := &SetCSSData{meta: &meta{TypeID: 15}}
msg := &SetCSSData{}
if msg.ID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -233,7 +233,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 16:
msg := &SetNodeScroll{meta: &meta{TypeID: 16}}
msg := &SetNodeScroll{}
if msg.ID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -246,7 +246,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 17:
msg := &SetInputTarget{meta: &meta{TypeID: 17}}
msg := &SetInputTarget{}
if msg.ID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -256,7 +256,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 18:
msg := &SetInputValue{meta: &meta{TypeID: 18}}
msg := &SetInputValue{}
if msg.ID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -269,7 +269,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 19:
msg := &SetInputChecked{meta: &meta{TypeID: 19}}
msg := &SetInputChecked{}
if msg.ID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -279,7 +279,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 20:
msg := &MouseMove{meta: &meta{TypeID: 20}}
msg := &MouseMove{}
if msg.X, err = ReadUint(reader); err != nil {
return nil, err
}
@ -289,7 +289,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 21:
msg := &MouseClickDepricated{meta: &meta{TypeID: 21}}
msg := &MouseClickDepricated{}
if msg.ID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -302,7 +302,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 22:
msg := &ConsoleLog{meta: &meta{TypeID: 22}}
msg := &ConsoleLog{}
if msg.Level, err = ReadString(reader); err != nil {
return nil, err
}
@ -312,7 +312,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 23:
msg := &PageLoadTiming{meta: &meta{TypeID: 23}}
msg := &PageLoadTiming{}
if msg.RequestStart, err = ReadUint(reader); err != nil {
return nil, err
}
@ -343,7 +343,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 24:
msg := &PageRenderTiming{meta: &meta{TypeID: 24}}
msg := &PageRenderTiming{}
if msg.SpeedIndex, err = ReadUint(reader); err != nil {
return nil, err
}
@ -356,7 +356,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 25:
msg := &JSException{meta: &meta{TypeID: 25}}
msg := &JSException{}
if msg.Name, err = ReadString(reader); err != nil {
return nil, err
}
@ -369,7 +369,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 26:
msg := &RawErrorEvent{meta: &meta{TypeID: 26}}
msg := &RawErrorEvent{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}
@ -388,7 +388,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 27:
msg := &RawCustomEvent{meta: &meta{TypeID: 27}}
msg := &RawCustomEvent{}
if msg.Name, err = ReadString(reader); err != nil {
return nil, err
}
@ -398,21 +398,21 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 28:
msg := &UserID{meta: &meta{TypeID: 28}}
msg := &UserID{}
if msg.ID, err = ReadString(reader); err != nil {
return nil, err
}
return msg, nil
case 29:
msg := &UserAnonymousID{meta: &meta{TypeID: 29}}
msg := &UserAnonymousID{}
if msg.ID, err = ReadString(reader); err != nil {
return nil, err
}
return msg, nil
case 30:
msg := &Metadata{meta: &meta{TypeID: 30}}
msg := &Metadata{}
if msg.Key, err = ReadString(reader); err != nil {
return nil, err
}
@ -422,7 +422,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 31:
msg := &PageEvent{meta: &meta{TypeID: 31}}
msg := &PageEvent{}
if msg.MessageID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -477,7 +477,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 32:
msg := &InputEvent{meta: &meta{TypeID: 32}}
msg := &InputEvent{}
if msg.MessageID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -496,7 +496,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 33:
msg := &ClickEvent{meta: &meta{TypeID: 33}}
msg := &ClickEvent{}
if msg.MessageID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -515,7 +515,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 34:
msg := &ErrorEvent{meta: &meta{TypeID: 34}}
msg := &ErrorEvent{}
if msg.MessageID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -537,7 +537,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 35:
msg := &ResourceEvent{meta: &meta{TypeID: 35}}
msg := &ResourceEvent{}
if msg.MessageID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -577,7 +577,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 36:
msg := &CustomEvent{meta: &meta{TypeID: 36}}
msg := &CustomEvent{}
if msg.MessageID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -593,7 +593,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 37:
msg := &CSSInsertRule{meta: &meta{TypeID: 37}}
msg := &CSSInsertRule{}
if msg.ID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -606,7 +606,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 38:
msg := &CSSDeleteRule{meta: &meta{TypeID: 38}}
msg := &CSSDeleteRule{}
if msg.ID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -616,7 +616,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 39:
msg := &Fetch{meta: &meta{TypeID: 39}}
msg := &Fetch{}
if msg.Method, err = ReadString(reader); err != nil {
return nil, err
}
@ -641,7 +641,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 40:
msg := &Profiler{meta: &meta{TypeID: 40}}
msg := &Profiler{}
if msg.Name, err = ReadString(reader); err != nil {
return nil, err
}
@ -657,7 +657,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 41:
msg := &OTable{meta: &meta{TypeID: 41}}
msg := &OTable{}
if msg.Key, err = ReadString(reader); err != nil {
return nil, err
}
@ -667,14 +667,14 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 42:
msg := &StateAction{meta: &meta{TypeID: 42}}
msg := &StateAction{}
if msg.Type, err = ReadString(reader); err != nil {
return nil, err
}
return msg, nil
case 43:
msg := &StateActionEvent{meta: &meta{TypeID: 43}}
msg := &StateActionEvent{}
if msg.MessageID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -687,7 +687,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 44:
msg := &Redux{meta: &meta{TypeID: 44}}
msg := &Redux{}
if msg.Action, err = ReadString(reader); err != nil {
return nil, err
}
@ -700,7 +700,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 45:
msg := &Vuex{meta: &meta{TypeID: 45}}
msg := &Vuex{}
if msg.Mutation, err = ReadString(reader); err != nil {
return nil, err
}
@ -710,7 +710,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 46:
msg := &MobX{meta: &meta{TypeID: 46}}
msg := &MobX{}
if msg.Type, err = ReadString(reader); err != nil {
return nil, err
}
@ -720,7 +720,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 47:
msg := &NgRx{meta: &meta{TypeID: 47}}
msg := &NgRx{}
if msg.Action, err = ReadString(reader); err != nil {
return nil, err
}
@ -733,7 +733,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 48:
msg := &GraphQL{meta: &meta{TypeID: 48}}
msg := &GraphQL{}
if msg.OperationKind, err = ReadString(reader); err != nil {
return nil, err
}
@ -749,7 +749,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 49:
msg := &PerformanceTrack{meta: &meta{TypeID: 49}}
msg := &PerformanceTrack{}
if msg.Frames, err = ReadInt(reader); err != nil {
return nil, err
}
@ -765,7 +765,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 50:
msg := &GraphQLEvent{meta: &meta{TypeID: 50}}
msg := &GraphQLEvent{}
if msg.MessageID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -787,7 +787,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 51:
msg := &FetchEvent{meta: &meta{TypeID: 51}}
msg := &FetchEvent{}
if msg.MessageID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -815,14 +815,14 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 52:
msg := &DOMDrop{meta: &meta{TypeID: 52}}
msg := &DOMDrop{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}
return msg, nil
case 53:
msg := &ResourceTiming{meta: &meta{TypeID: 53}}
msg := &ResourceTiming{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}
@ -850,7 +850,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 54:
msg := &ConnectionInformation{meta: &meta{TypeID: 54}}
msg := &ConnectionInformation{}
if msg.Downlink, err = ReadUint(reader); err != nil {
return nil, err
}
@ -860,14 +860,14 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 55:
msg := &SetPageVisibility{meta: &meta{TypeID: 55}}
msg := &SetPageVisibility{}
if msg.hidden, err = ReadBoolean(reader); err != nil {
return nil, err
}
return msg, nil
case 56:
msg := &PerformanceTrackAggr{meta: &meta{TypeID: 56}}
msg := &PerformanceTrackAggr{}
if msg.TimestampStart, err = ReadUint(reader); err != nil {
return nil, err
}
@ -913,7 +913,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 59:
msg := &LongTask{meta: &meta{TypeID: 59}}
msg := &LongTask{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}
@ -938,7 +938,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 60:
msg := &SetNodeAttributeURLBased{meta: &meta{TypeID: 60}}
msg := &SetNodeAttributeURLBased{}
if msg.ID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -954,7 +954,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 61:
msg := &SetCSSDataURLBased{meta: &meta{TypeID: 61}}
msg := &SetCSSDataURLBased{}
if msg.ID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -967,7 +967,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 62:
msg := &IssueEvent{meta: &meta{TypeID: 62}}
msg := &IssueEvent{}
if msg.MessageID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -989,7 +989,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 63:
msg := &TechnicalInfo{meta: &meta{TypeID: 63}}
msg := &TechnicalInfo{}
if msg.Type, err = ReadString(reader); err != nil {
return nil, err
}
@ -999,7 +999,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 64:
msg := &CustomIssue{meta: &meta{TypeID: 64}}
msg := &CustomIssue{}
if msg.Name, err = ReadString(reader); err != nil {
return nil, err
}
@ -1009,19 +1009,19 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 65:
msg := &PageClose{meta: &meta{TypeID: 65}}
msg := &PageClose{}
return msg, nil
case 66:
msg := &AssetCache{meta: &meta{TypeID: 66}}
msg := &AssetCache{}
if msg.URL, err = ReadString(reader); err != nil {
return nil, err
}
return msg, nil
case 67:
msg := &CSSInsertRuleURLBased{meta: &meta{TypeID: 67}}
msg := &CSSInsertRuleURLBased{}
if msg.ID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -1037,7 +1037,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 69:
msg := &MouseClick{meta: &meta{TypeID: 69}}
msg := &MouseClick{}
if msg.ID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -1053,7 +1053,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 70:
msg := &CreateIFrameDocument{meta: &meta{TypeID: 70}}
msg := &CreateIFrameDocument{}
if msg.FrameID, err = ReadUint(reader); err != nil {
return nil, err
}
@ -1063,7 +1063,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 107:
msg := &IOSBatchMeta{meta: &meta{TypeID: 107}}
msg := &IOSBatchMeta{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}
@ -1076,7 +1076,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 90:
msg := &IOSSessionStart{meta: &meta{TypeID: 90}}
msg := &IOSSessionStart{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}
@ -1110,14 +1110,14 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 91:
msg := &IOSSessionEnd{meta: &meta{TypeID: 91}}
msg := &IOSSessionEnd{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}
return msg, nil
case 92:
msg := &IOSMetadata{meta: &meta{TypeID: 92}}
msg := &IOSMetadata{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}
@ -1133,7 +1133,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 93:
msg := &IOSCustomEvent{meta: &meta{TypeID: 93}}
msg := &IOSCustomEvent{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}
@ -1149,7 +1149,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 94:
msg := &IOSUserID{meta: &meta{TypeID: 94}}
msg := &IOSUserID{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}
@ -1162,7 +1162,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 95:
msg := &IOSUserAnonymousID{meta: &meta{TypeID: 95}}
msg := &IOSUserAnonymousID{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}
@ -1175,7 +1175,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 96:
msg := &IOSScreenChanges{meta: &meta{TypeID: 96}}
msg := &IOSScreenChanges{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}
@ -1197,7 +1197,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 97:
msg := &IOSCrash{meta: &meta{TypeID: 97}}
msg := &IOSCrash{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}
@ -1216,7 +1216,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 98:
msg := &IOSScreenEnter{meta: &meta{TypeID: 98}}
msg := &IOSScreenEnter{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}
@ -1232,7 +1232,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 99:
msg := &IOSScreenLeave{meta: &meta{TypeID: 99}}
msg := &IOSScreenLeave{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}
@ -1248,7 +1248,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 100:
msg := &IOSClickEvent{meta: &meta{TypeID: 100}}
msg := &IOSClickEvent{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}
@ -1267,7 +1267,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 101:
msg := &IOSInputEvent{meta: &meta{TypeID: 101}}
msg := &IOSInputEvent{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}
@ -1286,7 +1286,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 102:
msg := &IOSPerformanceEvent{meta: &meta{TypeID: 102}}
msg := &IOSPerformanceEvent{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}
@ -1302,7 +1302,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 103:
msg := &IOSLog{meta: &meta{TypeID: 103}}
msg := &IOSLog{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}
@ -1318,7 +1318,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 104:
msg := &IOSInternalError{meta: &meta{TypeID: 104}}
msg := &IOSInternalError{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}
@ -1331,7 +1331,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 105:
msg := &IOSNetworkCall{meta: &meta{TypeID: 105}}
msg := &IOSNetworkCall{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}
@ -1362,7 +1362,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 110:
msg := &IOSPerformanceAggregated{meta: &meta{TypeID: 110}}
msg := &IOSPerformanceAggregated{}
if msg.TimestampStart, err = ReadUint(reader); err != nil {
return nil, err
}
@ -1408,7 +1408,7 @@ func ReadMessage(reader io.Reader) (Message, error) {
return msg, nil
case 111:
msg := &IOSIssueEvent{meta: &meta{TypeID: 111}}
msg := &IOSIssueEvent{}
if msg.Timestamp, err = ReadUint(reader); err != nil {
return nil, err
}

7
backend/services/sink/main.go
View file

@ -34,12 +34,7 @@ func main() {
env.String("TOPIC_RAW_IOS"),
},
func(sessionID uint64, message Message, _ *types.Meta) {
//typeID, err := GetMessageTypeID(value)
// if err != nil {
// log.Printf("Message type decoding error: %v", err)
// return
// }
typeID := message.Meta().TypeID
typeID := message.TypeID()
if !IsReplayerType(typeID) {
return
}