diff --git a/src/providers/mod.rs b/src/providers/mod.rs index 9c23004..5184bf1 100644 --- a/src/providers/mod.rs +++ b/src/providers/mod.rs @@ -37,6 +37,7 @@ pub mod pornzog; pub mod youjizz; pub mod beeg; pub mod tnaflix; +pub mod pornxp; // convenient alias pub type DynProvider = Arc; @@ -46,6 +47,7 @@ pub static ALL_PROVIDERS: Lazy> = Lazy::new(| m.insert("omgxxx", Arc::new(omgxxx::OmgxxxProvider::new()) as DynProvider); m.insert("beeg", Arc::new(beeg::BeegProvider::new()) as DynProvider); m.insert("tnaflix", Arc::new(tnaflix::TnaflixProvider::new()) as DynProvider); + m.insert("pornxp", Arc::new(pornxp::PornxpProvider::new()) as DynProvider); // add more here as you migrate them m }); diff --git a/src/providers/pornxp.rs b/src/providers/pornxp.rs new file mode 100644 index 0000000..63dd9b1 --- /dev/null +++ b/src/providers/pornxp.rs @@ -0,0 +1,266 @@ +use crate::DbPool; +use crate::api::ClientVersion; +use crate::providers::Provider; +use crate::status::*; +use crate::util::cache::VideoCache; +use crate::util::time::parse_time_to_seconds; +use crate::videos::{ServerOptions, VideoItem}; +use async_trait::async_trait; +use error_chain::error_chain; +use htmlentity::entity::{ICodedDataTrait, decode}; +// use std::sync::{Arc, RwLock}; +// use std::thread; +use std::vec; + +error_chain! { + foreign_links { + Io(std::io::Error); + HttpRequest(wreq::Error); + } +} + +#[derive(Debug, Clone)] +pub struct PornxpProvider { + url: String, +} +impl PornxpProvider { + pub fn new() -> Self { + let provider = PornxpProvider { + url: "https://pornxp.me".to_string(), + }; + provider + } + + fn build_channel(&self, clientversion: ClientVersion) -> Channel { + let _ = clientversion; + Channel { + id: "pornxpme".to_string(), + name: "PornXP".to_string(), + description: "For Those Who Know The Difference".to_string(), + premium: false, + favicon: "https://www.google.com/s2/favicons?sz=64&domain=pornxp.me".to_string(), + status: "active".to_string(), + categories: vec![], + options: vec![ + ChannelOption { + id: "sort".to_string(), + title: "Sort".to_string(), + description: "Sort the Videos".to_string(), + systemImage: "list.number".to_string(), + colorName: "blue".to_string(), + options: vec![ + FilterOption { + id: "new".into(), + title: "New".into(), + }, + FilterOption { + id: "best".into(), + title: "Best".into(), + }, + ], + multiSelect: false, + }, + ], + nsfw: true, + cacheDuration: None, + } + } + + async fn get( + &self, + cache: VideoCache, + page: u8, + sort: &str, + options: ServerOptions, + ) -> Result> { + let sort_string: String = match sort { + "best" => "best".to_string(), + _ => "new".to_string(), + }; + let video_url = format!( + "{}/{}?page={}", + self.url, sort_string, page + ); + let old_items = match cache.get(&video_url) { + Some((time, items)) => { + if time.elapsed().unwrap_or_default().as_secs() < 60 * 5 { + println!("Cache hit for URL: {}", video_url); + return Ok(items.clone()); + } else { + items.clone() + } + } + None => { + vec![] + } + }; + + let mut requester = options.requester.clone().unwrap(); + let text = requester.get(&video_url).await.unwrap(); + let video_items: Vec = self.get_video_items_from_html(text.clone()); + if !video_items.is_empty() { + cache.remove(&video_url); + cache.insert(video_url.clone(), video_items.clone()); + } else { + return Ok(old_items); + } + Ok(video_items) + } + + async fn query( + &self, + cache: VideoCache, + page: u8, + query: &str, + sort: &str, + options: ServerOptions, + ) -> Result> { + let search_string = query.to_string().to_lowercase().trim().to_string(); + + let sort_string: String = match sort { + "best" => "".to_string(), + _ => "&sort=new".to_string(), + }; + let video_url = format!( + "{}/tags/{}?page={}{}", + self.url, search_string, page, sort_string + ); + // Check our Video Cache. If the result is younger than 1 hour, we return it. + let old_items = match cache.get(&video_url) { + Some((time, items)) => { + if time.elapsed().unwrap_or_default().as_secs() < 60 * 5 { + return Ok(items.clone()); + } else { + let _ = cache.check().await; + return Ok(items.clone()); + } + } + None => { + vec![] + } + }; + + let mut requester = options.requester.clone().unwrap(); + + let text = requester.get(&video_url).await.unwrap(); + let video_items: Vec = self.get_video_items_from_html(text.clone()); + if !video_items.is_empty() { + cache.remove(&video_url); + cache.insert(video_url.clone(), video_items.clone()); + } else { + return Ok(old_items); + } + Ok(video_items) + } + + fn get_video_items_from_html(&self, html: String) -> Vec { + if html.is_empty() { + println!("HTML is empty"); + return vec![]; + } + let mut items: Vec = Vec::new(); + let raw_videos = html.split("id=\"pages\"").collect::>()[0] + .split("
>()[1] + .split("
") + .collect::>()[1..] + .to_vec(); + for video_segment in &raw_videos { + // let vid = video_segment.split("\n").collect::>(); + // for (index, line) in vid.iter().enumerate() { + // println!("Line {}: {}", index, line); + // } + let video_url: String = format!("{}{}", self.url, video_segment.split(">()[1] + .split("\"") + .collect::>()[0] + .to_string()); + let mut title = video_segment + .split("
") + .collect::>()[1] + .split("<") + .collect::>()[0] + .trim() + .to_string(); + // html decode + title = decode(title.as_bytes()).to_string().unwrap_or(title); + let id = video_url.split("/").collect::>()[4].to_string(); + + let thumb = format!("https:{}", video_segment.split(">()[1] + .split("src=\"").collect::>()[1] + .split("\"") + .collect::>()[0] + .to_string()); + let raw_duration = video_segment + .split("