Upload 3 files

Cargo.toml

@@ -12,7 +12,7 @@ tower-http = { version = "0.5", features = ["cors", "trace", "compression-br", "
 tracing-subscriber = "0.3"
 tokio = { version = "1", features = ["rt-multi-thread", "macros"] }
 serde = { version = "1.0", features = ["derive"] }
-reqwest = { version = "0.11", features = ["json", "rustls-tls", "cookies", "gzip"], default-features = false }
+reqwest = { version = "0.11", features = ["json", "rustls-tls", "cookies", "gzip", "stream"], default-features = false }
 serde_json = "1.0"
 thiserror = "1.0"
 bytes = "1"

src/main.rs

@@ -18,6 +18,7 @@ use cipher::{KeyIvInit, BlockDecryptMut};
 use cipher::block_padding::NoPadding;
 use cbc::Decryptor;
 use reqwest::{cookie::Jar, Url};
+use reqwest::header::ACCEPT;
 
 mod api;
 use api::{APIClient, APIError, Format};
@@ -146,7 +147,7 @@ fn blowfish_key(track_id: u32) -> [u8; 16] {
 
 fn decrypt_stripe(block: &mut [u8], key: &[u8; 16]) -> Result<(), ()> {
     let iv = [0u8, 1, 2, 3, 4, 5, 6, 7];
-    let mut dec = Decryptor::<Blowfish>::new_from_slices(key, &iv).map_err(|_| ())?;
+    let dec = Decryptor::<Blowfish>::new_from_slices(key, &iv).map_err(|_| ())?;
     dec.decrypt_padded_mut::<NoPadding>(block).map_err(|_| ())?;
     Ok(())
 }
@@ -225,7 +226,7 @@ async fn stream(State(state): State<Arc<RwLock<APIClient>>>, Query(q): Query<Str
     let mut carry: Vec<u8> = Vec::with_capacity(4096);
     let mut block_index: u64 = 0;
 
-    let mut upstream = upstream.bytes_stream().map_err(|_| ());
+    let mut upstream = upstream.bytes_stream();
 
     let out = async_stream::try_stream! {
         while let Some(chunk) = upstream.next().await {
@@ -337,7 +338,7 @@ async fn gw_light_call(
             ("api_version", "1.0"),
             ("api_token", api_token),
         ])
-        .header(http::header::ACCEPT, "*/*")
+        .header(ACCEPT, "*/*")
         .json(&params)
         .send()
         .await
@@ -362,8 +363,6 @@ async fn login(Json(req): Json<LoginReq>) -> impl IntoResponse {
     if email.is_empty() || pass.is_empty() {
         return (StatusCode::BAD_REQUEST, "Email and password_md5 required".to_string()).into_response();
     }
-
-    let url = "https://www.deezer.com".parse::<Url>().unwrap();
     let jar = Jar::default();
     let client = reqwest::Client::builder()
         .cookie_provider(Arc::new(jar))