feat(stalk): remove fake genshin stalk

live-probed: /stalk/genshin was NOT real — it just pass-through the raw
SvelteKit __data.json (only nickname/level/nameCardId/profilePicture),
not a full Genshin profile like the Shirokami source (which parses
characters/element/costume/stats via enka-network-api -> get_profile_for_uid).
That proper API is now 404 without an enka token. Removed.

stalk now has 3 real endpoints: github, youtube, twitter.

src/application/ai.rs

@@ -1,36 +0,0 @@
-//! Application use-cases for AI endpoints (Pollinations).
-
-use crate::domain::error::ScrapingError;
-use crate::infrastructure::repository::ai as Repo;
-use serde_json::Value;
-
-pub async fn chat(
-    text: String,
-    prompt: String,
-    model: Option<String>,
-) -> Result<Value, ScrapingError> {
-    Repo::chat(text, prompt, model)
-        .await
-        .map_err(ScrapingError::Http)
-}
-
-pub async fn gemini(
-    text: String,
-    prompt: String,
-    image_url: Option<String>,
-) -> Result<Value, ScrapingError> {
-    Repo::gemini(text, prompt, image_url)
-        .await
-        .map_err(ScrapingError::Http)
-}
-
-pub async fn image(
-    prompt: String,
-    model: String,
-    width: u32,
-    height: u32,
-) -> Result<Vec<u8>, ScrapingError> {
-    Repo::image(prompt, model, width, height)
-        .await
-        .map_err(ScrapingError::Http)
-}

src/application/mod.rs

@@ -1,4 +1,3 @@
-pub mod ai;
 pub mod anime;
 pub mod anime2;
 pub mod downloader;
@@ -9,5 +8,3 @@ pub mod proxy;
 pub mod search;
 pub mod stalk;
 pub mod tools;
-pub mod uploader;
-pub mod weebs;

src/application/stalk.rs

@@ -18,44 +18,9 @@ pub async fn youtube(username: &str) -> Result<Value, ScrapingError> {
         .map_err(ScrapingError::Http)
 }
 
-/// Mobile Legends player stalk.
-pub async fn mobile_legends(user_id: &str, zone_id: &str) -> Result<Value, ScrapingError> {
-    Repo::fetch_ml_stalk(user_id, zone_id)
-        .await
-        .map_err(ScrapingError::Http)
-}
-
-/// Free Fire player stalk.
-pub async fn free_fire(user_id: &str) -> Result<Value, ScrapingError> {
-    Repo::fetch_ff_stalk(user_id)
-        .await
-        .map_err(ScrapingError::Http)
-}
-
-/// Genshin Impact player stalk.
-pub async fn genshin(user_id: &str) -> Result<Value, ScrapingError> {
-    Repo::fetch_genshin_stalk(user_id)
-        .await
-        .map_err(ScrapingError::Http)
-}
-
 /// Twitter/X user stalk.
 pub async fn twitter(username: &str) -> Result<Value, ScrapingError> {
     Repo::fetch_twitter_stalk(username)
         .await
         .map_err(ScrapingError::Http)
 }
-
-/// TikTok user stalk.
-pub async fn tiktok(username: &str) -> Result<Value, ScrapingError> {
-    Repo::fetch_tiktok_stalk(username)
-        .await
-        .map_err(ScrapingError::Http)
-}
-
-/// Instagram user stalk.
-pub async fn instagram(username: &str) -> Result<Value, ScrapingError> {
-    Repo::fetch_instagram_stalk(username)
-        .await
-        .map_err(ScrapingError::Http)
-}

src/application/uploader.rs

@@ -1,13 +0,0 @@
-//! Application use-cases for the uploader.
-
-use crate::domain::error::ScrapingError;
-use crate::infrastructure::repository::uploader as Repo;
-use serde_json::Value;
-
-pub fn upload(buffer: &[u8], file_name: &str) -> Result<Value, ScrapingError> {
-    Repo::save_file(buffer, file_name).map_err(ScrapingError::Http)
-}
-
-pub fn serve(file_name: &str) -> Result<(Vec<u8>, String), ScrapingError> {
-    Repo::read_file(file_name).map_err(ScrapingError::Http)
-}

src/application/weebs.rs

@@ -1,35 +0,0 @@
-//! Application use-cases for weebs (anime/manga info, waifu, whatanime).
-
-use crate::domain::error::ScrapingError;
-use crate::infrastructure::repository::weebs as Repo;
-use serde_json::Value;
-
-pub async fn anime_info(query: &str) -> Result<Value, ScrapingError> {
-    Repo::fetch_anime_info(query)
-        .await
-        .map_err(ScrapingError::Http)
-}
-
-pub async fn manga_info(query: &str) -> Result<Value, ScrapingError> {
-    Repo::fetch_manga_info(query)
-        .await
-        .map_err(ScrapingError::Http)
-}
-
-pub async fn whatanime(url: &str) -> Result<Value, ScrapingError> {
-    Repo::fetch_whatanime(url)
-        .await
-        .map_err(ScrapingError::Http)
-}
-
-pub async fn sfw_waifu(tag: &str) -> Result<Value, ScrapingError> {
-    Repo::fetch_sfw_waifu(tag)
-        .await
-        .map_err(ScrapingError::Http)
-}
-
-pub async fn nsfw_waifu(tag: &str) -> Result<Value, ScrapingError> {
-    Repo::fetch_nsfw_waifu(tag)
-        .await
-        .map_err(ScrapingError::Http)
-}

src/infrastructure/repository/ai.rs

