h}2 dZddlmZmZmZddlmZmZmZm Z m Z m Z m Z m Z mZmZddlmZddlmZddlmZmZddlmZddlZdZd Zd Zd Zd Zd ZdZ dZ!dZ"dZ#dZ$dZ%dZ&dZ'dZ(dZ)dZ*dZ+dZ,dZ-dZ.dZ/dZ0dZ1d Z2d!Z3d"Z4d#Z5dZ6d Z7d Z8d$Z9dZ:d Z;d Zd Z?d Z@d$ZAGd%d&e ZBGd'd(eZCied)ed*ed+ed,ed-ed.e d/e!d0e"d1e#d2e$d3e%d4e&d5e'd6e(d7e)d8e*d9e+d:e,d;e-de0d?e1d@e2dAe3dBe4dCe5dDi ZDe6dEe7dFe8dGe9dHiZEe:dIe;dJedMe?dNe@dOeAdPiZGedQdd edRe6d eEedSdd edTdd edUdd edVe:d eFgZHdWZIdXZJGdYdZeZKGd[d\eZLGd]d^eZMGd_d`eZNGdadbeZOGdcddeZPGdedfeZQGdgdheZRGdidjeZSGdkdleZTGdmdneZUGdodpeZVGdqdreZWGdsdteZXGdudveZYGdwdxeZZGdydzeZ[Gd{d|eZ\Gd}d~eZ]GddeZ^GddeZ_GddeZ`GddeZaGddeZbGddeZcGddeZdGddeZeGddeZfGddeZgeeeKdeeeKdeeeKddeeKeLeeeKeMeeeKeNeeeKeOeeeKePeeeKeQeeeKeRe eeKeSe!eeKeTe"eeKeUe#eeKeVe$eeKeWe%eeKeXe&eeKeYe'eeKeZe(eeKe[e)eeKe\e*eeKe]e+eeKe^e,eeKe_e-eeKe`e.eeKeae/eeKebe0eeKece1eeKede2eeKeee3eeKefe4eeKege5eegeKdS)z} MQTT for Sensor Networks (MQTT-SN) Specification: http://www.mqtt.org/new/wp-content/uploads/2009/06/MQTT-SN_spec_v1.2.pdf )Packet bind_layersbind_bottom_up) BitField BitEnumField ByteField ByteEnumFieldConditionalField FieldLenField ShortFieldStrFixedLenField StrLenFieldXByteEnumField)UDP)Scapy_Exception)chborb)RandNumN c4eZdZdZdZdZdZfdZxZS)VariableFieldLenFielda MQTT-SN length field either has 1 byte for values [0x02, 0xff] or 3 bytes for values [0x0100, 0xffff]. If the first byte is 0x01 the length value comes in network byte-order in the next 2 bytes. MQTT-SN packets are at least 2 bytes long (length field + type field). c|||}|dks|dkrtd|jjz|dkr|dzt jd|zS|t |zS)Nrz%s: invalid length field valuez!H)i2mr __class____name__structpackr)selfpktsvals X/mounts/lovelace/software/anaconda3/lib/python3.11/site-packages/scapy/contrib/mqttsn.pyaddfieldzVariableFieldLenField.addfieldSs|hhsC   !GGv!"B"&."9#:;; ; 4ZZw;T3!7!77 7s3xx< c@t|ddkrgt|dkrtd|jjz|ddt|ddzt|dzfS|ddt|dfS)Nrrr0z%s: malformed length fieldrr)rlenrr8r9)r<r=r>s r@getfieldzVariableFieldLenField.getfield]s qt99  1vvzz%&B&*n&='>???QRR53qt99>S1YY66 6QRR5#ad))# #rBctSN)RandVariableFieldLen)r<s r@randvalzVariableFieldLenField.randvalfs#%%%rBcHtt|j|i|dSrG)superr2__init__)r<argskwargsr8s r@rLzVariableFieldLenField.__init__is,3#T**3TDVDDDDDrB) r9 __module__ __qualname____doc__rArErIrL __classcell__r8s@r@r2r2Lsx    $$$&&&EEEEEEEEErBr2ceZdZfdZxZS)rHcZtt|dddS)Nrr4)rKrHrL)r<r8s r@rLzRandVariableFieldLen.__init__ns* "D))221f=====rB)r9rOrPrLrRrSs@r@rHrHms8>>>>>>>>>rBrH ADVERTISESEARCHGWGWINFOCONNECTCONNACK WILLTOPICREQ WILLTOPIC WILLMSGREQWILLMSGREGISTERREGACKPUBLISHPUBACKPUBCOMPPUBRECPUBREL SUBSCRIBESUBACK UNSUBSCRIBEUNSUBACKPINGREQPINGRESP DISCONNECT WILLTOPICUPD WILLTOPICRESP WILLMSGUPD WILLMSGRESPzEncapsulated messagezFire and ForgetzAcknowledged deliverzAssured DeliveryzNo Connection requiredz Normal IDzPre-defined IDzShort Topic NameReservedAcceptedzRejected: congestionzRejected: invalid topic IDzRejected: not supporteddupqosretainwill cleansesstid_typecfd}|S)Nc t|jdrT|jjdkr|jjz dz S|jjdkr"|jjdkr|jjz dz St|jz dzS)NrDr5rrr4r)hasattr underlayerrDpayload)r= size_untils r@funz _mqttsn_length_from..funs CNE * * ;~!D((~)J6::.$q((s~/AF/J/J~)J6::3;*,q00rB)r~rs` r@_mqttsn_length_fromrs#11111 JrBc,|t|jz}|jtkrt |jdd|dz}nE|jt kr5t |jdd|t|jjzdz}|dkr|dz }|S)Ndurationr w_node_idrr5)rDr}typerlgetattr ENCAPS_MSGr)r=xress r@_mqttsn_len_adjustrs c#+ C J Z..6 q (j #+{D 1 1 =#ck+,,,q0 Tzz q JrBcJeZdZdZedddeeddegZdS)MQTTSNzMQTT-SN headerrDN) length_ofadjustrr) r9rOrPnamer2rr PACKET_TYPE fields_descrrBr@rrsK D eTU%7 9 9 9vq+.. KKKrBrcBeZdZdZeddeddgZdS)MQTTSNAdvertisezMQTT-SN advertise gatewaygw_idrrN)r9rOrPrrr rrrBr@rrs8 &D '1 :q!!KKKrBrc,eZdZdZeddgZdS)MQTTSNSearchGWzMQTT-SN search gatewayradiusrN)r9rOrPrrrrrBr@rrs) #D (AKKKrBrcXeZdZdZeddeddedgZdS) MQTTSNGwInfozMQTT-SN gateway inforrgw_addrr length_fromN)r9rOrPrrrrrrrBr@rrsI !D '1 Ir/B/B1/E/EFFFKKKrBrc teZdZdZeeddeddedded gzZ d S) MQTTSNConnectzMQTT-SN connect commandprot_idrrr client_idrrrN) r9rOrPr FLAG_FIELDSrr rrrrrBr@rrs` $D )Q :q!! K1D1DQ1G1GHHH!KKKrBrc.eZdZdZedeegZdS) MQTTSNConnackzMQTT-SN connect ACK return_codeNr9rOrPrr ACCEPTED RETURN_CODESrrrBr@rrs+ D mX|<<KKKrBrceZdZdZdS)MQTTSNWillTopicReqzMQTT-SN will topic requestNr9rOrPrrrBr@rrs 'DDDrBrcHeZdZdZeeddedgzZdS)MQTTSNWillTopiczMQTT-SN will topic will_topicrrrNr9rOrPrrrrrrrBr@rrsB D L"2E2Ea2H2HIII!KKKrBrceZdZdZdS)MQTTSNWillMsgReqzMQTT-SN will message requestNrrrBr@rr s )DDDrBrcBeZdZdZeddedgZdS) MQTTSNWillMsgzMQTT-SN will messagewill_msgrrrNr9rOrPrrrrrrBr@rrs: !D J0C0CA0F0FGGGKKKrBrc neZdZdZeddeddeddedgZd S) MQTTSNRegisterzMQTT-SN registertidrmid topic_namerrrN)r9rOrPrr rrrrrBr@rrsX D 5! 5! L"2E2Ea2H2HIIIKKKrBrcZeZdZdZeddeddedeegZdS) MQTTSNRegackzMQTT-SN register ACKrrrrN r9rOrPrr r rrrrrBr@rr sI !D 5! 5! mX|<<KKKrBrc teZdZdZeeddeddeddedgzZd S) MQTTSNPublishzMQTT-SN publish messagerrrdatarrrN) r9rOrPrrr rrrrrBr@rr)s` $D 5! 5! FB,?,?,B,BCCC!KKKrBrcZeZdZdZeddeddedeegZdS) MQTTSNPubackzMQTT-SN publish ACKrrrrNrrrBr@rr2sI D 5! 5! mX|<<KKKrBrc,eZdZdZeddgZdS) MQTTSNPubcompzMQTT-SN publish completerrNr9rOrPrr rrrBr@rr;) %D 5!KKKrBrc,eZdZdZeddgZdS) MQTTSNPubreczMQTT-SN publish receivedrrNrrrBr@rrBrrBrc,eZdZdZeddgZdS) MQTTSNPubrelzMQTT-SN publish releaserrNrrrBr@rrI) $D 5!KKKrBrc eZdZdZeeddeedddeeddd d eed de d  dgzZ dS)MQTTSNSubscribezMQTT-SN subscribe requestrrrNc|jdkSNrrxr=s r@zMQTTSNSubscribe.U S\T%9rB short_topicrlengthc|jdkSNrrrs r@rzMQTTSNSubscribe.WrrBrr0rc|jdvSN)rrrrs r@rzMQTTSNSubscribe.Z S\%ErB r9rOrPrrr r r rrrrrBr@rrPs &D 5!E40099 ; ;))-aHHH99 ; ;\41D1DQ1G1GIIIEE G G ! KKKrBrc`eZdZdZeeddeddedeegzZ dS) MQTTSNSubackzMQTT-SN subscribe ACKrrrrN) r9rOrPrrr r rrrrrBr@rr^sQ "D 5! 5! mX|<<!KKKrBrc eZdZdZeeddeedddeeddd d eed de d  dgzZ dS)MQTTSNUnsubscribezMQTT-SN unsubscribe requestrrrNc|jdkSrrrs r@rzMQTTSNUnsubscribe.lrrBrrrc|jdkSrrrs r@rzMQTTSNUnsubscribe.nrrBrr0rc|jdvSrrrs r@rzMQTTSNUnsubscribe.qrrBrrrBr@rrgs (D 5!E40099 ; ;))-aHHH99 ; ;\41D1DQ1G1GIIIEE G G ! KKKrBrc,eZdZdZeddgZdS)MQTTSNUnsubackzMQTT-SN unsubscribe ACKrrNrrrBr@rrurrBrcBeZdZdZeddedgZdS) MQTTSNPingReqzMQTT-SN ping requestrrrrNrrrBr@rr|s: !D K1D1DQ1G1GHHHKKKrBrceZdZdZdS)MQTTSNPingRespzMQTT-SN ping responseNrrrBr@rrs "DDDrBrcBeZdZdZeedddgZdS)MQTTSNDisconnectzMQTT-SN disconnect requestrNcht|jdo|jjdup|jjdkS)NrDr)r{r|rDrs r@rzMQTTSNDisconnect.s766Gn D( Ecn.@1.DrB)r9rOrPrr r rrrBr@rrsE 'D Jz4 ( ( G G  KKKrBrcHeZdZdZeeddedgzZdS)MQTTSNWillTopicUpdzMQTT-SN will topic updaterrrrNrrrBr@rrsB &D L"2E2Ea2H2HIII!KKKrBrc.eZdZdZedeegZdS)MQTTSNWillTopicRespzMQTT-SN will topic responserNrrrBr@rrs+ (D mX|<<KKKrBrcBeZdZdZeddedgZdS)MQTTSNWillMsgUpdzMQTT-SN will message updaterrrrNrrrBr@rrs: (D J0C0CA0F0FGGGKKKrBrc.eZdZdZedeegZdS)MQTTSNWillMsgRespzMQTT-SN will message responserNrrrBr@rrs+ *D mX|<<KKKrBrc reZdZdZedddedddedded  gZd S) MQTTSNEncapszMQTT-SN encapsulated messageresvdrrrrrrrrN)r9rOrPrrrrrrrBr@rrsc )D!Q1a   ++A..   KKKrBri[)sport)dport)rr)r)hrQ scapy.packetrrr scapy.fieldsrrrr r r r r rrscapy.layers.inetr scapy.errorr scapy.compatrrscapy.volatilerr:rVrWrXrYrZr[r\r]r^r_r`rarbrcrdrerfrgrhrirjrkrlrmrnrorprQOS_0QOS_1QOS_2QOS_NEG1 TID_NORMAL TID_PREDEF TID_SHORT TID_RESVDrREJ_CONJREJ_TID REJ_NOTSUPr2rHr QOS_LEVELSTOPIC_ID_TYPESrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrBr@r s  =<<<<<<<<<                        "!!!!!''''''!!!!!!!!""""""                                          EEEEEMEEEB>>>>>7>>>  { j H Y   Y  . {  Y j H Y H Y H  H!"{#$ H j Y j .? &9 B  !  &     ! z  j $ ))   HUAqLq*-- HXq! HVQ H[!QLZN;;             V   fV6FF((((((((f*****v***FV6F6F66     f   6        VF#####V###v&v     6   sF$''''sF$'''' Ct40000 FO)4444 FN2222 FLv.... FM0000 FM0000 F&\:::: FO)4444 F$:6666 FM0000 FN2222 FLv.... FM0000 FLv.... FM0000 FLv.... FLv.... FO)4444 FLv.... F%K8888 FN2222 FM0000 FN2222 F$:6666 F&\:::: F'm<<<< F$:6666 F%K8888 FLz2222 L&!!!!!rB