From 44da81774cc37e8bffd0d55f2e32d18cab37742c Mon Sep 17 00:00:00 2001
From: Alex X <alexey.khit@gmail.com>
Date: Thu, 1 Jan 2026 08:32:39 +0300
Subject: [PATCH] Add recv/send counters to xiaomi source

---
 pkg/xiaomi/backchannel.go | 4 ++++
 pkg/xiaomi/producer.go    | 2 ++
 2 files changed, 6 insertions(+)

diff --git a/pkg/xiaomi/backchannel.go b/pkg/xiaomi/backchannel.go
index 0224a594..a6f57b81 100644
--- a/pkg/xiaomi/backchannel.go
+++ b/pkg/xiaomi/backchannel.go
@@ -31,6 +31,7 @@ func (p *Producer) AddTrack(media *core.Media, _ *core.Codec, track *core.Receiv
 				buf = append(buf, transcode(pkt.Payload)...)
 				const size = 2 * 8000 * 0.040 // 16bit 40ms
 				for len(buf) >= size {
+					p.Send += size
 					_ = p.client.WriteAudio(miss.CodecPCM, buf[:size])
 					buf = buf[size:]
 				}
@@ -40,6 +41,7 @@ func (p *Producer) AddTrack(media *core.Media, _ *core.Codec, track *core.Receiv
 				buf = append(buf, pkt.Payload...)
 				const size = 8000 * 0.040 // 8bit 40 ms
 				for len(buf) >= size {
+					p.Send += size
 					_ = p.client.WriteAudio(miss.CodecPCMA, buf[:size])
 					buf = buf[size:]
 				}
@@ -54,12 +56,14 @@ func (p *Producer) AddTrack(media *core.Media, _ *core.Codec, track *core.Receiv
 				} else {
 					// convert two 20ms to one 40ms
 					buf = opus.JoinFrames(buf, pkt.Payload)
+					p.Send += len(buf)
 					_ = p.client.WriteAudio(miss.CodecOPUS, buf)
 					buf = nil
 				}
 			}
 		} else {
 			sender.Handler = func(pkt *rtp.Packet) {
+				p.Send += len(pkt.Payload)
 				_ = p.client.WriteAudio(miss.CodecOPUS, pkt.Payload)
 			}
 		}
diff --git a/pkg/xiaomi/producer.go b/pkg/xiaomi/producer.go
index 09ba7360..9abf66b0 100644
--- a/pkg/xiaomi/producer.go
+++ b/pkg/xiaomi/producer.go
@@ -164,6 +164,8 @@ func (p *Producer) Start() error {
 			return err
 		}
 
+		p.Recv += len(pkt.Payload)
+
 		// TODO: rewrite this
 		var name string
 		var pkt2 *core.Packet