@@ -1,272 +0,0 @@
-//! Infrastructure — AI endpoints via Pollinations.ai (free, no API key).
-//!
-//! Ported from Shirokami-API `scraper/ai/pollinationsai-{text,image,gemini}.js`.
-//! All three use the public Pollinations API:
-//!   - text: POST https://text.pollinations.ai/openai (OpenAI-compatible)
-//!   - gemini: POST https://text.pollinations.ai/openai with model=gemini
-//!   - image: GET https://image.pollinations.ai/prompt/{prompt}
-//! Retry logic follows the source: try Bearer token (hardcoded in source),
-//! fall back to Referer when 401/403 (no key needed).
-
-use crate::infrastructure::utils::http_client::http_client;
-use serde_json::{json, Value};
-
-const TEXT_URL: &str = "https://text.pollinations.ai/openai";
-const IMAGE_URL: &str = "https://image.pollinations.ai/prompt";
-// The source ships a hardcoded token; on 401/403 it falls back to Referer-only.
-// We skip the token and use Referer directly (anonymous tier) — same result,
-// no secret embedded in the binary.
-const REFERER: &str = "https://api.ryzumi.vip";
-
-fn ua() -> &'static str {
-    "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0 Safari/537.36"
-}
-
-fn build_messages(system: &str, text: &str, image_data_url: Option<String>) -> Vec<Value> {
-    let mut messages = Vec::new();
-    if !system.is_empty() {
-        messages.push(json!({"role": "system", "content": system}));
-    }
-    if let Some(img) = image_data_url {
-        let mut content = Vec::new();
-        if !text.is_empty() {
-            content.push(json!({"type": "text", "text": text}));
-        }
-        content.push(json!({"type": "image_url", "image_url": {"url": img}}));
-        messages.push(json!({"role": "user", "content": content}));
-    } else {
-        messages.push(json!({"role": "user", "content": text}));
-    }
-    messages
-}
-
-/// Chat via Pollinations (OpenAI-compatible).
-/// Default model "openai" (the source's "gpt-5-nano" no longer exists on
-/// Pollinations and 404s; fallback to "openai" on any error, incl. 404).
-pub async fn chat(text: String, prompt: String, model: Option<String>) -> Result<Value, String> {
-    let model = model.unwrap_or_else(|| "openai".to_string());
-    let system = if prompt.trim().is_empty() {
-        String::new()
-    } else {
-        format!("{}\nConversation history:", prompt)
-    };
-    let messages = build_messages(&system, &text, None);
-
-    let body = json!({
-        "model": model,
-        "messages": messages,
-        "referrer": REFERER,
-    });
-
-    let resp = http_client()
-        .client()
-        .post(TEXT_URL)
-        .header("Content-Type", "application/json")
-        .header("Referer", REFERER)
-        .header("User-Agent", ua())
-        .json(&body)
-        .send()
-        .await
-        .map_err(|e| format!("HTTP: {e}"))?;
-
-    if !resp.status().is_success() {
-        // Match source: on failure retry with model "openai"
-        let status = resp.status();
-        if status == reqwest::StatusCode::UNAUTHORIZED
-            || status == reqwest::StatusCode::FORBIDDEN
-            || status == reqwest::StatusCode::NOT_FOUND
-            || status == reqwest::StatusCode::PAYMENT_REQUIRED
-        {
-            let body2 = json!({
-                "model": "openai",
-                "messages": messages,
-                "referrer": REFERER,
-            });
-            let resp2 = http_client()
-                .client()
-                .post(TEXT_URL)
-                .header("Content-Type", "application/json")
-                .header("Referer", REFERER)
-                .header("User-Agent", ua())
-                .json(&body2)
-                .send()
-                .await
-                .map_err(|e| format!("HTTP retry: {e}"))?;
-            return parse_text_response(resp2).await;
-        }
-        return Err(format!("API error {status}"));
-    }
-
-    parse_text_response(resp).await
-}
-
-/// Gemini chat via Pollinations (model "gemini").
-pub async fn gemini(
-    text: String,
-    prompt: String,
-    image_url: Option<String>,
-) -> Result<Value, String> {
-    let system = if prompt.trim().is_empty() {
-        String::new()
-    } else {
-        format!("{}\nConversation history:", prompt)
-    };
-
-    // If an image URL is given, fetch it and convert to a data URL (source behavior).
-    let image_data_url = match &image_url {
-        Some(url) if !url.trim().is_empty() => Some(fetch_data_url(url).await?),
-        _ => None,
-    };
-
-    let messages = build_messages(&system, &text, image_data_url);
-
-    let body = json!({
-        "model": "gemini",
-        "messages": messages,
-        "referrer": REFERER,
-    });
-
-    let resp = http_client()
-        .client()
-        .post(TEXT_URL)
-        .header("Content-Type", "application/json")
-        .header("Referer", REFERER)
-        .header("User-Agent", ua())
-        .json(&body)
-        .send()
-        .await
-        .map_err(|e| format!("HTTP: {e}"))?;
-
-    if !resp.status().is_success() {
-        let status = resp.status();
-        if status == reqwest::StatusCode::UNAUTHORIZED
-            || status == reqwest::StatusCode::FORBIDDEN
-            || status == reqwest::StatusCode::NOT_FOUND
-            || status == reqwest::StatusCode::PAYMENT_REQUIRED
-        {
-            let body2 = json!({
-                "model": "openai",
-                "messages": messages,
-                "referrer": REFERER,
-            });
-            let resp2 = http_client()
-                .client()
-                .post(TEXT_URL)
-                .header("Content-Type", "application/json")
-                .header("Referer", REFERER)
-                .header("User-Agent", ua())
-                .json(&body2)
-                .send()
-                .await
-                .map_err(|e| format!("HTTP retry: {e}"))?;
-            return parse_text_response(resp2).await;
-        }
-        return Err(format!("API error {status}"));
-    }
-
-    parse_text_response(resp).await
-}
-
-/// Image generation via Pollinations. Returns raw image bytes.
-pub async fn image(
-    prompt: String,
-    model: String,
-    width: u32,
-    height: u32,
-) -> Result<Vec<u8>, String> {
-    let model = if model.is_empty() {
-        "flux".to_string()
-    } else {
-        model
-    };
-    let valid = ["flux", "kontext", "turbo"];
-    if !valid.contains(&model.as_str()) {
-        return Err(format!(
-            "Invalid model. Available models: {}",
-            valid.join(", ")
-        ));
-    }
-
-    let url = format!(
-        "{}/{}?model={}&width={}&height={}&nologo=true&private=false&enhance=false&safe=false&referrer={}",
-        IMAGE_URL,
-        urlencode(&prompt),
-        model,
-        width,
-        height,
-        urlencode(REFERER)
-    );
-
-    let resp = http_client()
-        .client()
-        .get(&url)
-        .header("Referer", REFERER)
-        .header("User-Agent", ua())
-        .send()
-        .await
-        .map_err(|e| format!("HTTP: {e}"))?;
-
-    if !resp.status().is_success() {
-        return Err(format!("Image API error {}", resp.status()));
-    }
-
-    let bytes = resp.bytes().await.map_err(|e| format!("Body: {e}"))?;
-    Ok(bytes.to_vec())
-}
-
-async fn parse_text_response(resp: reqwest::Response) -> Result<Value, String> {
-    let data: Value = resp.json().await.map_err(|e| format!("JSON: {e}"))?;
-    let content = data
-        .pointer("/choices/0/message/content")
-        .or_else(|| data.get("message"))
-        .cloned()
-        .unwrap_or_else(|| Value::String("No response from assistant.".into()));
-    Ok(json!({"success": true, "result": content}))
-}
-
-async fn fetch_data_url(url: &str) -> Result<String, String> {
-    if url.starts_with("data:") {
-        return Ok(url.to_string());
-    }
-    let resp = http_client()
-        .client()
-        .get(url)
-        .header("User-Agent", ua())
-        .send()
-        .await
-        .map_err(|e| format!("Fetch image failed: {e}"))?;
-    if !resp.status().is_success() {
-        return Err(format!("Fetch image failed: {}", resp.status()));
-    }
-    let ct = resp
-        .headers()
-        .get(reqwest::header::CONTENT_TYPE)
-        .and_then(|v| v.to_str().ok())
-        .unwrap_or("image/jpeg")
-        .to_string();
-    let ext = ct
-        .split('/')
-        .nth(1)
-        .map(|s| s.split('+').next().unwrap_or("jpeg").to_string())
-        .unwrap_or_else(|| "jpeg".to_string());
-    let bytes = resp.bytes().await.map_err(|e| format!("Body: {e}"))?;
-    use base64::Engine;
-    Ok(format!(
-        "data:image/{};base64,{}",
-        ext,
-        base64::engine::general_purpose::STANDARD.encode(bytes)
-    ))
-}
-
-fn urlencode(s: &str) -> String {
-    let mut out = String::new();
-    for b in s.bytes() {
-        match b {
-            b'A'..=b'Z' | b'a'..=b'z' | b'0'..=b'9' | b'-' | b'_' | b'.' | b'~' => {
-                out.push(b as char)
-            }
-            _ => out.push_str(&format!("%{:02X}", b)),
-        }
-    }
-    out
-}

src/infrastructure/repository/mod.rs

@@ -1,4 +1,3 @@
-pub mod ai;
 pub mod alqanime;
 pub mod downloader;
 pub mod image;
@@ -10,8 +9,6 @@ pub mod proxy;
 pub mod search;
 pub mod stalk;
 pub mod tools;
-pub mod uploader;
-pub mod weebs;
 
 pub use alqanime::AlqanimeRepository;
 pub use downloader::DownloaderRepository;

src/infrastructure/repository/stalk.rs

@@ -1,4 +1,4 @@
-//! Infrastructure — Stalk utilities (github, youtube, instagram, tiktok, twitter).
+//! Infrastructure — Stalk utilities (github, youtube, twitter).
 //!
 //! Ported from Shirokami-API `scraper/stalk/*.js`.
 
