Skip to content

Commit

Permalink
Merge pull request #65 from Bnyro/code-cleanup
Browse files Browse the repository at this point in the history
cleanup query handling and domain validation
  • Loading branch information
FireMasterK committed Aug 4, 2023
2 parents 1afcdf4 + b97632a commit 53329c4
Showing 1 changed file with 5 additions and 25 deletions.
30 changes: 5 additions & 25 deletions src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,7 @@ static CLIENT: Lazy<Client> = Lazy::new(|| {
}
});

const ANDROID_USER_AGENT: &str = "com.google.android.youtube/1537338816 (Linux; U; Android 13; en_US; ; Build/TQ2A.230505.002; Cronet/113.0.5672.24)";
const ALLOWED_DOMAINS: [&str; 8] = [
"youtube.com",
"googlevideo.com",
Expand Down Expand Up @@ -110,22 +111,10 @@ async fn index(req: HttpRequest) -> Result<HttpResponse, Box<dyn Error>> {
return Err("No host provided".into());
}

let rewrite = {
if let Some(rewrite) = query.get("rewrite") {
rewrite == "true"
} else {
true
}
};
let rewrite = query.get("rewrite") != Some("false");

#[cfg(feature = "avif")]
let avif = {
if let Some(avif) = query.get("avif") {
avif == "true"
} else {
false
}
};
let avif = query.get("avif") == Some("true");

let host = res.unwrap();
let domain = RE_DOMAIN.captures(host.as_str());
Expand All @@ -136,16 +125,7 @@ async fn index(req: HttpRequest) -> Result<HttpResponse, Box<dyn Error>> {

let domain = domain.unwrap().get(1).unwrap().as_str();

let mut allowed = false;

for allowed_domain in ALLOWED_DOMAINS.iter() {
if &domain == allowed_domain {
allowed = true;
break;
}
}

if !allowed {
if !ALLOWED_DOMAINS.contains(&domain) {
return Err("Domain not allowed".into());
}

Expand Down Expand Up @@ -187,7 +167,7 @@ async fn index(req: HttpRequest) -> Result<HttpResponse, Box<dyn Error>> {
}

if is_android {
request_headers.insert("User-Agent", "com.google.android.youtube/1537338816 (Linux; U; Android 13; en_US; ; Build/TQ2A.230505.002; Cronet/113.0.5672.24)".parse().unwrap());
request_headers.insert("User-Agent", ANDROID_USER_AGENT.parse().unwrap());
}

let resp = CLIENT.execute(request).await;
Expand Down

0 comments on commit 53329c4

Please sign in to comment.