AHjddlZddlZddlZddlmZmZmZmZmZm Z m Z ddl Z ddl m Z mZmZdedeedzdeefdZdeedfd e eefdee edzffd Zd e e edzfdee ezfd Zd ZdZdZd dZdZdZdZddddde ededeeedeffdeeedeffdeeedeffde eeedeffde eeedeffde eeedeffdeeedefffdZ deefdZ!y)!N)AnyCallableDictIterableListMappingOptional)ChannelT PubSubHandler Subscriptionkeysargsreturnc t|t|tttt fr|g}n t |}|r|j||S#t$r|g}Y#wxYwN) iter isinstancebytesstr bytearray memoryviewlist TypeErrorextend)r rs N/root/tools/cai/cai_env/lib/python3.12/site-packages/redis/commands/helpers.py list_or_argsrsa  T  dUCJ? @6D:D  D K vs:A A A .kwargsc|rt|d|ddng}i}|D]1}t|tr|j||j<-d||<3|j ||S)Nr)rrr handlernameupdate)rr parsed_args subscriptionsargs rparse_pubsub_subscriptionsr&#sn6:,tAwQR1rK: -infinitynaninfinityN) appendrfloatr3rrlowerint ValueError OverflowError)responseresspecial_valuesitemitem_strs r parse_to_listrFIs C5N ) < JJt   dE " JJt    H h $)9^)K JJx  ) 3t9%#)0 J  JJt    y9 ))JJuT{+"I.)JJx() )sH B%C%CCDC54D5 DDDDDcDdjdt|DS)z3 Returns a random N character long string. c3bK|]'}tjtj)ywr)randomchoicestringascii_lowercase.0r1s r z random_string..qs$23 f,,-s-/)joinrange)lengths r random_stringrTms& 777> ?##5599*EE @r'c`t|tjs$t|tjjr&|jj j ddSt|tjjr&|jj j ddSy)a?Return the user-supplied ``legacy_responses`` flag for ``client``. Defaults to ``True`` when the flag is not present in the client's ``connection_kwargs``. Mirrors :func:`get_protocol_version` so module command bases can read both the protocol and the response-shape selection from the same place. legacy_responsesTr]rgs rget_legacy_responsesrls}&%++&*VU]]=P=P*Q%%77;;> ?##5599:LdSS r') resp2_unified resp3_unifiedresp3_to_resp2_legacy user_protocolrkcommonresp2resp3rmrnroct|}|rC||j|xsi|S|dvr|j||S|j||S||dvr|j|||S||S|j||n||S)aReturn the merged module-callback dict for the given (protocol, legacy_responses) combination. Mirrors the selection used by :func:`redis._parsers.response_callbacks.get_response_callbacks` for the core callbacks: ``common`` is overlaid with the protocol-specific dict matching ``user_protocol`` and ``legacy_responses``. ``resp2_unified`` defaults to ``resp2``, ``resp3_unified`` to ``resp3``, and ``resp3_to_resp2_legacy`` to an empty dict. )3)dictr") rprkrqrrrsrmrnro callbackss rapply_module_callbacksrys*04F|I    28b 9 h &   U #    U #   MX$=   m.G] S NS S    m.G]U S r'iterablec0d|D}t|dkS)a Checks that at most one of the values in the iterable is truthy. Args: iterable: An iterable of values to check. Returns: True if at most one value is truthy, False otherwise. Raises: Might raise an error if the values in iterable are not boolean-compatible. For example if the type of the values implement __len__ or __bool__ methods and they raise an error. c32K|]}t|ywr)boolrNs rrPz(at_most_one_value_set..s (!d1g (sr)sum)rzvaluess rat_most_one_value_setrs)x (F v;! r') )"rVrJrLtypingrrrrrrr r^ redis.typingr r r rtuplerrwr&rr+r3r6rFrTrZrirlr>r}ryrr'rrs  >>s(3-$"649"  S/ #*3 +=#>  (MD( () 8]T%99: (\ !" )!HF ,>B=AEI"C="" hsCx(( ) " Xc3h'' ( " Xc3h'' ( "DhsCx&8!89:"DhsCx&8!89:"$DhsCx.@)@$AB" #xS! !""JHSMr'