diff --git a/backend/pkg/messages/filters.go b/backend/pkg/messages/filters.go
index 44b2c7959..a74d49eec 100644
--- a/backend/pkg/messages/filters.go
+++ b/backend/pkg/messages/filters.go
@@ -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
 }
diff --git a/backend/pkg/messages/legacy-message-transform.go b/backend/pkg/messages/legacy-message-transform.go
index 6774d95b1..3a42cdab0 100644
--- a/backend/pkg/messages/legacy-message-transform.go
+++ b/backend/pkg/messages/legacy-message-transform.go
@@ -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,
diff --git a/backend/pkg/messages/message.go b/backend/pkg/messages/message.go
new file mode 100644
index 000000000..d701d474f
--- /dev/null
+++ b/backend/pkg/messages/message.go
@@ -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
+}
diff --git a/backend/pkg/messages/messages.go b/backend/pkg/messages/messages.go
index e9aec5788..82a0f4f97 100644
--- a/backend/pkg/messages/messages.go
+++ b/backend/pkg/messages/messages.go
@@ -1,24 +1,8 @@
 // Auto-generated, do not edit
 package messages
 
-type Message interface {
-	Encode() []byte
-	Meta() *meta
-}
-
-type meta struct {
-	Timestamp int64
-	Index     uint64
-	TypeID    uint64
-}
-
-// Might also implement Encode() here (?)
-func (m *meta) Meta() *meta {
-	return m
-}
-
 type BatchMeta struct {
-	*meta
+	message
 	PageNo     uint64
 	FirstIndex uint64
 	Timestamp  int64
@@ -34,8 +18,12 @@ func (msg *BatchMeta) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *BatchMeta) TypeID() int {
+	return 80
+}
+
 type Timestamp struct {
-	*meta
+	message
 	Timestamp uint64
 }
 
@@ -47,8 +35,12 @@ func (msg *Timestamp) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *Timestamp) TypeID() int {
+	return 0
+}
+
 type SessionStart struct {
-	*meta
+	message
 	Timestamp            uint64
 	ProjectID            uint64
 	TrackerVersion       string
@@ -90,8 +82,12 @@ func (msg *SessionStart) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *SessionStart) TypeID() int {
+	return 1
+}
+
 type SessionDisconnect struct {
-	*meta
+	message
 	Timestamp uint64
 }
 
@@ -103,8 +99,12 @@ func (msg *SessionDisconnect) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *SessionDisconnect) TypeID() int {
+	return 2
+}
+
 type SessionEnd struct {
-	*meta
+	message
 	Timestamp uint64
 }
 
@@ -116,8 +116,12 @@ func (msg *SessionEnd) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *SessionEnd) TypeID() int {
+	return 3
+}
+
 type SetPageLocation struct {
-	*meta
+	message
 	URL             string
 	Referrer        string
 	NavigationStart uint64
@@ -133,8 +137,12 @@ func (msg *SetPageLocation) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *SetPageLocation) TypeID() int {
+	return 4
+}
+
 type SetViewportSize struct {
-	*meta
+	message
 	Width  uint64
 	Height uint64
 }
@@ -148,8 +156,12 @@ func (msg *SetViewportSize) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *SetViewportSize) TypeID() int {
+	return 5
+}
+
 type SetViewportScroll struct {
-	*meta
+	message
 	X int64
 	Y int64
 }
@@ -163,8 +175,12 @@ func (msg *SetViewportScroll) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *SetViewportScroll) TypeID() int {
+	return 6
+}
+
 type CreateDocument struct {
-	*meta
+	message
 }
 
 func (msg *CreateDocument) Encode() []byte {
@@ -175,8 +191,12 @@ func (msg *CreateDocument) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *CreateDocument) TypeID() int {
+	return 7
+}
+
 type CreateElementNode struct {
-	*meta
+	message
 	ID       uint64
 	ParentID uint64
 	index    uint64
@@ -196,8 +216,12 @@ func (msg *CreateElementNode) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *CreateElementNode) TypeID() int {
+	return 8
+}
+
 type CreateTextNode struct {
-	*meta
+	message
 	ID       uint64
 	ParentID uint64
 	Index    uint64
@@ -213,8 +237,12 @@ func (msg *CreateTextNode) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *CreateTextNode) TypeID() int {
+	return 9
+}
+
 type MoveNode struct {
-	*meta
+	message
 	ID       uint64
 	ParentID uint64
 	Index    uint64
@@ -230,8 +258,12 @@ func (msg *MoveNode) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *MoveNode) TypeID() int {
+	return 10
+}
+
 type RemoveNode struct {
-	*meta
+	message
 	ID uint64
 }
 
