a k#d}28@sdZddlmZmZmZddlmZmZmZm 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&d&e ZBGd'd(d(eZCed)ed*ed+ed,ed-ed.e d/e!d0e"d1e#d2e$d3e%d4e&d5e'd6e(d7e)d8e*d9e+d:e,d;e-de0d?e1d@e2dAe3dBe4dCe5dDiZDe6dEe7dFe8dGe9dHiZEe:dIe;dJedMe?dNe@dOeAdPiZGedQdd edRe6d eEedSdd edTdd edUdd edVe:d eFgZHdWdXZIdYdZZJGd[d\d\eZKGd]d^d^eZLGd_d`d`eZMGdadbdbeZNGdcddddeZOGdedfdfeZPGdgdhdheZQGdidjdjeZRGdkdldleZSGdmdndneZTGdodpdpeZUGdqdrdreZVGdsdtdteZWGdudvdveZXGdwdxdxeZYGdydzdzeZZGd{d|d|eZ[Gd}d~d~eZ\GdddeZ]GdddeZ^GdddeZ_GdddeZ`GdddeZaGdddeZbGdddeZcGdddeZdGdddeZeGdddeZfGdddeZgeeeKddeeeKddeeeKdddeeKeLedeeKeMedeeKeNedeeKeOedeeKePedeeKeQedeeKeRe deeKeSe!deeKeTe"deeKeUe#deeKeVe$deeKeWe%deeKeXe&deeKeYe'deeKeZe(deeKe[e)deeKe\e*deeKe]e+deeKe^e,deeKe_e-deeKe`e.deeKeae/deeKebe0deeKece1deeKede2deeKeee3deeKefe4deeKege5deegeKdS)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 cs8eZdZdZddZddZddZfdd ZZS) 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). cCsZ|||}|dks|dkr.td|jjn(|dkrJ|dtd|S|t|SdS)Nrz%s: invalid length field valuez!H)Zi2mr __class____name__structpackr)selfpktsvalr<K/var/www/html/gsl.tools/lib/python3.9/site-packages/scapy/contrib/mqttsn.pyaddfieldSs zVariableFieldLenField.addfieldcCspt|ddkrTt|dkr,td|jj|ddt|dd>t|dBfS|ddt|dfSdS)Nrrr/z%s: malformed length fieldrr)rlenrr4r5)r8r9r:r<r<r=getfield]s (zVariableFieldLenField.getfieldcCstSN)RandVariableFieldLenr8r<r<r=randvalfszVariableFieldLenField.randvalcstt|j|i|dSrA)superr0__init__)r8argskwargsr4r<r=rFiszVariableFieldLenField.__init__) r5 __module__ __qualname____doc__r>r@rDrF __classcell__r<r<rIr=r0Ls   r0cseZdZfddZZS)rBcstt|dddS)Nrr1)rErBrFrCrIr<r=rFnszRandVariableFieldLen.__init__)r5rJrKrFrMr<r<rIr=rBmsrB 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 supporteddupZqosretainZwillZ cleansesstid_typecsfdd}|S)Ncsbt|jdrP|jjdkr(|jjdS|jjdkrP|jjdkrP|jjdSt|jdS)Nr?r2rrr1r)hasattr underlayerr?payloadr9 size_untilr<r=funs   z _mqttsn_length_from..funr<)rsrtr<rrr=_mqttsn_length_froms rucCsx|t|j}|jtkr4t|jdddur4|d8}n0|jtkrdt|jdddurd|t|jjd}|dkrt|d7}|S)Ndurationr w_node_idrr2)r?rptyperdgetattr ENCAPS_MSGrw)r9xresr<r<r=_mqttsn_len_adjusts   r}c@s,eZdZdZedddededdegZdS)MQTTSNzMQTT-SN headerr?N)Z length_ofadjustrxr) r5rJrKnamer0r}r PACKET_TYPE fields_descr<r<r<r=r~s  r~c@s$eZdZdZeddeddgZdS)MQTTSNAdvertisezMQTT-SN advertise gatewaygw_idrrvN)r5rJrKrrr rr<r<r<r=rsrc@seZdZdZeddgZdS)MQTTSNSearchGWzMQTT-SN search gatewayradiusrN)r5rJrKrrrr<r<r<r=rsrc@s,eZdZdZeddeddeddgZdS) MQTTSNGwInfozMQTT-SN gateway inforrZgw_addrrZ length_fromN)r5rJrKrrr rurr<r<r<r=rsrc@s8eZdZdZeeddeddeddedd gZ d S) MQTTSNConnectzMQTT-SN connect commandZprot_idrrvr client_idrrrN) r5rJrKr FLAG_FIELDSrr r rurr<r<r<r=rs rc@seZdZdZedeegZdS) MQTTSNConnackzMQTT-SN connect ACK return_codeNr5rJrKrrACCEPTED RETURN_CODESrr<r<r<r=rs rc@seZdZdZdS)MQTTSNWillTopicReqzMQTT-SN will topic requestNr5rJrKrr<r<r<r=rsrc@s(eZdZdZeeddeddgZdS)MQTTSNWillTopiczMQTT-SN will topic will_topicrrrNr5rJrKrrr rurr<r<r<r=rsrc@seZdZdZdS)MQTTSNWillMsgReqzMQTT-SN will message requestNrr<r<r<r=r src@s$eZdZdZeddeddgZdS) MQTTSNWillMsgzMQTT-SN will messagewill_msgrrrNr5rJrKrr rurr<r<r<r=rsrc@s4eZdZdZeddeddeddeddgZd S) MQTTSNRegisterzMQTT-SN registertidrmid topic_namerrrN)r5rJrKrr r rurr<r<r<r=rs rc@s.eZdZdZeddeddedeegZdS) MQTTSNRegackzMQTT-SN register ACKrrrrN r5rJrKrr rrrrr<r<r<r=r s  rc@s8eZdZdZeeddeddeddeddgZd S) MQTTSNPublishzMQTT-SN publish messagerrrdatarrrN) r5rJrKrrr r rurr<r<r<r=r)s rc@s.eZdZdZeddeddedeegZdS) MQTTSNPubackzMQTT-SN publish ACKrrrrNrr<r<r<r=r2s  rc@seZdZdZeddgZdS) MQTTSNPubcompzMQTT-SN publish completerrNr5rJrKrr rr<r<r<r=r;src@seZdZdZeddgZdS) MQTTSNPubreczMQTT-SN publish receivedrrNrr<r<r<r=rBsrc@seZdZdZeddgZdS) MQTTSNPubrelzMQTT-SN publish releaserrNrr<r<r<r=rIsrc @sbeZdZdZeeddeeddddeeddd d d deed de d dddgZ dS)MQTTSNSubscribezMQTT-SN subscribe requestrrrNcCs |jdkSNrrmrqr<r<r=UzMQTTSNSubscribe. short_topicrlengthcCs |jdkSNrrrqr<r<r=rWrrr/rcCs |jdvSN)rrrrqr<r<r=rZr r5rJrKrrr r r r rurr<r<r<r=rPs rc@s2eZdZdZeeddeddedeegZ dS) MQTTSNSubackzMQTT-SN subscribe ACKrrrrN) r5rJrKrrr rrrrr<r<r<r=r^s  rc @sbeZdZdZeeddeeddddeeddd d d deed de d dddgZ dS)MQTTSNUnsubscribezMQTT-SN unsubscribe requestrrrNcCs |jdkSrrrqr<r<r=rlrzMQTTSNUnsubscribe.rrrcCs |jdkSrrrqr<r<r=rnrrr/rcCs |jdvSrrrqr<r<r=rqrrr<r<r<r=rgs rc@seZdZdZeddgZdS)MQTTSNUnsubackzMQTT-SN unsubscribe ACKrrNrr<r<r<r=rusrc@s$eZdZdZeddeddgZdS) MQTTSNPingReqzMQTT-SN ping requestrrrrNrr<r<r<r=r|src@seZdZdZdS)MQTTSNPingRespzMQTT-SN ping responseNrr<r<r<r=rsrc@s&eZdZdZeeddddgZdS)MQTTSNDisconnectzMQTT-SN disconnect requestrvNcCs$t|jdo"|jjdup"|jjdkS)Nr?r)rnror?rqr<r<r=rs zMQTTSNDisconnect.)r5rJrKrr r rr<r<r<r=rs rc@s(eZdZdZeeddeddgZdS)MQTTSNWillTopicUpdzMQTT-SN will topic updaterrrrNrr<r<r<r=rsrc@seZdZdZedeegZdS)MQTTSNWillTopicRespzMQTT-SN will topic responserNrr<r<r<r=rs rc@s$eZdZdZeddeddgZdS)MQTTSNWillMsgUpdzMQTT-SN will message updaterrrrNrr<r<r<r=rsrc@seZdZdZedeegZdS)MQTTSNWillMsgRespzMQTT-SN will message responserNrr<r<r<r=rs rc@s8eZdZdZedddedddedded d gZd S) MQTTSNEncapszMQTT-SN encapsulated messageZresvdrrrrrwrrrN)r5rJrKrrr rurr<r<r<r=rs  ri[)sport)dport)rr)rx)hrLZ scapy.packetrrrZ scapy.fieldsrrrrr r r r r rZscapy.layers.inetrZ scapy.errorrZ scapy.compatrrZscapy.volatilerr6rNrOrPrQrRrSrTrUrVrWrXrYrZr[r\r]r^r_r`rarbrcrdrerfrgrhrzZQOS_0ZQOS_1ZQOS_2ZQOS_NEG1Z TID_NORMALZ TID_PREDEFZ TID_SHORTZ TID_RESVDrZREJ_CONJZREJ_TIDZ REJ_NOTSUPr0rBrZ QOS_LEVELSZTOPIC_ID_TYPESrrrur}r~rrrrrrrrrrrrrrrrrrrrrrrrrrrrr<r<r<r=sF 0   !!