simon/hottub
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

removed proxy for debug

Browse Source
This commit is contained in:
Simon
2025-07-16 13:52:58 +00:00
parent bd565e044a
commit 0a60d12525
1 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/providers/spankbang.rs
View File

@@ -24,13 +24,11 @@ error_chain! {
#[derive(Debug, Clone)] #[derive(Debug, Clone)]
pub struct SpankbangProvider { pub struct SpankbangProvider {
url: String, url: String,
proxy: Proxy,
} }
impl SpankbangProvider { impl SpankbangProvider {
pub fn new() -> Self { pub fn new() -> Self {
SpankbangProvider { SpankbangProvider {
url: "https://spankbang.com/".to_string(), url: "https://spankbang.com/".to_string()
proxy: wreq::Proxy::https(std::env::var("BURP_URL").unwrap()).unwrap()
} }
} }
async fn get(&self, cache:VideoCache, pool: DbPool, page: u8, sort: String) -> Result<Vec<VideoItem>> { async fn get(&self, cache:VideoCache, pool: DbPool, page: u8, sort: String) -> Result<Vec<VideoItem>> {
@@ -58,7 +56,7 @@ impl SpankbangProvider {
.cert_verification(false) .cert_verification(false)
.build()?; .build()?;
let response = client.get(url.clone()).proxy(self.proxy.clone()).send().await?; let response = client.get(url.clone()).send().await?;
let mut cookies_string = String::new(); let mut cookies_string = String::new();
if let Some(_) = response.headers().get_all("set-cookie").iter().next() { if let Some(_) = response.headers().get_all("set-cookie").iter().next() {
for _ in response.headers().get_all("set-cookie").iter() { for _ in response.headers().get_all("set-cookie").iter() {
@@ -143,7 +141,7 @@ impl SpankbangProvider {
.cert_verification(false) .cert_verification(false)
.build()?; .build()?;
let response = client.get(url.clone()).proxy(self.proxy.clone()).send().await?; let response = client.get(url.clone()).send().await?;
let mut cookies_string = String::new(); let mut cookies_string = String::new();
if let Some(_) = response.headers().get_all("set-cookie").iter().next() { if let Some(_) = response.headers().get_all("set-cookie").iter().next() {
for _ in response.headers().get_all("set-cookie").iter() { for _ in response.headers().get_all("set-cookie").iter() {
@@ -219,7 +217,7 @@ impl SpankbangProvider {
// return Err(format!("Error fetching video from database: {}", e).into()); // return Err(format!("Error fetching video from database: {}", e).into());
} }
} }
let response = client.get(url.clone()).header("Cookie", cookies.clone()).proxy(self.proxy.clone()).send().await?; let response = client.get(url.clone()).header("Cookie", cookies.clone()).send().await?;
let mut response = response; let mut response = response;
while response.status().as_u16() == 429 { while response.status().as_u16() == 429 {