oh)dZddlZddlZddlZddlZddlmZmZmZddl m Z ddl m Z m Z mZmZmZmZdgZej&dd ej&d d Gd deZy) z4 IS class is used for connection to APRS-IS network N) __version__ string_typeis_py3)parse) GenericErrorConnectionDropConnectionError LoginError ParseError UnknownFormatIS r r cfeZdZdZddZdZdZdZdZddZ dZ d Z dd Z d Z d Zd ZddZy)rz The IS class is used to connect to aprs-is network and listen to the stream of packets. You can either run them through aprs.parse() or get them in raw form. Note: sending of packets is not supported yet ctjt|_t|_|j |||j||d|_d|_ d|_ d|_ y)z callsign - used when login in passwd - for verification, or "-1" if only listening Host & port - aprs-is server NF) logging getLogger__name__loggerr_parse set_server set_loginsockfilter _connectedbuf)selfcallsignpasswdhostports L/root/html/w1hd9_aprs_logger/venv/lib/python3.12/site-packages/aprslib/IS.py__init__z IS.__init__4sU''1   d# x(  rchtr|jd}|jj|y)Nzutf-8)rencodersendall)r texts r%_sendallz IS._sendallGs% ;;w'D $rc||_|jjd|j|jr|j d|jzyy)zD Set a specified aprs-is filter for this connection zSetting filter to: %sz #filter %s N)rrinforr+)r filter_texts r% set_filterz IS.set_filterLsF"  0$++> ?? MM*T[[8 9 rc ||_||_y)z+ Set callsign and password N)r!r")r r!r"s r%rz IS.set_loginWs!  rc||f|_y)z4 Set server ip/host and port to use N)server)r r#r$s r%rz IS.set_server^sTl rc|jry |j|jy#ttf$r|sYnwxYw|j j d|ztj|n)z Initiate connection to APRS server and attempt to login blocking = False - Should we block until connected and logged-in retry = 30 - Retry interval in seconds Nz"Retrying connection is %d seconds.) r_connect _send_loginr r rr-timesleep)r blockingretrys r%connectz IS.connectdsx ??     "0    KK  AEI J JJu s 1AAcnd|_d|_|j|jjyy)zX Closes the socket Called internally when Exceptions are raised FrN)rrrcloser s r%r<zIS.close{s/   99 IIOO  !rct|tstdt||js t d|dk(ry|j ddz} |jjd|jjd|j|y#tj$r)}|jt t|d}~wwxYw)zD Send a line, or multiple lines sperapted by '\r\n' zExpected line to be str, got %sz not connectedrNz r) isinstancer TypeErrortyperr rstripr setblocking settimeoutr+socketerrorr<str)r lineexps r%r)z IS.sendalls$ ,=tDzJ J!/2 2 2: {{6"V+ , II ! !! $ II  # MM$ || , JJL!#c(+ + ,sAB C3$CCc|js tdd} |j|D]I}|ddk7r#|r ||||j|.|jj d|K |syc#t $r<}|jjdd|j|jYd}~Dd}~wt$r<}|jjd d|j|jYd}~d}~wt$rE}|jjd |jj|jYd}~d}~wtt f$rt"tf$r)|j%|s|j'| Y|t($rY't*$rYy|jjd |xYw) a# When a position sentence is received, it will be passed to the callback function blocking: if true (default), runs forever, otherwise will return after one sentence You can still exit the loop, by raising StopIteration in the callback function immortal: When true, consumer will try to reconnect and stop propagation of Parse exceptions if false (default), consumer will return raw: when true, raw packet is passed to callback, otherwise the result from aprs.parse() znot connected to a serverrr# Server: %srz%s Packet: %sNrz%s: %s)r8zAPRS Packet: %s)rr _socket_readlinesrrdebugr logmessagepacketr r rG __class__rKeyboardInterrupt SystemExitr r<r:r StopIteration)r callbackr8immortalrawrIrJs r%consumerz IS.consumers!"=> >  228<>DAw#~$TN$T[[%67 )),=>@G S $8#++szzRR  R #7cjjQQ Q !!(CMM,B,BCKKPP%z2 "O4  LL(L3     !!"3T:sCAA>> G 2B>> G  2D G  ;E  AG G !G +G cNtj|jd|_y)z" Creates a socket N)rFcreate_connectionr2rr=s r% _open_socketzIS._open_sockets,,T[["= rcd|jjd|jd|jd |j|jj \}}|jjd|||jj d|jjd|jjtjtjd|jjd}tr|jd}|ddk(r+|jjd |j!n t#d  d|_y #t"$r:}|jj%t'||j)d }~wtj$tj*f$r`}|j)|jj%d t'|zt'|d k(r t#dt#|d }~wwxYw)z2 Attemps connection to the server zAttempting connection to %s:%srrzConnected to %s:%sr?ilatin-1rLz Banner: %szinvalid banner from serverNzSocket error: %sz timed outzno banner from serverT)rr-r2r^r getpeernamerDrE setsockoptrF SOL_SOCKET SO_KEEPALIVErecvrdecoderOrCr rGrHr<timeoutr)r raddrrportbanneres r%r4z IS._connects 94;;q>4;;WX>Z! )    99002LE5 KK  15% @ II ! !! $ II  # II !2!2F4G4G KYY^^C(Fy1ayC !!, @%&BCCA"  KK  c!f % JJL  fnn- ) JJL KK  03q69 :1v$%&=>>%a(( )s%D)E++ H/45F))&H/AH**H/cLd}|j|j|j|jdk7rd|jzndt}|j j d |j||jjd|jjt|dz}tr|jd}|j}|j jd||j!d d \}}}}}|dk(r t#d ||jk7rt#d|z|d k7r|jd k7r t#d|jd k(r|j j dy|j j dy#t"$r:}|j j%t'||j)d}~w|j)|j j%dt#dxYw)z. Sends login string to server z'user {0} pass {1} vers aprslib {3}{2} rz filter zSending login informationr?dr`rM z'Server responded with empty callsign???z verified,-1zPassword is incorrectzLogin successful (receive only)zLogin successfulNzFailed to login)formatr!r"rrrr-r+rrErelenrrfrCrOsplitr rGrHr<)r login_strtestxr!statusrks r%r5zIS._send_logins@ $$ MM KK*.++*;Z$++ %    45 0 MM) $ II  #99>>#i.3"67D{{9-;;=D KK  lD 1*.**S!*< 'Q8VQ2~ !JKK4==( !455$)< !899{{d"   !BC   !34  KK  c!f % JJL  0 JJL KK  / 0./ /s)D$F*F** H#35G((;H#c#\K |jjd d}d}tj|jggg|rdnd |jjd}|s&|jjdt d |xj|z c_ ||jvr7|jj|d \}|_ |||jvr7#tj$r7}|jjdt |zt dd}~wwxYw#tj$r^}|jjd t |zd t |vr|st|jdk(rYd}~yYd}~d}~wwxYww) zH Generator for complete lines, received from the server rz$socket error when setblocking(0): %szconnection droppedNrs izsocket.recv(): returned emptyzsocket error on recv(): %sz Resource temporarily unavailabler) rrDrFrGrrHr selectrerrrrs)r r8rk short_bufnewlinerIs r%rNzIS._socket_readlines5sg 7 II ! !! $ IG MM499+r2xtQ G " IINN40 !KK%%&EF()=>>! HH !HTXX%!%!;dh TXX%- || 7 KK  Ds1vM N !56 6 7"<< " !!">Q"GH5Q?#txx=A-!  "sZF,C+,F, AD8AF,*F,+D5>2D00D55F,8F) AF$ F,$F))F,N)rpzrotate.aprs.neti')F)TFF)F)r __module__ __qualname____doc__r&r+r/rrr:r<r)rZr^r4r5rNrr%rr+sK& :# . ,,5n> *X-0^#r)rrFryr6rrrrrparsingr exceptionsrr r r r r __all__ addLevelNameobjectrrrr%rsf$ .. &R&Q(mmr