>qaEdZddlZddlZddlmZGddeZGddeZd Zd Z d Z d Z d Z dZ dZdZGddZGddeZdS)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) PacketTypesceZdZdS) MQTTExceptionN__name__ __module__ __qualname__H/opt/windhager/venv/lib/python3.11/site-packages/paho/mqtt/properties.pyrrDr rceZdZdS)MalformedPacketNrr r r rrrr rcFttjd|S)N!H bytearraystructpacklengths r writeInt16r! V[v.. / //r cHtjd|dddS)Nrrrunpackbufs r readInt16r!&! =s2A2w ' ' **r cFttjd|S)N!Lrrs r writeInt32r%+rr cHtjd|dddS)Nr$rrrs r readInt32r(0r"r ctjddkrt|d}n2t|tdkr|nt |d}t t ||zS)Nrutf-8r )sys version_infortypebytesrlen)datas r writeUTFr25sh Qw''DzzT#YY..ttE$4H4H c$ii 4 ''r c|dkrt|}ntd|dz}||krtd|dd|zd}|D]V}t|}|dkr|dkrtd|dkrtd |d krtd W||dzfS) Nrz%Not enough data to read string lengthz Length delimited string too longr+iiz,[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)r!rdecodeord)buffermaxlenrr cord_cs r readUTFr:>s {{6""EFFF aKF @AAA 1V8  # #G , ,C IIA F??u!"PQQ Q D==!"KLL L F??!"GHH H  q=r c@tt||zSN)rr0)r6s r writeBytesr=Ss c&kk " "V ++r cDt|}|dd|z|dzfS)Nr)r!)r6rs r readBytesr?Ws+ v  F !AfH* vax ''r c>eZdZdZedZedZdS)VariableByteIntegerszh MQTT variable byte integer helper class. Used in several places in MQTT v5.0 properties. cd|cxkrdksnJd} |dz}|dz}|dkr|dz}tjddkr|t|gz }n|tt|z }|dkrnf|S)z Convert an integer 0 <= x <= 268435455 into multi-byte format. Returns the buffer convered from the integer. rr rr*)r,r-r/chr)xr6digits r encodezVariableByteIntegers.encodecs A"""""""""" GE #IA1uu "a''%..(%E +++Avv  r c|d}d}d} |dz }|d}|dd}||dz|zz }|dzdkrn|dz}2||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 rrNrDr )r6 multipliervaluer/rGs r r4zVariableByteIntegers.decodexsw   QJE1IEABBZF eckZ/ /Es{a # J u~r N)rr r __doc__ staticmethodrHr4r r r rArA\sT \(\r rAc`eZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdS) 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> ||_gd|_idddddddd d d d d ddddddddddddddddddd d!d"d#d$d%d&d'd(d)d*d+d,d-d. |_id|jd/tjtjgfd|jd0tjtjgfd|jd1tjtjgfd |jd1tjtjgfd |jd2tjtjgfd |jd3tjtjgfd|jd0tjtj tj gfd|jd1tj gfd|jd4tj gfd|jd1tjtj tj gfd|jd2tjtj tj gfd|jd/tjgfd|jd0tjgfd|jd/tjgfd|jd1tj gfd!|jd1tj tj gfd#|jd1tj tj tj tjtjtjtjtj tj g f|jd4tjtj gf|jd4tjtj gf|jd4tjgf|jd/tj gf|jd/tj gf|jd5tjtj tjtj tj tjtjtjtjtjtjtj tj tjgf|jd0tjtj gf|jd/tj gf|jd/tj gf|jd/tj gfd6 |_dS)7N)ByteTwo Byte IntegerFour Byte IntegerVariable Byte Integer Binary DataUTF-8 Encoded StringUTF-8 String PairzPayload Format IndicatorrzMessage Expiry Intervalrz Content Typer*zResponse TopiczCorrelation Data zSubscription Identifier zSession Expiry IntervalzAssigned Client IdentifierzServer Keep AlivezAuthentication MethodzAuthentication DatazRequest Problem InformationzWill Delay IntervalzRequest Response InformationzResponse InformationzServer Referencez Reason String!"#$%&'()*) zReceive MaximumzTopic Alias Maximumz Topic Aliasz Maximum QoSzRetain Availablez User PropertyzMaximum Packet SizezWildcard Subscription Availablez!Subscription Identifier AvailablezShared Subscription AvailablerRrTrWrVrUrSrX) rgrhrirjrkrlrmrnrorp) packetTypetypesnamesindexrPUBLISH WILLMESSAGE SUBSCRIBECONNECTCONNACK DISCONNECTAUTHPUBACKPUBRECPUBRELPUBCOMPSUBACKUNSUBACK UNSUBSCRIBE properties)selfrqs r __init__zProperties.__init__s$RRR  & %q  A  a    &r   &r  )"    $R  "2  *2  "2  +B  #B ! " R# $ "#% "#%/113-/7    <0     ((;+> @W*XY0     !455 8K[Md7ef 0    !788;;NP[Pg:hi 0    !788;;NP[Pg:hi 0     //+2E{G^1_`0  !!"9::%{'<=?0  !!"566%{':K@/0 2 !!"899%{'9;;M$k&9;;M& (> @PRS30 :!!"455%{':;=!!"455%{':;=!!"455 8K7LM!!&))K,?+@A!!&))K,?+@A!!"566%{':%{'9$k&8+:M'););+?(+*:Kz*Properties.__setattr__.. s&RRRuEMM#r22RRRr zProperty name must be one of rz Property z does not apply to packet type )ReceiveMaximum TopicAliasiz.%s property value must be in the range 1-65535)TopicAliasMaximumrz.%s property value must be in the range 0-65535)MaximumPacketSizeSubscriptionIdentifierrCz2%s property value must be in the range 1-268435455)RequestResponseInformationRequestProblemInformationPayloadFormatIndicatorz %s property value must be 0 or 1)robject __setattr__rsrrstrrqrrrNamesr.rhasattr__getattribute__)rrrL privateVarss r rzProperties.__setattr__s||C$$DDD ;     tT5 1 1 1 1 1RR @Q@QRRRRR#3C 8I8I4J4JJLLLdod6K6KD6Q6Q&RST&UUU#m'+tt[->t-O-O%QRRRE{{d2hh&&;;;"QYY%%--'HDQSSS222"QYY%%--'HDQSSSLLL"QYY%)*;*;'LPTUWWWrrr"aZZEQJJ':dCEEE""4(( H;;$r((**"GE4&&H"33D$??%GE   tT5 1 1 1 1 1r c d}d}|jD]W}|dd}t||r/|s|dz }||dzt t ||zz }d}X|dz }|S) N[Trrz, z : F])rsrrrrgetattr)rr6firstrrs r __str__zProperties.__str__/sJOO%%  D!\\#r22Nt^,, #dNF.50n556677#  r ci}|jD]p}|dd}t||rHt ||}|dkr-t |t r|||<k|||<q|S)NrrCorrelationData)rsrrrr isinstancer/hex)rr1rrvals r jsonzProperties.json=sJOO%% / /D!\\#r22Nt^,, /dN33!%666:c5;Q;Q6+.7799D((+.D( r cd}|jD],}|dd}t||rd}n-|S)NTrrF)rsrrr)rrcrrs r isEmptyzProperties.isEmptyIs] JOO%%  D!\\#r22Nt^,,   r c|jD]8}|dd}t||rt ||9dS)Nrr)rsrrrdelattr)rrrs r clearzProperties.clearRs]JOO%% . .D!\\#r22Nt^,, .n--- . .r cd}|t|z }||jdkr?tjddkr|t |z }nb|t|gz }nM||jdkr|t|z }n||jdkr|t|z }n||jdkr|t|z }n||jdkr|t|z }n}||jd kr|t|z }nL||jd kr.|t|dt|d zz }|S) Nr rRrr*rSrTrUrVrWrXr) rArHrrrtr,r-rEr/rr%r=r2)r identifierr.rLr6s r writePropertyzProperties.writePropertyXs&--j999 4:##F++ + +"Q&&#e**$%..( TZ%%&899 9 9 j'' 'FF TZ%%&9:: : : j'' 'FF TZ%%&=>> > > *11%88 8FF TZ%%m44 4 4 j'' 'FF TZ%%&<== = = huoo %FF TZ%%&9:: : : huQx((8E!H+=+== =F r c d}|jD]}|dd}t||r||}|j|d}||r.t||D]}|||||z }||||t||z }t t||zS)Nr rrr) rsrrrrrrrrrArHr0)rr6rrr attr_typeprops r rzProperties.packns JOO%% P PD!\\#r22Nt^,, P!22>BB  OJ7: &&~66P 'n = =FF$"4"4Z5>#F#FFFd00Y18~1N1NPPPF#**3v;;77&@@r c||jdkr |d}d}nZ||jdkrt|}d}n)||jdkrt|}d}n||jdkrt|\}}n||jd krt |\}}n||jd krt||\}}nZ||jd kr> > >299&AAOE88 TZ%%m44 4 4'//OE88 TZ%%&<== = =%fh77OE88 TZ%%&9:: : :%fh77OE8HII&F '80C D D FIFOE  !Hhr cDd}|jD]}|j||kr|}|Sr<)rs)rrrrs r getNameFromIdentzProperties.getNameFromIdents5 J  Dz$:-- r ctjddkrt|}|t|\}}||d}|}|dkrt|\}}||d}||z}|j|d}||||\}} || d}|| z}||} | dd} | | s't|| rtdtzt|| ||dk|||zfS)Nrr*rrz+Property '%s' must not exist more than once)r,r-rrrAr4rrrrrrrpropertysetattr) rr6rVBIlen propslenleftrVBIlen2rrLrpropnamers r rzProperties.unpacks  A  " "v&&F /66v>>& Q"6"="=## JGHH%F G #L 3A6I"// <11OE8HII&F H $L,,Z88H%--c266N&&~66 N74;X;X N#AHLNNN D(E * * *Q X&&&r N)rr r rMrrrrrrrrrrrrrr r r rPrPs$S S S jAAA+2+2+2Z      ... ,AAA"0'''''r rP)rMrr, packettypesr Exceptionrrrr!r%r(r2r:r=r?rArrPr r r rsh$ $$$$$$     I        m   000 +++ 000 +++ (((*,,,((( ////////dh'h'h'h'h'h'h'h'h'h'r