moq-boy 0.2.1

MoQ Boy - Crowd-controlled Game Boy streaming
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59

//! Status track: JSON state published to viewers each frame.
//!
//! Contains which buttons are held, per-viewer latency measurements,
//! encoding stats, and an optional location label. Only published
//! when the JSON changes from the previous frame to avoid waste.

use std::collections::BTreeMap;

use serde::Serialize;

use crate::emulator::Button;
use crate::stats::StatsReport;

/// Per-frame status broadcast to all viewers on the "status" track.
#[derive(Serialize)]
pub struct Status {
	/// Currently pressed buttons (union across all viewers).
	pub buttons: Vec<Button>,
	/// Per-viewer round-trip latency in milliseconds.
	pub latency: BTreeMap<String, u32>,
	/// Encoding and emulation performance stats.
	pub stats: StatsReport,
	/// Optional server location label (e.g. "Dallas, TX").
	#[serde(skip_serializing_if = "Option::is_none")]
	pub location: Option<String>,
}

/// Manages the status track, only publishing when content changes.
pub struct StatusPublisher {
	producer: moq_lite::TrackProducer,
	last_json: String,
}

impl StatusPublisher {
	pub fn new(broadcast: &mut moq_lite::BroadcastProducer) -> anyhow::Result<Self> {
		let track = moq_lite::Track {
			name: "status".to_string(),
			priority: 10,
		};
		let producer = broadcast.create_track(track)?;

		Ok(Self {
			producer,
			last_json: String::new(),
		})
	}

	/// Publish status if it changed since last call.
	pub fn publish(&mut self, status: &Status) {
		let json = serde_json::to_string(status).unwrap();
		if json != self.last_json {
			self.last_json = json.clone();
			if let Ok(mut group) = self.producer.append_group() {
				let _ = group.write_frame(json.into_bytes());
				let _ = group.finish();
			}
		}
	}
}