@@ -243,8 +275,12 @@ func (msg *RemoveNode) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *RemoveNode) TypeID() int {
+	return 11
+}
+
 type SetNodeAttribute struct {
-	*meta
+	message
 	ID    uint64
 	Name  string
 	Value string
@@ -260,8 +296,12 @@ func (msg *SetNodeAttribute) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *SetNodeAttribute) TypeID() int {
+	return 12
+}
+
 type RemoveNodeAttribute struct {
-	*meta
+	message
 	ID   uint64
 	Name string
 }
@@ -275,8 +315,12 @@ func (msg *RemoveNodeAttribute) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *RemoveNodeAttribute) TypeID() int {
+	return 13
+}
+
 type SetNodeData struct {
-	*meta
+	message
 	ID   uint64
 	Data string
 }
@@ -290,8 +334,12 @@ func (msg *SetNodeData) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *SetNodeData) TypeID() int {
+	return 14
+}
+
 type SetCSSData struct {
-	*meta
+	message
 	ID   uint64
 	Data string
 }
@@ -305,8 +353,12 @@ func (msg *SetCSSData) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *SetCSSData) TypeID() int {
+	return 15
+}
+
 type SetNodeScroll struct {
-	*meta
+	message
 	ID uint64
 	X  int64
 	Y  int64
@@ -322,8 +374,12 @@ func (msg *SetNodeScroll) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *SetNodeScroll) TypeID() int {
+	return 16
+}
+
 type SetInputTarget struct {
-	*meta
+	message
 	ID    uint64
 	Label string
 }
@@ -337,8 +393,12 @@ func (msg *SetInputTarget) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *SetInputTarget) TypeID() int {
+	return 17
+}
+
 type SetInputValue struct {
-	*meta
+	message
 	ID    uint64
 	Value string
 	Mask  int64
@@ -354,8 +414,12 @@ func (msg *SetInputValue) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *SetInputValue) TypeID() int {
+	return 18
+}
+
 type SetInputChecked struct {
-	*meta
+	message
 	ID      uint64
 	Checked bool
 }
@@ -369,8 +433,12 @@ func (msg *SetInputChecked) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *SetInputChecked) TypeID() int {
+	return 19
+}
+
 type MouseMove struct {
-	*meta
+	message
 	X uint64
 	Y uint64
 }
@@ -384,8 +452,12 @@ func (msg *MouseMove) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *MouseMove) TypeID() int {
+	return 20
+}
+
 type MouseClickDepricated struct {
-	*meta
+	message
 	ID             uint64
 	HesitationTime uint64
 	Label          string
@@ -401,8 +473,12 @@ func (msg *MouseClickDepricated) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *MouseClickDepricated) TypeID() int {
+	return 21
+}
+
 type ConsoleLog struct {
-	*meta
+	message
 	Level string
 	Value string
 }
@@ -416,8 +492,12 @@ func (msg *ConsoleLog) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *ConsoleLog) TypeID() int {
+	return 22
+}
+
 type PageLoadTiming struct {
-	*meta
+	message
 	RequestStart               uint64
 	ResponseStart              uint64
 	ResponseEnd                uint64
@@ -445,8 +525,12 @@ func (msg *PageLoadTiming) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *PageLoadTiming) TypeID() int {
+	return 23
+}
+
 type PageRenderTiming struct {
-	*meta
+	message
 	SpeedIndex        uint64
 	VisuallyComplete  uint64
 	TimeToInteractive uint64
@@ -462,8 +546,12 @@ func (msg *PageRenderTiming) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *PageRenderTiming) TypeID() int {
+	return 24
+}
+
 type JSException struct {
-	*meta
+	message
 	Name    string
 	Message string
 	Payload string
@@ -479,8 +567,12 @@ func (msg *JSException) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *JSException) TypeID() int {
+	return 25
+}
+
 type RawErrorEvent struct {
-	*meta
+	message
 	Timestamp uint64
 	Source    string
 	Name      string
@@ -500,8 +592,12 @@ func (msg *RawErrorEvent) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *RawErrorEvent) TypeID() int {
+	return 26
+}
+
 type RawCustomEvent struct {
-	*meta
+	message
 	Name    string
 	Payload string
 }
