Rǻi2UdZddlmZddlZddlmZddl m Z ejrddlm ZneZgdZd Zd ed <d Zd ed <dZd ed<dZd ed<dZd ed<dZd ed<dZd ed<dZd ed<dZd ed<dZd ed<dZded<Gd d!ZeZee e fezdzZ!d"ed#<d1d2d$Z"d3d%Z#d4d&Z$ d5d'Z%Gd(d)Z&Gd*d+Z'Gd,d-eejP.Z)Gd/d0eejP.Z*y)6zBase classes and helpers.) annotationsN)_typing)Address)Protocol)DEFAULT_DATABASE READ_ACCESSSYSTEM_DATABASEURI_SCHEME_BOLTURI_SCHEME_BOLT_ROUTINGURI_SCHEME_BOLT_SECURE'URI_SCHEME_BOLT_SELF_SIGNED_CERTIFICATEURI_SCHEME_NEO4JURI_SCHEME_NEO4J_SECURE(URI_SCHEME_NEO4J_SELF_SIGNED_CERTIFICATE WRITE_ACCESSAsyncBookmarkManagerAuth AuthTokenBookmarkManager Bookmarks ServerInfo basic_auth bearer_auth custom_auth kerberos_authREADz _t.Final[str]r WRITErboltr zbolt+sscrzbolt+sr neo4jrz neo4j+sscrzneo4j+srz bolt+routingr systemr z_t.Final[None]rc:eZdZdZ d ddZddZy)raG Container for auth details. :param scheme: specifies the type of authentication, examples: "basic", "kerberos" :type scheme: str | None :param principal: specifies who is being authenticated :type principal: str | None :param credentials: authenticates the principal :type credentials: str | None :param realm: specifies the authentication provider :type realm: str | None :param parameters: extra key word parameters passed along to the authentication provider :type parameters: typing.Any Nc \||_|||_|r||_|r||_|r||_yyN)scheme principal credentialsrealm parameters)selfr%r&r'r(r)s G/opt/lhia/marcimex/agent/venv/lib/python3.12/site-packages/neo4j/api.py__init__z Auth.__init__`s>   &DN *D  DJ (DO c\t|tstSt|t|k(Sr$) isinstancerNotImplementedvars)r*others r+__eq__z Auth.__eq__ts%%&! !DzT%[((r-r$) r% str | Noner&r4r'r4r(r4r)_t.AnyreturnNone)r2objectr6bool)__name__ __module__ __qualname____doc__r,r3r-r+rrNsP,! ))) )  )  ) )()r-rz _t.TypeAlias_TAuthctd|||S)a Generate a basic auth token for a given user and password. This will set the scheme to "basic" for the auth token. :param user: user name, this will set the principal :param password: current password, this will set the credentials :param realm: specifies the authentication provider :returns: auth token for use with :meth:`GraphDatabase.driver` or :meth:`AsyncGraphDatabase.driver` basicr)userpasswordr(s r+rrs x //r-ctdd|S)ac Generate a kerberos auth token with the base64 encoded ticket. This will set the scheme to "kerberos" for the auth token. :param base64_encoded_ticket: a base64 encoded service ticket, this will set the credentials :returns: auth token for use with :meth:`GraphDatabase.driver` or :meth:`AsyncGraphDatabase.driver` kerberosrB)base64_encoded_tickets r+rrs  B 5 66r-ctdd|S)ae Generate an auth token for Single-Sign-On providers. This will set the scheme to "bearer" for the auth token. :param base64_encoded_token: a base64 encoded authentication token generated by a Single-Sign-On provider. :returns: auth token for use with :meth:`GraphDatabase.driver` or :meth:`AsyncGraphDatabase.driver` bearerNrB)base64_encoded_tokens r+rrs $ 4 55r-c  t||||fi|S)a Generate a custom auth token. :param principal: specifies who is being authenticated :param credentials: authenticates the principal :param realm: specifies the authentication provider :param scheme: specifies the type of authentication :param parameters: extra key word parameters passed along to the authentication provider :returns: auth token for use with :meth:`GraphDatabase.driver` or :meth:`AsyncGraphDatabase.driver` rB)r&r'r(r%r)s r+rrs(  ; D DDr-cReZdZdZdZd dZd dZd dZed dZ e d dZ y)raG Container for an immutable set of bookmark string values. Bookmarks are used to causally chain sessions. See :meth:`Session.last_bookmarks` or :meth:`AsyncSession.last_bookmarks` for more information. Use addition to combine multiple Bookmarks objects:: bookmarks3 = bookmarks1 + bookmarks2 c"t|_yr$) frozenset _raw_valuesr*s r+r,zBookmarks.__init__s $;r-c djdjttt |j S)zc Represent the container as str. :returns: repr string with sorted values zz, )formatjoinmapreprsortedrPrQs r+__repr__zBookmarks.__repr__s5 +11 IIc$t'7'7 89 :  r-c,t|jS)z6Indicate whether there are bookmarks in the container.)r9rPrQs r+__bool__zBookmarks.__bool__sD$$%%r-ct|tr4|s|S|j}|j|jz|_|StS)z!Add multiple containers together.)r/r __class__rPr0)r*r2rets r+__add__zBookmarks.__add__sC eY ' .."C"..1B1BBCOJr-c|jS)z The raw bookmark values. You should not need to access them unless you want to serialize bookmarks. :returns: immutable list of bookmark string values :rtype: frozenset[str] )rPrQs r+ raw_valueszBookmarks.raw_valuessr-cBt|tr|f}|}g}|D]L}t|tstdt| |j d|j|Nt||_ |S#t $r}t d|d|d}~wwxYw)z Create a Bookmarks object from a list of raw bookmark string values. You should not need to use this method unless you want to deserialize bookmarks. :param values: ASCII string values (raw bookmarks) z'Raw bookmark values must be str. Found asciiz The value z is not ASCIIN) r/str TypeErrortypeencodeUnicodeEncodeError ValueErrorappendrOrP)clsvaluesobj bookmarksvaluees r+from_raw_valueszBookmarks.from_raw_valuess fc "YFe  $EeS)=d5k]K K W%   U # $$I. & K :eWM!BCJ Ks B B BBNr6rc)r6r9)r2rr6r)r6zfrozenset[str])rkz_t.Iterable[str]r6r) r:r;r<r=r,rXrZr^propertyr` classmethodrpr>r-r+rrsC ' &    r-rcVeZdZdZddZed dZed dZed dZd dZ y) rz?Represents a package of information relating to a Neo4j server.c.||_||_i|_yr$)_address_protocol_version _metadata)r*addressprotocol_versions r+r,zServerInfo.__init__s !1!r-c|jS)z%Network address of the remote server.)rvrQs r+ryzServerInfo.address!s}}r-c|jS)z Bolt protocol version with which the remote server communicates. This is returned as a 2-:class:`tuple` of ``(major, minor)`` integers. )rwrQs r+rzzServerInfo.protocol_version&s%%%r-cJt|jjdS)zAServer agent string by which the remote server identifies itself.server)rcrxgetrQs r+agentzServerInfo.agent0s4>>%%h/00r-c:|jj|y)z Update server information with extra metadata. This is typically drawn from the metadata received after successful connection initialisation. N)rxupdate)r*metadatas r+rzServerInfo.update5s h'r-N)ry_Addressrztuple[int, int])r6r)r6rrq)rdictr6r7) r:r;r<r=r,rrryrzrrr>r-r+rrsKI" &&11(r-rcheZdZdZej ddZej ddZy)ra Class to manage bookmarks throughout the driver's lifetime. Neo4j clusters are eventually consistent, meaning that there is no guarantee a query will be able to read changes made by a previous query. For cases where such a guarantee is necessary, the server provides bookmarks to the client. A bookmark is an abstract token that represents some state of the database. By passing one or multiple bookmarks along with a query, the server will make sure that the query will not get executed before the represented state(s) (or a later state) have been established. The bookmark manager is an interface used by the driver for keeping track of the bookmarks and this way keeping sessions automatically consistent. Configure the driver to use a specific bookmark manager with :ref:`bookmark-manager-ref`. This class is just an abstract base class that defines the required interface. Create a child class to implement a specific bookmark manager or make use of the default implementation provided by the driver through :meth:`.GraphDatabase.bookmark_manager`. .. note:: All methods must be concurrency safe. .. versionadded:: 5.0 .. versionchanged:: 5.3 The bookmark manager no longer tracks bookmarks per database. This effectively changes the signature of almost all bookmark manager related methods: * :meth:`.update_bookmarks` has no longer a ``database`` argument. * :meth:`.get_bookmarks` has no longer a ``database`` argument. * The ``get_all_bookmarks`` method was removed. * The ``forget`` method was removed. .. versionchanged:: 5.8 Stabilized from experimental. cy)z Handle bookmark updates. :param previous_bookmarks: The bookmarks used at the start of a transaction :param new_bookmarks: The new bookmarks retrieved at the end of a transaction Nr>r*previous_bookmarks new_bookmarkss r+update_bookmarksz BookmarkManager.update_bookmarkshs r-cy)z~ Return the bookmarks stored in the bookmark manager. :returns: The bookmarks for the given database Nr>rQs r+ get_bookmarkszBookmarkManager.get_bookmarksxs r-Nr_t.Collection[str]rrr6r7r6r)r:r;r<r=_abcabstractmethodrrr>r-r+rr?sX&P   .  *          r-r) metaclassceZdZdZej ddZej je_ej ddZejje_y)ra Same as :class:`.BookmarkManager` but with async methods. The driver comes with a default implementation of the async bookmark manager accessible through :attr:`.AsyncGraphDatabase.bookmark_manager()`. .. versionadded:: 5.0 .. versionchanged:: 5.3 See :class:`.BookmarkManager` for changes. .. versionchanged:: 5.8 Stabilized from experimental. c Kywr$r>rs r+rz%AsyncBookmarkManager.update_bookmarkss c Kywr$r>rQs r+rz"AsyncBookmarkManager.get_bookmarkss 9r-r+rrs|  .*   /??GG <<+99AAMr-rr$)rCrcrDrcr(r4r6r)rHrcr6r)rKrcr6r) r&r4r'r4r(r4r%r4r)r5r6r)+r= __future__r_abcrrGr_t _addressingrr TYPE_CHECKINGr _Protocolr8__all__r __annotations__rr rr rrrr r rrrtuplercr?rrrrrrABCMetarrr>r-r+rsk" '-.I 2$ ]#% m%!''9C'C(0 0")-):E(-E)22)77!))#'.'))))Z  S#X-4 4 0 7 6EEE E  E  E  E.QQh#(#(L@ i4<<@ FB9 Br-