Pf=ddlZddlmZmZddlmZmZmZmZm Z ddl m Z ddl m Z ddlmZddlmZdd lmZGd d ZdS) N)JSONDecodeErrorloads)DictListOptionalTupleUnion) DataError)deprecated_function)JsonType)decode_dict_keys)Pathc eZdZdZejfdedeedee dee e dffdZ ddeded%e d(eedeef d,Z" d=deded-ed&eed'eed(eedeefd.Z# d=d/ed0ed&eed'eed(eede$eeff d1Z%d?dedeedee e dffd2Z&ejfdedeede eeee ffd3Z'ejfded4edeede e eee ffd5Z(dejfd6edeedeede e eeffd7Z)edd8d9Z*edd8d:Z+edd8d;Z,dS)@ JSONCommandszjson commands.namepathargsreturnNc|t|g}|D]*}|||+|jdg|RS)zAppend the objects ``args`` to the array under the ``path` in key ``name``. For more information see `JSON.ARRAPPEND `_.. zJSON.ARRAPPENDstrappend_encodeexecute_command)selfrrrpiecesos N/var/www/html/env/lib/python3.11/site-packages/redis/commands/json/commands.py arrappendzJSONCommands.arrappends^D " + +A MM$,,q// * * * *#t#$4>v>>>>scalarstartstopc|t|||g}|,||||||jdg|RS)a: Return the index of ``scalar`` in the JSON array under ``path`` at key ``name``. The search can be limited using the optional inclusive ``start`` and exclusive ``stop`` indices. For more information see `JSON.ARRINDEX `_. Nz JSON.ARRINDEX)rrrr)rrrr"r#r$rs rarrindexzJSONCommands.arrindexsm"D 4<<#7#78   MM%  d####t#O=f====r!indexc|t||g}|D]*}|||+|jdg|RS)zInsert the objects ``args`` to the array at index ``index`` under the ``path` in key ``name``. For more information see `JSON.ARRINSERT `_. zJSON.ARRINSERTr)rrrr'rrrs r arrinsertzJSONCommands.arrinsert6s`D 5) + +A MM$,,q// * * * *#t#$4>v>>>>r!cJ|d|t|S)zReturn the length of the array JSON value under ``path`` at key``name``. For more information see `JSON.ARRLEN `_. z JSON.ARRLENrrrrrs rarrlenzJSONCommands.arrlenC"##M4TCCCr!cL|d|t||S)zPop the element at ``index`` in the array JSON value under ``path`` at key ``name``. For more information see `JSON.ARRPOP `_. z JSON.ARRPOPr+)rrrr's rarrpopzJSONCommands.arrpopMs$##M4TEJJJr!cN|d|t|||S)zTrim the array JSON value under ``path`` at key ``name`` to the inclusive range given by ``start`` and ``stop``. For more information see `JSON.ARRTRIM `_. z JSON.ARRTRIMr+)rrrr#r$s rarrtrimzJSONCommands.arrtrimZs&##ND#d))UDQQQr!cJ|d|t|S)zGet the type of the JSON value under ``path`` from key ``name``. For more information see `JSON.TYPE `_. z JSON.TYPEr+r,s rtypezJSONCommands.typed" ##Ks4yyAAAr!cJ|d|t|S)zReturn the JSON value under ``path`` at key ``name``. For more information see `JSON.RESP `_. z JSON.RESPr+r,s rrespzJSONCommands.respkr6r!cJ|d|t|S)zReturn the key names in the dictionary JSON value under ``path`` at key ``name``. For more information see `JSON.OBJKEYS `_. z JSON.OBJKEYSr+r,s robjkeyszJSONCommands.objkeysrs"##ND#d))DDDr!cJ|d|t|S)zReturn the length of the dictionary JSON value under ``path`` at key ``name``. For more information see `JSON.OBJLEN `_. z JSON.OBJLENr+r,s robjlenzJSONCommands.objlen|r.r!numbercr|d|t|||S)zIncrement the numeric (integer or floating point) JSON value under ``path`` at key ``name`` by the provided ``number``. For more information see `JSON.NUMINCRBY `_. zJSON.NUMINCRBYrrrrrrr=s r numincrbyzJSONCommands.numincrbys7 ## dCIIt||F/C/C   r!z4.0.0z deprecated since redisjson 1.0.0)versionreasoncr|d|t|||S)zMultiply the numeric (integer or floating point) JSON value under ``path`` at key ``name`` with the provided ``number``. For more information see `JSON.NUMMULTBY `_. zJSON.NUMMULTBYr?r@s r nummultbyzJSONCommands.nummultbys7## dCIIt||F/C/C   r!cJ|d|t|S)aEmpty arrays and objects (to have zero slots/keys without deleting the array/object). Return the count of cleared paths (ignoring non-array and non-objects paths). For more information see `JSON.CLEAR `_. z JSON.CLEARr+r,s rclearzJSONCommands.clears"##L$D BBBr!keycJ|d|t|S)zDelete the JSON value stored at key ``key`` under ``path``. For more information see `JSON.DEL `_. zJSON.DELr+)rrHrs rdeletezJSONCommands.deletes" ##JSYY???r!F) no_escaperKc8|g}|r|dt|dkr'|tjn'|D]$}|t |% |jdg|RS#t $rYdSwxYw)aD Get the object stored as a JSON value at key ``name``. ``args`` is zero or more paths, and defaults to root path ```no_escape`` is a boolean flag to add no_escape option to get non-ascii characters For more information see `JSON.GET `_. noescaperzJSON.GETN)rlenr root_pathrr TypeError)rrrKrrps rgetzJSONCommands.gets  & MM* % % % t99>> MM$.** + + + + & & c!ff%%%% '4' `_. z JSON.MGETrrr)rrSrrs rmgetzJSONCommands.mgetsE$ c$ii   #t#K9&9999r!objnxxx decode_keysc|rt|}|t|||g}|r|rtd|r|dn|r|d|jdg|RS)a Set the JSON value at key ``name`` under the ``path`` to ``obj``. ``nx`` if set to True, set ``value`` only if it does not exist. ``xx`` if set to True, set ``value`` only if it exists. ``decode_keys`` If set to True, the keys of ``obj`` will be decoded with utf-8. For the purpose of using this within a pipeline, this command is also aliased to JSON.SET. For more information see `JSON.SET `_. zNnx and xx are mutually exclusive: use one, the other or neither - but not bothNXXXzJSON.SET)rrr Exceptionrr)rrrrWrXrYrZrs rsetzJSONCommands.sets,  ("3''CD 4<<#4#45  " 2  MM$      MM$   #t#J88888r!tripletsc g}|D]L}||dt|d||dgM|jdg|RS)a Set the JSON value at key ``name`` under the ``path`` to ``obj`` for one or more keys. ``triplets`` is a list of one or more triplets of key, path, value. For the purpose of using this within a pipeline, this command is also aliased to JSON.MSET. For more information see `JSON.MSET `_. rr z JSON.MSET)extendrrr)rr`rtriplets rmsetzJSONCommands.msetso S SG MM71:s71: WQZ8P8PQ R R R R#t#K9&9999r!c|rt|}|t|||g}|jdg|RS)aa Merges a given JSON value into matching paths. Consequently, JSON values at matching paths are updated, deleted, or expanded with new children ``decode_keys`` If set to True, the keys of ``obj`` will be decoded with utf-8. For more information see `JSON.MERGE `_. z JSON.MERGE)rrrr)rrrrWrZrs rmergezJSONCommands.mergesR  ("3''CD 4<<#4#45#t#L:6::::r! file_namect|d5}t|}dddn #1swxYwY|||||||S)ah Set the JSON value at key ``name`` under the ``path`` to the content of the json file ``file_name``. ``nx`` if set to True, set ``value`` only if it does not exist. ``xx`` if set to True, set ``value`` only if it exists. ``decode_keys`` If set to True, the keys of ``obj`` will be decoded with utf-8. rNrXrYrZ)openrreadr_) rrrrhrXrYrZfp file_contents rset_filezJSONCommands.set_file)s()S ! ! ,R ++L , , , , , , , , , , , , , , ,xxdLRBKxXXXs"?AA json_path root_folderc ,i}tj|D]|\}}} | D]s} tj|| } | dd} || || |||d|| <_#t $rd|| <YpwxYw}|S)au Iterate over ``root_folder`` and set each JSON file to a value under ``json_path`` with the file name as the key. ``nx`` if set to True, set ``value`` only if it does not exist. ``xx`` if set to True, set ``value`` only if it exists. ``decode_keys`` If set to True, the keys of ``obj`` will be decoded with utf-8. .rrkTF)oswalkrjoinrsplitrpr) rrqrrrXrYrZset_files_resultrootdirsfilesfile file_pathrhs rset_pathzJSONCommands.set_pathBs$!#!5!5 8 8 D$ 8 8GLLt44  8 ) 0 0 5 5a 8IMM!!!$/ "37$Y//&88827$Y///8 8  s;A>>BBcl|g}|"|t||jdg|RS)zReturn the length of the string JSON value under ``path`` at key ``name``. For more information see `JSON.STRLEN `_. Nz JSON.STRLENrU)rrrrs rstrlenzJSONCommands.strlenhsD    MM#d)) $ $ $#t#M;F;;;;r!cJ|d|t|S)zToggle boolean value under ``path`` at key ``name``. returning the new value. For more information see `JSON.TOGGLE `_. z JSON.TOGGLEr+r,s rtogglezJSONCommands.togglesr.r!valuech|t|||g}|jdg|RS)aCAppend to the string JSON value. If two options are specified after the key name, the path is determined to be the first. If a single option is passed, then the root_path (i.e Path.root_path()) is used. For more information see `JSON.STRAPPEND `_. zJSON.STRAPPEND)rrr)rrrrrs r strappendzJSONCommands.strappend}s>D 4<<#6#67#t#$4>v>>>>r! subcommandc ddg}||vrtdt||g}|dkrH|td|||t||jdg|RS)zReturn the memory usage in bytes of a value under ``path`` from key ``name``. For more information see `JSON.DEBUG `_. MEMORYHELPzThe only valid subcommands are NzNo key specifiedz JSON.DEBUG)r rrr)rrrHrvalid_subcommandsrs rdebugzJSONCommands.debugs&v. . . .=sCT?U?UVV V  ! !{ 2333 MM#    MM#d)) $ $ $#t#L:6::::r!z/redisjson-py supported this, call get directly.c|j|i|SN)rRrrkwargss rjsongetzJSONCommands.jsongettx((((r!c|j|i|Sr)rVrs rjsonmgetzJSONCommands.jsonmgetsty$)&)))r!c|j|i|Sr)r_rs rjsonsetzJSONCommands.jsonsetrr!)NN)FFF)Fr)-__name__ __module__ __qualname____doc__rrOrrrr r intr r&r)r-r1r3r5r8r:r<rAr rErGrJforgetboolrRrVr_rrergrprrrrrrrrrr!rrr s7 0>t~/?/? ? ? ?'} ?HLX ? eCI  ? ? ? ?$ $" >>>> > } > sm > eCI >>>>2 ? ?" ?+. ?7;H~ ? eCI  ? ? ? ?0>t~/?/?DDD'}D eCI DDDD-dn..! K K Ksm K} K eCI  K K K KRR"R+.R69R eCI RRRR5CDN4D4DBBBHSMBcBBBB5CDN4D4DBBBHSMBBBBB0>t~/?/?EEE'}E eDItO$ %EEEE0>t~/?/?DDD'}D hsm DDDD c  c c    1STTT c  c c   UT 6DT^5E5E C C# CXc] C# C C C C6DT^5E5E@@#@Xc]@#@@@@F=B+3D> $x. !< :c :# :$x. : : : :"#"&+%9%9%9%9 %9 TN %9 TN %9d^%9 #%9%9%9%9N:T%S((:";<:#::::,', ;;;; ; d^ ; # ;;;;8#"&+YYYY Y TN Y TN Yd^Y #YYYY:#"&+ $ $ $ $  TN $ TN $ d^ $  c4i$ $ $ $ L < <3 t~/?/?DDD'}D tT(3-(( )DDDD;K;K ? ? ? # ?+3C= ? sD#'' ( ? ? ? ?",dn.. ;;;c];sm ; sDI~  ;;;;, Q))) Q*** Q)))))r!r)rujsonrrtypingrrrrr redis.exceptionsr redis.utilsr _utilr decodersrrrrrr!rrs ''''''''55555555555555&&&&&&++++++&&&&&&b)b)b)b)b)b)b)b)b)b)r!