feat: message bandwidth by type

cmd/server/main.go

@@ -72,5 +72,6 @@ func main() {
 	server.RegisterMetric(types.MessageCheckFailureMetric, &metrics.MessageCheckFailure{})
 	server.RegisterMetric(types.DialFailureMetric, &metrics.DialFailure{})
 	server.RegisterMetric(types.SentMessageTotalMetric, &metrics.SentMessageTotalMetric{})
+	server.RegisterMetric(types.RawMessageByTypeMetric, &metrics.RawMessageByTypeMetric{})
 	server.Start(*port)
 }

lib/database/sql/000026_raw_message_by_type.up.sql

@@ -0,0 +1,11 @@
+CREATE TABLE IF NOT EXISTS rawMessageByType (
+    id SERIAL PRIMARY KEY,
+    recordId INTEGER NOT NULL,
+    size INTEGER NOT NULL,
+    messageType TEXT NOT NULL,
+    timestamp INTEGER NOT NULL,
+    CONSTRAINT rawMessageByType_unique UNIQUE (recordId, timestamp)
+);
+
+ALTER TABLE rawMessageByType ADD CONSTRAINT fk_rawMessageByType_telemetryRecord
+            FOREIGN KEY (recordId) REFERENCES telemetryRecord(id);

lib/metrics/raw_message_by_type.go

@@ -0,0 +1,7 @@
+package metrics
+
+import "github.com/status-im/telemetry/pkg/types"
+
+type RawMessageByTypeMetric struct {
+	GenericMetric[types.RawMessageByType]
+}

pkg/types/types.go

@@ -23,6 +23,7 @@ const (
 	MissedRelevantMessageMetric    TelemetryType = "MissedRelevantMessages"
 	MessageDeliveryConfirmedMetric TelemetryType = "MessageDeliveryConfirmed"
 	SentMessageTotalMetric         TelemetryType = "SentMessageTotal"
+	RawMessageByTypeMetric         TelemetryType = "RawMessageByType"
 )
 
 type Origin int64
@@ -206,3 +207,10 @@ type SentMessageTotal struct {
 	Size      uint32 `json:"size"`
 	Timestamp int64  `json:"timestamp"`
 }
+
+type RawMessageByType struct {
+	TelemetryRecord
+	Size        uint32 `json:"size"`
+	MessageType string `json:"messageType"`
+	Timestamp   int64  `json:"timestamp"`
+}