U ZjC@sddlZddlmZGdddeZGdddeZdd Zd d Zd d ZddZ ddZ ddZ ddZ ddZ GdddZGdddZdS)N) PacketTypesc@s eZdZdS) MQTTExceptionN__name__ __module__ __qualname__r r W/var/www/html/TRUCKING_PROJECT/venv/lib/python3.8/site-packages/paho/mqtt/properties.pyrsrc@s eZdZdS)MalformedPacketNrr r r r r sr cCsttd|S)N!H bytearraystructpacklengthr r r writeInt16srcCstd|dddS)Nr rrunpackbufr r r readInt16#srcCsttd|S)N!Lr rr r r writeInt32(srcCstd|dddS)Nrrrrr r r readInt32-srcCs$t|tst|d}tt||S)Nutf-8) isinstancebytesrlen)datar r r writeUTF2s  r#cCs|dkrt|}ntd|d8}||kr2td|dd|d}|D]D}t|}|dkrp|dkrptd|dkrtd |d krLtd qL||dfS) Nrz%Not enough data to read string lengthz Length delimited string too longriiz,[MQTT-1.5.4-1] D800-DFFF found in UTF-8 datarz'[MQTT-1.5.4-2] Null found in UTF-8 dataiz#[MQTT-1.5.4-3] U+FEFF in UTF-8 data)rr decodeord)buffermaxlenrrcZord_cr r r readUTF9s   r)cCstt||SN)rr!)r&r r r writeBytesNsr+cCs t|}|dd||dfS)Nr)r)r&rr r r readBytesRsr,c@s(eZdZdZeddZeddZdS)VariableByteIntegerszh MQTT variable byte integer helper class. Used in several places in MQTT v5.0 properties. cCshd|krdks&ntd|dd}|d}|d}|dkrJ|dO}|t|g7}|dkr*qdq*|S)z Convert an integer 0 <= x <= 268435455 into multi-byte format. Returns the buffer converted from the integer. rzValue z must be in range 0-268435455) ValueErrorr )xr&digitr r r encode^szVariableByteIntegers.encodecCsXd}d}d}|d7}|d}|dd}||d@|7}|d@dkrFqP|d9}q ||fS)z Get the value of a multi-byte integer from a buffer Return the value, and the number of bytes used. [MQTT-1.5.5-1] the encoded value MUST use the minimum number of bytes necessary to represent the value rrNr0r )r&Z multipliervaluer r3r r r r$qs   zVariableByteIntegers.decodeN)rrr__doc__ staticmethodr4r$r r r r r-Ws  r-c@sxeZdZdZddZddZddZdd Zd d Zd d Z ddZ ddZ ddZ ddZ ddZddZddZdS) PropertiesabMQTT v5.0 properties class. See Properties.names for a list of accepted property names along with their numeric values. See Properties.properties for the data type of each property. Example of use:: publish_properties = Properties(PacketTypes.PUBLISH) publish_properties.UserProperty = ("a", "2") publish_properties.UserProperty = ("c", "3") First the object is created with packet type as argument, no properties will be present at this point. Then properties are added as attributes, the name of which is the string property name without the spaces. c%Cs||_dddddddg|_dd d d d d ddddddddddddddddddd d!d"d#|_|jdtjtjgf|jdtjtjgf|jdtjtjgf|jdtjtjgf|jdtjtjgf|jdtjtjgf|jdtjtj tj gf|jdtj gf|jdtj gf|jdtjtj tj gf|jdtjtj tj gf|jdtjgf|jdtjgf|jdtjgf|jdtj gf|jdtj tj gf|jdtj tj tj tjtjtjtjtj tj g f|jdtjtj gf|jdtjtj gf|jdtjgf|jdtj gf|jdtj gf|jdtjtj tjtj tj tjtjtjtjtjtjtj tj tjgf|jdtjtj gf|jdtj gf|jdtj gf|jdtj gfd$|_dS)%NByteTwo Byte IntegerFour Byte IntegerVariable Byte Integer Binary DataUTF-8 Encoded StringUTF-8 String Pairrr !"#$%&'()*)zPayload Format IndicatorzMessage Expiry Intervalz Content TypezResponse TopiczCorrelation DatazSubscription IdentifierzSession Expiry IntervalzAssigned Client IdentifierzServer Keep AlivezAuthentication MethodzAuthentication DatazRequest Problem InformationzWill Delay IntervalzRequest Response InformationzResponse InformationzServer Referencez Reason StringzReceive MaximumzTopic Alias Maximumz Topic Aliasz Maximum QoSzRetain Availablez User PropertyzMaximum Packet SizezWildcard Subscription Availablez!Subscription Identifier AvailablezShared Subscription Available)rrrArBrCrDrErFrGrHrIrJrKrLrMrNrOrPrQrRrSrTrUrVrWrXrY) packetTypetypesnamesindexrZPUBLISHZ WILLMESSAGEZ SUBSCRIBEZCONNECTZCONNACKZ DISCONNECTZAUTHZPUBACKZPUBRECZPUBRELZPUBCOMPZSUBACKZUNSUBACKZ UNSUBSCRIBE properties)selfrZr r r __init__s!                 zProperties.__init__cCs||dkS)N)rDrU)getIdentFromName)r_compressedNamer r r allowsMultipleszProperties.allowsMultiplecCs6d}|jD]"}||ddkr|j|}q2q|S)N )r\keysreplace)r_rbresultnamer r r ras  zProperties.getIdentFromNamecCs|dd}ddddg}||kr2t|||n`|dd|jDkr^td |j|j|j||d krtd |d t j |jt |t sJ|d kr|d ks|dkrt|dn|dkr|dks|dkrt|dnZ|dkr|d ks|dkrt|dn,|dkrJ|dkrJ|d krJt|d| |rt |t sh|g}t||rt|||}t|||dS)NrerfrZr[r\r^cSsg|]}|ddqS)rerf)rh).0Zanamer r r sz*Properties.__setattr__..zProperty name must be one of rz Property z does not apply to packet type )ZReceiveMaximumZ TopicAliasiz, property value must be in the range 1-65535)ZTopicAliasMaximumrz, property value must be in the range 0-65535)ZMaximumPacketSizeZSubscriptionIdentifierr.z0 property value must be in the range 1-268435455)ZRequestResponseInformationZRequestProblemInformationZPayloadFormatIndicatorz property value must be 0 or 1)rhobject __setattr__r\rgrrZr^rarZNamesrlistrchasattr__getattribute__)r_rjr6Z privateVarsr r r rnsV        zProperties.__setattr__cCsbd}d}|jD]B}|dd}t||r|s8|d7}||dt||7}d}q|d7}|S) N[Trerfz, z : F])r\rgrhrpgetattr)r_r&firstrjrbr r r __str__$s  zProperties.__str__cCs`i}|jD]L}|dd}t||rt||}|dkrRt|trR|||<q|||<q|S)NrerfZCorrelationData)r\rgrhrprtrr hex)r_r"rjrbvalr r r json1s    zProperties.jsoncCs6d}|jD]"}|dd}t||rd}q2q|S)NTrerfF)r\rgrhrp)r_rcrjrbr r r isEmpty=s  zProperties.isEmptycCs4|jD]$}|dd}t||r t||q dS)Nrerf)r\rgrhrpdelattr)r_rjrbr r r clearFs  zProperties.clearcCsd}|t|7}||jdkr2|t|g7}n||jdkrP|t|7}n||jdkrn|t|7}n||jdkr|t|7}nh||jdkr|t|7}nJ||jdkr|t|7}n,||jdkr|t|d t|d 7}|S) Nr/r:r;r<r=r>r?r@rr) r-r4r[r]r rrr+r#)r_ identifiertyper6r&r r r writePropertyLs"zProperties.writePropertyc Csd}|jD]x}|dd}t||r||}|j|d}||rnt||D]}|||||7}qTq||||t||7}qt t ||S)Nr/rerfr) r\rgrhrprar^rcrtrr-r4r!)r_r&rjrbr~ attr_typepropr r r r_s       zProperties.packcCs||jdkr|d}d}n||jdkrr?r@)r[r]rrr-r$r,r))r_r&rpropslenr6valuelenZvalue1Z valuelen1r r r readPropertyps, zProperties.readPropertycCs&d}|jD]}|j||kr |}q |Sr*)r\)r_r~rzrjr r r getNameFromIdents  zProperties.getNameFromIdentc Cs|t|\}}||d}|}|dkrt|\}}||d}||8}|j|d}||||\}} || d}|| 8}||} | dd} || st|| rt dt dt || |q&|||fS)Nrrerfz Property 'z' must not exist more than once) r}r-r$r^rrrhrcrprpropertysetattr) r_r&rZVBIlenZ propslenleftr~ZVBIlen2rr6rZpropnamerbr r r rs4      zProperties.unpackN)rrrr7r`rcrarnrvryr{r}rrrrrr r r r r9sU )   r9)rZ packettypesr Exceptionrr rrrrr#r)r+r,r-r9r r r r s 0