@@ -515,8 +611,12 @@ func (msg *RawCustomEvent) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *RawCustomEvent) TypeID() int {
+	return 27
+}
+
 type UserID struct {
-	*meta
+	message
 	ID string
 }
 
@@ -528,8 +628,12 @@ func (msg *UserID) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *UserID) TypeID() int {
+	return 28
+}
+
 type UserAnonymousID struct {
-	*meta
+	message
 	ID string
 }
 
@@ -541,8 +645,12 @@ func (msg *UserAnonymousID) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *UserAnonymousID) TypeID() int {
+	return 29
+}
+
 type Metadata struct {
-	*meta
+	message
 	Key   string
 	Value string
 }
@@ -556,8 +664,12 @@ func (msg *Metadata) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *Metadata) TypeID() int {
+	return 30
+}
+
 type PageEvent struct {
-	*meta
+	message
 	MessageID                  uint64
 	Timestamp                  uint64
 	URL                        string
@@ -601,8 +713,12 @@ func (msg *PageEvent) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *PageEvent) TypeID() int {
+	return 31
+}
+
 type InputEvent struct {
-	*meta
+	message
 	MessageID   uint64
 	Timestamp   uint64
 	Value       string
@@ -622,8 +738,12 @@ func (msg *InputEvent) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *InputEvent) TypeID() int {
+	return 32
+}
+
 type ClickEvent struct {
-	*meta
+	message
 	MessageID      uint64
 	Timestamp      uint64
 	HesitationTime uint64
@@ -643,8 +763,12 @@ func (msg *ClickEvent) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *ClickEvent) TypeID() int {
+	return 33
+}
+
 type ErrorEvent struct {
-	*meta
+	message
 	MessageID uint64
 	Timestamp uint64
 	Source    string
@@ -666,8 +790,12 @@ func (msg *ErrorEvent) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *ErrorEvent) TypeID() int {
+	return 34
+}
+
 type ResourceEvent struct {
-	*meta
+	message
 	MessageID       uint64
 	Timestamp       uint64
 	Duration        uint64
@@ -701,8 +829,12 @@ func (msg *ResourceEvent) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *ResourceEvent) TypeID() int {
+	return 35
+}
+
 type CustomEvent struct {
-	*meta
+	message
 	MessageID uint64
 	Timestamp uint64
 	Name      string
@@ -720,8 +852,12 @@ func (msg *CustomEvent) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *CustomEvent) TypeID() int {
+	return 36
+}
+
 type CSSInsertRule struct {
-	*meta
+	message
 	ID    uint64
 	Rule  string
 	Index uint64
@@ -737,8 +873,12 @@ func (msg *CSSInsertRule) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *CSSInsertRule) TypeID() int {
+	return 37
+}
+
 type CSSDeleteRule struct {
-	*meta
+	message
 	ID    uint64
 	Index uint64
 }
@@ -752,8 +892,12 @@ func (msg *CSSDeleteRule) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *CSSDeleteRule) TypeID() int {
+	return 38
+}
+
 type Fetch struct {
-	*meta
+	message
 	Method    string
 	URL       string
 	Request   string
@@ -777,8 +921,12 @@ func (msg *Fetch) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *Fetch) TypeID() int {
+	return 39
+}
+
 type Profiler struct {
-	*meta
+	message
 	Name     string
 	Duration uint64
 	Args     string
@@ -796,8 +944,12 @@ func (msg *Profiler) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *Profiler) TypeID() int {
+	return 40
+}
+
 type OTable struct {
-	*meta
+	message
 	Key   string
 	Value string
 }
@@ -811,8 +963,12 @@ func (msg *OTable) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *OTable) TypeID() int {
+	return 41
+}
+
 type StateAction struct {
-	*meta
+	message
 	Type string
 }
 
