oh*dZddlZddlZddlZddlZddlmZmZmZddl m Z ddl m Z ddl mZmZmZmZmZmZdgZej*dd ej*d d Gd deZy) z4 IS class is used for connection to APRS-IS network N) __version__ string_typeis_py3)parse) APRSPacket) GenericErrorConnectionDropConnectionError LoginError ParseError UnknownFormatIS r r cheZdZdZddZdZdZddZdZddZ 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 c tjtd|jj|_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__ __class__loggerr_parse set_server set_loginsockfilter _connectedbuf)selfcallsignpasswdhostport skip_logins N/root/html/w1hd9_aprs_logger/venv/lib/python3.12/site-packages/aprslib/inet.py__init__z IS.__init__5sf''8T^^=T=T(UV   d# x4  rchtr|jd}|jj|y)Nzutf-8)rencodersendall)r"texts r(_sendallz IS._sendallHs% ;;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)rrinfor r.)r" filter_texts r( set_filterz IS.set_filterMsF"  0$++> ?? MM*T[[8 9 rcJ|jjty)z+ Set callsign and password N)__dict__updatelocals)r"r#r$r's r(rz IS.set_loginXs VX&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|js|jy#tt f$r|sYnwxYw|j jd|ztj|z)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 _connectr' _send_loginr r rr0timesleep)r"blockingretrys r(connectz IS.connectds ??   $$&0    KK  AEI J JJu s,=AAcnd|_d|_|j|jjyy)zX Closes the socket Called internally when Exceptions are raised FrN)r r!rcloser"s r(rBzIS.close|s/   99 IIOO  !rct|tr t|}n%t|tst dt ||j s td|dk(ry|jddz} |jjd|jjd|j|y#tj$r)}|jtt|d}~wwxYw)zD Send a line, or multiple lines sperapted by '\r\n' z-Expected line to be str or APRSPacket, got %sz not connectedrNz ) isinstancerstrr TypeErrortyper r rstripr setblocking settimeoutr.socketerrorrB)r"lineexps r(r,z IS.sendalls dJ 't9DD+.KTRVZX X!/2 2 2: {{6"V+ , II ! !! $ II  # MM$ || , JJL!#c(+ + ,s4AB<<C8$C33C8c|js tdd} |j|D]X}|dddk7r#|r ||||j|.|jj d|j dZ |sy r#t$r<}|jjdd |j|jYd }~Dd }~wt$r<}|jjd d |j|jYd }~d }~wt$rE}|jjd |jj|jYd }~d }~wt t"f$rt$tf$r)|j'|s|j)| Yt*$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 serverrrrE# Server: %sutf8rz%s Packet: %sNrz%s: %s)r>zAPRS Packet: %s)r r _socket_readlinesrrdebugdecoder logmessagepacketr r rOrrKeyboardInterrupt SystemExitr rBr@r StopIteration)r"callbackr>immortalrawrPrQs r(consumerz IS.consumers!"=> >  228<MDAayD($TN$T[[%67 )), F8KLM@G S $8#++szzRR  R #7cjjQQ Q !!(CMM,B,BCKKPP%z2 "O4  LL(L3     !!"3T:sCA,B G2C  G2D G;EAG%G0G:GcNtj|jd|_y)z" Creates a socket N)rNcreate_connectionr8rrCs r( _open_socketzIS._open_sockets,,T[["= rcn|jjd|jd|jd |j|jj }|jjdt ||jjd|jjd|jjtjtjd|jjd}tr|jd}|ddk(r+|jj!d |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:%srrEzConnected to %srFilatin-1#z Banner: %szinvalid banner from serverNzSocket error: %sz timed outzno banner from serverT)rr0r8rfr getpeernamerHrLrM setsockoptrN SOL_SOCKET SO_KEEPALIVErecvrrXrWrKr rOrBtimeoutr )r"peerbanneres r(r:z IS._connects 94;;q>4;;WX>Z! )    99((*D KK  .D : II ! !! $ II  # II !2!2F4G4G KYY^^C(Fy1ayC !!, @%&BCCA"  KK  c!f % JJL  fnn- ) JJL KK  03q69 :1v$%&=>>%a(( )s%D.E00 H495F..&H4AH//H4cLd}|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 informationrFdrhrT z'Server responded with empty callsign???z verified,-1zPassword is incorrectzLogin successful (receive only)zLogin successfulNzFailed to login)formatr#r$rrrr0r.rrMrnlenrrXrKrWsplitr rOrHrB)r" login_strtest_r#statusrrs r(r;zIS._send_login s@ $$ MM KK*.++*;Z$++ %    45 0 MM) $ II  #99>>#i.3"67D{{9-;;=D KK  lD 1(, 3(: %Aq(FA2~ !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^}d t |vr|st|jdk(rYd}~y|jjd t |zYd}~d}~wwxYww) zH Generator for complete lines, received from the server rz$socket error when setblocking(0): %szconnection droppedNrs izsocket.recv(): returned emptyz Resource temporarily unavailablezsocket error on recv(): %srE) rrLrNrOrrHr selectrnryr!rz)r"r>rr short_bufnewlinerPs r(rVzIS._socket_readlines8sl 7 II ! !! $ IG MM499+r2xtQ G M IINN40 !KK%%&EF()=>>! HH !HTXX%!%!;dh TXX%1 || 7 KK  Ds1vM N !56 6 7"<< M6#a&@#488})KK%%&BSV&KLL MseF,C+,F, AD8AF,*F,+D5>2D00D55F,8F) 'F$2F,7'F$F,$F))F,N)rwzrotate.aprs.neti'F)rwF)F)TFF)F)r __module__ __qualname____doc__r)r.r2rrr@rBr,rbrfr:r;rVrr(rr,sK& :' # 0 ,05n> *X-0^%r)rrNrr<raprslibrrraprslib.parsingraprslib.packets.baseraprslib.exceptionsrr r r r r __all__ addLevelNameobjectrrrr(rsi$ 44!+ &R&Q(qqr