Struct ProxyManager 

pub struct ProxyManager { /* private fields */ }

Manages a set of SOCKS5 proxies: fetching from sources, normalizing URLs, tracking state, and caching reqwest::Client instances.

Implementations

impl ProxyManager

pub fn new(proxy_timeout: Duration) -> Self

Create a new ProxyManager with the given per-proxy connection timeout.

pub fn get_cookie(&self, proxy_url: &str) -> Option<String>

Retrieve the stored cookie value for a proxy node, if any.

pub fn set_cookie(&self, proxy_url: &str, value: String)

Store a cookie value for a proxy node, replacing any existing value.

pub fn increment_request_count(&self, proxy_url: &str) -> u32

Atomically increment the request count for a proxy and return the new value.

pub fn request_count(&self, proxy_url: &str) -> u32

Return the current request count for a proxy node.

pub fn reset_request_count(&self, proxy_url: &str)

Reset the request count for a proxy node and, if the node was Retired, restore it to Active. Dead nodes are not restored.

pub fn challenge_lock(&self, proxy_url: &str) -> Arc<Semaphore>

Acquire the per-proxy challenge lock (semaphore with 1 permit).

Ensures at most one concurrent challenge solve per proxy node.

pub async fn fetch_and_add( &self, sources: &[String], prefer_remote_dns: bool, ) -> Result<usize, ScatterProxyError>

Fetch proxy lists from the given source URLs, normalize each line, and add any new proxies to the manager.

Returns the count of newly added proxies across all sources. Errors fetching individual sources are logged but do not cause the overall call to fail.

pub fn all_proxy_urls(&self) -> Vec<String>

Get all proxy URLs currently in the manager.

pub fn get_active_proxies(&self) -> Vec<String>

Get proxy URLs that are eligible for scheduling (not Dead or Retired).

pub fn set_state(&self, proxy: &str, state: ProxyState)

Set the state of a proxy.

pub fn get_state(&self, proxy: &str) -> ProxyState

Get the state of a proxy. Returns Unknown if the proxy is not tracked.

pub fn proxy_counts(&self) -> (usize, usize, usize, usize, usize)

Count proxies by state.

Returns (total, active_or_unknown, cooldown_placeholder, dead, retired). The cooldown placeholder is always 0 — cooldown tracking lives in a separate module.

pub fn get_client(&self, proxy_url: &str) -> Result<Client, ScatterProxyError>

Get or create a reqwest::Client configured to route through the given proxy URL. Clients are cached for reuse.

pub fn normalize_proxy_url(raw: &str, prefer_remote_dns: bool) -> String

Normalize a raw proxy string to a full URL.

Rules:

• Empty lines and lines starting with # are returned as empty string.
• "socks5h://ip:port" → returned as-is.
• "socks5://ip:port" → replaced with "socks5h://" when prefer_remote_dns is true, otherwise kept as-is.
• Bare "ip:port" → prepended with "socks5h://" when prefer_remote_dns is true, otherwise "socks5://".

pub fn total_count(&self) -> usize

Total number of proxies being tracked.