wo4ha~ddlZddlmZddlmZmZddlmZddlm Z ej e Z GddeZ dS)N)files)configmessages) MessageSource)recurring_checkcteZdZdejdeddfdZdZdZe e j j dZ dS) FilesRecurringUpdateTaskindex is_updatedreturnNcK|rGtj|j|}|j|d{VdSdSN)r MessageType FilesUpdatedtype_sinkprocess_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*77 EJJG*,,W55 5 5 5 5 5 5 5 5 5 6 6c K||_||_|||_t jD]'}t j||j (dSr) _loopr create_task _update_task_taskrIndextypesadd_hookr)rloopsinktype_s r create_sourcez&FilesRecurringUpdateTask.create_sourcesz  %%d&7&7&9&9:: [&&(( ? ?E K (= > > > > ? ?rcVK|j|jd{VdSr)rcancelrs rshutdownz!FilesRecurringUpdateTask.shutdowns: jrc<Ktjd{VdSr)rupdate_and_log_errorr's rrz%FilesRecurringUpdateTask._update_task s-(***********r)__name__ __module__ __qualname__rrboolrr$r(rr FilesUpdatePERIODrrrr r s6[6.26 6666??? _V'.//++0/+++rr )loggingdefence360agentrdefence360agent.contractsrr!defence360agent.contracts.pluginsrdefence360agent.utilsr getLoggerr+loggerr r1rrr9s!!!!!!66666666;;;;;;111111  8 $ $+++++}+++++r