qjN d dl Z d dlZd dlZd dlZd dlmZ d dlmZ d dlm Z d dl
m Z d dl m
Z
mZ d dlmZ d dlmZmZmZ ej e Z G d d
e
e ZdS ) N)
AsyncIterator)int_from_envvar)
DomainList)get_myimunify_users) MessageSink
MessageSource) HostingPanel)Scoperecurring_checksplit_for_chunkc d e Zd Zej Zd dZd Zd Zd Z de
de
fdZ de e
fd Zd
ZdS ) SendDomainListNc d | _ |r || _ d S t dt t j d | _ d S )N IMUNIFY360_SEND_DOMAIN_PERIOD )days)_task_periodr intdatetime timedelta
total_seconds)selfperiods ]/opt/imunify360/venv/lib/python3.11/site-packages/defence360agent/plugins/send_domain_list.py__init__zSendDomainList.__init__ sY
!DLLL*/H&A...<<>>?? DLLL c
K dS )zMessageSink methodN )r loops r create_sinkzSendDomainList.create_sink' s
r c K || _ || _ | j t | j | j | _ d S N)_loop_sink create_taskr r _send_domain_listr )r r sinks r
create_sourcez SendDomainList.create_source* sT
Z++ A )ODL ) )$*@ A A C C
r c r K | j -d | j c| _ }| | d {V d S d S r# )r cancel)r ts r shutdownzSendDomainList.shutdown2 sG : ! $*MDJ
HHJJJGGGGGGGGG " !r
panel_typereturnc 4 ddd || S )Nprimaryalias)mainparked)get)r r. s r _panel_domain_type_to_imunifyz,SendDomainList._panel_domain_type_to_imunify8 s(
#j*
%
% &r c * K t }t d|j g }t d {V }|D ]}|d }t j | }| | d {V D ]K}| ||j |j
|d |j | |j
d Lt j }t |d D ] } t! }
||
d< | |
d< |
W V d S ) NzHostingsPanel: %susername myimunify_id)r8 docrootnamesecuresite_user_iduidtypei )
chunk_size timestampdomains)r loggerinfoNAMEr pwdgetpwnamget_user_domains_detailsappendr: domainpw_uidr6 r> timer r ) r hprA myimunify_usersuserr8 user_pwd domain_datar@ chunkmsgs r _create_domain_list_msgz&SendDomainList._create_domain_list_msg> sZ
^^ '111 3 5 5555555# DJ'H|H--H%'%@%@%J%J J J J J J J
$,#.#6 + 2.2>.B ' $ B B ' ,! !
IKK $W>>> E ,,C (C "C NIIIII r c K | 2 3 d {V }| j | d {V (6 d S r# )rS r% process_message)r rR s r r' z SendDomainList._send_domain_listZ sp 5577 2 2 2 2 2 2 2#*,,S11 1 1 1 1 1 1 1 1 877s ?r# )__name__
__module__ __qualname__r
AV_IM360SCOPEr r! r) r- strr6 r r rS r' r r r r r s NE ! ! !
& & & & & & }Z/H 82 2 2 2 2r r )r loggingrE rK typingr defence360agent.contracts.configr "defence360agent.contracts.messagesr &defence360agent.contracts.myimunify_idr !defence360agent.contracts.pluginsr r +defence360agent.subsys.panels.hosting_panelr defence360agent.utilsr
r r getLoggerrV rB r r r r re sB
: 9 9 9 9 9 F F F F F F E D D D D D
8 $ $B2 B2 B2 B2 B2[- B2 B2 B2 B2 B2r