mrfluffy/kami
1
0
Fork 0
mirror of https://github.com/mrfluffy-dev/kami.git synced 2026-01-17 12:50:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

she be working again

Browse Source
This commit is contained in:
Zastian Pretorius
2023-01-07 02:56:52 +00:00
parent e2b7f53da1
commit f39deb5321
3 changed files with 79 additions and 135 deletions
Download Patch File Download Diff File Expand all files Collapse all files

174
src/anime/scraper.rs
View File

@@ -1,7 +1,7 @@
use base64::{decode, encode};
use isahc::config::Configurable;
use isahc::{ReadResponseExt, Request, RequestExt};
use regex::Regex;
//use serde_json::json;
pub fn get_anime_html(url: &str) -> String {
let req = Request::builder()
@@ -16,126 +16,64 @@ pub fn get_anime_html(url: &str) -> String {
req.send().unwrap().text().unwrap()
}
pub fn get_ep_location(url: &str) -> String {
let request = Request::builder()
.method("HEAD")
.uri(url)
.header(
"user-agent",
"Mozilla/5.0 (X11; Linux x86_64; rv:99.0) Gecko/20100101 Firefox/100.0",
)
.body(())
.unwrap();
let response = request.send().unwrap();
let headers = response.headers();
let location = headers.get("location").unwrap();
location.to_str().unwrap().to_string()
pub fn get_post(id: &str) -> String {
let resp = Request::builder()
.method("POST")
.uri("https://yugen.to/api/embed/")
.header("x-requested-with", "XMLHttpRequest")
.body(id)
.unwrap()
.send()
.unwrap()
.text();
let resp: String = resp.as_ref().unwrap().to_string();
resp
}
pub fn anime_names(query: String) -> Vec<String> {
let url = format!("https://gogoanime.dk//search.html?keyword={}", query);
//relpace all spaces with %20
let url = url.replace(' ', "%20");
let html = get_anime_html(&url);
let re = Regex::new(r#"(?m)/category/([^"]*)"#).unwrap();
let mut anime_list: Vec<String> = Vec::new();
pub fn get_animes(query: String) -> (Vec<String>, Vec<String>) {
let query = query.replace(" ", "+");
let html = get_anime_html(&format!("https://yugen.to/search/?q={}", query));
let re = Regex::new(r#"href="(/anime[^"]*)""#).unwrap();
let mut animes_links = Vec::new();
for cap in re.captures_iter(&html) {
anime_list.push(cap.get(1).unwrap().as_str().trim().to_string());
animes_links.push(cap[1].to_string());
}
anime_list.dedup();
anime_list
}
pub fn get_anime_info(title: &str) -> (i32, u16) {
let url = format!("https://animixplay.to/v1/{}", title);
let html = get_anime_html(&url);
let re = Regex::new(r#"(?m)var malid = '([0-9]*)'"#).unwrap();
let mal_id = re
.captures_iter(&html)
.next()
.unwrap()
.get(1)
.unwrap()
.as_str()
.trim()
.to_string();
let re = Regex::new(r#"(?m)"eptotal":([\d]+)"#).unwrap();
let episodes = re
.captures_iter(&html)
.next()
.unwrap()
.get(1)
.unwrap()
.as_str()
.trim()
.to_string();
(
mal_id.parse::<i32>().unwrap_or(0),
episodes.parse::<u16>().unwrap_or(0),
)
}
pub fn anime_link(title: &str, ep: u64, provider: &str) -> (String, String) {
let url = format!("https://animixplay.to/v1/{}", title);
let html = get_anime_html(&url);
let re = Regex::new(r#"(?m)\?id=([^&]+)"#).unwrap();
let id1 = match re.captures_iter(&html).nth(ep as usize - 1) {
Some(cap) => cap.get(1).unwrap().as_str().trim().to_string(),
None => "".to_string(),
};
if id1 != "" {
if provider == "vrv" {
let title = format!("{} Episode {}", title.replace('-', " "), ep);
let encoded_id1 = encode(&id1);
let encoded_id2 = encode(&encoded_id1);
let mut last_byte = encoded_id1.as_bytes()[encoded_id1.len() - 2];
last_byte += 1;
let mut new_encoded_id1 = encoded_id1.as_bytes().to_vec();
new_encoded_id1.pop();
new_encoded_id1.pop();
new_encoded_id1.push(last_byte);
let new_encoded_id1 = String::from_utf8(new_encoded_id1).unwrap();
let ani_id = format!("cW9{}MVFhzM0dyVTh3ZTlP{}", new_encoded_id1, encoded_id2);
let result = get_ep_location(format!("https://animixplay.to/api/{}", ani_id).as_str());
//split the result into at # and return the second part
let result: String = std::str::from_utf8(
decode(result.split('#').nth(1).unwrap())
.unwrap()
.as_slice(),
)
.unwrap()
.to_string();
return (result, title);
} else if provider == "gogo" {
let title = format!("{} Episode {}", title.replace('-', " "), ep);
let encoded_id1 = encode(&id1);
let anime_id = encode(format!("{}LTXs3GrU8we9O{}", id1, encoded_id1));
let html = format!("https://animixplay.to/api/cW9{}", anime_id);
let url = get_ep_location(&html);
let url = url.split('#').nth(1).unwrap();
let url = std::str::from_utf8(&decode(url).unwrap())
.unwrap()
.to_string();
return (url, title);
} else {
panic!("Invalid provider");
}
} else {
let re = Regex::new(r#"(?m)r\.html#(.*)""#).unwrap();
let id2 = re
.captures_iter(&html)
.next()
.unwrap()
.get(1)
.unwrap()
.as_str()
.trim()
.to_string();
let url = decode(id2).unwrap();
let url = std::str::from_utf8(&url).unwrap().to_string();
let title = format!("{} Episode {}", title.replace('-', " "), ep);
return (url, title);
let re = Regex::new(r#"/" title="([^"]*)""#).unwrap();
let mut animes_names = Vec::new();
for cap in re.captures_iter(&html) {
animes_names.push(cap[1].to_string());
}
(animes_links, animes_names)
}
pub fn get_anime_info(url: &str) -> (i32, u16) {
let url = format!("https://yugen.to{}watch", url);
let html = get_anime_html(&url);
//print html and exit
let re = Regex::new(r#""mal_id":(\d*)"#).unwrap();
let mal_id = re.captures(&html).unwrap()[1].parse().unwrap();
let re =
Regex::new(r#"Episodes</div><span class="description" style="font-size: \d*px;">(\d*)"#)
.unwrap();
let episodes = re.captures(&html).unwrap()[1].parse().unwrap();
(mal_id, episodes)
}
pub fn get_anime_link(url: &str, episode: u64) -> String {
let url = &format!(
"https://yugen.to/watch{}{}/",
url.replace("/anime", ""),
episode
);
let html = get_anime_html(url);
let re = Regex::new(r#"iframe id="main-embed" src="https://yugen.to/e/(.*)=="#).unwrap();
let capture = re.captures(&html).unwrap();
let id = &capture[1];
let id = format!("id={}%3D%3D&ac=0", id);
let json = get_post(&id);
let re = Regex::new(r#"hls": \["(.*)","#).unwrap();
let capture = re.captures(&json).unwrap();
let link = &capture[1];
//return the link
link.to_string()
}