zf:@dZddlZddlZddlZddlmZddlmZejddkr%ddlm Z m Z Gdd e Z Gd d e Z ndd lm Z m Z Gd d e Z GddZdZGddZGddZGddZdS)zEModule that actually performs the ping, sending and receiving packetsN)icmp)network)IntEnumEnumceZdZdZdS) AutoNumbercvt|jdz}t|}||_|SNr)len __members__object__new___value)clsvalueobjs U/var/www/ffwdstore.be/apps/py-env/lib/python3.11/site-packages/pythonping/executor.pyrzAutoNumber.__new__s3((1,E..%%CCJJN)__name__ __module__ __qualname__rrrr r s#     rr ceZdZdZdZdZdS) SuccessOnrN)rrrOneMostAllrrrrrsrr)rautocJeZdZeZeZeZdS)rN)rrrr rrrrrrrrs/dfftvvdffrc$eZdZdZdZdZdZdS)Messagez2Represents an ICMP message with destination socketc0||_||_||_dS)aICreates a message that may be sent, or used to represent a response :param target: Target IP or hostname of the message :type target: str :param packet: ICMP packet composing the message :type packet: icmp.ICMP :param source: Source IP or hostname of the message :type source: strN)targetpacketsource)selfr%r&r's r__init__zMessage.__init__#s   rcD||jjdS)zPlaces the message on a socket :param source_socket: The socket to place the message on :type source_socket: network.SocketN)sendr&)r( source_sockets rr+z Message.send0s# 4;-.....rc*t|jSN)reprr&r(s r__repr__zMessage.__repr__7sDK   rN)rrr__doc__r)r+r1rrrr#r#!sG<<   ///!!!!!rr#c(t|dzdS)a Converts seconds into human-readable milliseconds with 2 digits decimal precision :param seconds: Seconds to convert :type seconds: Union[int, float] :return: The same time expressed in milliseconds, with 2 digits of decimal precision :rtype: floati)round)secondss rrepresent_seconds_in_msr7;s 4 # ##rcheZdZdZd dZedZedZedZdZ dZ dS) ResponsezCRepresents a response to an ICMP message, with metadata like timingNc>||_||_||_||_dS)aCreates a representation of ICMP message received in response :param message: The message received :type message: Union[None, Message] :param time_elapsed: Time elapsed since the original request was sent, in seconds :type time_elapsed: float :param source_request: ICMP packet represeting the request that originated this response :type source_request: ICMP :param repr_format: How to __repr__ the response. Allowed: legacy, None :type repr_format: strN)message time_elapsedsource_request repr_format)r(r;r<r=r>s rr)zResponse.__init__Gs) (,&rc|jduSr.) error_messager0s rsuccesszResponse.successWs!T))rc|jdS|jjjdkr|jjjdkrdS|jjjdkr-gd} ||jjjS#t$rYdSwxYwdS)Nz No responser)zNetwork UnreachablezHost UnreachablezProtocol UnreachablezPort UnreachablezFragmentation RequiredzSource Route FailedzNetwork Unknownz Host UnknownzSource Host IsolatedzECommunication with Destination Network is Administratively ProhibitedzBCommunication with Destination Host is Administratively ProhibitedzNetwork Unreachable for ToSzHost Unreachable for ToSz)Communication Administratively ProhibitedzHost Precedence ViolationzPrecedence Cutoff in Effect Unreachablez Network Error)r;r& message_type message_code IndexError)r(unreachable_messagess rr@zResponse.error_message[s <  = <  +q 0 0T\5H5UYZ5Z5Z4 <  +q 0 0$$$ $ %+DL,?,LMM % % %$}} %sA'' A54A5c*t|jSr.)r7r<r0s rtime_elapsed_mszResponse.time_elapsed_ms~s&t'8999rc|jdS|jrBd|jjt |jjj|jSd|j|jj|jS)NzRequest timed outz"Reply from {0}, {1} bytes in {2}msz{0} from {1} in {2}ms) r;rAformatr'r r&rawrJr@r0s r legacy_reprzResponse.legacy_reprs| < && < U7>>t|?R?B4rNr;rArLr'rJr r=rMr&r@r0s rr1zResponse.__repr__s  x ' '##%% % < ; < KRR #$D'+,,R/DL'+,,   399$,:MtOabbbrNN) rrrr2r)propertyrAr@rJrNr1rrrr9r9EsMM'''' **X*  X D::X:mmm c c c c crr9c eZdZdZgdejfdZejfdZ e dZ e dZ e dZ e dZd Zd Ze d Ze d Ze d Ze dZdZdZdZdS) ResponseListz%Represents a series of ICMP responsesFcg|_|||_||_d|_d|_d|_d|_d|_|D]}| |dS)aYCreates a ResponseList with initial data if available :param initial_set: Already existing responses :type initial_set: list :param verbose: Flag to enable verbose mode, defaults to False :type verbose: bool :param output: File where to write verbose output, defaults to stdout :type output: filerN) _responsesclearverboseoutputrtt_avgrtt_minrtt_maxstats_packets_sentstats_packets_returnedappend)r( initial_setrYrZresponses rr)zResponseList.__init__sy      "#&'## " "H KK ! ! ! ! " "rcd}d|jD}|tjkrd|v}nN|tjkr*|dt |z dk}n|tjkrd|v}|S)aCheck success state of the request. :param option: Sets a threshold for success sign. ( 1 - SuccessOn.One, 2 - SuccessOn.Most, 3 - SuccessOn.All ) :type option: int :return: Whether this set of responses is successful :rtype: bool Fcg|] }|j Sr)rA).0resps r z(ResponseList.success..sAAA AAArTg?)rWrrrcountr r)r(optionresult success_lists rrAzResponseList.successsAAAAA Y] " "\)FF y~ % %!''--L0A0AACGFF y} $ $,.F rc|jSr.) packets_lostr0s r packet_losszResponseList.packet_losss   rc*t|jSr.)r7r\r0s r rtt_min_mszResponseList.rtt_min_ms&t|444rc*t|jSr.)r7r]r0s r rtt_max_mszResponseList.rtt_max_msrqrc*t|jSr.)r7r[r0s r rtt_avg_mszResponseList.rtt_avg_msrqrc0g|_d|_d|_dS)Nr)rWr^r_r0s rrXzResponseList.clears"#&'###rc|j||xjdz c_t|dkr%|j|_|j|_|j|_no|jt|dz z|jzt|z |_|j|jkr |j|_|j|jkr |j|_|jr|xj dz c_ |j rt||j dSdS)Nr)file) rWr`r^r r<r[r]r\rAr_rYprintrZ)r(rs rr`zResponseList.appends  u%%% 1$ t99>> -DL -DL -DLL"\SYYq[9U=OOSVW[S\S\\DL!DL00$1 !DL00$1 = -  ' '1 , ' ' < + %dk * * * * * * + +rc |j|jz Sr.)r^r_r0s rstats_packets_lostzResponseList.stats_packets_losts&)DDDrc |j|jz Sr.)r_r^r0s rstats_success_ratioz ResponseList.stats_success_ratios*T-DDDrcd|jz Sr )r}r0s rstats_lost_ratiozResponseList.stats_lost_ratios4+++rc|jSr.)rr0s rrmzResponseList.packets_losts $$rc*t|jSr.)r rWr0s r__len__zResponseList.__len__s4?###rcd}|jD]}|d|z }|dz }|d|j|j|jz }|S)Nz{0} z z.Round Trip Times min/avg/max is {0}/{1}/{2} ms)rWrLrprurs)r(retrbs rr1zResponseList.__repr__sg . .H 9##H-- -CC v  ?FFtX\Xgimixyyy rc#&K|jD]}|VdSr.)rW)r(rbs r__iter__zResponseList.__iter__s,  HNNNN  rN)rrrr2sysstdoutr)rrrArSrnrprsrurXr`r{r}rrmrr1rrrrrUrUs{//#%uSZ""""*']$!!X!55X555X555X5((( +++(EEXEEEXE,,X,%%X%$$$rrUcbeZdZdZdddejddfdZdZdZd dZ e d Z d d Z dS) CommunicatorzYInstance actually communicating over the network, sending messages and handling responsesrNFc tj|d|| |_||_||_||_t |||_||_| |_ |jtj dz|_dSdS)aCreates an instance that can handle communication with the target device :param target: IP or hostname of the remote device :type target: str :param payload_provider: An iterable list of payloads to send :type payload_provider: PayloadProvider :param timeout: Timeout that will apply to all ping messages, in seconds :type timeout: Union[int, float] :param interval: Interval to wait between pings, in seconds :type interval: int :param socket_options: Options to specify for the network.Socket :type socket_options: tuple :param seed_id: The first ICMP packet ID to use :type seed_id: Union[None, int] :param verbose: Flag to enable verbose mode, defaults to False :type verbose: bool :param output: File where to write verbose output, defaults to stdout :type output: file :param repr_format: How to __repr__ the response. Allowed: legacy, None :type repr_format: strr)optionsr')rYrZN) rSocketsocketprovidertimeoutintervalrU responsesseed_idr>osgetpid) r(r%payload_providerrrsocket_optionsrrYrZr'r>s rr)zCommunicator.__init__s},nVV^TZ[[[ (    %gfEEE & < 9;;/DLLL rcdSr.rr0s r__del__zCommunicator.__del__0s rctjtjj|||}|j|j|S)aaSends one ICMP Echo Request on the socket :param packet_id: The ID to use for the packet :type packet_id: int :param sequence_number: The sequence number to use for the packet :type sequence_number: int :param payload: The payload of the ICMP message :type payload: Union[str, bytes] :rtype: ICMP)payload identifiersequence_number)rICMPTypes EchoRequestrr+r&)r( packet_idrris r send_pingzCommunicator.send_ping3sL I J " / C C C """rc|}tj}|dkr|j|\}}}|dkr|||j|kra|jtjjj krB|d} n ||j k} | r0ttd||d||z ||j S|dktd|||j S)a"Listens for a packet of a given id for a given timeout :param packet_id: The ID of the packet to listen for, the same for request and response :type packet_id: int :param timeout: How long to listen for the specified packet, in seconds :type timeout: float :param payload_pattern: Payload reply pattern to match to request, if set to None, match by ID only :type payload_pattern: Union[None, bytes] :return: The response to the request with the specified packet_id :rtype: ResponserrNTr)r>)rrrreceiveunpackidrErrtype_idrr9r#r>) r(rrpayload_patternr= time_leftrb raw_packetr,payload_matcheds r listen_forzCommunicator.listen_forDs 9;;!mm37;3F3Fy3Q3Q 0J yS   +++;)++0EI_Ig0g0g&.+/+:h>N+N&T'HmA>N(O(OQX[dQdftCGCS T T TT#!mm$g~4CSTTTTrc |dz }|dkrd}|S)aIncreases an ICMP sequence number and reset if it gets bigger than 2 bytes :param sequence_number: The sequence number to increase :type sequence_number: int :return: The increased sequence number of 1, in case an increase was not possible :rtype: intrrr)rs r increase_seqzCommunicator.increase_seqes$ 1 V # #Orc |j|j}d}|jD]}||||}|s6|j|||jd|n:|j|||j|j|| |}|j rtj |j dS)zPerforms all the pings and stores the responses :param match_payloads: optional to set to True to make sure requests and replies have equivalent payloads :type match_payloads: boolrN) rrXrrrr`rrrrrtimesleep)r(match_payloadsrseqricmp_outs rrunzCommunicator.runrs \ } * *G~~j#w??H! m%%dooj$,PTV^&_&_````%%dooj$,PXP`bj&k&klll##C((C} * 4=))) * *rrR)F) rrrr2rrr)rrr staticmethodrrrrrrr sccSU_csz$D0000B   "UUUUB  \ ******rr)r2rrrrrr version_infoenumrrr rr r#r7r9rUrrrrrsKK A!""""""""TJ #"""""""G !!!!!!!!4$$$ScScScScScScScScjppppppppfw*w*w*w*w*w*w*w*w*w*r