z*_check_for_lua_globals..<s$YYYsk#w ::YYYr(z, ) setglobalskeyslenrmsgsGLOBAL_VARIABLE_MSGformatjoin)r)r*unexpected_globals unexpecteds r&_check_for_lua_globalsr<9s[00227799::=MM ""YYFXYYY $299$))J:O:OPPQQQ#"r(lvlargsct||t|dkr-ttjdd|t vrttjd d|D}t t ||dS)Nrz redis.log()two cg|]P}t|tt|tr|dnt |QS)r-)r!boolr"r#r$)r/xs r&r1z"_lua_redis_log..FsPsssa_ijkmq_r_rsAu)=)=IAHHW%%%3q66sssr() r<r5rr6REQUIRES_MORE_ARGS_MSGr8REDIS_LOG_LEVELS_TO_LOGGINGr4LOG_INVALID_DEBUG_LEVEL_MSGr9LOGGERlog)r)r*r=r>msgs r&_lua_redis_logrK@s;(8999 4yy1}}$5<<]ERRSSS -224444$:;;; ((ssSWsss t tC JJ*3/55555r(objc|tSt|tr|St|tr d|DSt|t rd|DS|S)ziConvert a pure python object obtained after JSON deserialization into a usable object in the lua runtime.Nc,g|]}t|S_cjson_python_to_luar/items r&r1z(_cjson_python_to_lua..Ts!;;;t$T**;;;r(cNi|]"\}}t|t|#SrOrPr/keyvalues r& z(_cjson_python_to_lua..Vs1eee:3PU$S))+?+F+Feeer()_lua_cjson_nullr!r$encodelistdictitems)rLs r&rQrQMs {#szz||#t<;;s;;;;#tfeeY\YbYbYdYdeeee Jr(c 8|turdSt|tr|St|}|dkr|St |}td|Do=t|t tdt|dzk}|rd| DSt|}d|DS)zaConvert a passed lua runtime object obtained before JSON serialization into a pure python object.Ntablec3@K|]}t|tVdSN)r!int)r/ks r& z'_cjson_lua_to_python..is,44!:a%%444444r(rc,g|]}t|SrO_cjson_lua_to_pythonrRs r&r1z(_cjson_lua_to_python..ls!DDDt$T**DDDr(cNi|]"\}}t|t|#SrOrfrUs r&rXz(_cjson_lua_to_python..ps0 _ _ _zsE  % %';E'B'B _ _ _r()rYr!r"r# LUA_MODULElua_typer[r4allsortedranger5valuesr\r])rLrjr4is_arrayds r&rgrgZs ot#uzz||""3''H7   D44t44444feTUWZ[_W`W`cdWdNeNeIfIf9fHEDDszz||DDDD S A _ _UVU\U\U^U^ _ _ __r(rWct||t|}tj|dS)N),:) separators)r<rgjsondumpsrZ)r)r*rWs r&_lua_cjson_encoderwssA;(8999  ' 'E :e 3 3 3 : : < <kwargsc|t|_|ddp t}t|dkrtdd}|D]} |||j|E#tj $r*}t d|d|Yd}~yd}~wwxYwtt|j|i|dS)N lua_modulesrTrunpack_returned_tupleszFailed to load LUA module "z", make sure it is installed: )r2load_lua_modulespopr5ri LuaRuntimerequirerZaddLuaErrorrHerrorsuperr__init__)selfr>rlua_modules_setr)moduleex __class__s r&rzScriptingCommandsMixin.__init__s/ ! #$*JJ}d$C$C$Lsuu   ! # #1;1F1FPTmq1F1r1rK) k kk'' 888)--f5555!*kkkLL!iv!i!ieg!i!ijjjjjjjjk 5$d++4dEfEEEEEs/AB11C* C%%C*r)rWrct|tur|St|tthvr'd|St tj)Nz{:.17g}) typer"rbfloatr8rZrr6LUA_COMMAND_ARG_MSG)rr)rWs r&_convert_redis_argz)ScriptingCommandsMixin._convert_redis_args^ ;;%  L %[[S%L ( (##E**1133 3d677 7r(resultc2t|ttfr|St|trt j|dSt|t rd|jiS|dSt|tr$fd|D}|St|trQttj | }fd|D}|St|tr5|jdrtt j|t%dt)|)NF) humanfriendlyokc<g|]}|SrO_convert_redis_resultr/rSr)rs r&r1z@ScriptingCommandsMixin._convert_redis_result..)ZZZ433KFFZZZr(c<g|]}|SrOrrs r&r1z@ScriptingCommandsMixin._convert_redis_result..rr(zERR wrong number of argumentsz%Unexpected return type from redis: {})r!r"rbrrrZrr|rWr[r\ itertoolschainr]r startswithr6WRONG_ARGS_MSG7 RuntimeErrorr8r)rr)r converteds`` r&rz,ScriptingCommandsMixin._convert_redis_results fucl + + M fe $ $ 5<e<<< <  - - 5))5&,*?@@ @ ^5  % % 5ZZZZZSYZZZI)))44 4 fd # # ])/6<<>>:;;FZZZZZSYZZZI)))44 4  , , ]|&&'FGG 8!$"6777LFMMdSYll[[\\ \r(Tnestedct|dkrdD]}||vr|||}t|tst t j|dkrt|cS|r%t | ddcSt | ddg}tj dD]8}||vrn1||}| ||9|St|tr|St|trt!|St|t"r|rdndS|S)Nr_)rerrrr-r.r)rirj_convert_lua_resultr!r"rr6LUA_WRONG_NUMBER_ARGS_MSGrr#rcountappendr$rZrrbrC)rrrrVrJ result_listindexrSs r&rz*ScriptingCommandsMixin._convert_lua_results   v & &' 1 1& J J&==226#;??C%c511J)$*HIIIe||+C00000J*3::gy+I+IJJJJJ)#**Wi*H*HIII!K"++ C C&&Ee}""4#;#;D#A#ABBBB   $ $ )==?? "  & & )v;;   % % )(11D ( r(r*opct|t|\}}fd|D}|||d}|}|S)Nc<g|]}|SrO)r)r/argr)rs r&r1z:ScriptingCommandsMixin._lua_redis_call..s)NNN#D++K==NNNr(T)r<rrrr) rr)r*rr>funcsignew_argsrs `` r&_lua_redis_callz&ScriptingCommandsMixin._lua_redis_calls {,<===&&';B'?'?@@ cNNNNNNNN""4h==++K@@ r(c |j|||g|RS#t$r.}|dt|icYd}~Sd}~wwxYw)Nr)r Exceptionr|r$)rr)r*rr>rs r&_lua_redis_pcallz'ScriptingCommandsMixin._lua_redis_pcallst ='4' 5ErQDQQQ Q = = =))63r77*;<< < < < < < < =s A #AA A )flagsscriptnumkeys keys_and_argscx|t|krttj|dkrttjt j|}||j j |<t dd}d d|jD}|d|d}t!}|||d||||dt%j|j||t%j|j||t%jt,||tt0t%jt2||t%jt4||t6 || ||} nb#t$r} | j tj!kr|j"dkrttj#|j j$d kr>ttj%&|'ttj!|j"dkr?ttj(&|'| t| j d} ~ wtj)$rD} ttj(&|'| d} ~ wwxYwtU|||+| d S) NrTr cg|] }|d|d S)z = require('z')rO)r/rs r&r1z/ScriptingCommandsMixin.eval..s)'n'n'nf6(I(Iv(I(I(I'n'n'nr(a function(keys, argv, redis_call, redis_pcall, redis_log, redis_log_levels, cjson_encode, cjson_decode, cjson_null) redis = {} redis.call = redis_call redis.pcall = redis_pcall redis.log = redis_log for level, pylevel in python.iterex(redis_log_levels.items()) do redis[level] = pylevel end redis.error_reply = function(msg) return {err=msg} end redis.status_reply = function(msg) return {ok=msg} end cjson = {} cjson.encode = cjson_encode cjson.decode = cjson_decode cjson.null = cjson_null KEYS = keys ARGV = argv z end valkeyF)r),r5rr6TOO_MANY_KEYS_MSGNEGATIVE_KEYS_MSGhashlibsha1 hexdigestrZ_server script_cacherirr9revalr2r| functoolspartialrrrK as_attrgetterREDIS_LOG_LEVELSrwr~rYupdater3r4executerWrversionLUA_COMMAND_ARG_MSG6 server_typeVALKEY_LUA_COMMAND_ARG_MSGr8r#SCRIPT_ERROR_MSGrr<r) rrrrrr)modules_import_str set_globalsr*rrs r&rzScriptingCommandsMixin.evalsH S'' ' 'd455 5 Q;;d455 5|F##--//6688*0 !$'-7-B-BDim-B-n-n !YY'n'nX\Xm'n'n'noo!&& &$'     0&)UU  " "='#: ; ;  " "=#: ; ;  d2KAQ R R  d3[BR S S  nk;K L L  $ $%5 6 6  />N O O  />N O O    3 3 5 5 : : < <=== O ((00FF ( ( (x4333<$&&%d&?@@@\-99%d&E&L<[[]]&[&[\\\%d&>???|d""!$"7">">t{{}}b"Q"QRRRbh'' '" O O Od3::4;;=="MMNN N O {,<===''u'===s%H33 N>C>L<<N?N  NEVALSHA)namefixedrepeatrrc |jj|}n'#t$rttjwxYw|j||g|RSra)rrKeyErrorrr6NO_MATCHING_SCRIPT_MSGr)rrrrrs r&evalshazScriptingCommandsMixin.evalsha)s` ;\.t4FF ; ; ;d9:: : ;ty9=9999s$9z SCRIPT LOADc"t|dkr,ttjd|d}t j|}||j j |<|S)NrSCRIPTr) r5rr6BAD_SUBCOMMAND_MSGr8rrrrZrr)rr>rrs r& script_loadz"ScriptingCommandsMixin.script_load1st t99>>d5<.>s+HHH4DDL5566HHHr()rr5rr6rrr>s` r& script_existsz$ScriptingCommandsMixin.script_exists:sI <4  CIINNd233 3HHHH4HHHHr(z SCRIPT FLUSHct|dks*t|dkrCt|ddvr,ttjdi|j_tS)Nrr>syncasyncr) r5rrr6rr8rrrrs r& script_flushz#ScriptingCommandsMixin.script_flush@sd t99q==SYY!^^tAw0G0GOb0b0bd5< [ [value] [opt] ...]. Subcommands are:zDEBUG (YES|SYNC|NO)z7 Set the debug mode for subsequent scripts executed.zEXISTS [ ...]zN Return information about the existence of the scripts in the script cache.zFLUSH [ASYNC|SYNC]z< Flush the Lua scripts cache. Very dangerous on replicas.zU When called without the optional mode argument, the behavior is determined by thezF lazyfree-lazy-user-flush configuration directive. Valid modes are:z4 * ASYNC: Asynchronously flush the scripts cache.z2 * SYNC: Synchronously flush the scripts cache.KILLz, Kill the currently executing Lua script.z LOAD