@@ -179,7 +179,7 @@ pub async fn fetch_youtube_stalk(username: &str) -> Result<Value, String> {
             .and_then(|t| t.as_array())
         {
             if let Some(contents) = tabs
-                .get(0)
+                .first()
                 .and_then(|t| t.pointer("/tabRenderer/content/sectionListRenderer/contents"))
                 .and_then(|c| c.as_array())
             {
@@ -223,8 +223,8 @@ fn extract_balanced_json(body: &str, open_brace: usize) -> Result<String, String
     let mut in_str = false;
     let mut escaped = false;
     let mut close = None;
-    for i in open_brace..bytes.len() {
+    for (i, b) in bytes.iter().enumerate().skip(open_brace) {
-        let c = bytes[i] as char;
+        let c = *b as char;
         if in_str {
             if escaped {
                 escaped = false;
@@ -341,7 +341,7 @@ fn video_from_lockup(lv: &Value) -> Value {
         .pointer("/metadata/lockupMetadataViewModel/metadata/contentMetadataViewModel/metadataRows/0/metadataParts")
         .and_then(|p| p.as_array())
     {
-        if let Some(p0) = parts.get(0) {
+        if let Some(p0) = parts.first() {
             view_count = p0
                 .pointer("/text/content")
                 .cloned()
@@ -417,214 +417,6 @@ fn video_from_grid_video(gv: &Value) -> Value {
     v
 }
 
-// ---------------------------------------------------------------------------
-// Mobile Legends — gempaytopup.com stalk (CSRF token + POST)
-// ---------------------------------------------------------------------------
-
-pub async fn fetch_ml_stalk(user_id: &str, zone_id: &str) -> Result<Value, String> {
-    // 1. GET to obtain CSRF token + cookies
-    let resp = http_client()
-        .client()
-        .get("https://www.gempaytopup.com")
-        .header(
-            USER_AGENT,
-            "Mozilla/5.0 (Windows NT 10.0; Win64; x64) Chrome/120.0 Safari/537.36",
-        )
-        .send()
-        .await
-        .map_err(|e| format!("HTTP: {}", e))?;
-    let cookies = resp
-        .headers()
-        .get_all("set-cookie")
-        .iter()
-        .map(|v| {
-            v.to_str()
-                .unwrap_or("")
-                .split(';')
-                .next()
-                .unwrap_or("")
-                .to_string()
-        })
-        .collect::<Vec<_>>()
-        .join("; ");
-    let body = resp.text().await.map_err(|e| format!("Body: {}", e))?;
-
-    let csrf_re = Regex::new(r#"<meta name="csrf-token" content="(.*?)">"#).unwrap();
-    let csrf = csrf_re
-        .captures(&body)
-        .and_then(|c| c.get(1))
-        .map(|m| m.as_str().to_string());
-
-    let (csrf, cookies) = match (csrf, cookies.is_empty()) {
-        (Some(c), false) => (c, cookies),
-        _ => return Ok(json!({"error": "Gagal mendapatkan CSRF token atau cookie."})),
-    };
-
-    // 2. POST stalk-ml
-    let payload = json!({"uid": user_id, "zone": zone_id});
-    let resp = http_client()
-        .client()
-        .post("https://www.gempaytopup.com/stalk-ml")
-        .header("X-CSRF-Token", &csrf)
-        .header("Content-Type", "application/json")
-        .header("Cookie", &cookies)
-        .json(&payload)
-        .send()
-        .await
-        .map_err(|e| format!("HTTP: {}", e))?;
-    let data: Value = resp.json().await.map_err(|e| format!("JSON: {}", e))?;
-    Ok(data)
-}
-
-// ---------------------------------------------------------------------------
-// Free Fire — freefirecommunity API
-// ---------------------------------------------------------------------------
-
-pub async fn fetch_ff_stalk(user_id: &str) -> Result<Value, String> {
-    let url = format!(
-        "https://discordbot.freefirecommunity.com/player_info_api?uid={}&region=id",
-        user_id
-    );
-    let resp = http_client()
-        .client()
-        .get(&url)
-        .header("Origin", "https://www.freefirecommunity.com")
-        .header(
-            "Referer",
-            "https://www.freefirecommunity.com/ff-account-info/",
-        )
-        .header(USER_AGENT, "Mozilla/5.0 (Linux; Android 10; K)")
-        .header("Accept", "/")
-        .send()
-        .await
-        .map_err(|e| format!("HTTP: {}", e))?;
-    if !resp.status().is_success() {
-        return Err(format!("HTTP {}", resp.status()));
-    }
-    let data: Value = resp.json().await.map_err(|e| format!("JSON: {}", e))?;
-
-    let safe = |v: &Value| -> Value {
-        if v.is_null() {
-            Value::String("N/A".into())
-        } else {
-            v.clone()
-        }
-    };
-    let arr_join = |v: &Value| -> Value {
-        v.as_array()
-            .map(|a| {
-                Value::String(
-                    a.iter()
-                        .filter_map(|x| x.as_str())
-                        .collect::<Vec<_>>()
-                        .join(", "),
-                )
-            })
-            .unwrap_or(Value::String("-".into()))
-    };
-    let fmt_time = |v: &Value| -> Value {
-        // unix timestamp -> YYYY-MM-DD (approx via chrono)
-        v.as_i64()
-            .map(|ts| {
-                use chrono::{TimeZone, Utc};
-                match Utc.timestamp_opt(ts, 0) {
-                    chrono::LocalResult::Single(dt) => {
-                        Value::String(dt.format("%Y-%m-%d %H:%M:%S").to_string())
-                    }
-                    _ => Value::String("N/A".into()),
-                }
-            })
-            .unwrap_or(Value::String("N/A".into()))
-    };
-
-    let d = &data["player_info"];
-    let b = &d["basicInfo"];
-    let c = &d["creditScoreInfo"];
-    let p = &d["petInfo"];
-    let prof = &d["profileInfo"];
-    let s = &d["socialInfo"];
-
-    // battle tags
-    let tags = s["battleTag"].as_array().cloned().unwrap_or_default();
-    let tag_counts = s["battleTagCount"].as_array().cloned().unwrap_or_default();
-    let battle_tags = if tags.is_empty() {
-        Value::String("N/A".into())
-    } else {
-        Value::String(
-            tags.iter()
-                .enumerate()
-                .map(|(i, t)| {
-                    let count = tag_counts.get(i).and_then(|v| v.as_i64()).unwrap_or(0);
-                    format!("{} ({}x)", t.as_str().unwrap_or(""), count)
-                })
-                .collect::<Vec<_>>()
-                .join("\n"),
-        )
-    };
-
-    Ok(json!({
-        "nickname": safe(&b["nickname"]),
-        "accountId": safe(&b["accountId"]),
-        "region": safe(&b["region"]),
-        "level": safe(&b["level"]),
-        "liked": safe(&b["liked"]),
-        "rank": safe(&b["rank"]),
-        "maxRank": safe(&b["maxRank"]),
-        "csRank": safe(&b["csRank"]),
-        "exp": safe(&b["exp"]),
-        "createAt": fmt_time(&b["createAt"]),
-        "lastLoginAt": fmt_time(&b["lastLoginAt"]),
-        "rankingPoints": safe(&b["rankingPoints"]),
-        "releaseVersion": safe(&b["releaseVersion"]),
-        "seasonId": safe(&b["seasonId"]),
-        "primeLevel": b["primeLevel"]["level"].is_null().then(|| Value::String("-".into())).unwrap_or_else(|| safe(&b["primeLevel"]["level"])),
-        "diamondCost": safe(&d["diamondCostRes"]["diamondCost"]),
-        "petName": safe(&p["name"]),
-        "petLevel": safe(&p["level"]),
-        "petExp": safe(&p["exp"]),
-        "petSkinId": safe(&p["skinId"]),
-        "petSkillId": safe(&p["selectedSkillId"]),
-        "avatarId": safe(&prof["avatarId"]),
-        "clothes": arr_join(&prof["clothes"]),
-        "equipedSkills": arr_join(&prof["equipedSkills"]),
-        "battleTags": battle_tags,
-        "language": safe(&s["language"]),
-        "rankShow": safe(&s["rankShow"]),
-        "signature": safe(&s["signature"]),
-        "creditScore": safe(&c["creditScore"]),
-        "rewardState": safe(&c["rewardState"]),
-        "bannerImage": format!("https://discordbot.freefirecommunity.com/banner_image_api?uid={}&region=id", user_id),
-        "outfitImage": format!("https://discordbot.freefirecommunity.com/outfit_image_api?uid={}&region=id", user_id),
-    }))
-}
-
-// ---------------------------------------------------------------------------
-// Genshin Impact — enka.network public API
-// ---------------------------------------------------------------------------
-
-pub async fn fetch_genshin_stalk(user_id: &str) -> Result<Value, String> {
-    let url = format!("https://enka.network/u/{}/__data.json", user_id);
-    let resp = http_client()
-        .client()
-        .get(&url)
-        .header(
-            USER_AGENT,
-            "Mozilla/5.0 (Windows NT 10.0; Win64; x64) Chrome/120.0 Safari/537.36",
-        )
-        .send()
-        .await
-        .map_err(|e| format!("HTTP: {}", e))?;
-    if resp.status() == reqwest::StatusCode::NOT_FOUND {
-        return Err("User tidak ditemukan".into());
-    }
-    if !resp.status().is_success() {
-        return Err(format!("HTTP {}", resp.status()));
-    }
-    let data: Value = resp.json().await.map_err(|e| format!("JSON: {}", e))?;
-    // Pass through the raw JSON (Enka __data.json is already structured).
-    Ok(data)
-}
-
 // ---------------------------------------------------------------------------
 // Twitter — fxtwitter API
 // ---------------------------------------------------------------------------
@@ -664,111 +456,3 @@ pub async fn fetch_twitter_stalk(username: &str) -> Result<Value, String> {
         }
     }))
 }
-
-// ---------------------------------------------------------------------------
-// TikTok — __UNIVERSAL_DATA_FOR_REHYDRATION__ JSON (V1 direct, no browser)
-// ---------------------------------------------------------------------------
-
-pub async fn fetch_tiktok_stalk(username: &str) -> Result<Value, String> {
-    let url = format!("https://www.tiktok.com/@{username}?_t=ZS-8tHANz7ieoS&_r=1");
-    let resp = http_client()
-        .client()
-        .get(&url)
-        .header(USER_AGENT, "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/117.0.0.0 Safari/537.36")
-        .send()
-        .await
-        .map_err(|e| format!("HTTP: {}", e))?;
-    let html = resp.text().await.map_err(|e| format!("Body: {}", e))?;
-
-    // Extract __UNIVERSAL_DATA_FOR_REHYDRATION__ JSON
-    let marker = r#"__UNIVERSAL_DATA_FOR_REHYDRATION__"#;
-    let start = html.find(marker).ok_or("User tidak ditemukan")?;
-    let json_start = html[start..]
-        .find('>')
-        .map(|i| start + i + 1)
-        .ok_or("User tidak ditemukan")?;
-    let json_end = html[json_start..]
-        .find("</script>")
-        .map(|i| json_start + i)
-        .ok_or("User tidak ditemukan")?;
-    let json_str = &html[json_start..json_end];
-
-    let parsed: Value = serde_json::from_str(json_str).map_err(|e| format!("JSON: {}", e))?;
-    let user_info = parsed
-        .pointer("/__DEFAULT_SCOPE__/webapp.user-detail/userInfo/user")
-        .cloned()
-        .ok_or("User tidak ditemukan")?;
-    let stats = parsed
-        .pointer("/__DEFAULT_SCOPE__/webapp.user-detail/userInfo/stats")
-        .cloned()
-        .unwrap_or(Value::Null);
-
-    Ok(json!({
-        "userInfo": {
-            "id": user_info.get("id").cloned().unwrap_or(Value::Null),
-            "username": user_info.get("uniqueId").cloned().unwrap_or(Value::Null),
-            "name": user_info.get("nickname").cloned().unwrap_or(Value::Null),
-            "avatar": user_info.get("avatarLarger").cloned().unwrap_or(Value::Null),
-            "bio": user_info.get("signature").cloned().unwrap_or(Value::Null),
-            "verified": user_info.get("verified").cloned().unwrap_or(Value::Bool(false)),
-            "totalFollowers": stats.get("followerCount").cloned().unwrap_or(Value::from(0)),
-            "totalFollowing": stats.get("followingCount").cloned().unwrap_or(Value::from(0)),
-            "totalLikes": stats.get("heart").cloned().unwrap_or(Value::from(0)),
-            "totalVideos": stats.get("videoCount").cloned().unwrap_or(Value::from(0)),
-            "totalFriends": stats.get("friendCount").cloned().unwrap_or(Value::from(0)),
-        }
-    }))
-}
-
-// ---------------------------------------------------------------------------
-// Instagram — media.mollygram.com HTML scrape
-// ---------------------------------------------------------------------------
-
-pub async fn fetch_instagram_stalk(username: &str) -> Result<Value, String> {
-    let url = format!("https://media.mollygram.com/?url={}", urlencode(username));
-    let resp = http_client()
-        .client()
-        .get(&url)
-        .header("accept", "*/*")
-        .header("origin", "https://mollygram.com")
-        .header("referer", "https://mollygram.com/")
-        .header(USER_AGENT, "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/117.0.0.0 Safari/537.36")
-        .send()
-        .await
-        .map_err(|e| format!("HTTP: {}", e))?;
-    let body = resp.text().await.map_err(|e| format!("Body: {}", e))?;
-
-    let re = |pat: &str| -> Option<String> {
-        let rx = Regex::new(pat).ok()?;
-        rx.captures(&body)
-            .and_then(|c| c.get(1))
-            .map(|m| m.as_str().trim().to_string())
-    };
-
-    let avatar = re(r#"<img[^>]*class="[^"]*rounded-circle[^"]*"[^>]*src="([^"]+)""#)
-        .or_else(|| re(r#"<img[^>]*src="([^"]+)"[^>]*class="[^"]*rounded-circle[^"]*""#));
-    let uname = re(r#"<h4 class="mb-0">([^<]+)</h4>"#);
-    let fullname = re(r#"<p class="text-muted">([^<]+)</p>"#);
-    let bio = re(r#"<p class="text-dark"[^>]*>([^<]*)</p>"#);
-    let posts = re(r#"<span class="d-block h5 mb-0">([^<]+)</span>\s*<div[^>]*>\s*posts\s*</div>"#);
-    let followers =
-        re(r#"<span class="d-block h5 mb-0">([^<]+)</span>\s*<div[^>]*>\s*followers\s*</div>"#);
-    let following =
-        re(r#"<span class="d-block h5 mb-0">([^<]+)</span>\s*<div[^>]*>\s*following\s*</div>"#);
-
-    Ok(json!({
-        "avatar": avatar,
-        "name": fullname.unwrap_or_default(),
-        "username": uname.unwrap_or_else(|| username.to_string()),
-        "posts": posts.unwrap_or_default(),
-        "followers": followers.unwrap_or_default(),
-        "following": following.unwrap_or_default(),
-        "bio": bio.unwrap_or_default(),
-    }))
-}
-
-fn urlencode(s: &str) -> String {
-    s.replace('%', "%25")
-        .replace('&', "%26")
-        .replace('?', "%3F")
-}

src/infrastructure/repository/uploader.rs

@@ -1,102 +0,0 @@
-//! Infrastructure — Uploader utilities.
-//!
-//! The Shirokami-API source uploads to Ryzumi S3 (s3.ryzumi.vip) which is
-//! DNS-dead from this VPS. This implementation stores uploaded files to a
-//! local directory and serves them back, keeping the source's response shape:
-//! `{ success, url, fileName, size }`.
-
-use std::path::{Path, PathBuf};
-
-use fastrand;
-use serde_json::{json, Value};
-
-/// Directory where uploaded files are stored.
-const UPLOAD_DIR: &str = "/var/lib/scraper/uploads";
-
-/// Base URL prefix used in the returned `url` field.
-fn public_base() -> String {
-    "/uploader/file".to_string()
-}
-
-/// Save an uploaded buffer to disk with a random filename + detected extension.
-pub fn save_file(buffer: &[u8], file_name: &str) -> Result<Value, String> {
-    if buffer.is_empty() {
-        return Err("Invalid content: buffer is required".into());
-    }
-
-    let dir = PathBuf::from(UPLOAD_DIR);
-    std::fs::create_dir_all(&dir).map_err(|e| format!("mkdir: {e}"))?;
-
-    // Detect extension: prefer the provided filename, else infer from magic.
-    let extension = if file_name.contains('.') {
-        file_name.split('.').last().unwrap_or("").to_lowercase()
-    } else {
-        infer_extension(buffer).to_string()
-    };
-
-    if extension.is_empty() {
-        return Err("Unable to determine file extension".into());
-    }
-
-    let random = hex::encode(&fastrand::u64(..).to_le_bytes());
-    let key = format!("{random}.{extension}");
-    let path = dir.join(&key);
-
-    std::fs::write(&path, buffer).map_err(|e| format!("write: {e}"))?;
-
-    let url = format!("{}/{}", public_base(), key);
-    Ok(json!({
-        "success": true,
-        "url": url,
-        "fileName": key,
-        "size": buffer.len(),
-    }))
-}
-
-/// Serve the file bytes for a given filename.
-pub fn read_file(file_name: &str) -> Result<(Vec<u8>, String), String> {
-    // Prevent path traversal.
-    let safe = Path::new(file_name)
-        .file_name()
-        .and_then(|s| s.to_str())
-        .ok_or("invalid filename")?;
-    let path = PathBuf::from(UPLOAD_DIR).join(safe);
-    let bytes = std::fs::read(&path).map_err(|e| format!("read: {e}"))?;
-    let mime = infer_mime(safe).to_string();
-    Ok((bytes, mime))
-}
-
-fn infer_extension(buf: &[u8]) -> &'static str {
-    if buf.starts_with(b"\x89PNG\r\n\x1a\n") {
-        "png"
-    } else if buf.starts_with(b"\xff\xd8\xff") {
-        "jpg"
-    } else if buf.starts_with(b"GIF87a") || buf.starts_with(b"GIF89a") {
-        "gif"
-    } else if buf.starts_with(b"RIFF") && &buf[8..12] == b"WEBP" {
-        "webp"
-    } else if buf.starts_with(b"%PDF") {
-        "pdf"
-    } else if buf.starts_with(b"PK\x03\x04") {
-        "zip"
-    } else {
-        "bin"
-    }
-}
-
-fn infer_mime(name: &str) -> &'static str {
-    let ext = name.rsplit('.').next().unwrap_or("");
-    match ext {
-        "png" => "image/png",
-        "jpg" | "jpeg" => "image/jpeg",
-        "gif" => "image/gif",
-        "webp" => "image/webp",
-        "pdf" => "application/pdf",
-        "zip" => "application/zip",
-        "txt" => "text/plain",
-        "mp4" => "video/mp4",
-        "webm" => "video/webm",
-        "mp3" => "audio/mpeg",
-        _ => "application/octet-stream",
-    }
-}

src/infrastructure/repository/weebs.rs

@@ -1,196 +0,0 @@
-//! Infrastructure — Weebs endpoints (anime/manga info, waifu pics, whatanime).
-//!
-//! Ported from Shirokami-API `scraper/weebs/*.js`. These are public JSON
-//! APIs that we proxy/forward (jikan.moe, waifu.pics, trace.moe).
-
-use crate::infrastructure::utils::http_client::http_client;
-use reqwest::header::USER_AGENT;
-use serde_json::{json, Value};
-
-/// Anime info from jikan.moe, ported from anime-search's `getAnimeInfo`.
-pub async fn fetch_anime_info(query: &str) -> Result<Value, String> {
-    let url = format!("https://api.jikan.moe/v4/anime?q={}", urlencode(query));
-    let data = get_json(&url).await?;
-
-    let arr = data
-        .get("data")
-        .and_then(|d| d.as_array())
-        .cloned()
-        .unwrap_or_default();
-    if arr.is_empty() {
-        return Ok(json!({ "error": "Anime tidak ditemukan" }));
-    }
-    let anime = &arr[0];
-
-    let judul = anime
-        .get("titles")
-        .and_then(|t| t.as_array())
-        .and_then(|t| t.first())
-        .and_then(|t| t.get("title"))
-        .and_then(|t| t.as_str())
-        .unwrap_or("Title not available");
-    let genrenya = join_names(anime.get("genres"));
-
-    Ok(json!({
-        "title": judul,
-        "url": anime.get("url").and_then(|v| v.as_str()).unwrap_or(""),
-        "type": anime.get("type").and_then(|v| v.as_str()).unwrap_or(""),
-        "score": anime.get("score").cloned().unwrap_or(Value::Null),
-        "members": anime.get("members").cloned().unwrap_or(Value::Null),
-        "status": anime.get("status").and_then(|v| v.as_str()).unwrap_or(""),
-        "synopsis": anime.get("synopsis").and_then(|v| v.as_str()).unwrap_or(""),
-        "favorites": anime.get("favorites").cloned().unwrap_or(Value::Null),
-        "images": anime.get("images").cloned().unwrap_or(Value::Null),
-        "genres": genrenya,
-    }))
-}
-
-/// Manga info from jikan.moe, ported from anime-search's `getMangaInfo`.
-pub async fn fetch_manga_info(query: &str) -> Result<Value, String> {
-    let url = format!("https://api.jikan.moe/v4/manga?q={}", urlencode(query));
-    let data = get_json(&url).await?;
-
-    let arr = data
-        .get("data")
-        .and_then(|d| d.as_array())
-        .cloned()
-        .unwrap_or_default();
-    if arr.is_empty() {
-        return Ok(json!({ "error": "Manga tidak ditemukan" }));
-    }
-    let manga = &arr[0];
-
-    let judul = manga
-        .get("titles")
-        .and_then(|t| t.as_array())
-        .map(|tt| {
-            tt.iter()
-                .filter_map(|j| {
-                    let title = j.get("title").and_then(|v| v.as_str()).unwrap_or("");
-                    let ty = j.get("type").and_then(|v| v.as_str()).unwrap_or("");
-                    if title.is_empty() {
-                        None
-                    } else {
-                        Some(format!("{} [{}]", title, ty))
-                    }
-                })
-                .collect::<Vec<_>>()
-                .join(", ")
-        })
-        .unwrap_or_default();
-    let genrenya = join_names(manga.get("genres"));
-
-    Ok(json!({
-        "title": judul,
-        "chapters": manga.get("chapters").cloned().unwrap_or(Value::Null),
-        "type": manga.get("type").and_then(|v| v.as_str()).unwrap_or(""),
-        "status": manga.get("status").and_then(|v| v.as_str()).unwrap_or(""),
-        "genre": genrenya,
-        "volumes": manga.get("volumes").cloned().unwrap_or(Value::Null),
-        "favorites": manga.get("favorites").cloned().unwrap_or(Value::Null),
-        "score": manga.get("score").cloned().unwrap_or(Value::Null),
-        "scored": manga.get("scored").cloned().unwrap_or(Value::Null),
-        "scored_by": manga.get("scored_by").cloned().unwrap_or(Value::Null),
-        "rank": manga.get("rank").cloned().unwrap_or(Value::Null),
-        "popularity": manga.get("popularity").cloned().unwrap_or(Value::Null),
-        "members": manga.get("members").cloned().unwrap_or(Value::Null),
-        "url": manga.get("url").and_then(|v| v.as_str()).unwrap_or(""),
-        "background": manga.get("background").and_then(|v| v.as_str()).unwrap_or(""),
-        "synopsis": manga.get("synopsis").and_then(|v| v.as_str()).unwrap_or(""),
-    }))
-}
-
-/// What anime is in this screenshot? trace.moe reverse-image search.
-pub async fn fetch_whatanime(url: &str) -> Result<Value, String> {
-    let api = format!(
-        "https://api.trace.moe/search?cutBorders&url={}",
-        urlencode(url)
-    );
-    let data = get_json(&api).await?;
-
-    let result = data
-        .get("result")
-        .and_then(|r| r.as_array())
-        .and_then(|r| r.first())
-        .cloned();
-    let Some(r) = result else {
-        return Ok(json!({ "error": "Anime tidak ditemukan" }));
-    };
-
-    let similarity = r
-        .get("similarity")
-        .and_then(|s| s.as_f64())
-        .map(|s| (s * 100.0).round() as i64)
-        .unwrap_or(0);
-
-    Ok(json!({
-        "judul": r.get("filename").and_then(|v| v.as_str()).unwrap_or(""),
-        "episode": r.get("episode").and_then(|v| v.as_str()).unwrap_or(""),
-        "similarity": similarity,
-        "videoURL": r.get("video").and_then(|v| v.as_str()).unwrap_or(""),
-        "videoIMG": r.get("image").and_then(|v| v.as_str()).unwrap_or(""),
-    }))
-}
-
-/// SFW waifu image from waifu.pics.
-pub async fn fetch_sfw_waifu(tag: &str) -> Result<Value, String> {
-    let url = format!("https://api.waifu.pics/sfw/{}", urlencode(tag));
-    get_json(&url).await
-}
-
-/// NSFW waifu image from waifu.pics.
-pub async fn fetch_nsfw_waifu(tag: &str) -> Result<Value, String> {
-    let url = format!("https://api.waifu.pics/nsfw/{}", urlencode(tag));
-    get_json(&url).await
-}
-
-// ============================================================================
-// Helpers
-// ============================================================================
-
-async fn get_json(url: &str) -> Result<Value, String> {
-    let resp = http_client()
-        .client()
-        .get(url)
-        .header(USER_AGENT, "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0 Safari/537.36")
-        .send()
-        .await
-        .map_err(|e| format!("HTTP error: {}", e))?;
-    if !resp.status().is_success() {
-        return Err(format!("HTTP {} from upstream", resp.status()));
-    }
-    resp.json::<Value>()
-        .await
-        .map_err(|e| format!("JSON parse: {}", e))
-}
-
-/// Join an array of { name: "X" } objects into a comma-separated string.
-fn join_names(v: Option<&Value>) -> String {
-    v.and_then(|g| g.as_array())
-        .map(|arr| {
-            arr.iter()
-                .filter_map(|g| {
-                    g.get("name")
-                        .and_then(|n| n.as_str())
-                        .map(|s| s.to_string())
-                })
-                .collect::<Vec<_>>()
-                .join(", ")
-        })
-        .unwrap_or_default()
-}
-
-/// Minimal URL-encode (space -> %20, keep alphanumerics and safe chars).
-fn urlencode(s: &str) -> String {
-    let mut out = String::new();
-    for b in s.bytes() {
-        match b {
-            b'A'..=b'Z' | b'a'..=b'z' | b'0'..=b'9' | b'-' | b'_' | b'.' | b'~' => {
-                out.push(b as char)
-            }
-            b' ' => out.push_str("%20"),
-            _ => out.push_str(&format!("%{:02X}", b)),
-        }
-    }
-    out
-}

src/observability/openapi_modules.rs

@@ -74,18 +74,7 @@ use utoipa::OpenApi;
         // ── Stalk module ───────────────────────────────────────────
         crate::presentation::handler::stalk::github_handler,
         crate::presentation::handler::stalk::youtube_handler,
-        crate::presentation::handler::stalk::mobile_legends_handler,
-        crate::presentation::handler::stalk::free_fire_handler,
-        crate::presentation::handler::stalk::genshin_handler,
         crate::presentation::handler::stalk::twitter_handler,
-        crate::presentation::handler::stalk::tiktok_handler,
-        crate::presentation::handler::stalk::instagram_handler,
-        // ── Weebs module ───────────────────────────────────────────
-        crate::presentation::handler::weebs::anime_info_handler,
-        crate::presentation::handler::weebs::manga_info_handler,
-        crate::presentation::handler::weebs::whatanime_handler,
-        crate::presentation::handler::weebs::sfw_waifu_handler,
-        crate::presentation::handler::weebs::nsfw_waifu_handler,
         // ── Search module ──────────────────────────────────────────
         crate::presentation::handler::search::bmkg_handler,
         crate::presentation::handler::search::jadwal_sholat_handler,
@@ -102,13 +91,6 @@ use utoipa::OpenApi;
         // ── Image module ───────────────────────────────────────────
         crate::presentation::handler::image::brat_handler,
         crate::presentation::handler::image::brat_animated_handler,
-        // ── Uploader module ────────────────────────────────────────
-        crate::presentation::handler::uploader::ryzencdn_handler,
-        crate::presentation::handler::uploader::serve_file_handler,
-        // ── AI module ──────────────────────────────────────────────
-        crate::presentation::handler::ai::chat_handler,
-        crate::presentation::handler::ai::gemini_handler,
-        crate::presentation::handler::ai::image_handler,
     ),
     components(
         schemas(
@@ -122,13 +104,10 @@ use utoipa::OpenApi;
         (name = "komik", description = "Komik endpoints"),
         (name = "download", description = "Media download endpoints (23 platforms)"),
         (name = "misc", description = "Miscellaneous utilities (currency, gold, server)"),
-        (name = "stalk", description = "User profile stalking (GitHub, YT, Twitter, TikTok, IG, FF, ML, Genshin)"),
+        (name = "stalk", description = "User profile stalking (GitHub, YT, Twitter)"),
-        (name = "weebs", description = "Weeb endpoints (anime info, manga, anime search, waifu)"),
         (name = "search", description = "Search endpoints (BMKG, prayer times, weather, YouTube, Google)"),
         (name = "tool", description = "Utility tools (WHOIS, IP lookup, URL shortener, tracking, hosting)"),
         (name = "image", description = "Image generation (brat static & animated)"),
-        (name = "uploader", description = "File upload and serve"),
-        (name = "ai", description = "AI endpoints (chat, gemini, image generation)"),
     )
 )]
 pub struct ModuleApiDoc;

src/presentation/handler/ai.rs

@@ -1,103 +0,0 @@
-//! Axum handlers for AI endpoints (Pollinations).
-
-use axum::body::Body;
-use axum::extract::Query;
-use axum::http::{header, StatusCode};
-use axum::response::Response;
-use axum::Json;
-use serde::Deserialize;
-use serde_json::Value;
-
-use crate::application::ai as use_cases;
-use crate::presentation::error::AppError;
-
-#[derive(Deserialize)]
-pub struct AiParams {
-    pub text: Option<String>,
-    pub prompt: Option<String>,
-    pub model: Option<String>,
-    pub image_url: Option<String>,
-    pub url: Option<String>,
-    pub width: Option<u32>,
-    pub height: Option<u32>,
-}
-
-/// GET /ai/chat?text=...&prompt=...&model=...
-#[utoipa::path(
-    get,
-    path = "/ai/chat",
-    tag = "ai",
-    operation_id = "ai_chat_handler",
-    responses(
-        (status = 200, description = "OK", body = serde_json::Value),
-        (status = 400, description = "Bad Request"),
-        (status = 502, description = "Upstream error"),
-    )
-)]
-
-pub async fn chat_handler(Query(params): Query<AiParams>) -> Result<Json<Value>, AppError> {
-    let text = params
-        .text
-        .ok_or_else(|| AppError::BadRequest("Missing 'text' parameter".to_string()))?;
-    let result = use_cases::chat(text, params.prompt.unwrap_or_default(), params.model).await?;
-    Ok(Json(result))
-}
-
-/// GET /ai/gemini?text=...&prompt=...&image_url=...
-#[utoipa::path(
-    get,
-    path = "/ai/gemini",
-    tag = "ai",
-    operation_id = "ai_gemini_handler",
-    responses(
-        (status = 200, description = "OK", body = serde_json::Value),
-        (status = 400, description = "Bad Request"),
-        (status = 502, description = "Upstream error"),
-    )
-)]
-
-pub async fn gemini_handler(Query(params): Query<AiParams>) -> Result<Json<Value>, AppError> {
-    let text = params
-        .text
-        .ok_or_else(|| AppError::BadRequest("Missing 'text' parameter".to_string()))?;
-    let result =
-        use_cases::gemini(text, params.prompt.unwrap_or_default(), params.image_url).await?;
-    Ok(Json(result))
-}
-
-/// GET /ai/image?prompt=...&model=...&width=...&height=... — returns image bytes.
-#[utoipa::path(
-    get,
-    path = "/ai/image",
-    tag = "ai",
-    operation_id = "ai_image_handler",
-    responses(
-        (status = 200, description = "OK", body = serde_json::Value),
-        (status = 400, description = "Bad Request"),
-        (status = 502, description = "Upstream error"),
-    )
-)]
-
-pub async fn image_handler(Query(params): Query<AiParams>) -> Result<Response<Body>, AppError> {
-    let prompt = params
-        .prompt
-        .ok_or_else(|| AppError::BadRequest("Missing 'prompt' parameter".to_string()))?;
-    let model = params.model.unwrap_or_else(|| "flux".to_string());
-    let width = params.width.unwrap_or(1024);
-    let height = params.height.unwrap_or(1024);
-
-    let bytes = use_cases::image(prompt, model, width, height).await?;
-    // Pollinations flux returns JPEG by default.
-    let mime = if bytes.starts_with(b"\xff\xd8\xff") {
-        "image/jpeg"
-    } else if bytes.starts_with(b"\x89PNG\r\n\x1a\n") {
-        "image/png"
-    } else {
-        "application/octet-stream"
-    };
-    Response::builder()
-        .status(StatusCode::OK)
-        .header(header::CONTENT_TYPE, mime)
-        .body(Body::from(bytes))
-        .map_err(|e| AppError::Internal(format!("build response: {e}")))
-}

src/presentation/handler/mod.rs

@@ -1,4 +1,3 @@
-pub mod ai;
 pub mod anime;
 pub mod anime2;
 pub mod downloader;
@@ -10,5 +9,3 @@ pub mod proxy;
 pub mod search;
 pub mod stalk;
 pub mod tools;
-pub mod uploader;
-pub mod weebs;

src/presentation/handler/stalk.rs

@@ -68,82 +68,6 @@ pub async fn youtube_handler(
     Ok((StatusCode::OK, Json(result)))
 }
 
-/// GET /stalk/mobile-legends?user_id=...&zone_id=... (aliases: userid, zoneid)
-#[utoipa::path(
-    get,
-    path = "/stalk/mobile-legends",
-    tag = "stalk",
-    operation_id = "stalk_mobile_legends",
-    params(StalkParams),
-    responses(
-        (status = 200, description = "Mobile Legends player info", body = Value),
-        (status = 400, description = "Missing user_id/zone_id"),
-        (status = 502, description = "Upstream error"),
-    )
-)]
-pub async fn mobile_legends_handler(
-    Query(params): Query<StalkParams>,
-) -> Result<(StatusCode, Json<Value>), AppError> {
-    let user_id = params
-        .user_id
-        .or(params.userid)
-        .ok_or_else(|| AppError::BadRequest("Missing 'user_id' parameter".to_string()))?;
-    let zone_id = params
-        .zone_id
-        .or(params.zoneid)
-        .ok_or_else(|| AppError::BadRequest("Missing 'zone_id' parameter".to_string()))?;
-    let result = use_cases::mobile_legends(&user_id, &zone_id).await?;
-    Ok((StatusCode::OK, Json(result)))
-}
-
-/// GET /stalk/free-fire?user_id=... (alias: userid)
-#[utoipa::path(
-    get,
-    path = "/stalk/free-fire",
-    tag = "stalk",
-    operation_id = "stalk_free_fire",
-    params(StalkParams),
-    responses(
-        (status = 200, description = "Free Fire player info", body = Value),
-        (status = 400, description = "Missing user_id"),
-        (status = 502, description = "Upstream error"),
-    )
-)]
-pub async fn free_fire_handler(
-    Query(params): Query<StalkParams>,
-) -> Result<(StatusCode, Json<Value>), AppError> {
-    let user_id = params
-        .user_id
-        .or(params.userid)
-        .ok_or_else(|| AppError::BadRequest("Missing 'user_id' parameter".to_string()))?;
-    let result = use_cases::free_fire(&user_id).await?;
-    Ok((StatusCode::OK, Json(result)))
-}
-
-/// GET /stalk/genshin-impact?user_id=... (alias: userid)
-#[utoipa::path(
-    get,
-    path = "/stalk/genshin-impact",
-    tag = "stalk",
-    operation_id = "stalk_genshin",
-    params(StalkParams),
-    responses(
-        (status = 200, description = "Genshin Impact profile", body = Value),
-        (status = 400, description = "Missing user_id"),
-        (status = 502, description = "Upstream error"),
-    )
-)]
-pub async fn genshin_handler(
-    Query(params): Query<StalkParams>,
-) -> Result<(StatusCode, Json<Value>), AppError> {
-    let user_id = params
-        .user_id
-        .or(params.userid)
-        .ok_or_else(|| AppError::BadRequest("Missing 'user_id' parameter".to_string()))?;
-    let result = use_cases::genshin(&user_id).await?;
-    Ok((StatusCode::OK, Json(result)))
-}
-
 /// GET /stalk/twitter?username=...
 #[utoipa::path(
     get,
@@ -166,49 +90,3 @@ pub async fn twitter_handler(
     let result = use_cases::twitter(&username).await?;
     Ok((StatusCode::OK, Json(result)))
 }
-
-/// GET /stalk/tiktok?username=...
-#[utoipa::path(
-    get,
-    path = "/stalk/tiktok",
-    tag = "stalk",
-    operation_id = "stalk_tiktok",
-    params(StalkParams),
-    responses(
-        (status = 200, description = "TikTok user profile", body = Value),
-        (status = 400, description = "Missing username"),
-        (status = 502, description = "Upstream error"),
-    )
-)]
-pub async fn tiktok_handler(
-    Query(params): Query<StalkParams>,
-) -> Result<(StatusCode, Json<Value>), AppError> {
-    let username = params
-        .username
-        .ok_or_else(|| AppError::BadRequest("Missing 'username' parameter".to_string()))?;
-    let result = use_cases::tiktok(&username).await?;
-    Ok((StatusCode::OK, Json(result)))
-}
-
-/// GET /stalk/instagram?username=...
-#[utoipa::path(
-    get,
-    path = "/stalk/instagram",
-    tag = "stalk",
-    operation_id = "stalk_instagram",
-    params(StalkParams),
-    responses(
-        (status = 200, description = "Instagram user profile", body = Value),
-        (status = 400, description = "Missing username"),
-        (status = 502, description = "Upstream error"),
-    )
-)]
-pub async fn instagram_handler(
-    Query(params): Query<StalkParams>,
-) -> Result<(StatusCode, Json<Value>), AppError> {
-    let username = params
-        .username
-        .ok_or_else(|| AppError::BadRequest("Missing 'username' parameter".to_string()))?;
-    let result = use_cases::instagram(&username).await?;
-    Ok((StatusCode::OK, Json(result)))
-}

