mBNjL)ddlmZmZmZddlmZddlmZddl m Z ddl m Z ddl mZmZdd lmZd Zd Zd ZGd dZy))ListOptionalUnionN) DriverInfo) RedisError)get_package_version) Cluster_Conn Is_Cluster) AsyncGraphz GRAPH.UDFz GRAPH.LISTz GRAPH.CONFIGc eZdZdZ ddZededdfdZdedefdZ de efd Z d ede e effd Zdd eddfd Zdd ZddZddZdd ededefdZddeedefdZdZdefdZy)FalkorDBa Asynchronous FalkorDB Class for interacting with a FalkorDB server. Supports both TCP and Unix socket connections. Usage example:: from falkordb.asyncio import FalkorDB # connect to the database and select the 'social' graph db = FalkorDB() graph = db.select_graph("social") # connect using a Unix socket db = FalkorDB.from_url("unix:///path/to/redis.sock") graph = db.select_graph("social") # get a single 'Person' node from the graph and print its name response = await graph.query("MATCH (n:Person) RETURN n LIMIT 1") result = response.result_set person = result[0][0] print(person.properties['name']) Nc% tjd"id|d|ddd|d|d|d|d |d |d | d | d | ddd| d| d|d|d|d|d|d|d|d|d|d|dt||xs td|d|d|d |d!|}%t |%rt |%| || |!|"|#|$}%|%|_|%j|_|%j|_y)#Nhostportdbrpasswordsocket_timeoutsocket_connect_timeoutsocket_keepalivesocket_keepalive_optionsconnection_poolunix_socket_pathencodingencoding_errorsdecode_responsesTretry_on_errorssl ssl_keyfile ssl_certfile ssl_cert_reqs ssl_ca_certs ssl_ca_datassl_check_hostnamemax_connectionssingle_connection_clienthealth_check_interval client_name driver_infousernameretryredis_connect_funccredential_providerprotocol) redisRedisrr r r connectionflushdbexecute_command)&selfrrrrrrrrrrrrrr r!r"r#r$r%r&r'r(r)lib_name lib_versionr+r, connect_funcr.r/cluster_error_retry_attempts startup_nodesrequire_full_coveragereinitialize_stepsread_from_replicas address_remapconns& j/Users/ahmed/devFolder/Ultron/claude-voice/.venv/lib/python3.12/site-packages/falkordb/asyncio/falkordb.py__init__zFalkorDB.__init__(sR{{          *  $:  .  &>  ,  .    ,  "  *    $!  "&#  $(%  &&'  ($)  * 2+  ,,-  .&>/  0#81  2$3  4#8[-Q?  D d ,%"" D|| #33urlreturnc |jdrd|tddz}n"|jdrd|tddz}d|d<tj|fi|}||jS) aN Creates a new FalkorDB instance from a URL. Args: cls: The class itself. url (str): The URL. kwargs: Additional keyword arguments to pass to the ``DB.from_url`` function. Returns: DB: A new DB instance. Usage example:: db = FalkorDB.from_url("falkor://[[username]:[password]]@localhost:6379") db = FalkorDB.from_url("falkors://[[username]:[password]]@localhost:6379") db = FalkorDB.from_url("unix://[username@]/path/to/socket.sock?db=0[&password=password]") z falkor://zredis://Nz falkors://z rediss://Tr)r) startswithlenr1from_urlr)clsrDkwargsr@s rArIzFalkorDB.from_urlsy* >>+ &s3{#3#566C ^^L )C $5$7 88C%)!"~~c,V,4#7#788rCgraph_idctt|tr|dk(rtdt|dt ||S)z Selects a graph by creating a new Graph instance. Args: graph_id (str): The identifier of the graph. Returns: AsyncGraph: A new Graph instance associated with the selected graph. z*Expected a string parameter, but received .) isinstancestr TypeErrortyper )r6rLs rA select_graphzFalkorDB.select_graphsA(C(HN>>>s #,*,namecjK|jjtd|d{}|dS7 w)aA Retrieve a DB level configuration. For a list of available configurations see: https://docs.falkordb.com/configuration.html#falkordb-configuration-parameters Args: name (str): The name of the configuration. Returns: int or str: The configuration value. GETNr r3r5 CONFIG_CMD)r6rYress rA config_getzFalkorDB.config_gets2OO33JtLL1v Ms %31 3cbK|jjtd||d{S7w)aD Update a DB level configuration. For a list of available configurations see: https://docs.falkordb.com/configuration.html#falkordb-configuration-parameters Args: name (str): The name of the configuration. value: The value to set. Returns: None SETNr\)r6rYvalues rA config_setzFalkorDB.config_sets)__44ZeTTTTs &/-/ctK |jjd{y7#t$rYywxYww)z5 Close the underlying connection(s). N)r3acloserrWs rArezFalkorDB.acloses2  //((* * *   s(8)')8) 5858cK|Sw)z2Return self to support async with-statement usage.r0rWs rA __aenter__zFalkorDB.__aenter__s  sc@K|jd{y7w)z:Close the connection when exiting an async with-statement.N)re)r6exc_typeexc_valexc_tbs rA __aexit__zFalkorDB.__aexit__skkms scriptreplacecKtdg}|r|jd|j||gt|jrS|jj D]4}|jj |}|j|d{}6S|jj|d{}|S7+7w)a: Load a User Defined Function (UDF) library. Args: name (str): The name of the library to load. script (str): The UDF script contents. replace (bool, optional): If True, replace an existing library with the same name. Defaults to False. LOADREPLACEN)UDF_CMDappendextendr r3 get_primariesget_redis_connectionr5)r6rYrmrnargsnodeclientresps rAudf_loadzFalkorDB.udf_loads   KK " T6N# doo &557==dC3V33T::8 988$??D ;?s$BCB<$C5B>6C>Clib with_codecKtdg}||j||r|jd|jj|d{S7w)a List User Defined Function (UDF) libraries. Args: lib (str, optional): If provided, filter the list to this specific library. with_code (bool, optional): If True, include the library source code in the result. Defaults to False. Returns: list: A list of UDF libraries and their metadata. LISTNWITHCODE)rrrsr3r5)r6r|r}rws rAudf_listzFalkorDB.udf_listsO  ? KK   KK #4T__44d;;;;sA A AAcDKt|jrZ|jjD];}|jj|}|j t dd{}=S|jj t dd{}|S727w)zK Flush (remove) all User Defined Function (UDF) libraries. FLUSHNr r3rurvr5rr)r6rxryrzs rA udf_flushzFalkorDB.udf_flush*s doo &557==dC#33GWEE8 88'JJD FJs$A'B )B*+B BB B cHKt|jr[|jjD]<}|jj|}|j t d|d{}>S|jj t d|d{}|S737w)z Delete a User Defined Function (UDF) library. Args: lib (str): The name of the library to delete. DELETENr)r6r|rxryrzs rA udf_deletezFalkorDB.udf_delete;s doo &557==dC#33GXsKK8 88(CPPD LPs$A(B"*B+,B"B B" B")$ localhostiNNNNNNNzutf-8strictNFNNrequiredNNFNFrNrz1.0.0NNNNrNFFN)N)rEN)rEr)F)NF)__name__ __module__ __qualname____doc__rB classmethodrQrIr rTrrXrintr_rcrergrlboolr{rrrrr0rCrArrsD0 #!%    !& %&# MY4v939Z99<*S*Z*" ?49 ?SU38_ USUU   3d:<(3-<4<0"CrCr)typingrrr redis.asyncioasyncior1redis.driver_inforredis.exceptionsr_versionr clusterr r graphr rrrVr]rr0rCrArs:((('*-    {{rC