ng\j2:SSKrSSKrSSKJrJrJrJr SSKJr SSK r SSK J r J r J r Jr SSKJrJr SSKJrJr "S S \5r"S S \\ R,R.5r"S S\\ R0R25r"SS\5r"SS\5rg)N)JSONDecodeError JSONDecoder JSONEncoderloads)Literal)apply_module_callbacksget_legacy_responsesget_protocol_version nativestr)FPHAType JSONCommands) bulk_of_jsons decode_listc\rSrSrSrS\"5\"54SjrSrSr Sr Sr S r \ S 5r\ S 5rS rSS jrSrg) _JSONBase Create a client for talking to json. :param decoder: :type json.JSONDecoder: An instance of json.JSONDecoder :param encoder: :type json.JSONEncoder: An instance of json.JSONEncoder Nc <^TRTRTRS[TR5STRSTRS. n0STR_STR_STR_STR_S TR_S [_S [_S [_S TR_SU4Sj_SU4Sj_STR_STR_STR_STR_STR_n0n[[[TRTRTRSS.nSS0n TR TR TRTR SS.n UTlURTlUTl [[TR5[TR5UUUUU U S9Tl TRR5H upTRRX5 M" UTlUTlg)rc0U=(a [U5S:H$NOKr rs W/home/edenadmin/noVNC/venv/lib/python3.13/site-packages/redis/commands/json/__init__.py$_JSONBase.__init__...sA$>)A,$*>$>c0U=(a [U5S:H$rrrs rrr0s1#=1)=#=r c0U=(a [U5S:H$rrrs rrr2s!"< ! (<"TRU5$N_decoderkwargsselfs rrr@ $,,q/r JSON.NUMMULTBYc&>TRU5$r+r,r.s rrrAr1r JSON.OBJKEYSzJSON.STRAPPENDz JSON.OBJLENz JSON.STRLENr%cUbU/$U$r+rs rrrUs!-A3#>Q#>r )r&r'r(r)r2r$ JSON.TYPEr7cUS/:XaS$U$r+r6rs rrrXs1;4#=A#=r cX[U[5(a[U5S:XaUS$U$)Nr r) isinstancelistlenrs rrres':a+>+>3q6Q;1Q4#UTU#Ur )r)r2r4r$r7)commonresp2resp3 resp2_unified resp3_unifiedresp3_to_resp2_legacyN)r-rint_decode_json_numop_decode_resp_command_unified_decode_resp3_legacy_numop_resp_floats_to_str_commandclientexecute_commandMODULE_VERSIONr r r _MODULE_CALLBACKSitemsset_response_callback __encoder__ __decoder__) r0rHversiondecoderencoderrK_RESP2_MODULE_CALLBACKS_RESP3_MODULE_CALLBACKS_RESP2_UNIFIED_MODULE_CALLBACKS_RESP3_UNIFIED_MODULE_CALLBACKS'_RESP3_TO_RESP2_LEGACY_MODULE_CALLBACKSkeyvalues ` r__init___JSONBase.__init__sF <<,, >&t||4=<<<  # dll# T\\#  dll#  4<< # DLL # # #  #  3#   #  A#  A#  DLL#  dll#  4<<#  4<<# 4<+ ' =+ '#=="== LL99U 3 / %55%!7  -  -$))99"I " 00668JC KK - -c 99#"r c@UcU$URRU5nUc[eU$![aJ URRUR55s$![a [ U5ss$f=f[[ 4a [ U5s$f=f)zGet the decoder.)rOdecode TypeErrorAttributeErrorrr)r0objxs rr-_JSONBase._decode}s ;J $  '',AyH ( (''..szz|<<! ("3'' (0 $s# # $s2%- B(A# B#A=8B<A==BBc UcU$URR[U[5(aUOUR55n[U[ 5(dU/nU$![[ 4a Us$f=f)uDecode a JSON.NUMINCRBY / JSON.NUMMULTBY result and normalise it to the unified array form. RESP2 wire returns a JSON bulk string — a scalar for legacy paths and a JSON-encoded list for dollar paths. RESP3 wire returns a native list. The unified shape is always a list. )rOr]r:strr_rr;)r0r`r/results rrD_JSONBase._decode_json_numopsv ;J %%,,!#s++F &$''XF 0 J sAA!!A65A6c URU5nURS5n[U[5(a?UR S5(d)[U[ 5(a[ U5S:XaUS$U$)aBDecode RESP3 JSON numeric operations back to legacy RESP2 shape. RedisJSON returns a RESP3 array for both legacy paths (``.foo``) and JSONPath paths (``$.foo``). The command builder records the path so default RESP3-wire legacy clients can keep v8 scalar results for legacy paths while leaving JSONPath results as lists. _json_path$r r)r-getr:rd startswithr;r<)r0r`r/repaths rrF$_JSONBase._decode_resp3_legacy_numopsdc"zz,' tS ! !OOC((64((F q !9  r cBURURU55$)zDecode JSON.RESP and lift string-encoded floats inside the nested response to native ``float`` values so the unified shape matches the RESP3 wire. )_convert_resp_floatsr-r0r`s rrE&_JSONBase._decode_resp_command_unifieds ((c):;;r cBURURU55$)zDecode JSON.RESP and re-encode native ``float`` values back to their string form so the legacy RESP2 shape is preserved when the wire is RESP3. )_resp_floats_to_strr-rps rrG%_JSONBase._resp_floats_to_str_commands '' S(9::r cR[U[5(a&UVs/sHn[RU5PM sn$[U[[ 45(a3[U[ 5(aUR 5OUn[U5$U$s snf![[4a Us$f=f)a Recursively convert string-encoded JSON floats. RESP2 has no native double type, so JSON.RESP returns JSON floats as bulk strings. Any string/bytes leaf that parses as ``float`` is the unified representation of such a value; non-numeric strings are left untouched. ) r:r;rrordbytesr]float ValueError OverflowError)r`itemrYs rro_JSONBase._convert_resp_floatss c4 EHISTI2248SI I cC< ( ($.sE$:$:CJJLE U|# J  .   sB ? BB&%B&c[U[5(a&UVs/sHn[RU5PM sn$[U[5(a [ U5$U$s snf)zRecursively walk ``obj`` and convert native ``float`` values back to their string-encoded form. Lists are walked element-wise; non-float leaves are returned unchanged. )r:r;rrsrwrd)r`rzs rrs_JSONBase._resp_floats_to_strsR c4 DGHCDI11$7CH H c5 ! !s8O IsAc8URRU5$)zGet the encoder.)rNencoderps r_encode_JSONBase._encodes&&s++r c [UR[R5(a[ URR URR URR RURRURRURRR5URRURRURRS9 nO=[URR [#URR$5UUS9nUR&UlUR(UlU$)aCreates a pipeline for the JSON module, that can be used for executing JSON commands, as well as classic core commands. Usage example: r = redis.Redis() pipe = r.json().pipeline() pipe.jsonset('foo', '.', {'hello!': 'world'}) pipe.jsonget('foo') pipe.jsonget('notakey') ) nodes_managercommands_parser startup_nodesresult_callbackscluster_response_callbackscluster_error_retry_attemptsread_from_replicasreinitialize_stepslock)connection_poolresponse_callbacks transaction shard_hint)r:rHredis RedisClusterClusterPipelinerrrrrretry get_retriesrr_lockPipelinerdictrrr-)r0rrps rpipeline_JSONBase.pipelines dkk5#5#5 6 6"kk77 $ ; ;"kk77EE!%!=!=+/;;+Q+Q-1[[->->-J-J-L#';;#A#A#';;#A#A[[&& A $ ; ;#' (F(F#G'% ALL LL r )rJrKrOrNrHrI)TN)__name__ __module__ __qualname____firstlineno____doc__rrrZr-rDrFrErG staticmethodrorsrr__static_attributes__r6r rrrsf#KM;=^#@$$(&<;$  ,#r rc\rSrSrSrSrg)ri z Cluster pipeline for the module.r6Nrrrrrrr6r rrr s*r rc\rSrSrSrSrg)rizPipeline for the module.r6Nrr6r rrrs"r rc*\rSrSr%Sr\S\S'Srg)JSONiF_is_async_clientr6N)rrrrrr__annotations__rr6r rrrs',gen,r rc\rSrSr%Sr\S\S'SS\S\S\S\S-S \S-S \S-S \ \-S-S \S-4S jjr SS\S\S\S-S \S-S \S-S \ \-S-S \ \\44Sjjr Sr g) AsyncJSONiTrNnamerl file_namenxxx decode_keysfphareturnc # S[S[4Sjn[R"X5IShvN n UR UUU UUUUS9IShvN $N!N7f)z Set the JSON value at key ``name`` under the ``path`` to the content of the json file ``file_name``. This runs the blocking file read in a thread pool to avoid blocking the event loop. fprc[U5n[UR55sSSS5 $!,(df  g=fr+)openrread)rfs r _read_file&AsyncJSON.set_file.._read_file.s"bQQVVXs/ =Nrrrr)rdrasyncio to_threadset) r0rrlrrrrrr file_contents rset_fileAsyncJSON.set_filesh$ '3 '4 '%..zEE XX   #   F s!+AAA A AA json_path root_folderc .# S[S[[4Sjn0n[R"Xr5IShvN n U H9n U R S5Sn UR U UU UUUUS9IShvN SX'M; U$NEN![ a S X'MTf=f7f) z Iterate over ``root_folder`` and set each JSON file to a value under ``json_path`` with the file name as the key. This method runs blocking filesystem operations (os.walk and file reads) in a thread pool to avoid blocking the event loop. folderrc/n[R"U5H=up#nUH1nUR[RR X%55 M3 M? U$)zCWalk directory and return list of file paths (runs in thread pool).)oswalkappendrljoin)r file_pathsrootdirsfilesfiles r_walk_directory+AsyncJSON.set_path.._walk_directoryNsKJ%'WWV_!E!D%%bggll4&>?"&5 r N.rrTF)rdr;rrrsplitrr) r0rrrrrrrset_files_resultr file_pathrs rset_pathAsyncJSON.set_path=s" C DI #,,_JJ #I 4&,,S1!4 mm +$/3 +$& +K# 4.3 + 4sE4BA< B,B-A>.B6B>BBBBBr6)FFFN)rrrrrrrrdboolrrrrrr6r rrrs&*gdm* #(&*     4K  4K  D[ nt#   J #(&*1 1 1  4K 1 4K 1 D[ 1 nt#1  c4i1 1 r r)rrjsonrrrrtypingrrhelpersr r r r commandsrrdecodersrrrclusterrrHrrrr6r rrs AA  -0x xv+lEMM$A$A+#|U\\22#-9-U U r