Mi>+SSKJrJrJrJr SSKJrJr SSKJ r SSK r SSK r SSK r "SS5r "SS\5r"S S \5rg) )ListDictOptionalTuple)ABCabstractmethod)cycleNc \rSrSrSS\S\\S\\S\\4SjjrS\\4S jr\S \SS4S j5r \S \ SS4S j5r \SS\S\ S4Sjj5r S\ 4SjrSSjrSrg) ProxyConfig NserverusernamepasswordipcdXlX lX0lU=(d UR5Ulg)aConfiguration class for a single proxy. Args: server: Proxy server URL (e.g., "http://127.0.0.1:8080") username: Optional username for proxy authentication password: Optional password for proxy authentication ip: Optional IP address for verification purposes N)r rr_extract_ip_from_serverr)selfr rrrs q/var/www/eduai.edurigo.com/storigo/production/storigo_env/lib/python3.13/site-packages/crawl4ai/proxy_strategy.py__init__ProxyConfig.__init__ s*   6446returncSUR;a2URRS5SRS5nUS$URRS5nUS$![a gf=f)z#Extract IP address from server URL.z://:rN)r split Exception)rpartss rr#ProxyConfig._extract_ip_from_server#so  # ))%0399#>Qx ))#.Qx  sAA$A$$ A10A1 proxy_strcURS5n[U5S:XaUup#pE[SUSU3UUUS9$[U5S:XaUup#[SUSU3US9$[SU35e)zMCreate a ProxyConfig from a string in the format 'ip:port:username:password'.rzhttp://r rrr)r rzInvalid proxy string format: )rlenr ValueError)r rrportrrs r from_stringProxyConfig.from_string0s$ u:?+0 (Bh AdV,!!   Z1_HB AdV,  >(+^^J/^^J/~~d#   renv_varc/n[R"US5RS5nUH0nU(dM UR[R U55 M2 U$![ an[SU35 SnAU$SnAff=f)zLoad proxies from environment variable. Args: env_var: Name of environment variable containing comma-separated proxy strings Returns: List of ProxyConfig objects ,z(Error loading proxies from environment: N)osgetenvrappendr r(rprint)r/proxies proxy_listproxyes rfrom_envProxyConfig.from_envOs B7B/55c:J#{66u=>$  B s rget_next_proxy$ProxyRotationStrategy.get_next_proxy~s  r7cg)z(Add proxy configurations to the strategyNrOrr7s r add_proxies!ProxyRotationStrategy.add_proxiess rN session_idttlc # g7faN Get or create a sticky proxy for a session. If session_id already has an assigned proxy (and hasn't expired), return it. If session_id is new, acquire a new proxy and associate it. Args: session_id: Unique session identifier ttl: Optional time-to-live in seconds for this session Returns: ProxyConfig for this session NrO)rr[r\s rget_proxy_for_session+ProxyRotationStrategy.get_proxy_for_sessions & rVc # g7fzk Release a sticky session, making the proxy available for reuse. Args: session_id: Session to release NrOrr[s rrelease_session%ProxyRotationStrategy.release_sessions  rVcgz Get the proxy for an existing session without creating new one. Args: session_id: Session to look up Returns: ProxyConfig if session exists and hasn't expired, None otherwise NrOrcs rget_session_proxy'ProxyRotationStrategy.get_session_proxys rcg)z\ Get all active sticky sessions. Returns: Dictionary mapping session_id to ProxyConfig NrOr>s rget_active_sessions)ProxyRotationStrategy.get_active_sessionss rrON)rHrIrJrK__doc__rrr rTrrYrLintr_rdrhrrkrNrOrrrQrQ{s; h{&;   4 #4  "  c]  +    (      C  H[4I     T#{*:%;  rrQc\rSrSrSrSS\\4SjjrS\\4SjrS\ \4Sjr SS \ S \ \ S\ \4S jjr S \ SS4S jrS \ S\ \4S jrS\\ \44SjrS\ 4SjrSrg)RoundRobinProxyStrategyaSimple round-robin proxy rotation strategy using ProxyConfig objects. Supports sticky sessions where a session_id can be bound to a specific proxy for the duration of the session. This is useful for deep crawling where you want to maintain the same IP address across multiple requests. Nr7c/UlSUl0Ul[R"5UlU(aUR U5 gg)zg Initialize with optional list of proxy configurations Args: proxies: List of ProxyConfig objects N)_proxies _proxy_cycle _sessionsasyncioLock _session_lockrYrXs rr RoundRobinProxyStrategy.__init__s>,.  NP$\\^    W % rcnURRU5 [UR5Ulg)z$Add new proxies to the rotation poolN)rtextendr rurXs rrY#RoundRobinProxyStrategy.add_proxiess% W%!$--0rrcX# UR(dg[UR5$7f)z%Get next proxy in round-robin fashionN)runextr>s rrT&RoundRobinProxyStrategy.get_next_proxys"  D%%&&s(*r[r\c"# URIShvN XR;amURUup4nUbUOUnUb>[R"5U- nXv:aURU O&UsSSS5IShvN $UsSSS5IShvN $UR5IShvN nU(a%U[R"5U4URU'UsSSS5IShvN $NNqN`NIN !,IShvN (df  g=f7fr^)ryrvtimerT)rr[r\r9 created_at session_ttl effective_ttlelapseds rr_-RoundRobinProxyStrategy.get_proxy_for_sessions$%%%^^+15 1K.;(+K  ,"iikJ6G/ NN:6$&%%!&%%$--//E.3TYY[#-Fz*-&%%$0%&%%%sDC+DAC5/ D;C-<DC5 DC/DC5'C1(1C5 D%C3&D-D/D1C53D5D ;C> < D Dc# URIShvN XR;a URU SSS5IShvN gN1N!,IShvN (df  g=f7frb)ryrvrcs rrd'RoundRobinProxyStrategy.release_session s=%%%^^+NN:.&%%%%%sBA#AA#A  A#AA#A# A A  A A#cXR;agURUup#nUb[R"5U- nXT:agU$rg)rvr)rr[r9rr\rs rrh)RoundRobinProxyStrategy.get_session_proxysH ^^ +!% !;3 ?iikJ.G~ rc[R"5n0nURR5HunupEnUb X- nXv:aMXBU'M U$)zu Get all active sticky sessions (excluding expired ones). Returns: Dictionary mapping session_id to ProxyConfig )rrvitems)r current_timeactive_sessionsr[r9rr\rs rrk+RoundRobinProxyStrategy.get_active_sessions-s[yy{ 48NN4H4H4J 0J0C&3>*/J ' 5Krc# URIShvN [R"5n/nURR5H*unupEnUcMX- nXv:dMUR U5 M, UHnURU M [ U5sSSS5IShvN $NN!,IShvN (df  g=f7f)zU Remove all expired sessions from tracking. Returns: Number of sessions removed N)ryrrvrr5r%)rrexpiredr[r9rr\rs rcleanup_expired_sessions0RoundRobinProxyStrategy.cleanup_expired_sessionsAs%%%99;LG8<8L8L8N4 4U?*7G~z2 9O & NN:.&w<&%%%%%sPCB)CrsE..#  l2l2^A CA FW 3W r