TXry5 N d dl mZ d dlmZmZ d dlmZmZ G d de ZdS ) )
namedtuple)
FloatField BlobField)instanceModelc e Zd ZdZ G d d Z ed Z ed Z e dd Z
e dd Z e d
Z
e dd Ze d fd Z xZS )
MessageToSendzc
Storage for messages to be sent to server
while connection to server is not available
c e Zd Zej ZdZdS )MessageToSend.Metamessages_to_send_nrN)__name__
__module__ __qualname__r dbdatabasedb_table [/opt/imunify360/venv/lib/python3.11/site-packages/defence360agent/model/messages_to_send.pyMetar s ;(r r F)nullMessageToSendTztimestamp message c | | j | }|S N)selectorder_by timestamplimit)clsr olds r
get_oldestzMessageToSend.get_oldest s2 jjll##CM2288??
r c | | j | }| S r )deletewhereidin_execute)r queryqs r delete_inzMessageToSend.delete_in s9 JJLL svzz% 0 0 1 1yy{{r c & | | j | }| | j | }| S r ) r r r r r$ r% r& r' r( )r r r! r* s r
delete_oldzMessageToSend.delete_old" sb jjll##CM2288?? JJLL svzz# / /yy{{r returnNc t dt | d D ]G} fd|||dz D } t j |fi | Hd S )Nr d c H g | ] } j | S r )r _asdict).0rowr s r
z-MessageToSend.insert_many.., s= 7:""C(0022 r )rangelensuper insert_manyr( )r rowskwargsidata __class__s ` r r9 zMessageToSend.insert_many( s q#d))S)) : :A >B1q3w;>O D
EGG / / / / 7 7 9 9 9 9 : :r )r )r. N)r
r r __doc__r r r r messager r classmethodr" r+ r- r9
__classcell__)r> s @r r r s
) ) ) ) ) ) ) )
&&&IiU###G Z 02EFFN [ [ [
: : : : : [: : : : :r r N) collectionsr peeweer r defence360agent.modelr r r r r r rF s{ " " " " " " ( ( ( ( ( ( ( ( 1 1 1 1 1 1 1 1': ': ': ': ':E ': ': ': ': ':r