diff --git a/telemetry/client.go b/telemetry/client.go index 0aabb6ae0..c3494513d 100644 --- a/telemetry/client.go +++ b/telemetry/client.go @@ -46,6 +46,7 @@ func (c *Client) PushReceivedMessages(filter transport.Filter, sshMessage *types "messageType": message.Type.String(), "receiverKeyUID": c.keyUID, "nodeName": c.nodeName, + "messageSize": len(sshMessage.Payload), }) } body, _ := json.Marshal(postBody) diff --git a/wakuv2/waku.go b/wakuv2/waku.go index dde980238..6c34abce0 100644 --- a/wakuv2/waku.go +++ b/wakuv2/waku.go @@ -563,11 +563,19 @@ func (w *Waku) telemetryBandwidthStats(telemetryServerURL string) { ticker := time.NewTicker(time.Second * 20) defer ticker.Stop() + today := time.Now() + for { select { case <-w.quit: return - case <-ticker.C: + case now := <-ticker.C: + // Reset totals when day changes + if now.Day() != today.Day() { + today = now + w.bandwidthCounter.Reset() + } + storeStats := w.bandwidthCounter.GetBandwidthForProtocol(store.StoreID_v20beta4) relayStats := w.bandwidthCounter.GetBandwidthForProtocol(relay.WakuRelayID_v200) go telemetry.PushProtocolStats(relayStats, storeStats)