Wlc҄ 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 ZdZdZdS )MessageToSend.Metamessages_to_sendresidentN)__name__
__module__ __qualname__r dbdatabasedb_tableschema Q/opt/imunify360/venv/lib/python3.11/site-packages/im360/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 r; zMessageToSend.insert_many) s q#d))S)) : :A >B1q3w;>O D
EGG / / / / 7 7 9 9 9 9 : :r )r )r0 N)r r r __doc__r r r r messager r classmethodr$ r- r/ r;
__classcell__)r@ s @r r r s
&&&IiU###G Z 02EFFN [ [ [
: : : : : [: : : : :r r N) collectionsr peeweer r defence360agent.modelr r r r r r rH s{ " " " " " " ( ( ( ( ( ( ( ( 1 1 1 1 1 1 1 1(: (: (: (: (:E (: (: (: (: (:r