Edit File: files_recurring_update.cpython-311.opt-1.pyc
� �*vha � �~ � d dl Z d dlmZ d dlmZmZ d dlmZ d dlm Z e j e � � Z G d� de� � Z dS )� N)�files)�config�messages)� MessageSource)�recurring_checkc �t � e Zd Zdej deddfd�Zd� Zd� Z e e j j � � d� � � Z dS ) �FilesRecurringUpdateTask�index� is_updated�returnNc � � K � |rGt j � |j |� � }| j � |� � � d {V �� d S d S �N)r � MessageType� FilesUpdated�type�_sink�process_message)�selfr r �messages �c/opt/imunify360/venv/lib/python3.11/site-packages/defence360agent/plugins/files_recurring_update.py�_on_files_updatez)FilesRecurringUpdateTask._on_files_update sb � � � � � 6� �*�7�7�� �E�J�J�G��*�,�,�W�5�5� 5� 5� 5� 5� 5� 5� 5� 5� 5� 6� 6� c � � K � || _ || _ |� | � � � � � | _ t j � � � D ]'}t j � || j � � �(d S r ) �_loopr � create_task� _update_task�_taskr �Index�types�add_hookr )r �loop�sink�type_s r � create_sourcez&FilesRecurringUpdateTask.create_source sz � � � ��� ��� ��%�%�d�&7�&7�&9�&9�:�:�� ��[�&�&�(�(� ?� ?�E� �K� � ���(=� >� >� >� >� ?� ?r c � �V K � | j � � � | j � d {V �� d S r )r �cancel�r s r �shutdownz!FilesRecurringUpdateTask.shutdown s: � � � � � �������j���������r c � �< K � t j � � � d {V �� d S r )r �update_and_log_errorr' s r r z%FilesRecurringUpdateTask._update_task s- � � � ��(�*�*�*�*�*�*�*�*�*�*�*r )�__name__� __module__� __qualname__r r �boolr r$ r( r r � FilesUpdate�PERIODr � r r r r s� � � � � � �6��[�6�.2�6� �6� 6� 6� 6�?� ?� ?�� � � �_�V�'�.�/�/�+� +� 0�/�+� +� +r r )�logging�defence360agentr �defence360agent.contractsr r �!defence360agent.contracts.pluginsr �defence360agent.utilsr � getLoggerr+ �loggerr r1 r r �<module>r9 s� �� ���� !� !� !� !� !� !� 6� 6� 6� 6� 6� 6� 6� 6� ;� ;� ;� ;� ;� ;� 1� 1� 1� 1� 1� 1� �� �8� $� $��+� +� +� +� +�}� +� +� +� +� +r
Back to File Manager