@@ -824,8 +980,12 @@ func (msg *StateAction) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *StateAction) TypeID() int {
+	return 42
+}
+
 type StateActionEvent struct {
-	*meta
+	message
 	MessageID uint64
 	Timestamp uint64
 	Type      string
@@ -841,8 +1001,12 @@ func (msg *StateActionEvent) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *StateActionEvent) TypeID() int {
+	return 43
+}
+
 type Redux struct {
-	*meta
+	message
 	Action   string
 	State    string
 	Duration uint64
@@ -858,8 +1022,12 @@ func (msg *Redux) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *Redux) TypeID() int {
+	return 44
+}
+
 type Vuex struct {
-	*meta
+	message
 	Mutation string
 	State    string
 }
@@ -873,8 +1041,12 @@ func (msg *Vuex) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *Vuex) TypeID() int {
+	return 45
+}
+
 type MobX struct {
-	*meta
+	message
 	Type    string
 	Payload string
 }
@@ -888,8 +1060,12 @@ func (msg *MobX) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *MobX) TypeID() int {
+	return 46
+}
+
 type NgRx struct {
-	*meta
+	message
 	Action   string
 	State    string
 	Duration uint64
@@ -905,8 +1081,12 @@ func (msg *NgRx) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *NgRx) TypeID() int {
+	return 47
+}
+
 type GraphQL struct {
-	*meta
+	message
 	OperationKind string
 	OperationName string
 	Variables     string
@@ -924,8 +1104,12 @@ func (msg *GraphQL) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *GraphQL) TypeID() int {
+	return 48
+}
+
 type PerformanceTrack struct {
-	*meta
+	message
 	Frames          int64
 	Ticks           int64
 	TotalJSHeapSize uint64
@@ -943,8 +1127,12 @@ func (msg *PerformanceTrack) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *PerformanceTrack) TypeID() int {
+	return 49
+}
+
 type GraphQLEvent struct {
-	*meta
+	message
 	MessageID     uint64
 	Timestamp     uint64
 	OperationKind string
@@ -966,8 +1154,12 @@ func (msg *GraphQLEvent) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *GraphQLEvent) TypeID() int {
+	return 50
+}
+
 type FetchEvent struct {
-	*meta
+	message
 	MessageID uint64
 	Timestamp uint64
 	Method    string
@@ -993,8 +1185,12 @@ func (msg *FetchEvent) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *FetchEvent) TypeID() int {
+	return 51
+}
+
 type DOMDrop struct {
-	*meta
+	message
 	Timestamp uint64
 }
 
@@ -1006,8 +1202,12 @@ func (msg *DOMDrop) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *DOMDrop) TypeID() int {
+	return 52
+}
+
 type ResourceTiming struct {
-	*meta
+	message
 	Timestamp       uint64
 	Duration        uint64
 	TTFB            uint64
@@ -1033,8 +1233,12 @@ func (msg *ResourceTiming) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *ResourceTiming) TypeID() int {
+	return 53
+}
+
 type ConnectionInformation struct {
-	*meta
+	message
 	Downlink uint64
 	Type     string
 }
@@ -1048,8 +1252,12 @@ func (msg *ConnectionInformation) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *ConnectionInformation) TypeID() int {
+	return 54
+}
+
 type SetPageVisibility struct {
-	*meta
+	message
 	hidden bool
 }
 
@@ -1061,8 +1269,12 @@ func (msg *SetPageVisibility) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *SetPageVisibility) TypeID() int {
+	return 55
+}
+
 type PerformanceTrackAggr struct {
-	*meta
+	message
 	TimestampStart     uint64
 	TimestampEnd       uint64
 	MinFPS             uint64
@@ -1100,8 +1312,12 @@ func (msg *PerformanceTrackAggr) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *PerformanceTrackAggr) TypeID() int {
+	return 56
+}
+
 type LongTask struct {
-	*meta
+	message
 	Timestamp     uint64
 	Duration      uint64
 	Context       uint64
@@ -1125,8 +1341,12 @@ func (msg *LongTask) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *LongTask) TypeID() int {
+	return 59
+}
+
 type SetNodeAttributeURLBased struct {
-	*meta
+	message
 	ID      uint64
 	Name    string
 	Value   string
@@ -1144,8 +1364,12 @@ func (msg *SetNodeAttributeURLBased) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *SetNodeAttributeURLBased) TypeID() int {
+	return 60
+}
+
 type SetCSSDataURLBased struct {
-	*meta
+	message
 	ID      uint64
 	Data    string
 	BaseURL string
@@ -1161,8 +1385,12 @@ func (msg *SetCSSDataURLBased) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *SetCSSDataURLBased) TypeID() int {
+	return 61
+}
+
 type IssueEvent struct {
-	*meta
+	message
 	MessageID     uint64
 	Timestamp     uint64
 	Type          string
@@ -1184,8 +1412,12 @@ func (msg *IssueEvent) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *IssueEvent) TypeID() int {
+	return 62
+}
+
 type TechnicalInfo struct {
-	*meta
+	message
 	Type  string
 	Value string
 }
