fix(yt): various fixes

Author: decahedron1

Cargo.toml

@@ -10,6 +10,7 @@ edition = "2021"
 rust-version = "1.75"
 
 [dependencies]
+tracing = "0.1"
 irc = { version = "1.0", optional = true, default-features = false }
 tokio = { version = "1.42", default-features = false, features = [ "net" ] }
 futures-util = { version = "0.3", default-features = false }

src/youtube/mod.rs

@@ -49,7 +49,7 @@ pub(crate) fn get_http_client() -> &'static reqwest::Client {
 		let mut headers = HeaderMap::new();
 		// Set our Accept-Language to en-US so we can properly match substrings
 		headers.append(header::ACCEPT_LANGUAGE, HeaderValue::from_static("en-US,en;q=0.5"));
-		headers.append(header::USER_AGENT, HeaderValue::from_static("Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:123.0) Gecko/20100101 Firefox/123.0"));
+		headers.append(header::USER_AGENT, HeaderValue::from_static("Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:138.0) Gecko/20100101 Firefox/138.0"));
 		// Referer is required by Signaler endpoints.
 		headers.append(header::REFERER, HeaderValue::from_static("https://www.youtube.com/"));
 		reqwest::Client::builder().default_headers(headers).build().unwrap()
@@ -172,7 +172,9 @@ pub async fn stream(options: &ChatContext) -> Result<BoxStream<'_, Result<Action
 				'i: loop {
 					match chunk.cont().await {
 						Some(Ok(c)) => chunk = c,
-						Some(Err(err)) => eprintln!("{err:?}"),
+						Some(Err(e)) => {
+							tracing::error!(source = ?e, trigger = "between-sessions", "Failed to fetch continuation");
+						}
 						_ => break 'i
 					};
 
@@ -216,7 +218,9 @@ pub async fn stream(options: &ChatContext) -> Result<BoxStream<'_, Result<Action
 
 								match chunk.cont().await {
 									Some(Ok(c)) => chunk = c,
-									Some(Err(err)) => eprintln!("{err:?}"),
+									Some(Err(e)) => {
+										tracing::error!(source = ?e, trigger = "signal", "Failed to fetch continuation");
+									}
 									_ => break 'i
 								};
 								channel.topic = chunk.signaler_topic.clone().unwrap();
@@ -244,7 +248,7 @@ pub async fn stream(options: &ChatContext) -> Result<BoxStream<'_, Result<Action
 							}
 							Ok(None) => break,
 							Err(e) => {
-								eprintln!("{e:?}");
+								tracing::error!(source = ?e, "Signaler stream errored");
 								break;
 							}
 						}

src/youtube/types/get_live_chat.rs

@@ -66,16 +66,15 @@ impl GetLiveChatResponse {
 	pub async fn fetch(options: &ChatContext, continuation: impl AsRef<str>) -> Result<Self, Error> {
 		let body = GetLiveChatRequestBody::new(continuation.as_ref(), &options.client_version, "WEB");
 		Ok(get_http_client()
-			.post(Url::parse_with_params(if options.live_status.updates_live() { TANGO_LIVE_ENDPOINT } else { TANGO_REPLAY_ENDPOINT }, [
-				("key", options.api_key.as_str()),
-				("prettyPrint", "false")
-			])?)
+			.post(Url::parse_with_params(
+				if options.live_status.updates_live() { TANGO_LIVE_ENDPOINT } else { TANGO_REPLAY_ENDPOINT },
+				[("key", options.api_key.as_str()), ("prettyPrint", "false")]
+			)?)
 			.simd_json(&body)?
 			.send()
 			.await?
 			.simd_json()
-			.await
-			.unwrap())
+			.await?)
 	}
 }
 

src/youtube/types/streams_page.rs

@@ -31,7 +31,6 @@ pub enum PageContentsRenderer {
 #[serde(rename_all = "camelCase")]
 pub enum TabItemRenderer {
 	TabRenderer {
-		endpoint: FeedEndpoint,
 		title: String,
 		#[serde(default)]
 		selected: bool,
@@ -40,21 +39,6 @@ pub enum TabItemRenderer {
 	ExpandableTabRenderer {}
 }
 
-#[derive(Debug, Deserialize)]
-#[serde(rename_all = "camelCase")]
-pub struct FeedEndpoint {
-	pub browse_endpoint: BrowseEndpoint,
-	pub command_metadata: CommandMetadata
-}
-
-#[derive(Debug, Deserialize)]
-#[serde(rename_all = "camelCase")]
-pub struct BrowseEndpoint {
-	pub browse_id: String,
-	pub params: String,
-	pub canonical_base_url: String
-}
-
 #[derive(Debug, Deserialize)]
 #[serde(rename_all = "camelCase")]
 pub enum FeedContentsRenderer {
@@ -79,7 +63,6 @@ pub enum RichGridItem {
 pub enum RichItemContent {
 	#[serde(rename_all = "camelCase")]
 	VideoRenderer {
-		description_snippet: LocalizedText,
 		thumbnail: ImageContainer,
 		thumbnail_overlays: Vec<ThumbnailOverlay>,
 		video_id: String