Ihk=ddlZddlmZmZddlmZmZmZmZm Z ddl m Z ddl m Z ddlmZddlmZdd lmZGd d Zy) N)JSONDecodeErrorloads)DictListOptionalTupleUnion) DataError)deprecated_function)JsonType)decode_dict_keys)Pathc`eZdZdZej fdedeedee deee fdZ ddeded%e d(eedeef d,Z! d=deded-ed&eed'eed(eedeefd.Z" d=d/ed0ed&eed'eed(eede#eeff d1Z$d?dedeedeee fd2Z%ej fdedeede&eeee ffd3Z'ej fded4edeede&e eee ffd5Z(dej fd6edeedeede&e eeffd7Z)edd8d9Z*edd8d:Z+edd8d;Z,y)@ JSONCommandszjson commands.namepathargsreturnc|t|g}|D]"}|j|j|$|jdg|S)zAppend the objects ``args`` to the array under the ``path` in key ``name``. For more information see `JSON.ARRAPPEND `_.. zJSON.ARRAPPENDstrappend_encodeexecute_command)selfrrrpiecesos U/var/www/html/planif/env/lib/python3.12/site-packages/redis/commands/json/commands.py arrappendzJSONCommands.arrappendsND " +A MM$,,q/ * +#t##$4>v>>Nscalarstartstopc|t||j|g}|$|j|||j||jdg|d|giS)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 `_. z JSON.ARRINDEXkeys)rrrr)rrrr"r#r$rs rarrindexzJSONCommands.arrindexs`"D 4<<#78   MM%  d##t##OJfJD6JJr!indexc|t||g}|D]"}|j|j|$|jdg|S)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.arrinsert6sPD 5) +A MM$,,q/ * +#t##$4>v>>r!c@|jd|t||gS)zReturn the length of the array JSON value under ``path`` at key``name``. For more information see `JSON.ARRLEN `_. z JSON.ARRLENr&rrrrrs rarrlenzJSONCommands.arrlenC$##M4T$#PPr!c<|jd|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##M4TEJJr!c>|jd|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)UDQQr!c@|jd|t||gS)zGet the type of the JSON value under ``path`` from key ``name``. For more information see `JSON.TYPE `_. z JSON.TYPEr,r-r.s rtypezJSONCommands.typed$ ##Ks4yv#NNr!c@|jd|t||gS)zReturn the JSON value under ``path`` at key ``name``. For more information see `JSON.RESP `_. z JSON.RESPr,r-r.s rrespzJSONCommands.respkr8r!c@|jd|t||gS)zReturn the key names in the dictionary JSON value under ``path`` at key ``name``. For more information see `JSON.OBJKEYS `_. z JSON.OBJKEYSr,r-r.s robjkeyszJSONCommands.objkeysrs$##ND#d)4&#QQr!c@|jd|t||gS)zReturn the length of the dictionary JSON value under ``path`` at key ``name``. For more information see `JSON.OBJLEN `_. z JSON.OBJLENr,r-r.s robjlenzJSONCommands.objlen|r0r!numbercZ|jd|t||j|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.numincrbys- ## dCIt||F/C  r!z4.0.0z deprecated since redisjson 1.0.0)versionreasoncZ|jd|t||j|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.NUMMULTBYrArBs r nummultbyzJSONCommands.nummultbys-## dCIt||F/C  r!c:|jd|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 BBr!keyc:|jd|t|S)zDelete the JSON value stored at key ``key`` under ``path``. For more information see `JSON.DEL `_. zJSON.DELr-)rrJrs rdeletezJSONCommands.deletes ##JSY??r!F) no_escaperMc"|g}|r|jdt|dk(r$|jtjn!|D]}|jt | |j dg|d|giS#t $rYywxYw)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.GETr&N)rlenr root_pathrr TypeError)rrrMrrps rgetzJSONCommands.gets  MM* % t9> MM$..* + & c!f% &  '4'' IVI4&I I  s+B B Br&cpg}||z }|jt||jdg|d|iS)z Get the objects stored as a JSON values under ``path``. ``keys`` is a list of one or more keys. For more information see `JSON.MGET `_. z JSON.MGETr&rrr)rr&rrs rmgetzJSONCommands.mgets?$ c$i #t##KD&DtDDr!objnxxx decode_keysc|r t|}|t||j|g}|r |r td|r|j dn|r|j d|j dg|S)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)rrrrXrYrZr[rs rsetzJSONCommands.sets{, "3'CD 4<<#45 "2  MM$   MM$ #t##J888r!tripletsc g}|D]7}|j|dt|d|j|dg9|jdg|S)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)rrartriplets rmsetzJSONCommands.msets^ SG MM71:s71: WQZ8PQ R S#t##K9&99r!c||r t|}|t||j|g}|jdg|S)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)rrrrXr[rs rmergezJSONCommands.mergesB "3'CD 4<<#45#t##L:6::r! file_namect|5}t|j}ddd|j|||||S#1swY xYw)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. NrYrZr[)openrreadr`) rrrrirYrZr[fp file_contents rset_filezJSONCommands.set_file)sO()_ , +L ,xxdLRBKxXX , ,s AA json_path root_folderc i}tj|D]^\}}} | D]S} tjj|| } | j dd} |j | || |||d|| <U`|S#t $rd|| <YjwxYw)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) rrqrrrYrZr[set_files_resultrootdirsfilesfile file_pathris rset_pathzJSONCommands.set_pathBs$!#!5 8 D$ 8GGLLt4  8 ) 0 0 5a 8IMM!!!$/ "37$Y/ 8 8" '827$Y/8s0A;;B  B cn|g}||jt||jdg|d|giS)zReturn the length of the string JSON value under ``path`` at key ``name``. For more information see `JSON.STRLEN `_. z JSON.STRLENr&rV)rrrrs rstrlenzJSONCommands.strlenhs@    MM#d) $#t##MHFH$HHr!c:|jd|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.toggless##M4TCCr!valuecb|t||j|g}|jdg|S)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}s6D 4<<#67#t##$4>v>>r! subcommandcddg}||vrtdt||g}|dk(r8| td|j||jt||jdg|S)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 zNo key specifiedz JSON.DEBUG)r rrr)rrrJrvalid_subcommandsrs rdebugzJSONCommands.debugs&v. . .=sCT?UV V  !{ 233 MM#  MM#d) $#t##L:6::r!z/redisjson-py supported this, call get directly.c&|j|i|SN)rTrrkwargss rjsongetzJSONCommands.jsongettxx(((r!c&|j|i|Sr)rWrs rjsonmgetzJSONCommands.jsonmgetstyy$)&))r!c&|j|i|Sr)r`rs rjsonsetzJSONCommands.jsonsetrr!)NN)FFF)Fr)-__name__ __module__ __qualname____doc__rrQrrrr intr r'r*r/r3r5r7r:r<r>rCr rGrIrLforgetboolrTrWr`rrfrhrprrrr rrrrrrr!rrr s0>t~~/? ? ?'} ?HLX ? hsm  ?$ $" KKK K } K sm K hsm K2 ? ?" ?+. ?7;H~ ? hsm  ?0>t~~/?QQ'}Q hsm Q-dnn.! K Ksm K} K hsm  KRR"R+.R69R hsm R5CDNN4DOOHSMOcO5CDNN4DOOHSMOO0>t~~/?RR'}R htCy! "R0>t~~/?QQ'}Q hsm Q c  c c 1ST c  c c U 6DT^^5E C# CXc] C# C6DT^^5E@#@Xc]@#@F=B+3D> $x. !< Ec E# E$x. E"#"&+%9%9%9 %9 TN %9 TN %9d^%9 #%9N:T%S((:";<:#:,', ;;; ; d^ ; # ;8#"&+YYY Y TN Y TN Yd^Y #Y:#"&+ $ $ $  TN $ TN $ d^ $  c4i$ L I3 Ihsm ItHSM?R I0>t~~/?DD'}D tT(3-(( )D>;K ? ? # ?+3C= ? sD#'' ( ?",dnn. ;;c];sm ; sDI~  ;, Q)) Q** Q))r!r)rujsonrrtypingrrrrr redis.exceptionsr redis.utilsr _utilr decodersrrrrrr!rrs, '55&+&b)b)r!