h*'rddlmZmZddlmZmZmZmZmZm Z m Z m Z m Z ddl mZddlmZddlmZmZddlmZddlmZGdd eZGd d eZd d ddddddddddddddZddddZGd d!eZd"d#d$d%ZGd&d'eZGd(d)eZd*d+d,d-d.d/d0Z Gd1d2eZ!Gd3d4eZ"Gd5d6eZ#Gd7d8eZ$Gd9d:eZ%Gd;deZ'Gd?d@e'Z(GdAdBeZ)dCdDdEdFdGd/dHdIdJdKdLdMdN Z*GdOdPeZ+GdQdReZ,GdSdTeZ-eeedUVeeedUWeeedXYeee!dZYeee"d[Yeee#d\Yeee$d]Yeee%d^Yeee&d_Yeee)d`Yeee+daYeee,dbYeee-dcYeeeddYeeeee!eee"eee#eee$eee%eee&eee)eee+eee,eee-eeeedeS)f)Packet bind_layers) BitEnumField ByteEnumField ByteFieldConditionalField FieldLenFieldFieldListFieldPacketListField ShortField StrLenField)TCP)Scapy_Exception)orbchb)RandNum)confc eZdZdZdZdZdS)VariableFieldLenFieldc|||}g}|r|dkr||dz|dz}nZ||t|dz dfdt |D}||zSt|dkrt d|jjz||dzS) Nc3RK|]!\}}t||krdndzV"dS)rrN)r).0ival lastoffsets V/mounts/lovelace/software/anaconda3/lib/python3.11/site-packages/scapy/contrib/mqtt.py z1VariableFieldLenField.addfield..)sT ? ?$*As!$CZ11S$I J J ? ? ? ? ? ?r%s: malformed length field)i2mappendlenjoin enumerater __class____name__)selfpktsrdatars @r addfieldzVariableFieldLenField.addfieldshhsC   ?Syy C#I&&&  C    YY] xx ? ? ? ?.7oo ? ? ???4x4yy1}}%&B&*n&='>??? ?7{rcd}t|D]^\}}t|}||dzd|zzz }|dzdkr||dzd|fcS|dkrtd|jjz_dS)Nrrrrr#)r)rrr*r+)r,r-r.valueoffsetcurbytes r getfieldzVariableFieldLenField.getfield2s(|| ? ?OFG'llG gmv 6 6E}!!!~u,,,,zz%&B&*n&='>???  ? ?rctSN)RandVariableFieldLenr,s r randvalzVariableFieldLenField.randval=s#%%%rN)r+ __module__ __qualname__r0r6r;rr rrsA& ? ? ?&&&&&rrceZdZdZdS)r9c2tj|dddS)Nri)r__init__r:s r rAzRandVariableFieldLen.__init__Bsq),,,,,rN)r+r<r=rAr>rr r9r9As#-----rr9CONNECTCONNACKPUBLISHPUBACKPUBRECPUBRELPUBCOMP SUBSCRIBESUBACK UNSUBSCRIBEUNSUBACKPINGREQPINGRESP DISCONNECTAUTH)rr2r" zAt most once deliveryzAt least once deliveryzExactly once delivery)rrr2c eZdZdZedddeedddddd ed dd eed ddddd ed dd dgZdS)MQTTzMQTT fixed headertyperrQDUPrDisabledEnabledrrQOSr2RETAINr'Nc*t|jSr8)r'payload)r-xs r z MQTT.osC 4D4Dr) length_ofadjust) r+r<r=namerCONTROL_PACKET_TYPE QOS_LEVELr fields_descr>rr r^r^bs D VQ#677 UAqj&/#1#1 2 2 UAq),, Xq!)2&4&4 5 5 eTU%D%D G G G KKKrr^zv3.1zv3.1.1zv5.0)r"rQrRceZdZdZedddeddded d eed d d dddedd d dddedd d dddedd de edd d dddedd d dddedd d ddde dd edddeddde edddde edddd e ed!dd"d#e ed"dd$d%e ed&dd'd(e ed'dd)d*e ed+dd,d-e ed,dd.d/gZ dS)0 MQTTConnectz MQTT connectlengthN protonamerjc|jSr8rrr-s r rizMQTTConnect.CJr length_from protolevelrR usernameflagrrrarbrc passwordflagwillretainflag willQOSflagr2willflag cleansessreservedklive clientIdlenclientIdc|jSr8)rrxs r rizMQTTConnect.sCOrwtoplen willtopicc|jdkSNrrrxs r rizMQTTConnect. S\Q%6rc|jSr8)rrxs r rizMQTTConnect.S[rc|jdkSrrrxs r rizMQTTConnect.rrwmsglenwillmsgc|jdkSrrrxs r rizMQTTConnect.rrc|jSr8)rrxs r rizMQTTConnect.rrc|jdkSrrrxs r rizMQTTConnect.rruserlenusernamec|jdkSrr}rxs r rizMQTTConnect.S%5%:rc|jSr8)rrxs r rizMQTTConnect.rrc|jdkSrrrxs r rizMQTTConnect.rrpasslenpasswordc|jdkSrr~rxs r rizMQTTConnect.rrc|jSr8)rrxs r rizMQTTConnect.rrc|jdkSrrrxs r rizMQTTConnect.rr) r+r<r=rlr r rPROTOCOL_LEVELrrnr rror>rr rqrqzs D h <<< K 6 6 8 8 8 lA~66 ^Qz/8,:,: ; ; ^Qz/8,:,: ; ; %q!1:.<.< = = ]Aq)44 ZA:+4(6(6 7 7 [!QJ,5)7)7 8 8 ZA:+4(6(6 7 7 7A mTZ@@@ J ; ; = = = y$+NNN66 8 8["1H1HJJJ66 8 8 y$)LLL66 8 8Y1H1HJJJ66 8 8 y$*MMM:: < <Z1H1HJJJ:: < < y$*MMM:: < <Z1H1HJJJ:: < rr rrs DKKKrrzConnection AcceptedzUnacceptable protocol versionzIdentifier rejectedzServer unavailablezBad username/passwordzNot authorized)rrr2r"rQrRcDeZdZdZeddeddegZdS) MQTTConnackz MQTT connacksessPresentFlagrretcodeN)r+r<r=rlrr RETURN_CODEror>rr rrs; D #Q'' iK00KKKrrceZdZdZedddedddeed dd ed dd gZdS) MQTTPublishz MQTT publishrrNtopicrtruc|jSr8rwrxs r rizMQTTPublish.ryrrzmsgidcB|jjdkp|jjdkS)Nrr2) underlayerrdrxs r rizMQTTPublish.s%cn&8A&='>&)n&8A&=rr3c~|jjdkr|jj|jz dz n|jj|jz dz S)Nrr2rQ)rrdr'rrrxs r rizMQTTPublish.sD~)Q..-0N,>,Ka,O,ON&3a7r) r+r<r=rlr r rr ror>rr rrs D h888 GR 6 6 8 8 8GT22?? @ @  GR!8!8 9 9 9 KKKrrc,eZdZdZeddgZdS) MQTTPubackz MQTT pubackrNr+r<r=rlr ror>rr rr) D 7D!!KKKrrc,eZdZdZeddgZdS) MQTTPubrecz MQTT pubrecrNrr>rr rrrrrc,eZdZdZeddgZdS) MQTTPubrelz MQTT pubrelrNrr>rr rrrrrc,eZdZdZeddgZdS) MQTTPubcompz MQTT pubcomprNrr>rr rrs) D 7D!!KKKrrcReZdZdZedddedddgZd ZdS) MQTTTopicz MQTT topicrrNrrtruc|jSr8rwrxs r rizMQTTTopic.s rrzctjSr8)r padding_layer)r,rgs r guess_payload_classzMQTTTopic.guess_payload_classs !!r)r+r<r=rlr r rorr>rr rrs[ D h888 GR-B-BCCCK """""rrc:eZdZejeddegzZdS) MQTTTopicQOSrdrN)r+r<r=rrorrnr>rr rrs,'==9+M+M*NNKKKrrcFeZdZdZeddedgegZdS) MQTTSubscribezMQTT subscriberNtopicspkt_cls)r+r<r=rlr r rror>rr rrs= D 7D!!"l;;;KKKrrz Granted QoS 0z Granted QoS 1z Granted QoS 2zUnspecified errorzImplementation specific errorzTopic Filter invalidzPacket Identifier in usezQuota exceededz"Shared Subscriptions not supportedz&Subscription Identifiers not supportedz$Wildcard Subscriptions not supported) rrr2rc ZeZdZdZeddeddeddegZdS) MQTTSubackz MQTT subackrNretcodesru) r+r<r=rlr r rALLOWED_RETURN_CODEror>rr rrsI D 7D!!z4r4AT)U)UVVKKKrrcFeZdZdZeddedgegZdS)MQTTUnsubscribezMQTT unsubscriberNrr)r+r<r=rlr r rror>rr rrs= D 7D!!"i888KKKrrc,eZdZdZeddgZdS) MQTTUnsubackz MQTT unsubackrNrr>rr rr%s) D 7D!!KKKrri[)sport)dportr)r_r2r"rQrRrSrTrUrVrWrXr[N). scapy.packetrr scapy.fieldsrrrrr r r r r scapy.layers.inetr scapy.errorr scapy.compatrrscapy.volatiler scapy.configrrr9rmrnr^rrqrrrrrrrrrrrrrrrr>rr rs-,,,,,,,                      "!!!!!''''''!!!!!!!!"""""" & & & & &M & & &F-----7---(   6$ -----&---`V &  &     &    &""""""""OOOOO9OOOF     )  $  . 2 0   f6 CT"""" CT"""" D+A&&&& D+A&&&& D+A&&&& D*1%%%% D*1%%%% D*1%%%% D+A&&&& D-a(((( D*1%%%% D/++++ D,R(((( D.r**** K K K J J J K M4 J OT""" L$ ND!!!!!r