u gJ5ndZddlZddlZddlZddlZddlZddlZddlZGdde Z e dkrej dZ eej dZej dZe e ee Z eedS#ewxYwdS) zDStream beast raw data from a TCP server, convert to mode-s messages.NcPeZdZfdZdZdZdZdZdZdZ dZ d d Z xZ S) TcpClientctt|||_||_g|_d|_||_|jdvr#tdtj dd|_ d|_ d|_ dS)N)rawbeastskysensez.datatype must be either raw, beast or skysenseF)superr__init__hostportbuffersocketdatatypeprintos_exit raw_pipe_in stop_flagexception_queue)selfr r r __class__s >/import/home/andy/PROGRAMMING/ModeS/amModeS/extra/tcpclient.pyr zTcpClient.__init__ s i'')))      = < < < B C C C HQKKK#cXtjtj|_|jtjd|jtjd|jd|jd|j dS)Nri'ztcp://:) zmqContextrSTREAM setsockoptLINGERRCVTIMEOconnectr r rs rr#zTcpClient.connectskmm**3:66  sz1--- s|U333 TYYY BCCCCCrc8|jdS)N)rcloser$s rstopzTcpClient.stop#s rcbg}d}d|_|jD]}|dkr1d}tj}||j|g|dkr d}d|_|sJd|cxkrdks!nd|cxkrd ksnd |cxkrd krnx|jt |z|_g|_|S) z Read raw ADS-B data type. String strats with "*" and ends with ";". For example: *5d484ba898f8c6; *8d400cd5990d7e9a10043e5e6da0; *a0001498be800030aa0000c7a75f; F;T*09AFaf) current_msgrtimeappendchr)rmessagesmsg_stopbtss rread_raw_bufferzTcpClient.read_raw_buffer&s = =ABwwY[[!12 6777Bww #%  =2====b====B!MMMMrMMMMR1^^^^PS^^^^^#'#3c!ff#<  rchg}g}d}|t|jkr |j||dzddgkr|d|dz }n|t|jdz kr'|j|dkr|dn|j|dkr\|t|jdz kr|dnKt|dkr||g}n ||j||dz }|t|jk t|dkrlg}t|D]N\}}|dkr.|t|dz kr|||g9||Odg|z|_ng|_g}|D]}t j}|d} | dkr(dd|dd D}n/| d kr(dd |dd D}nzt|d vrtj|} | dvrt|dkr| dvrt|dkr|||g|S)Handle mode-s beast data type. "1" : 6 byte MLAT timestamp, 1 byte signal level, 2 byte Mode-AC "2" : 6 byte MLAT timestamp, 1 byte signal level, 7 byte Mode-S short frame "3" : 6 byte MLAT timestamp, 1 byte signal level, 14 byte Mode-S long frame "4" : 6 byte MLAT timestamp, status data, DIP switch configuration settings (not on Mode-S Beast classic) : true 0x1a is 0x1a, and "1", "2" and "3" are 0x31, 0x32 and 0x33 timestamp: wiki.modesbeast.com/Radarcape:Firmware_Versions#The_GPS_timestamp rr 2r)c3 K|] }d|zV dSz%02XN.0is r z.TcpClient.read_beast_buffer..&;;Qfqj;;;;;;r3c3 K|] }d|zV dSrArBrCs rrFz.TcpClient.read_beast_buffer..rGrr rNrO) lenrr4 enumerateextendr3joinpmsdf) r messages_mlatmsgrEremindermr6mmr9msgtyperas rread_beast_bufferzTcpClient.read_beast_bufferBs"   #dk""""{1q1u9%$55 4   Qs4;''!+++$+a.D2H2H 4    Q4''DK((1,,,JJt$$$$XX\\!((---C 4;q>*** FA!#dk""""& s88a<<H!# ' '1IIAC1 $4$4OOQF++++OOA&&&&&3,DKKDK ' 'BBeG$gg;;"QrT(;;;;;Dgg;;"QrT(;;;;;3xxx''B]""s3xx2~~111c#hh"nn OOS"I & & & &rcg}g}d}|t|jkr |j||dzddgkr|d|dz }n|t|jdz kr'|j|dkr|dn|j|dkr\|t|jdz kr|dnKt|dkr||g}n ||j||dz }|t|jk t|dkrlg}t|D]N\}}|dkr.|t|dz kr|||g9||Odg|z|_ng|_g}|D]}t j}|d} | dkr(dd|dd D}n/| d kr(dd |dd D}n{t|d vr tj|} |d} | dz } | dz} dtj | z}| dvrt|dkr| dvrt|dkr||||g|S)r<rr=r>r r?r)c3 K|] }d|zV dSrArBrCs rrFz;TcpClient.read_beast_buffer_rssi_piaware..rGrrHrIrJc3 K|] }d|zV dSrArBrCs rrFz;TcpClient.read_beast_buffer_rssi_piaware..rGrrLrM rPrNrTrO) r\rr4r]r^r3r_r`ramathlog10)rrbrcrErdrer6rfr9rgraraw_rssi rssi_ratio signalLevel dbfs_rssis rread_beast_buffer_rssi_piawarez(TcpClient.read_beast_buffer_rssi_piawares"   #dk""""{1q1u9%$55 4   Qs4;''!+++$+a.D2H2H 4    Q4''DK((1,,,JJt$$$$XX\\!((---C 4;q>*** FA!#dk""""& s88a<<H!# ' '1IIAC1 $4$4OOQF++++OOA&&&&&3,DKKDK% 2% 2BBeG$gg;;"QrT(;;;;;Dgg;;"QrT(;;;;;3xxx''  B!uH!CJ$/KTZ 444I]""s3xx2~~111c#hh"nn OOS)R0 1 1 1 1rc*d}d}t|j|krdSg}t|j|krYd}|j||kr|j||z|kr|dz }|j|dz r|j||dz}n|j||dz}dd |D}|dz }|j||d z}|dd zd z|dd zz|d d z z}|d dzdz|ddzz|ddzz|dz} || dzz} |d z }|dz }|j|d|_||| gn|jdd|_t|j|kY|S)aSkysense stream format. :: ---------------------------------------------------------------------------------- Field SS MS MS MS MS MS MS MS MS MS MS MS MS MS MS TS TS TS TS TS TS RS RS RS ---------------------------------------------------------------------------------- Position: 0 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 ---------------------------------------------------------------------------------- SS field - Start character Position 0: 1 byte = 8 bits Start character '$' MS field - Payload Position 1 through 14: 14 bytes = 112 bits Mode-S payload In case of DF types that only carry 7 bytes of information position 8 through 14 are set to 0x00. TS field - Time stamp Position 15 through 20: 6 bytes = 48 bits Time stamp with fields as: Lock Status - Status of internal time keeping mechanism Equal to 1 if operating normally Bit 47 - 1 bit Time of day in UTC seconds, between 0 and 86399 Bits 46 through 30 - 17 bits Nanoseconds into current second, between 0 and 999999999 Bits 29 through 0 - 30 bits RS field - Signal Level Position 21 through 23: 3 bytes = 24 bits RSSI (received signal strength indication) and relative noise level with fields RNL, Q12.4 unsigned fixed point binary with 4 fractional bits and 8 integer bits. This is and indication of the noise level of the message. Roughly 40 counts per 10dBm. Bits 23 through 12 - 12 bits RSSI, Q12.4 unsigned fixed point binary with 4 fractional bits and 8 integer bits. This is an indication of the signal level of the received message in ADC counts. Roughly 40 counts per 10dBm. Bits 11 through 0 - 12 bits r[$Nrr rlrNr)c3 K|] }d|zV dSrArB)rDjs rrFz1TcpClient.read_skysense_buffer..Fs&::Qfqj::::::rrnr=?rUrQrHrRg& .>)r\rr_r4) r SS_MSGLENGTH SS_STARTCHARr6rEpayloadrctsbinsecnanor9s rread_skysense_bufferzTcpClient.read_skysense_buffersp  t{  | + +4$+--A A,..KL 01\AAQ;q>Q&5"k!a"f*5GG#k!a!e)4Ggg::':::::R AAI.a4B.58q=AU1XQR]SAho",Qx2~'Qx1}&Ah 4&=(QQ"k,--8 b ****"k!""o =$+-->rc>|D]\}}td||fzdS)z/re-implement this method to handle the messagesz %15.9f %sN)r)rr6rcts rhandle_messageszTcpClient.handle_messagesZs9 * *FC +C( ) ) ) ) * *rNc||_||_||_| d|jdD}|j||jdkr| }n?|jdkr| }n|jdkr| }|s| |n]#tjj$rYt $r;}t#j}|j|j||d}~wwxYw)NTcg|]}|SrBrBrCs r z!TcpClient.run..gs>>>!A>>>rirrr)rrrr#rrecvrr^rrhr:rrrerrorAgain Exception traceback format_excput)rrrrreceivedr6etbs rrunz TcpClient.run_s_&."   >>t{'7'7'='=>>> ""8,,,=G++#5577HH]e++#3355HH]j00#88::H3((22229?      )++'3(,,R000  / s$BC" C""D<8 D<6D77D<)NNN) __name__ __module__ __qualname__r r#r'r:rhrurrr __classcell__)rs@rrr s$$$$$ DDD 8UUUn___B^^^@*** !!!!!!!!rr__main__r r=r})r r r)__doc__rsysr3amModeSr`rrroobjectrrargvr intr rclientrr'rBrrrsJJ  ttttttttn  z 8A;D 3sx{  Dx{H YDth ? ? ?F   s 2BB2