Upload main.rs

src/main.rs

@@ -942,6 +942,9 @@ async fn oauth_access_token(
 
     let status = r.status();
     let text = r.text().await.map_err(|_| "oauth:read".to_string())?;
+    if status.as_u16() == 403 && text.to_ascii_lowercase().contains("access denied") {
+        return Err("oauth:blocked:403".to_string());
+    }
     let v: serde_json::Value = serde_json::from_str(&text).map_err(|_| {
         let snip: String = text.chars().take(200).collect();
         format!("oauth:parse:{}:{}", status.as_u16(), snip)
@@ -1023,8 +1026,6 @@ async fn gw_light_call(
             .header("X-Requested-With", "XMLHttpRequest")
             .header("Accept-Language", "en-US,en;q=0.9")
             .header("Content-Language", "en-US")
-            .header("X-User-IP", "1.1.1.1")
-            .header("x-deezer-client-ip", "1.1.1.1")
             .header(
                 "User-Agent",
                 "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/79.0.3945.130 Safari/537.36",
@@ -1035,6 +1036,9 @@ async fn gw_light_call(
 
         let status = r.status();
         let text = r.text().await.map_err(|_| "read".to_string())?;
+        if status.as_u16() == 403 && text.to_ascii_lowercase().contains("access denied") {
+            return Err("blocked:403".to_string());
+        }
         let json: GwResp = serde_json::from_str(&text).map_err(|_| {
             let snip: String = text.chars().take(200).collect();
             format!("parse:{}:{}", status.as_u16(), snip)
@@ -1123,8 +1127,6 @@ async fn gw_light_call_custom(
         .header("X-Requested-With", "XMLHttpRequest")
         .header("Accept-Language", "en-US,en;q=0.9")
         .header("Content-Language", "en-US")
-        .header("X-User-IP", "1.1.1.1")
-        .header("x-deezer-client-ip", "1.1.1.1")
         .header(
             "User-Agent",
             "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/79.0.3945.130 Safari/537.36",
@@ -1135,6 +1137,9 @@ async fn gw_light_call_custom(
 
     let status = r.status();
     let text = r.text().await.map_err(|_| "read".to_string())?;
+    if status.as_u16() == 403 && text.to_ascii_lowercase().contains("access denied") {
+        return Err("blocked:403".to_string());
+    }
     let json: GwResp = serde_json::from_str(&text).map_err(|_| {
         let snip: String = text.chars().take(200).collect();
         format!("parse:{}:{}", status.as_u16(), snip)
@@ -1465,7 +1470,7 @@ async fn pair_page(Host(host): Host, headers: HeaderMap, Query(q): Query<PairPag
     html.push_str(r#"<div class="muted" style="margin:10px 0 14px">Нажми кнопку, войди в Deezer и подтверди доступ. После успеха вернись на телевизор.</div>"#);
     html.push_str(r#"<button id="dz-login" type="button">Войти через Deezer</button>"#);
     html.push_str(r#"<div id="msg" class="muted" style="margin:12px 0 0"></div>"#);
-    html.push_str(r#"<div class="muted" style="margin:12px 0 8px">Если OAuth не работает (redirect_uri) — используй вход по логину/паролю ниже.</div>"#);
+    html.push_str(r#"<div class="muted" style="margin:12px 0 8px">Рекомендуется OAuth (кнопка выше). Вход по логину/паролю ниже может блокироваться на некоторых прокси/хостингах (403 Access Denied).</div>"#);
     html.push_str(r#"<form method="POST" action="/pair/complete" autocomplete="on" style="margin:10px 0 0">"#);
     html.push_str(r#"<input type="hidden" name="code" value="" id="pair-code-hidden">"#);
     html.push_str(r#"<div class="row"><input name="email" type="email" placeholder="Email" autocomplete="username" required></div>"#);