tj(dZddlmZddlmZmZddlmZmZddl m Z ddl m Z ddl mZmZmZmZGdd Zd S) z+Synchronous store client for LangGraph SDK.) annotations)MappingSequence)AnyLiteral)_provided_vals)SyncHttpClient)ItemListNamespaceResponseQueryParamTypesSearchItemsResponseceZdZdZd1dZ d2d3dZddddd4dZ d5d6dZ d7d8d(Z d9ddd*d:d0Z dS);SyncStoreClientaA client for synchronous operations on a key-value store. Provides methods to interact with a remote key-value store, allowing storage and retrieval of items within namespaced hierarchies. ???+ example "Example" ```python client = get_sync_client(url="http://localhost:2024")) client.store.put_item(["users", "profiles"], "user123", {"name": "Alice", "age": 30}) ``` httpr returnNonec||_dS)N)r)selfrs W/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/langgraph_sdk/_sync/store.py__init__zSyncStoreClient.__init__ s  NkeystrvalueMapping[str, Any]index!Literal[False] | list[str] | Nonettl int | NoneheadersMapping[str, str] | NoneparamsQueryParamTypes | None namespace Sequence[str]c|D]}d|vrtd|d|||||d} |jdt| ||dS)aStore or update an item. Args: namespace: A list of strings representing the namespace path. key: The unique identifier for the item within the namespace. value: A dictionary containing the item's data. index: Controls search indexing - None (use defaults), False (disable), or list of field paths to index. ttl: Optional time-to-live in minutes for the item, or None for no expiration. headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. Returns: `None` ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:8123") client.store.put_item( ["documents", "user123"], key="item456", value={"title": "My Document", "content": "Hello World"} ) ``` .Invalid namespace label '1'. Namespace labels cannot contain periods ('.').)r$rrrr /store/itemsjsonr r"N) ValueErrorrputr) rr$rrrrr r"labelpayloads rput_itemzSyncStoreClient.put_item#sH  Ee|| hhhh #    !8!8'RX      r) refresh_ttlr r"r2 bool | Noner c|D]}d|vrtd|d|d|d}|||d<|r|||jd||S) atRetrieve a single item. Args: key: The unique identifier for the item. namespace: Optional list of strings representing the namespace path. refresh_ttl: Whether to refresh the TTL on this read operation. If `None`, uses the store's default behavior. headers: Optional custom headers to include with the request. Returns: The retrieved item. ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:8123") item = client.store.get_item( ["documents", "user123"], key="item456", ) print(item) ``` ```shell ---------------------------------------------------------------- { 'namespace': ['documents', 'user123'], 'key': 'item456', 'value': {'title': 'My Document', 'content': 'Hello World'}, 'created_at': '2024-07-30T12:00:00Z', 'updated_at': '2024-07-30T12:00:00Z' } ``` r'r(r)rr$Nr2r*)r"r )r-joinupdaterget)rr$rr2r r"r/ query_paramss rget_itemzSyncStoreClient.get_itemWsX  Ee|| hhhh 03)ATAT'U'U  "*5L '  (    ' ' 'y}}^L'}RRRrcH|jd||d||dS)asDelete an item. Args: key: The unique identifier for the item. namespace: Optional list of strings representing the namespace path. headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. Returns: `None` ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:8123") client.store.delete_item( ["documents", "user123"], key="item456", ) ``` r*r5r+N)rdelete)rr$rr r"s r delete_itemzSyncStoreClient.delete_itemsA:  955      r rfilterMapping[str, Any] | Nonelimitintoffsetquery str | Nonenamespace_prefixr c j||||||d} |jdt| ||S)a*Search for items within a namespace prefix. Args: namespace_prefix: List of strings representing the namespace prefix. filter: Optional dictionary of key-value pairs to filter results. limit: Maximum number of items to return (default is 10). offset: Number of items to skip before returning results (default is 0). query: Optional query for natural language search. refresh_ttl: Whether to refresh the TTL on items returned by this search. If `None`, uses the store's default behavior. headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. Returns: A list of items matching the search criteria. ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:8123") items = client.store.search_items( ["documents"], filter={"author": "John Doe"}, limit=5, offset=0 ) print(items) ``` ```shell ---------------------------------------------------------------- { "items": [ { "namespace": ["documents", "user123"], "key": "item789", "value": { "title": "Another Document", "author": "John Doe" }, "created_at": "2024-07-30T12:00:00Z", "updated_at": "2024-07-30T12:00:00Z" }, # ... additional items ... ] } ``` )rFr?rArCrDr2z/store/items/searchr+rpostr) rrFr?rArCrDr2r r"r0s r search_itemszSyncStoreClient.search_itemssVx!1&   y~~ !((    rd)r r"prefixlist[str] | Nonesuffix max_depthr ch|||||d}|jdt|||S)a List namespaces with optional match conditions. Args: prefix: Optional list of strings representing the prefix to filter namespaces. suffix: Optional list of strings representing the suffix to filter namespaces. max_depth: Optional integer specifying the maximum depth of namespaces to return. limit: Maximum number of namespaces to return (default is 100). offset: Number of namespaces to skip before returning results (default is 0). headers: Optional custom headers to include with the request. Returns: A list of namespaces matching the criteria. ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:8123") namespaces = client.store.list_namespaces( prefix=["documents"], max_depth=3, limit=10, offset=0 ) print(namespaces) ``` ```shell ---------------------------------------------------------------- [ ["documents", "user123", "reports"], ["documents", "user456", "invoices"], ... ] ``` )rLrNrOrArCz/store/namespacesr+rH) rrLrNrOrArCr r"r0s rlist_namespaceszSyncStoreClient.list_namespacessS`"   y~~ ((    r)rr rr)NNNN)rrrrrrrrr r!r"r#r$r%rr) rrr$r%r2r3r r!r"r#rr )NN) rrr r!r"r#r$r%rr)Nr>rNNNN)r?r@rArBrCrBrDrEr2r3r r!r"r#rFr%rr )NNNrKr)rLrMrNrMrOrrArBrCrBr r!r"r#rr ) __name__ __module__ __qualname____doc__rr1r:r=rJrQrrrrs  48,0)-2 2 2 2 2 t$(,0)-7S7S7S7S7S7S|-1)- " " " " " P,0 #',0)-H H H H H X$(#' $ ; -1)-; ; ; ; ; ; ; ; rrN)rU __future__rcollections.abcrrtypingrrlanggraph_sdk._shared.utilitiesrlanggraph_sdk._sync.httpr langgraph_sdk.schemar r r r rrVrrr]s11""""""--------::::::333333g g g g g g g g g g r