6NF d Z ddlZddlZddlZddlZddlZddlZddlm Z ddl
m Z ddl m
Z
ddlmZ ddlmZ ddlmZmZmZ ej e Z G d d
Z G d d ZdS )
z1Collector for WordPress CVE protection incidents. N)Path) defaultdict)WPSite) get_data_dir)IncidentFileParser)upsert_wordpress_incident bulk_create_wordpress_incidentsbuild_incident_dictc h e Zd ZdZ ddededefdZd Zd
ed ed ee ef fd
Z
d
ed efdZ dS )IncidentRateLimitera
Rate limiter to prevent DoS attacks via incident flooding.
Implements per-rule-per-IP rate limiting as per spec:
- Maximum 100 incidents for each rule from the same IP within 15 minutes
Memory-optimized implementation with bounded entry count using LRU eviction.
d ' max_incidents_per_rule_per_iptime_window_secondsmax_unique_entriesc || _ || _ || _ t t | _ d| _ t j | _ dS )aI
Initialize the rate limiter.
Args:
max_incidents_per_rule_per_ip: Max incidents per rule per IP (default: 100)
time_window_seconds: Time window in seconds (default: 900 = 15 minutes)
max_unique_entries: Max unique (rule_id, IP) combinations to track (default: 10000)
< N) max_per_rule_per_ip time_windowr r listincident_timescleanup_intervaltime last_cleanup)selfr r r s a/opt/imunify360/venv/lib/python3.11/site-packages/defence360agent/wordpress/incident_collector.py__init__z IncidentRateLimiter.__init__" sK $A ."4 *$ / / " IKK c ~ t j }|| j z
g }| j D ]5\ }} fd|D }|r || j |< | | 6|D ]
}| j |= t | j | j k rt | j d }t dt | j t | j dz z
}|d| D ]
\ }}| j |= t d| j | || _ dS )zHRemove records older than the time window and enforce max entries limit.c g | ]
}|k | S r" .0tscutoffs r
z.C ===Rfbr c 2 | d r| d d ndS )N r r" )xs r z:IncidentRateLimiter._cleanup_old_records..R s 1 4ad1gg1 r )keyr* g?NzARate limiter exceeded max entries (%d), removed %d oldest entries)
r r r itemsappendlenr sortedmaxintloggerwarningr )
r nowkeys_to_deleter-
timestampsrecententries_by_age
num_to_remove_r& s
@r _cleanup_old_recordsz(IncidentRateLimiter._cleanup_old_records: s ikkt'' # 2 8 8 : : + +OC====:===F
++1#C(( %%c****! ) )C#C(( t" # #d&= = = ##))++44 N D'((3t/F/L+M+MM M ) - 8
-
-Q',, NN'
r rule_id attacker_ipreturnc t j | j z
| j k r| t j }|| j z
||f}|| j v rB| j | } fd|D }|r|| j |< t
| }n
| j |= d}nd}|| j k r#| j dz }dd| d| d| d| j d | d
fS d S ) z
Check if adding an incident would exceed rate limits.
Args:
rule_id: Rule identifier
attacker_ip: IP address of the attacker
Returns:
Tuple of (allowed: bool, reason: str)
c g | ]
}|k | S r" r" r# s r r' z8IncidentRateLimiter.check_rate_limit.. r( r r r Fz Rate limit exceeded for rule z from IP z: /z within z minutes)TOK)r r r r= r r r0 r )
r r> r? r6 r- r8 r9 recent_countwindow_minutesr& s
@r check_rate_limitz$IncidentRateLimiter.check_rate_limitf sF 9;;* *T-B B B % % ' ' 'ikkt'' $ $% % % ,S1J====:===F
!+1#C( "6{{ ', L 43 3 3 ! - 3N1G 1 1#1 1$1 1'+'?1 1 '1 1 1
zr c t j }||f}|| j vr
|g| j |< dS | j | }t | | j k r| d | | dS )z
Record that an incident was added.
Args:
rule_id: Rule identifier
attacker_ip: IP address
r N)r r r0 r popr/ )r r> r? r6 r- r8 s r record_incidentz#IncidentRateLimiter.record_incident s ikk $ d) ) )(+uD $ $ $ ,S1J:$":::q!!! c " " " " "r N)r
r r ) __name__
__module__ __qualname____doc__r3 r r= strtupleboolrG rJ r" r r r r s .1#&"' ( ('*( !( ( ( ( (0* * * X22),2 tSy 2 2 2 2h#s # # # # # # #r r c t e Zd ZdZd dedz fdZ d dededefd Z d d
ee dedefd Z
e d e dee fd
Z
ej d Ze de defd Zdededz dedefdZdededz fdZdee dededz dedef
dZdedededz defdZdedededz dededef dZdS ) IncidentCollectorzM
Collect and persist WordPress incidents from plugin incident files.
N rate_limiterc V |p
t | _ t | _ dS )z
Initialize the incident collector.
Args:
rate_limiter: Optional rate limiter (creates default if not provided)
N)r rT r parser)r rT s r r zIncidentCollector.__init__ s) ) A,?,A,A(** r Tsitedelete_after_processingr@ c K g } t | d{V }t d|| | s t d| g S | | }t d|| |s t d| g S t dt | | | | }|D ]5}| |||| d{V }| | 6n3# t $ r&} t
d|| Y d} ~ nd} ~ ww xY wt dt | | |S ) ab
Collect incidents from a single WordPress site.
Args:
site: WordPress site to collect incidents from
ruleset_version: Version of the ruleset being used
delete_after_processing: Whether to delete incident files after processing
Returns:
List of collected Incident objects
Nz Data directory for site %s: %sz)Data directory does not exist for site %s Incident files for site %s: %sz#No incident files found for site %sz%Found %d incident file(s) for site %sz*Error collecting incidents for site %s: %sz$Collected %d incident(s) for site %s) r r4 debugexists_get_incident_filesr0 _get_site_username
_process_fileextend Exceptionerrorinfo)
r rW rX collected_incidentsdata_dirincident_filesusername
incident_filefile_incidentses
r collect_incidents_for_sitez,IncidentCollector.collect_incidents_for_site s !% )$ / ///////H LL94 J J J??$$
H$OOO ! 5 5h ? ?N LL0$
"
BDIII LL7N##
..t44H!/
;
;
'+'9'9! + ( ( " " " " " " $**>::::
; LL<
2 # $ $
#"s& A!D/ (AD/ 8A6D/ /
E 9 EE sitesc K g }|D ]3}| || d{V }| | 4|r6t dt | t | |S )a
Collect incidents from multiple WordPress sites.
Args:
sites: List of WordPress sites
delete_after_processing: Whether to delete incident files after processing
Returns:
List of collected Incident objects
Nz2Collected %d WordPress incident(s) from %d site(s))rk r` r4 rc r0 )r rl rX all_collected_incidentsrW site_incidentss r collect_incidents_for_sitesz-IncidentCollector.collect_incidents_for_sites s #% ; ;D#'#B#B'$ $ N
$ * *> : : : : " KKD+,,E
'&r re c |dz }t d|| | r| s t d| g S g }| D ]k} t j | }n# t $ r Y $w xY wt j |j
r*| | r| | lt d|| |S )a
Get all incident files in the incidents directory.
Only returns files older than one hour to give the WordPress plugin
time to process and finalize the incident data before collection.
Args:
data_dir: Path to the imunify-security data directory
Returns:
List of incident file paths, sorted by modification time
incidentsz#Incidents directory for site %s: %sz.Incidents directory does not exist for site %srZ )
r4 r[ r\ is_diriterdiroslstatOSError stat_moduleS_ISREGst_mode_is_incident_filer/ )clsre
incidents_dirrf fsts r r] z%IncidentCollector._get_incident_files" s0 !;.
18]
##%% ]-A-A-C-C LL@(
I &&(( ) )A
Xa[[
"2:..
)33H3H3K3K
) %%a((( ,h
s B
B"!B"z ^\d{4}-\d{2}-\d{2}-\d{2}\.php$ file_pathc Z t | j |j S )z
Check if a file is an incident file based on naming pattern.
Args:
file_path: Path to the file to check
Returns:
True if file matches pattern yyyy-mm-dd-hh.php
)rQ
_FILE_PATTERNmatchname)r| r s r r{ z#IncidentCollector._is_incident_fileL s% C%++IN;;<<"> " # # '
N $$$555 8-:LMMM& & LLC "
IIIIII s% AC BC
D*#D
DDc t j |j }|j S # t $ r-}t
d|j || Y d }~d S d }~ww xY w)Nz.Failed to get username for uid=%d, site %s: %s)pwdgetpwuiduidpw_namera r4 rb )r rW user_inforj s r r^ z$IncidentCollector._get_site_username ss
TX..I $ $ LL@
44444 s "
A"AArr incident_file_namec g }d}|D ]}| dd }| d p| dd } | j || \ }
} |
s"t d|| |dz
}|j |j ||j d} t || }
| |
| j
|| g }|rD t | }n3# t $ r&}t
d || Y d }~nd }~ww xY wt d
|t | | |S ) Nr r> unknown REMOTE_ADDRr? #Rate limit exceeded for site %s: %sr* domain site_pathrg user_idz+Failed to bulk insert incidents from %s: %sz(Processed file %s: %d stored, %d dropped)getrT rG r4 r5 r docrootr r
r/ rJ r ra rb rc r0 )r rr rW rg r incidents_to_insert
dropped_countincidentr> r? allowedreason site_info
incident_datacreated_incidentsrj s r r z)IncidentCollector._process_file_incidents s !
" D DH ll9i88G",,}55 y: :K # / @ @ OGV
9
"
+ !\ $ 8 I 0) D DM & &} 5 5 5 - -g{ C C C C
$C'% %!!
A&
6 ! " "
! s (C8 8
D( D##D(r c 4 | dd }| d p| dd }| j || \ }}|s t d|| d S | |||||| S )Nr> r r r? r )r rT rG r4 r5 _store_incident) r r rW rg r r> r? r r s r _process_incidentz#IncidentCollector._process_incident s ,,y)44 ll=11
X\\ 96
6
+<<
NN5
4##
r r> r? c |j |j ||j d}t || }| j || |S # t $ r'}t d|| Y d }~d S d }~ww xY w)Nr z$Failed to store incident from %s: %s) r r r r rT rJ ra r4 rb ) r r rW rg r> r? r r rj s r r z!IncidentCollector._store_incident s + !\ $ 8 I 1 H
- -g{ C C CO LL6"
44444
s AA
A6 A11A6)N)T)rK rL rM rN r r r rQ r rk rp classmethodr r] recompiler r{ rO r_ r^ dictr r r r" r r rS rS s + +%84%? + + + + )-?# ?#?# "&?#
?# ?# ?# ?#H )- ' 'F| ' "& '
' ' ' 'B $ 4 $ DJ $ $ $ [$ N BJ @AAM
=$
=4
=
=
= [
=/ / * /
"& /
/ / / /b v #* @!:@! @! * @!
@!
@! @! @! @!D
*
D *
r rS )rN loggingru r statrx r r pathlibr collectionsr defence360agent.model.wordpressr defence360agent.wordpress.clir )defence360agent.wordpress.incident_parserr (defence360agent.model.wordpress_incidentr r r
getLoggerrK r4 r rS r" r r r sQ 7 7
# # # # # # 2 2 2 2 2 2 6 6 6 6 6 6 H H H H H H
8 $ $V# V# V# V# V# V# V# V#rh h h h h h h h h hr