src/presentation/handler/uploader.rs

@@ -1,82 +0,0 @@
-//! Axum handlers for the uploader.
-//!
-//! POST /uploader/ryzencdn — multipart file upload, saved to local disk.
-//! GET  /uploader/file/:name — serve an uploaded file.
-
-use axum::body::Body;
-use axum::extract::{Multipart, Path};
-use axum::http::{header, StatusCode};
-use axum::response::Response;
-use axum::Json;
-use serde_json::Value;
-
-use crate::application::uploader as use_cases;
-use crate::presentation::error::AppError;
-
-/// POST /uploader/ryzencdn — accept a multipart file upload.
-#[utoipa::path(
-    post,
-    path = "/uploader/ryzencdn",
-    tag = "uploader",
-    operation_id = "uploader_ryzencdn_handler",
-    responses(
-        (status = 200, description = "OK", body = serde_json::Value),
-        (status = 400, description = "Bad Request"),
-        (status = 502, description = "Upstream error"),
-    )
-)]
-
-pub async fn ryzencdn_handler(mut multipart: Multipart) -> Result<Json<Value>, AppError> {
-    // Read the first file field.
-    let mut file_name = String::from("");
-    let mut data: Vec<u8> = Vec::new();
-
-    while let Some(field) = multipart
-        .next_field()
-        .await
-        .map_err(|e| AppError::BadRequest(format!("multipart: {e}")))?
-    {
-        let name = field.name().unwrap_or("file").to_string();
-        if name == "file" {
-            file_name = field.file_name().unwrap_or("").to_string();
-            let content = field
-                .bytes()
-                .await
-                .map_err(|e| AppError::BadRequest(format!("bytes: {e}")))?;
-            data = content.to_vec();
-            break;
-        }
-    }
-
-    if data.is_empty() {
-        return Err(AppError::BadRequest(
-            "No file field named 'file' in multipart body".into(),
-        ));
-    }
-
-    let result = use_cases::upload(&data, &file_name)?;
-    Ok(Json(result))
-}
-
-/// GET /uploader/file/:name — serve an uploaded file.
-#[utoipa::path(
-    get,
-    path = "/uploader/file/:name",
-    tag = "uploader",
-    operation_id = "uploader_serve_file_handler",
-    responses(
-        (status = 200, description = "OK", body = serde_json::Value),
-        (status = 400, description = "Bad Request"),
-        (status = 502, description = "Upstream error"),
-    )
-)]
-
-pub async fn serve_file_handler(Path(name): Path<String>) -> Result<Response<Body>, AppError> {
-    let (bytes, mime) = use_cases::serve(&name)?;
-    Response::builder()
-        .status(StatusCode::OK)
-        .header(header::CONTENT_TYPE, mime)
-        .header(header::CACHE_CONTROL, "public, max-age=86400")
-        .body(Body::from(bytes))
-        .map_err(|e| AppError::Internal(format!("build response: {e}")))
-}

