U >qaE@sdZddlZddlZddlmZGdddeZGdddeZd d Zd d Z d dZ ddZ ddZ ddZ ddZddZGdddZGdddeZdS)a ******************************************************************* Copyright (c) 2017, 2019 IBM Corp. All rights reserved. This program and the accompanying materials are made available under the terms of the Eclipse Public License v2.0 and Eclipse Distribution License v1.0 which accompany this distribution. The Eclipse Public License is available at http://www.eclipse.org/legal/epl-v10.html and the Eclipse Distribution License is available at http://www.eclipse.org/org/documents/edl-v10.php. Contributors: Ian Craggs - initial implementation and/or documentation ******************************************************************* N) PacketTypesc@s eZdZdS) MQTTExceptionN__name__ __module__ __qualname__r r W/var/www/html/flasktest/Project_env/lib/python3.8/site-packages/paho/mqtt/properties.pyrsrc@s eZdZdS)MalformedPacketNrr r r r r sr cCsttd|S)N!H bytearraystructpacklengthr r r writeInt16!srcCstd|dddS)Nr rrunpackbufr r r readInt16&srcCsttd|S)N!Lr rr r r writeInt32+srcCstd|dddS)Nrrrrr r r readInt320srcCsHtjddkrt|d}nt|tdkr.|nt|d}tt||S)Nrutf-8)sys version_infortypebytesrlen)datar r r writeUTF5s 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 readUTF>s   r-cCstt||SN)rr%)r*r r r writeBytesSsr/cCs t|}|dd||dfS)Nr)r)r*rr r r readBytesWsr0c@s(eZdZdZeddZeddZdS)VariableByteIntegerszh MQTT variable byte integer helper class. Used in several places in MQTT v5.0 properties. cCs|d|krdksntd}|d}|d}|dkr>|dO}tjddkr\|t|g7}n|tt|7}|dkrqxq|S)z Convert an integer 0 <= x <= 268435455 into multi-byte format. Returns the buffer convered from the integer. rr r)AssertionErrorr!r"r$chr)xr*digitr r r encodecszVariableByteIntegers.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 rrNr3r )r*Z multipliervaluer$r7r r r r(xs   zVariableByteIntegers.decodeN)rrr__doc__ staticmethodr8r(r r r r r1\s  r1c@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 Pairrrr !"#$%&'()*)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)rrrrErFrGrHrIrJrKrLrMrNrOrPrQrRrSrTrUrVrWrXrYrZr[r\) packetTypetypesnamesindexrZPUBLISHZ WILLMESSAGEZ SUBSCRIBEZCONNECTZCONNACKZ DISCONNECTZAUTHZPUBACKZPUBRECZPUBRELZPUBCOMPZSUBACKZUNSUBACKZ UNSUBSCRIBE properties)selfr]r r r __init__s!                 zProperties.__init__cCs||dkS)N)rGrX)getIdentFromName)rbcompressedNamer r r allowsMultipleszProperties.allowsMultiplecCs6d}|jD]"}||ddkr|j|}q2q|S)N )r_keysreplace)rbreresultnamer r r rds  zProperties.getIdentFromNamecCs|dd}ddddg}||kr2t|||nb|dd|jDkr`td t|j|j|j| |d krtd |t j |jft |t gkrF|d kr|d ks|d krtd|n||dkr|dks|d krtd|nV|dkr|d ks|dkrtd|n*|dkrF|dkrF|d krFtd|| |rt |t gkrj|g}t||rt|||}t|||dS)Nrhrir]r^r_racSsg|]}|ddqS)rhri)rk).0anamer r r sz*Properties.__setattr__..zProperty name must be one of rz,Property %s does not apply to packet type %s)ZReceiveMaximumZ TopicAliasiz.%s property value must be in the range 1-65535)ZTopicAliasMaximumrz.%s property value must be in the range 0-65535)ZMaximumPacketSizeZSubscriptionIdentifierr2z2%s property value must be in the range 1-268435455)ZRequestResponseInformationZRequestProblemInformationZPayloadFormatIndicatorz %s property value must be 0 or 1)rkobject __setattr__r_rjrstrr]rardrZNamesr#rfhasattr__getattribute__)rbrmr:Z privateVarsr r r rrsf      zProperties.__setattr__cCsdd}d}|jD]D}|dd}t||r|s8|d7}||dtt||7}d}q|d7}|S) N[Trhriz, z : F])r_rjrkrtrsgetattr)rbr*firstrmrer r r __str__/s   zProperties.__str__cCs`i}|jD]L}|dd}t||rt||}|dkrRt|trR|||<q|||<q|S)NrhriZCorrelationData)r_rjrkrtrx isinstancer$hex)rbr&rmrevalr r r json=s    zProperties.jsoncCs6d}|jD]"}|dd}t||rd}q2q|S)NTrhriF)r_rjrkrt)rbrcrmrer r r isEmptyIs  zProperties.isEmptycCs4|jD]$}|dd}t||r t||q dS)Nrhri)r_rjrkrtdelattr)rbrmrer r r clearRs  zProperties.clearcCsd}|t|7}||jdkrNtjddkr>|t|7}n|t|g7}n||jdkrl|t|7}n||jdkr|t |7}n||jdkr|t|7}nj||jdkr|t |7}nL||jd kr|t |7}n.||jd kr|t |dt |d 7}|S) Nr r>rrr?r@rArBrCrDr) r1r8r^r`r!r"r5r$rrr/r')rb identifierr#r:r*r r r writePropertyXs&zProperties.writePropertyc Csd}|jD]x}|dd}t||r||}|j|d}||rnt||D]}|||||7}qTq||||t||7}qt t ||S)Nr rhrir) r_rjrkrtrdrarfrxrr1r8r%)rbr*rmrer attr_typepropr r r rns       zProperties.packcCs||jdkr|d}d}n||jdkrrrr?rr@rrArBrCrD)r^r`rrr1r(r0r-)rbr*r#propslenr:valuelenZvalue1Z valuelen1r r r readPropertys, zProperties.readPropertycCs&d}|jD]}|j||kr |}q |Sr.)r_)rbrrrmr r r getNameFromIdents  zProperties.getNameFromIdentc Cstjddkrt|}|t|\}}||d}|}|dkrt|\}}||d}||8}|j|d}||||\}} || d}|| 8}||} | dd} | | st || rt dt t|| |q<|||fS)Nrrrhriz+Property '%s' must not exist more than once)r!r"rrr1r(rarrrkrfrtrpropertysetattr) rbr*rZVBIlenZ propslenleftrZVBIlen2rr:rZpropnamerer r r rs8     zProperties.unpackN)rrrr;rcrfrdrrrzr~rrrrrrrr r r r r=sU -  r=)r;rr!Z packettypesr Exceptionrr rrrrr'r-r/r0r1rqr=r r r r s  2