Spaces:

recycleactor
/

deezer

Paused

App Files Files Community

recycleactor commited on Jul 1

Commit

e314da3

verified ·

1 Parent(s): 4039d14

Upload main.rs

Browse files

Files changed (1) hide show

src/main.rs +55 -8

src/main.rs CHANGED Viewed

@@ -1212,6 +1212,21 @@ fn forwarded_proto(headers: &HeaderMap) -> String {
         .to_string()
 }
 #[derive(Deserialize)]
 struct PairStatusQuery {
     code: String,
@@ -1337,12 +1352,17 @@ async fn pair_page(Host(host): Host, headers: HeaderMap, Query(q): Query<PairPag
     let code = q.code.unwrap_or_default().trim().to_string();
     let safe_code = htmlesc(&code);
     let scheme = forwarded_proto(&headers);
-    let channel_url = format!("{scheme}://{host}/pair/channel");
     let app_id = deezer_app_id();
     let code_js = serde_json::to_string(&code).unwrap_or_else(|_| "\"\"".to_string());
-    let channel_url_js = serde_json::to_string(&channel_url).unwrap_or_else(|_| "\"\"".to_string());
-    let app_id_js = serde_json::to_string(&app_id).unwrap_or_else(|_| "\"\"".to_string());
     let mut html = String::with_capacity(6000);
     html.push_str(r#"<!doctype html><html><head><meta charset="utf-8"><meta name="viewport" content="width=device-width,initial-scale=1">"#);
@@ -1360,16 +1380,42 @@ async fn pair_page(Host(host): Host, headers: HeaderMap, Query(q): Query<PairPag
     html.push_str(r#"<script>(function(){"#);
     html.push_str("var code=");
     html.push_str(&code_js);
-    html.push_str(r#";var msg=document.getElementById('msg');function setMsg(cls,text){msg.className=cls?(cls+' muted'):'muted';msg.textContent=text;}if(!code){setMsg('err','Нет кода пары. Открой ссылку заново с QR.');return;}function postToken(at,uid){return fetch('/pair/oauth',{method:'POST',headers:{'Content-Type':'application/json'},body:JSON.stringify({code:code,access_token:at,user_id:String(uid||'')})}).then(function(r){return r.json().catch(function(){return {};}).then(function(j){return {ok:r.ok,json:j};});});}function start(){function initDZ(){try{if(!window.DZ||!DZ.init){return false;}DZ.init({appId:"#);
-    html.push_str(&app_id_js);
-    html.push_str(r#",channelUrl:"#);
-    html.push_str(&channel_url_js);
-    html.push_str(r#"});return true;}catch(e){return false;}}if(!initDZ()){setMsg('err','Не удалось инициализировать Deezer SDK.');return;}document.getElementById('dz-login').addEventListener('click',function(){setMsg('','Ожидаю Deezer…');DZ.login(function(resp){if(resp&&resp.authResponse&&resp.authResponse.accessToken){setMsg('','Сохраняю токен…');postToken(resp.authResponse.accessToken,resp.authResponse.userID).then(function(r){if(r.ok&&!r.json.error){setMsg('ok','Готово ✓ Вернись на телевизор.');}else{setMsg('err','Ошибка сохранения: '+(r.json.error||'error'));}}).catch(function(){setMsg('err','Ошибка сети при сохранении');});}else{setMsg('err','Вход отменён или не удалось получить токен');}},{perms:'basic_access,email,manage_library,listening_history'});});}function loadSdk(){var s=document.createElement('script');s.src='https://cdns-files.deezer.com/js/min/dz.js';s.onload=function(){start();};s.onerror=function(){setMsg('err','Не удалось загрузить Deezer SDK (dz.js). Проверь сеть/блокировщик.');};document.head.appendChild(s);}loadSdk();})();</script>"#);
     html.push_str(r#"<p class="muted" style="margin:14px 0 0">Если Deezer пишет про неверный redirect/domain — нужно указать свой <b>DEEZER_APP_ID</b> для домена этого сервера.</p>"#);
     html.push_str(r#"</div></body></html>"#);
     Html(html)
 }
 #[derive(Deserialize)]
 struct PairCompleteForm {
     code: String,
@@ -1957,6 +2003,7 @@ async fn main() {
         .route("/pair", get(pair_page))
         .route("/pair/channel", get(pair_channel))
         .route("/pair/oauth", post(pair_oauth))
         .route("/pair/complete", post(pair_complete))
         .route("/oauth/me", post(oauth_me))
         .route("/oauth/playlists", post(oauth_playlists))

         .to_string()
 }
+fn urlenc(s: &str) -> String {
+    let mut out = String::with_capacity(s.len() + 16);
+    for &b in s.as_bytes() {
+        let c = b as char;
+        let ok = matches!(c, 'A'..='Z' | 'a'..='z' | '0'..='9' | '-' | '_' | '.' | '~');
+        if ok {
+            out.push(c);
+        } else {
+            out.push('%');
+            out.push_str(&format!("{:02X}", b));
+        }
+    }
+    out
+}
 #[derive(Deserialize)]
 struct PairStatusQuery {
     code: String,
     let code = q.code.unwrap_or_default().trim().to_string();
     let safe_code = htmlesc(&code);
     let scheme = forwarded_proto(&headers);
     let app_id = deezer_app_id();
+    let redirect_url = format!("{scheme}://{host}/pair/oauth_cb?code={}", urlenc(&code));
+    let oauth_url = format!(
+        "https://connect.deezer.com/oauth/auth.php?app_id={}&redirect_uri={}&perms={}&response_type=token",
+        urlenc(&app_id),
+        urlenc(&redirect_url),
+        urlenc("basic_access,email,manage_library,listening_history")
+    );
     let code_js = serde_json::to_string(&code).unwrap_or_else(|_| "\"\"".to_string());
+    let oauth_url_js = serde_json::to_string(&oauth_url).unwrap_or_else(|_| "\"\"".to_string());
     let mut html = String::with_capacity(6000);
     html.push_str(r#"<!doctype html><html><head><meta charset="utf-8"><meta name="viewport" content="width=device-width,initial-scale=1">"#);
     html.push_str(r#"<script>(function(){"#);
     html.push_str("var code=");
     html.push_str(&code_js);
+    html.push_str(r#";var oauthUrl="#);
+    html.push_str(&oauth_url_js);
+    html.push_str(r#";var msg=document.getElementById('msg');function setMsg(cls,text){msg.className=cls?(cls+' muted'):'muted';msg.textContent=text;}if(!code){setMsg('err','Нет кода пары. Открой ссылку заново с QR.');return;}document.getElementById('dz-login').addEventListener('click',function(){setMsg('','Открываю Deezer…');if(!oauthUrl){setMsg('err','Не удалось собрать Deezer OAuth URL');return;}window.location.href=oauthUrl;});})();</script>"#);
     html.push_str(r#"<p class="muted" style="margin:14px 0 0">Если Deezer пишет про неверный redirect/domain — нужно указать свой <b>DEEZER_APP_ID</b> для домена этого сервера.</p>"#);
     html.push_str(r#"</div></body></html>"#);
     Html(html)
 }
+#[derive(Deserialize)]
+struct PairOauthCbQuery {
+    code: Option<String>,
+}
+async fn pair_oauth_cb(Query(q): Query<PairOauthCbQuery>) -> impl IntoResponse {
+    let code = q.code.unwrap_or_default().trim().to_string();
+    let safe_code = htmlesc(&code);
+    let code_js = serde_json::to_string(&code).unwrap_or_else(|_| "\"\"".to_string());
+    let mut html = String::with_capacity(3500);
+    html.push_str(r#"<!doctype html><html><head><meta charset="utf-8"><meta name="viewport" content="width=device-width,initial-scale=1">"#);
+    html.push_str(r#"<title>Deezer Login</title>"#);
+    html.push_str(r#"<style>body{font-family:system-ui,-apple-system,Segoe UI,Roboto,Arial,sans-serif;background:#0b0b0b;color:#fff;margin:0;padding:20px}.box{max-width:420px;margin:0 auto;background:#151515;padding:18px;border-radius:12px}.muted{color:#aaa;font-size:13px;line-height:1.35}.ok{color:#1db954}.err{color:#ff5a5a}</style>"#);
+    html.push_str(r#"</head><body><div class="box">"#);
+    html.push_str(r#"<h2 style="margin:0 0 6px">Deezer: вход для ТВ</h2>"#);
+    html.push_str(r#"<div class="muted">Код пары: <b>"#);
+    html.push_str(&safe_code);
+    html.push_str(r#"</b></div>"#);
+    html.push_str(r#"<div id="msg" class="muted" style="margin:12px 0 0">Получаю токен…</div>"#);
+    html.push_str(r#"<script>(function(){"#);
+    html.push_str("var code=");
+    html.push_str(&code_js);
+    html.push_str(r#";var msg=document.getElementById('msg');function setMsg(cls,text){msg.className=cls?(cls+' muted'):'muted';msg.textContent=text;}function parseHash(){var h=window.location.hash||'';if(h.charAt(0)==='#')h=h.slice(1);var out={};h.split('&').forEach(function(p){if(!p)return;var i=p.indexOf('=');var k=i>=0?p.slice(0,i):p;var v=i>=0?p.slice(i+1):'';try{k=decodeURIComponent(k);}catch(e){}try{v=decodeURIComponent(v);}catch(e){}out[k]=v;});return out;}if(!code){setMsg('err','Нет кода пары. Вернись на телевизор и обнови QR/ссылку.');return;}var h=parseHash();var at=h.access_token||'';if(!at){setMsg('err','Deezer не вернул access_token. Попробуй ещё раз.');return;}try{history.replaceState(null,'',window.location.pathname+window.location.search);}catch(e){}fetch('/pair/oauth',{method:'POST',headers:{'Content-Type':'application/json'},body:JSON.stringify({code:code,access_token:at})}).then(function(r){return r.json().catch(function(){return {};}).then(function(j){return {ok:r.ok,json:j};});}).then(function(r){if(r.ok&&!r.json.error){setMsg('ok','Готово ✓ Вернись на телевизор.');}else{setMsg('err','Ошибка сохранения: '+(r.json.error||'error'));}}).catch(function(){setMsg('err','Ошибка сети при сохранении');});})();</script>"#);
+    html.push_str(r#"</div></body></html>"#);
+    (StatusCode::OK, Html(html)).into_response()
+}
 #[derive(Deserialize)]
 struct PairCompleteForm {
     code: String,
         .route("/pair", get(pair_page))
         .route("/pair/channel", get(pair_channel))
         .route("/pair/oauth", post(pair_oauth))
+        .route("/pair/oauth_cb", get(pair_oauth_cb))
         .route("/pair/complete", post(pair_complete))
         .route("/oauth/me", post(oauth_me))
         .route("/oauth/playlists", post(oauth_playlists))