;<Æ7 d dl Z d dlZd dlmZ d dlmZmZ d dlmZ d dl m
Z
d dl m Z d dl
mZ d dlmZ ej e Z G d d
ee
ZdS ) N) Generator) send_messageFGWSendMessgeException)Core) MessageSink)g)SendToServerClient)Scopec f e Zd Zej Zej dee j
ddf fd Z ddZ dS )SendToServerFGWreturnNc # t K t j t j }| | V d S )N)r FileBasedGatewayAPIr VERSION_set_api_attrs)selfapis F/opt/imunify360/venv/lib/python3.11/site-packages/im360/plugins/fgw.py_get_apizSendToServerFGW._get_api s: .t|<<!!#&&&&&&& c 8 K | j rd S | j }t dt | | 5 } t j d r2t dt d |D |
| d {V | j dk r2t d| j n\# t $ rO | j
| t d| j Y nw xY wd d d d S # 1 swxY w Y d S )NzSending %s messagesDEBUGz!Writing messages to gw folder: %sc 3 n K | ]0}|d |d dd t |d fV 1dS )r N( )len).0ms r z9SendToServerFGW._send_pending_messages..% sC L LaadAaD"Is1Q4yy 9 L L L L L Lr r z Still need to send %s messagesz Unsuccessful to send %s messages)_pendingemptypop_allloggerinfor r r getlist
send_messagesqsizer put_manywarning)r messagesr s r _send_pending_messagesz&SendToServerFGW._send_pending_messages s = 4=((** )3x==999
]]__
5>> KK; L L8 L L LLL ''111111111=&&((1,,KK8
++-- *
&&x0006M''))
s8 3F5B0D&%F&AE?<F>E??FFF)r
N)
__name__
__module__ __qualname__r
IM360SCOPE
contextlibcontextmanagerr r r r r, r r r r sh KE ' <3T4? @' ' ' ' r r )r2 loggingtypingr defence360agent.api.serverr r defence360agent.contracts.configr !defence360agent.contracts.pluginsr &defence360agent.internals.global_scoper defence360agent.plugins.clientr defence360agent.utilsr
getLoggerr- r# r r4 r r r> s K K K K K K K K 1 1 1 1 1 1 9 9 9 9 9 9 4 4 4 4 4 4 = = = = = = ' ' ' ' ' ' 8 $ $$ $ $ $ $(+ $ $ $ $ $r