o mi@sdZddlmZddlZddlZddlZddlmZddlm Z m Z m Z ddl Z ddl mZddlmZmZmZmZmZmZmZmZmZmZmZddlmZmZmZmZm Z m!Z!m"Z"dd l#m$Z$m%Z%m&Z&dd l'm(Z(dd l)m*Z*m+Z+m,Z,ej-e,dfZ.ej-e,dfZ/ej-e,e+dfZ0ed d GdddZ1GdddZ2GdddZ3ed d GdddZ4GdddZ5GdddZ6GdddZ7GdddZ8dS)zRDF4J client module.) annotationsN) dataclass)AnyBinaryIOIterable)BNode) RDF4JUnsupportedProtocolErrorRDFLibParserErrorRepositoryAlreadyExistsErrorRepositoryErrorRepositoryNotFoundErrorRepositoryNotHealthyErrorRepositoryResponseFormatErrorTransactionClosedErrorTransactionCommitErrorTransactionPingErrorTransactionRollbackError)build_context_parambuild_infer_param build_sparql_query_accept_headerbuild_spo_paramrdf_payload_to_streamvalidate_graph_namevalidate_no_bnodes)DATASET_DEFAULT_GRAPH_IDDatasetGraph)Result)IdentifiedNodeLiteralURIRefT)frozenc@s"eZdZUdZded<ded<dS)NamespaceListingResultz'RDF4J namespace and prefix name result.strprefix namespaceN)__name__ __module__ __qualname____doc____annotations__r+r+U/home/kim/smarthome/.venv/lib/python3.10/site-packages/rdflib/contrib/rdf4j/client.pyr"-s  r"c@sbeZdZdZdddZedd Zed d ZdddZddZ dddZ dddZ d ddZ dS)!RDF4JNamespaceManagerzA namespace manager for RDF4J repositories. Parameters: identifier: The identifier of the repository. http_client: The httpx.Client instance. identifierr# http_client httpx.ClientcCs||_||_dSN) _identifier _http_clientselfr.r/r+r+r,__init__=s zRDF4JNamespaceManager.__init__cC|jSr1r3r5r+r+r,r/Az!RDF4JNamespaceManager.http_clientcCr7zRepository identifier.r2r9r+r+r,r.Ez RDF4JNamespaceManager.identifierreturnlist[NamespaceListingResult]c Cszddi}|jjd|jd|d}|z|}|dd}dd |DWSttfy<}ztd |d }~ww) aList all namespace declarations in the repository. Returns: list[NamespaceListingResult]: List of namespace and prefix name results. Raises: RepositoryResponseFormatError: If the response format is unrecognized. Acceptapplication/sparql-results+json/repositories/ /namespacesheadersresultsbindingscSs(g|]}t|dd|dddqS)r$valuer%)r$r%)r").0rowr+r+r, ^s  z.RDF4JNamespaceManager.list..Unrecognised response format: N)r/getr.raise_for_statusjsonKeyError ValueErrorrr5rEresponsedatarFerrr+r+r,listJs   zRDF4JNamespaceManager.listcCs.ddi}|jjd|jd|d}|dS)z3Clear all namespace declarations in the repository.r@rArBrCrDN)r/deleter.rN)r5rErSr+r+r,clearhs  zRDF4JNamespaceManager.clearr$ str | Nonec Csz|stdddi}z|jjd|jd||d}||jWStjy<}z|jj dkr7WYd}~dSd}~ww) zGet the namespace URI for a given prefix. Parameters: prefix: The prefix to lookup. Returns: The namespace URI or `None` if not found. Prefix cannot be empty.r@ text/plainrB /namespaces/rDN) rQr/rMr.rNtexthttpxHTTPStatusErrorrS status_code)r5r$rErSrUr+r+r,rMrs   zRDF4JNamespaceManager.getr%cCsL|std|s tdddi}|jjd|jd|||d}|dS) a!Set the namespace URI for a given prefix. !!! note If the prefix was previously mapped to a different namespace, this will be overwritten. Parameters: prefix: The prefix to set. namespace: The namespace URI to set. rZzNamespace cannot be empty. Content-Typer[rBr\rEcontentN)rQr/putr.rN)r5r$r%rErSr+r+r,sets  zRDF4JNamespaceManager.setcCs2|std|jd|jd|}|dS)z|Remove the namespace declaration for a given prefix. Parameters: prefix: The prefix to remove. rZrBr\N)rQr/rWr.rN)r5r$rSr+r+r,removes  zRDF4JNamespaceManager.removeNr.r#r/r0)r>r?)r$r#r>rY)r$r#r%r#)r$r#) r&r'r(r)r6propertyr/r.rVrXrMrfrgr+r+r+r,r-5s     r-c@sreZdZdZdddZedd Zed d Zed ddZ d ddZ d!ddZ d"ddZ d"ddZ d ddZdS)#GraphStoreManagerzAn RDF4J Graph Store Protocol Client. Parameters: identifier: The identifier of the repository. http_client: The httpx.Client instance. r.r#r/r0cC||_||_d|_dS)Napplication/n-triples)r2r3 _content_typer4r+r+r,r6 zGraphStoreManager.__init__cCr7r1r8r9r+r+r,r/r:zGraphStoreManager.http_clientcCr7r;r<r9r+r+r,r.r=zGraphStoreManager.identifier graph_name URIRef | strcCsBi}t|tr |tkst|tr|ttkr |St||d<|S)Ngraph) isinstancer rr#)roparamsr+r+r,_build_graph_name_paramss   z*GraphStoreManager._build_graph_name_paramscCs,d|jd}t|tr|tkr|d7}|S)NrBz/rdf-graphs/servicez?default)r.rrr r)r5rourlr+r+r, _build_urlszGraphStoreManager._build_urlr>rcCsd|stdt|d|ji}||pd}|jj||||d}|t|dj |j |jdS)a}Fetch all statements in the specified graph. Parameters: graph_name: The graph name of the graph. For the default graph, use [`DATASET_DEFAULT_GRAPH_ID`][rdflib.graph.DATASET_DEFAULT_GRAPH_ID]. Returns: A [`Graph`][rdflib.graph.Graph] object containing all statements in the graph. Graph name must be provided.r@NrErs)r.rTformat) rQrrmrtr/rMrvrNrparser^)r5rorErsrSr+r+r,rMs  zGraphStoreManager.getrTstr | bytes | BinaryIO | GraphcC|stdt|t|\}}d|ji}||pd}z|jj|||||d}|W|r7| dSdS|r@| ww)a"Add statements to the specified graph. Parameters: graph_name: The graph name of the graph. For the default graph, use [`DATASET_DEFAULT_GRAPH_ID`][rdflib.graph.DATASET_DEFAULT_GRAPH_ID]. data: The RDF data to add. rwrbNrErsrd) rQrrrmrtr/postrvrNcloser5rorTstream should_closerErsrSr+r+r,add(     zGraphStoreManager.addcCr})a3Overwrite statements in the specified graph. Parameters: graph_name: The graph name of the graph. For the default graph, use [`DATASET_DEFAULT_GRAPH_ID`][rdflib.graph.DATASET_DEFAULT_GRAPH_ID]. data: The RDF data to overwrite with. rwrbNr~) rQrrrmrtr/rervrNrrr+r+r, overwrite"rzGraphStoreManager.overwritecCsD|stdt|||pd}|jj|||d}|dS)aClear all statements in the specified graph. Parameters: graph_name: The graph name of the graph. For the default graph, use [`DATASET_DEFAULT_GRAPH_ID`][rdflib.graph.DATASET_DEFAULT_GRAPH_ID]. rwNrs)rQrrtr/rWrvrNr5rorsrSr+r+r,rXAs   zGraphStoreManager.clearNrh)rorp)rorpr>r)rorprTr|)r&r'r(r)r6rir/r. staticmethodrtrvrMrrrXr+r+r+r,rjs       rjc@s>eZdZUdZded<ded<ded<ded<dZd ed <dS) RepositoryListingResulta'RDF4J repository listing result. Parameters: identifier: Repository identifier. uri: Repository URI. readable: Whether the repository is readable by the client. writable: Whether the repository is writable by the client. title: Repository title. r#r.uriboolreadablewritableNrYtitle)r&r'r(r)r*rr+r+r+r,rRs  rc@seZdZdZd@ddZedd Zed d ZedAddZedBddZ dCddZ dDdEddZ e dFddZ dGd d!ZdGd"d#ZdHd%d&Z     ' dIdJd2d3Z  dKdLd7d8Z   dMdNd9d:Z    dOdPdd?ZdS)Q RepositoryzRDF4J repository client. Parameters: identifier: The identifier of the repository. http_client: The httpx.Client instance. r.r#r/r0cCs||_||_d|_d|_dSr1)r2r3_namespace_manager_graph_store_managerr4r+r+r,r6ms zRepository.__init__cCr7r1r8r9r+r+r,r/sr:zRepository.http_clientcCr7r;r<r9r+r+r,r.wr=zRepository.identifierr>r-cC |jdur t|j|j|_|jS)z%Namespace manager for the repository.N)rr-r.r/r9r+r+r, namespaces| zRepository.namespacesrjcCr)z'Graph store manager for the repository.N)rrjr.r/r9r+r+r,graphsrzRepository.graphsrc Csddd}z|jjd|j|dd}|WdStjyG}z!|jjdkr1td |jd t d |jd |jjd |jj d }~ww)a%Repository health check. Returns: bool: True if the repository is healthy, otherwise an error is raised. Raises: RepositoryNotFoundError: If the repository is not found. RepositoryNotHealthyError: If the repository is not healthy. application/sparql-queryrA)rbr@rBzASK {}rcTr] Repository not found.z is not healthy.  - N) r/rr2rNr_r`rSrar r r^)r5rErSrUr+r+r,healths&   zRepository.healthNro&URIRef | Iterable[URIRef] | str | NoneintcCsDt|i}t|||jjd|jd|d}|||jS)The number of statements in the repository or in the specified graph name. Parameters: graph_name: Graph name(s) to restrict to. The default value `None` queries all graphs. To query just the default graph, use [`DATASET_DEFAULT_GRAPH_ID`][rdflib.graph.DATASET_DEFAULT_GRAPH_ID]. Returns: The number of statements. Raises: RepositoryResponseFormatError: Fails to parse the repository size. rBz/sizer)rrr/rMr.rN_to_sizer^rr+r+r,sizes  zRepository.sizerc CsNzt|}|dkr |WStd|ty&}ztd||d}~ww)NrzInvalid repository size: z!Failed to parse repository size: )rrQr)rrHrUr+r+r,rszRepository._to_sizequeryc Ksddi}t|||s|jjd|j||d}n|jjd|j|d|i|d}|ztjt |j |j d ddd WSt y]}ztd |j dd ||d }~ww) aExecute a SPARQL query against the repository. !!! note A POST request is used by default. If any keyword arguments are provided, a GET request is used instead, and the arguments are passed as query parameters. Parameters: query: The SPARQL query to execute. **kwargs: Additional keyword arguments to include as query parameters in the request. See [RDF4J REST API - Execute SPARQL query](https://rdf4j.org/documentation/reference/rest-api/#tag/SPARQL/paths/~1repositories~1%7BrepositoryID%7D/get) for the list of supported query parameters. rbrrBrcrrx;r content_type$Failed to parse SPARQL query result : N)rr/rr.rMrNrr{ioBytesIOrdrEsplitrPr )r5rkwargsrErSrUr+r+r,rs2    zRepository.querycCs0ddi}|jjd|jd||d}|dS)zExecute a SPARQL update operation on the repository. Parameters: query: The SPARQL update query to execute. rbzapplication/sparql-updaterB /statementsrcN)r/rr.rN)r5rrErSr+r+r,updates  zRepository.updatelist[IdentifiedNode]c Csddi}|jjd|jd|d}|z:g}|ddD],}|dd }|dd }|d kr:|t|q |d krF|t|q td ||WSt yc}zt d||d}~ww)zGet a list of all graph names in the repository. Returns: A list of graph names. Raises: RepositoryResponseFormatError: Fails to parse the repository graph names. r@rArBz /contextsrDrFrGZ contextIDrHtyperZbnodezInvalid graph name type: z(Failed to parse repository graph names: N) r/rMr.rNrOappendr rrQ Exceptionr)r5rErSvaluesrJrH value_typerUr+r+r, graph_namess2   zRepository.graph_namesTsubj SubjectTypepred PredicateTypeobj ObjectTypeinferrrYGraph | Datasetc Cst|||||dur d}d|i}i}t||t||||t||d|jjd|jd||d} | gd} z,|| vrJtj | j |d } n t j | j |d } |j D] } | j| j| jd d qX| WSty{} ztd | | d} ~ ww) Get RDF statements from the repository matching the filtering parameters. !!! Note The terms for `subj`, `pred`, `obj` or `graph_name` cannot be [`BNodes`][rdflib.term.BNode]. Parameters: subj: Subject of the statement to filter by, or `None` to match all. pred: Predicate of the statement to filter by, or `None` to match all. obj: Object of the statement to filter by, or `None` to match all. graph_name: Graph name(s) to restrict to. The default value `None` queries all graphs. To query just the default graph, use [`DATASET_DEFAULT_GRAPH_ID`][rdflib.graph.DATASET_DEFAULT_GRAPH_ID]. infer: Specifies whether inferred statements should be included in the result. content_type: The content type of the response. A triple-based format returns a [Graph][rdflib.graph.Graph], while a quad-based format returns a [`Dataset`][rdflib.graph.Dataset]. Returns: A [`Graph`][rdflib.graph.Graph] or [`Dataset`][rdflib.graph.Dataset] object with the repository namespace prefixes bound to it. Napplication/n-quadsr@rrBrrxrl text/turtlezapplication/rdf+xmlryTreplaceError parsing RDF: )rrrrr/rMr.rNrr{r^rrrVbindr$r%rr r5rrrrorrrErsrSZtriple_formatsretvalresultrUr+r+r,rM&s4$   zRepository.getrT(str | bytes | BinaryIO | Graph | Datasetbase_uric Cszt|\}}z.d|p di}i}|dur||d<|jjd|jd|||d}|W|r3|dSdS|r<|ww)TUpload and append statements to the repository. Parameters: data: The RDF data to upload. base_uri: The base URI to resolve against for any relative URIs in the data. content_type: The content type of the data. Defaults to `application/n-quads` when the value is `None`. rbrNbaseURIrBrr~)rr/rr.rNr r5rTrrrrrErsrSr+r+r,uploadis$      zRepository.uploadc Cst|\}}t|z3d|pdi}i}t|||dur ||d<|jjd|jd|||d} | W|r<|dSdS|rE|ww)a]Upload and overwrite statements in the repository. Parameters: data: The RDF data to upload. graph_name: Graph name(s) to restrict to. The default value `None` applies to all graphs. To apply to just the default graph, use [`DATASET_DEFAULT_GRAPH_ID`][rdflib.graph.DATASET_DEFAULT_GRAPH_ID]. base_uri: The base URI to resolve against for any relative URIs in the data. content_type: The content type of the data. Defaults to `application/n-quads` when the value is `None`. rbrNrrBrr~)rrrr/rer.rNr) r5rTrorrrrrErsrSr+r+r,rs(       zRepository.overwriteNonecCsPt||||i}t||t|||||jjd|jd|d}|dS)aDeletes statements from the repository matching the filtering parameters. !!! Note The terms for `subj`, `pred`, `obj` or `graph_name` cannot be [`BNodes`][rdflib.term.BNode]. Parameters: subj: Subject of the statement to filter by, or `None` to match all. pred: Predicate of the statement to filter by, or `None` to match all. obj: Object of the statement to filter by, or `None` to match all. graph_name: Graph name(s) to restrict to. The default value `None` queries all graphs. To query just the default graph, use [`DATASET_DEFAULT_GRAPH_ID`][rdflib.graph.DATASET_DEFAULT_GRAPH_ID]. rBrrN)rrrr/rWr.rN)r5rrrrorsrSr+r+r,rWs   zRepository.deleteccs8t| }|VWddS1swYdS)aDCreate a new transaction for the repository. !!! warning Transaction instances are not thread-safe. Do not share a single Transaction instance across multiple threads. Each thread should create its own transaction, or use appropriate synchronization if sharing is required. N) Transactioncreate)r5Ztxnr+r+r, transactions "zRepository.transactionrh)r>r-)r>rjr>rr1)rorr>r)rr#rr#)r>rNNNNTNrrrrrrrorrrrrYr>rNNrTrrrYrrY)NNN)rTrrorrrYrrY)NNNN) rrrrrrrorr>r)r&r'r(r)r6rir/r.rrrrrrrrrrMrrrW contextlibcontextmanagerrr+r+r+r,resN         & # F " + #rc@seZdZdZd=ddZdd Zd d Zed d ZeddZ ed>ddZ ddZ e d?ddZ ddZddZddZd@dAd!d"ZdBd$d%ZdBd&d'Z  dCdDd-d.Z     / dEdFd8d9Z  dCdGd;d<ZdS)Hra]An RDF4J transaction. !!! warning Transaction instances are not thread-safe. Do not share a single Transaction instance across multiple threads. Each thread should create its own transaction, or use appropriate synchronization if sharing is required. Parameters: repo: The repository instance. reporrur#cCrkNF)_repo_url_closed)r5rrur+r+r,r6rnzTransaction.__init__cC|Sr1r+r9r+r+r, __enter__zTransaction.__enter__cCsB|js|dur |dSz|WdStyYdSwdSr) is_closedcommitrollbackrr5exc_typeexc_valexc_tbr+r+r,__exit__s  zTransaction.__exit__cCr7)zThe repository instance.)rr9r+r+r,rr=zTransaction.repocCr7)zThe transaction URL.)rr9r+r+r,ru r=zTransaction.urlr>rcCr7)z"Whether the transaction is closed.)rr9r+r+r,rr=zTransaction.is_closedcCs|jrtddS)Nz The transaction has been closed.)rrr9r+r+r,_raise_for_closedszTransaction._raise_for_closedcCs2|jd|jd}||jd}|||S)zCreate a new transaction for the repository. Parameters: repo: The repository instance. Returns: A new Transaction instance. rBz /transactionsZLocation)r/rr.rNrE)clsrrSrur+r+r,rs    zTransaction.createcCsP|ddi}|jjj|j|d}|jdkr#td|jd|jd|_dS) zCommit the transaction. Raises: TransactionCommitError: If the transaction commit fails. TransactionClosedError: If the transaction is closed. actionZCOMMITrzTransaction commit failed: rTN) rrr/rerurarr^rr5rsrSr+r+r,r*s  zTransaction.commitcCsD||jj|j}|jdkrtd|jd|jd|_dS)zRoll back the transaction. Raises: TransactionRollbackError: If the transaction rollback fails. TransactionClosedError: If the transaction is closed. zTransaction rollback failed: rTN) rrr/rWrurarr^rr5rSr+r+r,r:s  zTransaction.rollbackcCsJ|ddi}|jjj|j|d}|jdkr#td|jd|jdS)zPing the transaction. Raises: RepositoryTransactionPingError: If the transaction ping fails. TransactionClosedError: If the transaction is closed. rZPINGrrzTransaction ping failed: rN)rrr/rerurarr^rr+r+r,pingIs zTransaction.pingNrorcCsL|t|ddi}t|||jjj|j|d}||j|j S)rrZSIZEr) rrrrr/rerurNrr^rr+r+r,rXs zTransaction.sizerc Ks|i}t||d|d}|jjj|j|i||d}|ztjt |j |j d dddWStyR}ztd|j dd ||d }~ww) aExecute a SPARQL query against the repository. Parameters: query: The SPARQL query to execute. **kwargs: Additional keyword arguments to include as query parameters in the request. See [RDF4J REST API - Execute SPARQL query](https://rdf4j.org/documentation/reference/rest-api/#tag/SPARQL/paths/~1repositories~1%7BrepositoryID%7D/get) for the list of supported query parameters. ZQUERY)rrrxrbrrrrrN)rrrr/rerurNrr{rrrdrErrPr rM)r5rrrErsrSrUr+r+r,rqs*    zTransaction.querycKs:|d|d}|jjj|ji||d}|dS)aExecute a SPARQL update operation on the repository. Parameters: query: The SPARQL update query to execute. **kwargs: Additional keyword arguments to include as query parameters See [RDF4J REST API - Execute a transaction action](https://rdf4j.org/documentation/reference/rest-api/#tag/Transactions/paths/~1repositories~1%7BrepositoryID%7D~1transactions~1%7BtransactionID%7D/put) for the list of supported query parameters. ZUPDATE)rrrN)rrr/rerurN)r5rrrsrSr+r+r,rs   zTransaction.updaterTrrrYrc Cs|t|\}}d|pdi}ddi}|dur||d<z|jjj|j|||d}|W|r6|dSdS|r?|ww)rrbrrZADDNrr~rrrr/rerurNrrr+r+r,rs&     zTransaction.uploadTrrrrrrrrc Cs|t|||||durd}d|i}ddi}t||t||||t||d|jjj|j||d} | gd} z-|| vrMt j | j |d } n t j | j |d } |jjD] } | j| j| jd d q\| WSty} ztd | | d} ~ ww) rNrr@rGETrrxrryTrr)rrrrrrr/rerurNrr{r^rrrVrr$r%rr rr+r+r,rMs6$  zTransaction.getrc Cs|ddi}t|\}}d|pdi}|dur||d<z|jjj|j|||d}|W|r6|dSdS|r?|ww)aDelete statements from the repository. !!! Note This function operates differently to [`Repository.delete`][rdflib.contrib.rdf4j.client.Repository.delete] as it does not use filter parameters. Instead, it expects a data payload. See the notes from [graphdb.js#Deleting](https://github.com/Ontotext-AD/graphdb.js?tab=readme-ov-file#deleting-1) for more information. Parameters: data: The RDF data to upload. base_uri: The base URI to resolve against for any relative URIs in the data. content_type: The content type of the data. Defaults to `application/n-quads` when the value is `None`. rDELETErbrNrr~r) r5rTrrrsrrrErSr+r+r,rWs&     zTransaction.delete)rrrur#r)rrr>rr1)rorrrrrr)rTrrrYrrYr>r)r&r'r(r)r6rrrirrurr classmethodrrrrrrrrrMrWr+r+r+r,rsB         " Grc@sReZdZdZdddZeddZdd d ZdddZ ddddZ dddZ dS) RepositoryManagerz|A client to manage server-level repository operations. Parameters: http_client: The httpx.Client instance. r/r0cCs ||_dSr1r8)r5r/r+r+r,r62s zRepositoryManager.__init__cCr7r1r8r9r+r+r,r/5r:zRepositoryManager.http_clientr>list[RepositoryListingResult]c Cspddi}|jjd|d}|z|}|dd}dd|DWSttfy7}ztd |d }~ww) zList all available repositories. Returns: list[RepositoryListingResult]: List of repository results. Raises: RepositoryResponseFormatError: If the response format is unrecognized. r@rAz /repositoriesrDrFrGc SsLg|]"}t|dd|dd|dd|dd|diddqS)idrHrrrr)r.rrrr)rrM)rIrr+r+r,rKKs    z*RepositoryManager.list..rLN)r/rMrNrOrPrQrrRr+r+r,rV9s   zRepositoryManager.list repository_idr#rcCst||j}||S)aGet a repository by ID. !!! Note This performs a health check before returning the repository object. Parameters: repository_id: The identifier of the repository. Returns: Repository: The repository instance. Raises: RepositoryNotFoundError: If the repository is not found. RepositoryNotHealthyError: If the repository is not healthy. )rr/r)r5rrr+r+r,rMXs zRepositoryManager.getrrTrc Csnzd|i}|jjd|||d}|||WStjy6}z|jjdkr1td|dd}~ww)aCreate a new repository. Parameters: repository_id: The identifier of the repository. data: The repository configuration in RDF. content_type: The repository configuration content type. Raises: RepositoryAlreadyExistsError: If the repository already exists. RepositoryNotHealthyError: If the repository is not healthy. rbrBrcirz already exists.N) r/rerNrMr_r`rSrar )r5rrTrrErSrUr+r+r,rls    zRepositoryManager.createrc Csz&|jd|}||jdkr$td|d|jd|jWd StjyB}z|j jdkr=t d|dd }~ww) aDelete a repository. Parameters: repository_id: The identifier of the repository. Raises: RepositoryNotFoundError: If the repository is not found. RepositoryError: If the repository is not deleted successfully. rBrz9Unexpected response status code when deleting repository rrr]rrN) r/rWrNrar r^stripr_r`rSr )r5rrSrUr+r+r,rWs   zRepositoryManager.deleteN)r/r0)r>r)rr#r>r)r)rr#rTr#rr#r>r)rr#r>r) r&r'r(r)r6rir/rVrMrrWr+r+r+r,r+s     rc@s`eZdZdZ  ddd d ZddZddZeddZedddZ ed ddZ ddZ dS)! RDF4JClientaRDF4J client. This client and its inner management objects perform HTTP requests via httpx and may raise httpx-specific exceptions. Errors documented by RDF4J in its protocol specification are mapped to specific exceptions in this library where applicable. Error mappings are documented on each management method. The underlying httpx client is reused across requests, and connection pooling is handled automatically by httpx. Parameters: base_url: The base URL of the RDF4J server. auth: Authentication credentials. Can be a tuple (username, password) for basic auth, or a string for token-based auth (e.g., "GDB ") which is added as the Authorization header. timeout: Request timeout in seconds or an httpx.Timeout for fine-grained control (default: 30.0). kwargs: Additional keyword arguments to pass to the httpx.Client. N>@base_urlr#authtuple[str, str] | str | Nonetimeoutfloat | httpx.Timeoutrrc Ks|ds |d7}d}t|tr|}nt|tr&|di}||d<||d<tjd |||d||_t|j |_ z|j }Wntj yW}z | td||d}~ww|dkrh| td|ddS) N/rE Authorization)rrrz"Failed to check protocol version: zRDF4J server protocol version z2 is not supported. Minimum required version is 12.r+)endswithrrtupler#rMr_ZClientr3rr/_repository_managerprotocol RequestErrorrr) r5rrrrZ httpx_authrEZprotocol_versionrUr+r+r,r6s@       zRDF4JClient.__init__cCrr1r+r9r+r+r,rrzRDF4JClient.__enter__cCs |dSr1)rrr+r+r,rs zRDF4JClient.__exit__cCr7r1r8r9r+r+r,r/r:zRDF4JClient.http_clientr>rcCr7)z.Server-level repository management operations.)rr9r+r+r, repositoriesr=zRDF4JClient.repositoriesfloatcCs*|jjdddid}|t|jS)zhThe RDF4J REST API protocol version. Returns: The protocol version number. z /protocolr@r[rD)r/rMrNr r^rrr+r+r,rszRDF4JClient.protocolcCs|jdS)z"Close the underlying httpx.Client.N)r/rr9r+r+r,rszRDF4JClient.close)Nr)rr#rrrrrr)r>r)r>r ) r&r'r(r)r6rrrir/r rrr+r+r+r,rs #    r)9r) __future__rrrtypingt dataclassesrrrrr_ZrdflibrZrdflib.contrib.rdf4j.exceptionsrr r r r r rrrrrZrdflib.contrib.rdf4j.utilrrrrrrrZ rdflib.graphrrrZ rdflib.queryrZ rdflib.termrrr Unionrrrr"r-rjrrrrrr+r+r+r,sB   4$  }!Jt