@@ -1199,8 +1431,12 @@ func (msg *TechnicalInfo) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *TechnicalInfo) TypeID() int {
+	return 63
+}
+
 type CustomIssue struct {
-	*meta
+	message
 	Name    string
 	Payload string
 }
@@ -1214,8 +1450,12 @@ func (msg *CustomIssue) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *CustomIssue) TypeID() int {
+	return 64
+}
+
 type PageClose struct {
-	*meta
+	message
 }
 
 func (msg *PageClose) Encode() []byte {
@@ -1226,8 +1466,12 @@ func (msg *PageClose) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *PageClose) TypeID() int {
+	return 65
+}
+
 type AssetCache struct {
-	*meta
+	message
 	URL string
 }
 
@@ -1239,8 +1483,12 @@ func (msg *AssetCache) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *AssetCache) TypeID() int {
+	return 66
+}
+
 type CSSInsertRuleURLBased struct {
-	*meta
+	message
 	ID      uint64
 	Rule    string
 	Index   uint64
@@ -1258,8 +1506,12 @@ func (msg *CSSInsertRuleURLBased) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *CSSInsertRuleURLBased) TypeID() int {
+	return 67
+}
+
 type MouseClick struct {
-	*meta
+	message
 	ID             uint64
 	HesitationTime uint64
 	Label          string
@@ -1277,8 +1529,12 @@ func (msg *MouseClick) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *MouseClick) TypeID() int {
+	return 69
+}
+
 type CreateIFrameDocument struct {
-	*meta
+	message
 	FrameID uint64
 	ID      uint64
 }
@@ -1292,8 +1548,12 @@ func (msg *CreateIFrameDocument) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *CreateIFrameDocument) TypeID() int {
+	return 70
+}
+
 type IOSBatchMeta struct {
-	*meta
+	message
 	Timestamp  uint64
 	Length     uint64
 	FirstIndex uint64
@@ -1309,8 +1569,12 @@ func (msg *IOSBatchMeta) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *IOSBatchMeta) TypeID() int {
+	return 107
+}
+
 type IOSSessionStart struct {
-	*meta
+	message
 	Timestamp      uint64
 	ProjectID      uint64
 	TrackerVersion string
@@ -1340,8 +1604,12 @@ func (msg *IOSSessionStart) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *IOSSessionStart) TypeID() int {
+	return 90
+}
+
 type IOSSessionEnd struct {
-	*meta
+	message
 	Timestamp uint64
 }
 
