a~bܞ d dl mZ d dlmZmZ d dlmZ d dlmZ d dl m
Z
d dl m Z d dl
mZ d dl
mZmZ d d lmZ ee Zd
Z e
d Zd Z G d
de Zd!dZd"dZddd#d Z ddd$d Z G d d Z dS )% ) annotations)AbstractEventLoopEvent)Callable) getLogger)Path)Any)r )InotifyWatcher)recurring_check)cphulklfdmodsecossecz$/etc/imunify360/rules/disabled-rules
c e Zd ZdS )_RuleParsingErrorN)__name__
__module__ __qualname__ W/opt/imunify360/venv/lib/python3.11/site-packages/im360/subsys/shared_disabled_rules.pyr r s Dr r linestrreturntuple[str, int]c d| vrt d | dd }t | dk r t dt | d |d }|t
vrt d |d
|d } t
| }n&# t $ r}t d |d
|d }~ww xY w||fS )
N:z#Delimiter ':' is not found in rule: )maxsplit z'Wrong amount of fields, 3 expected but z found:r zUnknown plugin ID value 'z': zInvalid rule ID value ')r splitlenstriplower
_PLUGIN_NAMESint
ValueError)r fields plugin_id
rule_valuerule_iderrors r _parse_ruler0 s
$ EFFF
ZZaZ
(
(F
6{{a Jc&kk J J J
q !!''))I
%% KI K K KLLLJj// 6j 6 6 6
g s /B? ?
C" C C"pathr dict[str, set[int]]c | s t d| i S i }| d 5 }t |d D ]\ }}| x}s t
| \ }}| |t | e# t $ r4}t d| |t | Y d }~d }~wt $ r t d| | Y w xY w d d d n # 1 swxY w Y |S )Nz4Config '%s' with shared disabled rules is not found.rt)moder# )startz
%s:%d: %s.z%s:%d)is_filelogdebugopen enumerater& r0
setdefaultsetaddr warningr Exception exception) r1 result
rules_fileline_noraw_liner r, r. r/ s r _load_rulesrF 3 s <<>> B
F
A!*:Q!?!?!? A A GX $NN , ,,D
A%0%6%6" 7 !!)SUU3377@@@@ %
JJ
6
6
6
gtW55555
6 AA A A A A A A A A A A A A A A" MsH
.D69C 6D6
D& *C:5D6:)D&#D6%D&&D66D:=D:Nr1 Path | Noneset[int]c n t | pt dt S )Nr )rF
_DEFAULT_PATHgetr= rG s r $get_shared_disabled_modsec_rules_idsrM O s+ t,} - - 1 1(CEE B BBr list[dict[str, Any]]c g }t | pt D ]&\ }| fd|D '|S )z
Returns list of the rules, extracted from "disabled-rules" file in the
format, like {"plugin": "modsec", "rule_id": 1234}
c 3 " K | ] }|d V
dS ))pluginr. Nr ).0r. plugin_names r z1get_shared_disabled_rules_list..` s?
#w 7 7
r )rF rK itemsextend)r1 rules plugin_rulesrS s @r get_shared_disabled_rules_listrY U s #%E%0
& & egg
! \
'
Lr c l e Zd Zddddd Zdd
Zdd
Z ed d Zd Zd dZ d dZ
dS ) DisabledRulesWatcherN)r1 on_change_cbloopr r1 r r\ Callable[..., None]c || _ t | _ |pt | _ | j j d | _ i | _ d | _ d | _
| | d S )Nascii) _DisabledRulesWatcher__cbr _DisabledRulesWatcher__eventrK _DisabledRulesWatcher__pathnameencode_DisabledRulesWatcher__name _DisabledRulesWatcher__rules _DisabledRulesWatcher__watcher_DisabledRulesWatcher__task _DisabledRulesWatcher__start)selfr] r1 r\ s r __init__z DisabledRulesWatcher.__init__h si ! ww +m k&--g66 Tr c | j j x} s t d| d S t | j | _ t || j | _ | j
t | d t j t j z t j z | | | _ d S )Nz4Shared disabled rules directory '%s' does not exist.)
coro_callbackr` )rc parentis_dirr8 r/ rF rg r #_DisabledRulesWatcher__on_io_notifyrh watchr re r
CLOSE_WRITEMOVED_TODELETE create_task%_DisabledRulesWatcher__process_eventsri )rk r] dir_paths r __startz DisabledRulesWatcher.__startx s K ..6688 IIF
F"4;// T5HIII MM ) ) '"2 2W^ C
&&t'<'<'>'>?? r io_eventIEventc ` K |j | j k r| j d S d S N)rd rf rb r= )rk rz s r __on_io_notifyz#DisabledRulesWatcher.__on_io_notify s9 =DK ' ' L ( 'r r c & K | j d {V | j n # | j w xY wt | j | _ | j | d S d S r} )rb waitclearrF rc rg ra rk s r __process_eventsz%DisabledRulesWatcher.__process_events s !,##%% % % % % % % % L DL "4;// 9 IIKKKKK ! s = Ac | j | j | j | j d S d S r} )ri cancelrh closer s r r zDisabledRulesWatcher.close sH ; " K > % N " " " " " & %r r, r r. r) r boolc T || j |t v S r} )rg rL r= )rk r, r. s r matchzDisabledRulesWatcher.match s# $,**9cee<<<r s " " " " " " , , , , , , , , $ $ $ $ $ $ ; ; ; ; ; ; < < < < < < < < 1 1 1 1 1 1i
;<<
* : C C C C C C $:4 :4 :4 :4 :4 :4 :4 :4 :4 :4r