PATH:
opt
/
imunify360
/
venv
/
lib
/
python3.11
/
site-packages
/
defence360agent
/
plugins
/
__pycache__
/
Editing: send_domain_list.cpython-311.pyc
� ���iN � �� � 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)�Scope�recurring_check�split_for_chunkc �d � e Zd Zej Zd d�Zd� Zd� Zd� Z de de fd�Z 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 �int�datetime� timedelta� total_seconds)�self�periods �]/opt/imunify360/venv/lib/python3.11/site-packages/defence360agent/plugins/send_domain_list.py�__init__zSendDomainList.__init__ sY � ��� � � �!�D�L�L�L�*�/��H�&�A�.�.�.�<�<�>�>�?�?� � �D�L�L�L� 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� )�O�D�L� )� )�$�*@� 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 � � � � �:� !� �$�*�M�D�J�� �H�H�J�J�J��G�G�G�G�G�G�G�G�G� "� !r � panel_type�returnc �4 � ddd�� ||� � S )N�primary�alias)�main�parked)�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�� � �L��t j � � }t |d�� � D ] } t! � � } || d< | | d< | W V � � d S ) NzHostingsPanel: %s�username� myimunify_id)r8 �docroot�name�securesite_user_id�uid�typei� )� chunk_size� timestamp�domains)r �logger�info�NAMEr �pwd�getpwnam�get_user_domains_details�appendr: �domain�pw_uidr6 r> �timer r ) r �hprA �myimunify_users�userr8 �user_pwd� domain_datar@ �chunk�msgs r �_create_domain_list_msgz&SendDomainList._create_domain_list_msg> sZ � � � � �^�^��� � �'���1�1�1��� 3� 5� 5�5�5�5�5�5�5��#� � �D��J�'�H��|�H�-�-�H�%'�%@�%@��%J�%J� J� J� J� J� J� J� � � ����$,�#.�#6� +� 2�.2�>�.B� '�� $� B� B� '� ,�!� !� � � � � � � � �I�K�K� �$�W��>�>�>� � �E� �,�,�C� (�C� � � "�C� �N��I�I�I�I�I� � 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 � � � � �5�5�7�7� 2� 2� 2� 2� 2� 2� 2�#��*�,�,�S�1�1� 1� 1� 1� 1� 1� 1� 1� 1� 8�7�7s �?r# )�__name__� __module__� __qualname__r �AV_IM360�SCOPEr r! r) r- �strr6 r r rS r' r r r r r s� � � � � � � �N�E�� � � �!� !� !� � � �� � � &�� &�� &� &� &� &� �}�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 �<module>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
SAVE
CANCEL