@@ -1353,8 +1621,12 @@ func (msg *IOSSessionEnd) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *IOSSessionEnd) TypeID() int {
+	return 91
+}
+
 type IOSMetadata struct {
-	*meta
+	message
 	Timestamp uint64
 	Length    uint64
 	Key       string
@@ -1372,8 +1644,12 @@ func (msg *IOSMetadata) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *IOSMetadata) TypeID() int {
+	return 92
+}
+
 type IOSCustomEvent struct {
-	*meta
+	message
 	Timestamp uint64
 	Length    uint64
 	Name      string
@@ -1391,8 +1667,12 @@ func (msg *IOSCustomEvent) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *IOSCustomEvent) TypeID() int {
+	return 93
+}
+
 type IOSUserID struct {
-	*meta
+	message
 	Timestamp uint64
 	Length    uint64
 	Value     string
@@ -1408,8 +1688,12 @@ func (msg *IOSUserID) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *IOSUserID) TypeID() int {
+	return 94
+}
+
 type IOSUserAnonymousID struct {
-	*meta
+	message
 	Timestamp uint64
 	Length    uint64
 	Value     string
@@ -1425,8 +1709,12 @@ func (msg *IOSUserAnonymousID) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *IOSUserAnonymousID) TypeID() int {
+	return 95
+}
+
 type IOSScreenChanges struct {
-	*meta
+	message
 	Timestamp uint64
 	Length    uint64
 	X         uint64
@@ -1448,8 +1736,12 @@ func (msg *IOSScreenChanges) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *IOSScreenChanges) TypeID() int {
+	return 96
+}
+
 type IOSCrash struct {
-	*meta
+	message
 	Timestamp  uint64
 	Length     uint64
 	Name       string
@@ -1469,8 +1761,12 @@ func (msg *IOSCrash) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *IOSCrash) TypeID() int {
+	return 97
+}
+
 type IOSScreenEnter struct {
-	*meta
+	message
 	Timestamp uint64
 	Length    uint64
 	Title     string
@@ -1488,8 +1784,12 @@ func (msg *IOSScreenEnter) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *IOSScreenEnter) TypeID() int {
+	return 98
+}
+
 type IOSScreenLeave struct {
-	*meta
+	message
 	Timestamp uint64
 	Length    uint64
 	Title     string
@@ -1507,8 +1807,12 @@ func (msg *IOSScreenLeave) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *IOSScreenLeave) TypeID() int {
+	return 99
+}
+
 type IOSClickEvent struct {
-	*meta
+	message
 	Timestamp uint64
 	Length    uint64
 	Label     string
@@ -1528,8 +1832,12 @@ func (msg *IOSClickEvent) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *IOSClickEvent) TypeID() int {
+	return 100
+}
+
 type IOSInputEvent struct {
-	*meta
+	message
 	Timestamp   uint64
 	Length      uint64
 	Value       string
@@ -1549,8 +1857,12 @@ func (msg *IOSInputEvent) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *IOSInputEvent) TypeID() int {
+	return 101
+}
+
 type IOSPerformanceEvent struct {
-	*meta
+	message
 	Timestamp uint64
 	Length    uint64
 	Name      string
@@ -1568,8 +1880,12 @@ func (msg *IOSPerformanceEvent) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *IOSPerformanceEvent) TypeID() int {
+	return 102
+}
+
 type IOSLog struct {
-	*meta
+	message
 	Timestamp uint64
 	Length    uint64
 	Severity  string
@@ -1587,8 +1903,12 @@ func (msg *IOSLog) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *IOSLog) TypeID() int {
+	return 103
+}
+
 type IOSInternalError struct {
-	*meta
+	message
 	Timestamp uint64
 	Length    uint64
 	Content   string
@@ -1604,8 +1924,12 @@ func (msg *IOSInternalError) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *IOSInternalError) TypeID() int {
+	return 104
+}
+
 type IOSNetworkCall struct {
-	*meta
+	message
 	Timestamp uint64
 	Length    uint64
 	Duration  uint64
@@ -1633,8 +1957,12 @@ func (msg *IOSNetworkCall) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *IOSNetworkCall) TypeID() int {
+	return 105
+}
+
 type IOSPerformanceAggregated struct {
-	*meta
+	message
 	TimestampStart uint64
 	TimestampEnd   uint64
 	MinFPS         uint64
@@ -1672,8 +2000,12 @@ func (msg *IOSPerformanceAggregated) Encode() []byte {
 	return buf[:p]
 }
 
+func (msg *IOSPerformanceAggregated) TypeID() int {
+	return 110
+}
+
 type IOSIssueEvent struct {
-	*meta
+	message
 	Timestamp     uint64
 	Type          string
 	ContextString string
@@ -1692,3 +2024,7 @@ func (msg *IOSIssueEvent) Encode() []byte {
 	p = WriteString(msg.Payload, buf, p)
 	return buf[:p]
 }
+
+func (msg *IOSIssueEvent) TypeID() int {
+	return 111
+}
diff --git a/backend/pkg/messages/read-message.go b/backend/pkg/messages/read-message.go
index 60f9c17a8..59c8e739c 100644
--- a/backend/pkg/messages/read-message.go
+++ b/backend/pkg/messages/read-message.go
@@ -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
 		}
diff --git a/backend/services/sink/main.go b/backend/services/sink/main.go
index a649bb6ef..1a23919c6 100644
--- a/backend/services/sink/main.go
+++ b/backend/services/sink/main.go
@@ -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
 			}