src/presentation/handler/weebs.rs

@@ -1,125 +0,0 @@
-//! Axum handlers for weebs endpoints.
-//!
-//! Ported from Shirokami-API `scraper/weebs/*.js`.
-
-use axum::extract::Query;
-use axum::http::StatusCode;
-use axum::Json;
-use serde::Deserialize;
-use serde_json::Value;
-
-use crate::application::weebs as use_cases;
-use crate::presentation::error::AppError;
-
-#[derive(Deserialize)]
-pub struct WeebsParams {
-    pub query: Option<String>,
-    pub q: Option<String>,
-    pub url: Option<String>,
-    pub tag: Option<String>,
-}
-
-fn require(v: Option<&String>, name: &str) -> Result<String, AppError> {
-    v.cloned()
-        .ok_or_else(|| AppError::BadRequest(format!("Missing '{}' parameter", name)))
-}
-
-/// GET /weebs/anime-info?query=naruto
-#[utoipa::path(
-    get,
-    path = "/weebs/anime-info",
-    tag = "weebs",
-    operation_id = "weebs_anime_info_handler",
-    responses(
-        (status = 200, description = "OK", body = serde_json::Value),
-        (status = 400, description = "Bad Request"),
-        (status = 502, description = "Upstream error"),
-    )
-)]
-
-pub async fn anime_info_handler(
-    Query(p): Query<WeebsParams>,
-) -> Result<(StatusCode, Json<Value>), AppError> {
-    let query = require(p.query.as_ref().or(p.q.as_ref()), "query")?;
-    Ok((StatusCode::OK, Json(use_cases::anime_info(&query).await?)))
-}
-
-/// GET /weebs/manga-info?query=one%20piece
-#[utoipa::path(
-    get,
-    path = "/weebs/manga-info",
-    tag = "weebs",
-    operation_id = "weebs_manga_info_handler",
-    responses(
-        (status = 200, description = "OK", body = serde_json::Value),
-        (status = 400, description = "Bad Request"),
-        (status = 502, description = "Upstream error"),
-    )
-)]
-
-pub async fn manga_info_handler(
-    Query(p): Query<WeebsParams>,
-) -> Result<(StatusCode, Json<Value>), AppError> {
-    let query = require(p.query.as_ref().or(p.q.as_ref()), "query")?;
-    Ok((StatusCode::OK, Json(use_cases::manga_info(&query).await?)))
-}
-
-/// GET /weebs/whatanime?url=<image-url>
-#[utoipa::path(
-    get,
-    path = "/weebs/whatanime",
-    tag = "weebs",
-    operation_id = "weebs_whatanime_handler",
-    responses(
-        (status = 200, description = "OK", body = serde_json::Value),
-        (status = 400, description = "Bad Request"),
-        (status = 502, description = "Upstream error"),
-    )
-)]
-
-pub async fn whatanime_handler(
-    Query(p): Query<WeebsParams>,
-) -> Result<(StatusCode, Json<Value>), AppError> {
-    let url = require(p.url.as_ref(), "url")?;
-    Ok((StatusCode::OK, Json(use_cases::whatanime(&url).await?)))
-}
-
-/// GET /weebs/sfw-waifu?tag=waifu
-#[utoipa::path(
-    get,
-    path = "/weebs/sfw-waifu",
-    tag = "weebs",
-    operation_id = "weebs_sfw_waifu_handler",
-    responses(
-        (status = 200, description = "OK", body = serde_json::Value),
-        (status = 400, description = "Bad Request"),
-        (status = 502, description = "Upstream error"),
-    )
-)]
-
-pub async fn sfw_waifu_handler(
-    Query(p): Query<WeebsParams>,
-) -> Result<(StatusCode, Json<Value>), AppError> {
-    let tag = require(p.tag.as_ref(), "tag")?;
-    Ok((StatusCode::OK, Json(use_cases::sfw_waifu(&tag).await?)))
-}
-
-/// GET /weebs/nsfw-waifu?tag=waifu
-#[utoipa::path(
-    get,
-    path = "/weebs/nsfw-waifu",
-    tag = "weebs",
-    operation_id = "weebs_nsfw_waifu_handler",
-    responses(
-        (status = 200, description = "OK", body = serde_json::Value),
-        (status = 400, description = "Bad Request"),
-        (status = 502, description = "Upstream error"),
-    )
-)]
-
-pub async fn nsfw_waifu_handler(
-    Query(p): Query<WeebsParams>,
-) -> Result<(StatusCode, Json<Value>), AppError> {
-    let tag = require(p.tag.as_ref(), "tag")?;
-    Ok((StatusCode::OK, Json(use_cases::nsfw_waifu(&tag).await?)))
-}

