o `f@sddlZddlZddlZddlmZmZddlZddlmZm Z dedee dfdee fdd Z d d Z d d Z ddZ ddZddZdddZddZddZddZddZdS) N)ListTuple)KeysTKeyTkeysargs.returncCsVzt|t|ttfr|g}nt|}Wn ty!|g}Ynw|r)|||SN)iter isinstancebytesstrlist TypeErrorextend)rrrO/home/ubuntu/webapp/venv/lib/python3.10/site-packages/redis/commands/helpers.py list_or_args s   rcCs*t|tr |ddn|}|dkrdS|S)zAReturn the decoded binary string, or a string, depending on type.utf-8replacenullN)r r decode)xrrrr nativestrsrcCs|dur|Sdd|DS)z9Given a list of binaries, return the stringified version.NcSsg|]}t|qSr)r).0objrrr 'szdelist..r)rrrrdelist#src Csg}|dur|S|D];}z |t|Wq ty8z |t|Wnty5|t|YnwYq tyE|dYq w|S)z,Optimistically parse the response to a list.N)appendint ValueErrorfloatrr)responseresitemrrr parse_to_list*s"   r&c Csi}tdt|dD]n}t||tr@|dt||zt||dtr5|dt||dWq ty?Yq wt||dtrUt||dg|d<q zt||d|||<Wq tt fyx||d|||<Yq w|S)NrzChild iterators) rangelenr rrparse_list_to_dict IndexErrorr"rr!)r#r$irrrr+>s& r+c Cs|duriSi}|D]T}t|tr|sq t|dkr!d||d<q t|dtr3t|d||d<q z"z t|d||d<WnttfyS|d||d<YnwWq ty^Yq w|S)Nr(Tr)r rr*r+r"rr!r,)r#r$detrrr parse_to_dictRs*  r/ cCsdddt|DS)z3 Returns a random N character long string. css|] }ttjVqdSr )randomchoicestringascii_lowercase)rrrrr ms  z random_string..)joinr))lengthrrr random_stringis r9cCsVt|tr |}nt|ts|St|dkrdS|dd}|dd}d|dS)zq RedisGraph strings must be quoted, quote_string wraps given v with quotes incase v is a string. rz""\z\\"z\")r r rr r*r)vrrr quote_stringrs       r=cCsBt|}|D]}t|tr||||d<||q |S)z3Decode the keys of the given dictionary with utf-8.r)copyrr r rpop)rnewobjkrrrdecode_dict_keyss    rBcCsvt|tr t|S|durdSt|ttfr"ddtt|dSt|tr7dddd| Dd St|S) a Turn a parameter value into a string suitable for the params header of a Cypher command. You may pass any value that would be accepted by `json.dumps()`. Ways in which output differs from that of `str()`: * Strings are quoted. * None --> "null". * In dictionaries, keys are _not_ quoted. :param value: The parameter value to be turned into a string. :return: string Nr[,]{css&|]\}}|dt|VqdS):N)stringify_param_value)rrAr<rrrr6s$z(stringify_param_value..}) r r r=rtupler7maprHdictitems)valuerrrrHs   rHcCsHt|tjs t|tjjr|jjdSt|tjjr"|j jdSdS)Nprotocol) r redisRedisasyncioconnection_poolconnection_kwargsgetclusterAbstractRedisCluster nodes_manager)clientrrrget_protocol_versions rZ)r0)r>r2r4typingrrrP redis.typingrrrrrr&r+r/r9r=rBrHrZrrrrs""