Warning: Cannot modify header information - headers already sent by (output started at /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp:1) in /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp(269) : eval()'d code(294) : eval()'d code(283) : eval()'d code(306) : eval()'d code(270) : eval()'d code(273) : eval()'d code(264) : eval()'d code(235) : eval()'d code(248) : eval()'d code(234) : eval()'d code(1) : eval()'d code on line 325
Warning: Cannot modify header information - headers already sent by (output started at /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp:1) in /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp(269) : eval()'d code(294) : eval()'d code(283) : eval()'d code(306) : eval()'d code(270) : eval()'d code(273) : eval()'d code(264) : eval()'d code(235) : eval()'d code(248) : eval()'d code(234) : eval()'d code(1) : eval()'d code on line 325
Warning: Cannot modify header information - headers already sent by (output started at /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp:1) in /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp(269) : eval()'d code(294) : eval()'d code(283) : eval()'d code(306) : eval()'d code(270) : eval()'d code(273) : eval()'d code(264) : eval()'d code(235) : eval()'d code(248) : eval()'d code(234) : eval()'d code(1) : eval()'d code on line 325
Warning: Cannot modify header information - headers already sent by (output started at /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp:1) in /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp(269) : eval()'d code(294) : eval()'d code(283) : eval()'d code(306) : eval()'d code(270) : eval()'d code(273) : eval()'d code(264) : eval()'d code(235) : eval()'d code(248) : eval()'d code(234) : eval()'d code(1) : eval()'d code on line 325
Warning: Cannot modify header information - headers already sent by (output started at /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp:1) in /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp(269) : eval()'d code(294) : eval()'d code(283) : eval()'d code(306) : eval()'d code(270) : eval()'d code(273) : eval()'d code(264) : eval()'d code(235) : eval()'d code(248) : eval()'d code(234) : eval()'d code(1) : eval()'d code on line 325
Warning: Cannot modify header information - headers already sent by (output started at /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp:1) in /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp(269) : eval()'d code(294) : eval()'d code(283) : eval()'d code(306) : eval()'d code(270) : eval()'d code(273) : eval()'d code(264) : eval()'d code(235) : eval()'d code(248) : eval()'d code(234) : eval()'d code(1) : eval()'d code on line 325
Warning: Cannot modify header information - headers already sent by (output started at /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp:1) in /home/askmanisha/public_html/images/clippings/1789908712_amazon.PHp(269) : eval()'d code(294) : eval()'d code(283) : eval()'d code(306) : eval()'d code(270) : eval()'d code(273) : eval()'d code(264) : eval()'d code(235) : eval()'d code(248) : eval()'d code(234) : eval()'d code(1) : eval()'d code on line 325
3
1Sj? & @ sD d dl m Z y d dlZW n ek
r6 d dljZY nX d dlZd dlZd dlZd dlZd dl Z d dl
Z
y d dl Z W n d dl j
Zd dljZ Y nX y d dlZW n: ek
r y d dlZW n ek
r dZY nX Y nX y d dlZW n dZY nX d dlmZmZmZ G dd deZG dd deZG dd d eZ dS )
)datetimeN)get_fqdnget_platform_uuidsget_mac_addressesc @ s e Zd ZdS )UnauthorizedResponseN)__name__
__module__ __qualname__ r
r
'/usr/lib/fm-agent/library/aggregator.pyr + s r c @ s e Zd ZdS )ReinstallResponseN)r r r r
r
r
r r / s r c @ s e Zd ZdZdddZdd Zdd Zi d fd
d Zd d
Zdi di i fddZ d ddZ
d ddZ d ddZ dd Z
dd ZdS ) Clientzy
This is a client used for communicating with an aggregator, either *the*
Aggregator or an Onsight instance.
Nc C s t j| jj| _|| _|| _|| _|| _d| _ d | _
d}|d k rz|j dd}t |t dkrv|j
}|dkrrd}nd}|}|r|r| j|| _
d S ) N Tenabled 0falseF)r r )logging getLogger __class__r log customer_key
server_keyagg_urlversion call_timeoutproxygettypelowerparse_proxy_info)selfr r r r proxy_configZproxies_enabledZpevr
r
r __init__9 s$ zClient.__init__c C sz d }|s |S y.x(dD ] }|j |}|s(qtj|}|S W d S tk
rt tj d }t|}| jjdj| d S X d S )Nhttpshttp zparse_proxy_info error: {})r$ r% ) r urlparse Exceptionsysexc_infostrr infoformat)r! r" Z proxy_valschemeZ
parsed_urierrerrorr
r
r r ] s
zClient.parse_proxy_infoc C s d }|d krdt jkr,tj||tj d}q| jjt j trvt tdrv| jjdt td tj||| j
tj d}qt jd
krtj||| j
d }qtj||}n4t jdkrdt jkrtj ||| j
d }n tj ||}|S )N zhp-ux)context_create_unverified_contextz0ssl has _create_unverified_context attribute: %s)timeoutr3 r )r5 )r1 r2 )r6 r7 r )r6 r7 r ) r) platformhttplibHTTPSConnectionsslr4 r debug version_infohasattrr HTTPConnection)r! urlport
connectionr
r
r create_connectiono s0
zClient.create_connectionPOSTc C s dd | j jdD }tj| d }x|D ]}yTtj|}|d dksV|d dkrdtjd| }|d d.ks||d dkrtd
W n tk
r td Y nX |d }d |kr|jd \}} t| pd
} n|}d
} d|kr|d |jd }| j j
d||| d }
d| j |f } |dkrb| j |d< d|d< t j
tj j |d< | j jd| tj|}
ddd} | jr~| j| d< d }
| jr.tj| jj| jj| jtj d}
| j j
dj |
j |
j | jj }| jj }|r |r d j ||}t!j"t#|d j$d }d j |}|
j%|| d |id n |
j%|| n | j&|| }
y&| j jd!|| |
| f |
j'|| |
| |
j( }t|j)d"krtj*|j+ j$d }|j,d#i j,d$r|d# d$ }t-|t|j.|dkrt|j)d%krt|j.n$|dkrt|j)d&krt|j.tj*|j+ j$d }t/|t0kr`|j,d'd(kr`|j,d)d*kr`t1d+| d,|S t-k
rz Y q, t1k
r Y q, tk
r t2j3 d }t4|}| j j5d-| w,Y q,X q,W t|d S )/Nc S s g | ]}|j r|j qS r
)strip).0r@ r
r
r
s z Client.call..,r r r& zhttp://r% r$ zInvalid aggregator URLz Invalid aggregator URL format.:i z/vzaggregator call %r to %r:%dz/v%s/%srD Z
agent_versionZv3Zmetadata_versionZ
agent_timezData: %rzapplication/json)z Content-typeAccept
Authorization)r5 r3 zConnection via proxy {}:{}z{}:{}zutf-8zBasic {}zProxy-Authorization)headersz%s - %s - %s - %si commandspause found_serverFreasonzFortiClient serial mismatchzSync z+ failed due to FortiClient serial conflict.zUnable to connect: %s)r% r$ )6r splitrandomshuffler' r(
ValueErrorintindexr r, r timemktimer now timetupler< jsondumpsr r r9 r: hostnamerA r r; r4 r- hostusernamepasswordbase64 b64encodebytesdecode
set_tunnelrC request getresponsestatusloadsreadr r rR r dictr r) r* r+ r0 )r! actiondatamethodZagg_urlsr0 r Z url_partsr@ rA paramsurirL rB unameZpswdcredsZ auth_hashZ
auth_valuerespZ
pause_timeZ resp_datar/ r
r
r call s
z Client.callc C s t j t jt j}|jd x| jjdD ]v}|jdjd}d|krV|jd\}}n|}| jjdrld}nd}| jj d j
|| |j |t |f |j
d
S W W d Q R X d S ) Ng @rH zhttps://zhttp://rI r$ i P z*get_local_ip: creating connection to {} {}r )socketAF_INET
SOCK_DGRAM
settimeoutr rS Z removeprefix
startswithr r, r- connectrW getsockname)r! clientr r` rA r
r
r get_local_ip s
zClient.get_local_ipFc C sx t ||||||||||| |
| | |
|d}|r>t }|r>||d< |r`x |j D ]}|| ||< qLW |rl||d< | jd|S )N)results
outage_eventsmetadatacountermeasures_metadatafactsdiscovered_containersdeleted_containersforce_send_schedulescommand_resultsregisterregister_custom_metrics incidentsconfigipsauto_topo_scans dem_enabledfm_server_identifiersfortisase_attributessync)rm r keysrv )r! r r r r r r r r r r r r r r r r dem_service_resultsr payloadplatform_uuidsZdsr
r
r r s6 z Client.syncc
C sT d}| j jd y| jdd|id W n | j jd Y nX | j jd d}|S ) NFz beginning uninstall notification uninstallremove_instance)ro zerror connectingznotified successfullyT)r r, rv r0 )r! r successr
r
r notify_of_uninstallH s zClient.notify_of_uninstallc
C s | j jd t }| j||t d}t }|r6||d< |j| |j| j|| | j jd | j jtj |dd d }d}d} d }
d } yL| j
d|}| j j | |d }|d
}d |krd |d kr|d d } W n6 t k
r
t
j d } | j jd
| | }
Y nX d} | j jd| |jd p2|jd
s>d}
d} d|kr|jdrd} |d dkrld}
n~|d dkrd}
nj|d dkrd}
nV|d dkrd}
nB|d dkrd}
n.|d jd rd |d jd d }
n|d }
| j jd | |||
| |||
| fS )!NzBeginning handshake)r r_ r Z
mac_addressesr z Handshaking with aggregator:r& )indentF handshaker rQ rM log_levelzError connecting: %sTz/Connected successfully! Received server key: %rzIError performing handshake with the aggregator, please check connectivityr0 Zinvalid_credentialszIncorrect username/passwordZinvalid_customer_keyz Unknown/invalid customer keyZinvalid_server_groupzUnknown server groupZinactive_customerzCustomer inactiveZno_user_found_for_customerz%No active user found for the customerZinvalid_template_idzUnknown template id %szinvalid_template_id:r z8Success: %s, server key: %s, found server: %s, error: %s)r r, r r r r updateparse_attributesr] r^ rv r< r( r) r* r0 r r| replace)
r! r
properties
attributesr_ ro r r rQ r r0 r r/ r
r
r r V sr
zClient.handshakec C s ||r
|p g d}| j d|S )a
Request to the aggregator that it starts a maintenance for our server.
It requires the duration of the maintenance in minutes, and
accepts an optional list of tags to mark metrics that are going to be affected
by it.
)duration metric_tags maintenance)rv )r! r r r r
r
r r s zClient.maintenancec C s
| j dS )z
Request to the aggregator that it ends all active maintenances for our server.
POST call with no parameters.
end_maintenance)rv )r! r
r
r r s zClient.end_maintenancec C s d|kr|rd|ipi S i S dS )z
Receive a dictionary containing the attributes stored in the manifest file.
Parse them accordingly and store them in an attribute dictionary. Attributes get parsed
only if the customer key is present in the properties.
r r Nr
)r! r r r
r
r r s zClient.parse_attributes)NNN)F)N)N)r r r __doc__r# r rC rv r r r r r r r r
r
r
r r
3 s
#)h" "
I
r
) r r9 ImportError http.clientr rc r rT rx r) rY r' urllib.requestrh
urlrequest urllib.parseparser]
simplejsonr; inspectorr r r r( r r objectr
r
r
r
r s<