src/presentation/router.rs

@@ -282,51 +282,10 @@ pub fn build_router(app_state: Arc<AppState>) -> anyhow::Result<Router> {
             "/stalk/youtube",
             axum::routing::get(crate::presentation::handler::stalk::youtube_handler),
         )
-        .route(
-            "/stalk/mobile-legends",
-            axum::routing::get(crate::presentation::handler::stalk::mobile_legends_handler),
-        )
-        .route(
-            "/stalk/free-fire",
-            axum::routing::get(crate::presentation::handler::stalk::free_fire_handler),
-        )
-        .route(
-            "/stalk/genshin-impact",
-            axum::routing::get(crate::presentation::handler::stalk::genshin_handler),
-        )
         .route(
             "/stalk/twitter",
             axum::routing::get(crate::presentation::handler::stalk::twitter_handler),
         )
-        .route(
-            "/stalk/tiktok",
-            axum::routing::get(crate::presentation::handler::stalk::tiktok_handler),
-        )
-        .route(
-            "/stalk/instagram",
-            axum::routing::get(crate::presentation::handler::stalk::instagram_handler),
-        )
-        // Weebs routes
-        .route(
-            "/weebs/anime-info",
-            axum::routing::get(crate::presentation::handler::weebs::anime_info_handler),
-        )
-        .route(
-            "/weebs/manga-info",
-            axum::routing::get(crate::presentation::handler::weebs::manga_info_handler),
-        )
-        .route(
-            "/weebs/whatanime",
-            axum::routing::get(crate::presentation::handler::weebs::whatanime_handler),
-        )
-        .route(
-            "/weebs/sfw-waifu",
-            axum::routing::get(crate::presentation::handler::weebs::sfw_waifu_handler),
-        )
-        .route(
-            "/weebs/nsfw-waifu",
-            axum::routing::get(crate::presentation::handler::weebs::nsfw_waifu_handler),
-        )
         // Search routes
         .route(
             "/search/bmkg",
@@ -382,28 +341,6 @@ pub fn build_router(app_state: Arc<AppState>) -> anyhow::Result<Router> {
             "/image/brat/animated",
             axum::routing::get(crate::presentation::handler::image::brat_animated_handler),
         )
-        // Uploader routes
-        .route(
-            "/uploader/ryzencdn",
-            axum::routing::post(crate::presentation::handler::uploader::ryzencdn_handler),
-        )
-        .route(
-            "/uploader/file/{name}",
-            axum::routing::get(crate::presentation::handler::uploader::serve_file_handler),
-        )
-        // AI routes
-        .route(
-            "/ai/chat",
-            axum::routing::get(crate::presentation::handler::ai::chat_handler),
-        )
-        .route(
-            "/ai/gemini",
-            axum::routing::get(crate::presentation::handler::ai::gemini_handler),
-        )
-        .route(
-            "/ai/image",
-            axum::routing::get(crate::presentation::handler::ai::image_handler),
-        )
         // Health
         .route(
             "/health",