tjnddlZddlZddlZddlmZmZddlmZddlm Z ddl m Z Gdde Z dS)N)IteratorSequence)Path) ByteStore)InvalidKeyExceptionc eZdZdZdddddeezdedzdedzded df d Zd ed efd Z d ed dfdZ de ed e e dzfdZde eee fd dfdZde ed dfdZdddedzd eefdZdS)LocalFileStorea`BaseStore` interface that works on the local file system. Examples: Create a `LocalFileStore` instance and perform operations on it: ```python from langchain_classic.storage import LocalFileStore # Instantiate the LocalFileStore with the root path file_store = LocalFileStore("/path/to/root") # Set values for keys file_store.mset([("key1", b"value1"), ("key2", b"value2")]) # Get values for keys values = file_store.mget(["key1", "key2"]) # Returns [b"value1", b"value2"] # Delete keys file_store.mdelete(["key1"]) # Iterate over keys for key in file_store.yield_keys(): print(key) # noqa: T201 ``` NF) chmod_file chmod_dir update_atime root_pathr r r returnc|t||_||_||_||_dS)aImplement the `BaseStore` interface for the local file system. Args: root_path: The root path of the file store. All keys are interpreted as paths relative to this root. chmod_file: Sets permissions for newly created files, overriding the current `umask` if needed. chmod_dir: Sets permissions for newly created dirs, overriding the current `umask` if needed. update_atime: Updates the filesystem access time (but not the modified time) when a file is read. This allows MRU/LRU cache policies to be implemented for filesystems where access time updates are disabled. N)rabsoluter r r r )selfr r r r s c/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/langchain_classic/storage/file_system.py__init__zLocalFileStore.__init__'s9*i1133$"(keycdtjd|sd|}t||j|z }|j}t j||g}|t|krd|d|d|d|}t||S)zGet the full path for a given key relative to the root path. Args: key: The key relative to the root path. Returns: The full path for the given key. z^[a-zA-Z0-9_.\-/]+$zInvalid characters in key: z Invalid key: z+. Key should be relative to the full path. z vs. z and full path of ) rematchrr resolveospath commonpathstr)rrmsg full_pathr common_paths r_get_full_pathzLocalFileStore._get_full_pathAsx.44 +555C%c** *^c)2244 N**,, g(()Y)?@@ #i.. ( (NNNNN#.NNBKNN &c** *rdir_pathc|sS||j|d|j||jdSdSdS)a(Makes a store directory path (including parents) with specified permissions. This is needed because `Path.mkdir()` is restricted by the current `umask`, whereas the explicit `os.chmod()` used here is not. Args: dir_path: The store directory to make. T)exist_okN)exists_mkdir_for_storeparentmkdirr chmod)rr"s rr&zLocalFileStore._mkdir_for_storeYst   /  ! !(/ 2 2 2 NNDN ) ) )~)t~.....  / /*)rkeyscpg}|D]}||}|rp|}|||jr?t j|tj|j f|d|S)a Get the values associated with the given keys. Args: keys: A sequence of keys. Returns: A sequence of optional values associated with the keys. If a key is not found, the corresponding value will be `None`. N) r!r% read_bytesappendr rutimetimestatst_mtime)rr*valuesrrvalues rmgetzLocalFileStore.mgeths&( $ $C++C00I!! $!,,.. e$$$$RHYinn6F6F6O(PQQQ d#### rkey_value_pairsc|D]j\}}||}||j|||j||jkdS)zvSet the values for the given keys. Args: key_value_pairs: A sequence of key-value pairs. N)r!r&r' write_bytesr r))rr5rr3rs rmsetzLocalFileStore.msets| * 1 1JC++C00I  ! !)"2 3 3 3  ! !% ( ( (*000  1 1rc|D]?}||}|r|@dS)zzDelete the given keys and their associated values. Args: keys: A sequence of keys to delete. N)r!r%unlink)rr*rrs rmdeletezLocalFileStore.mdeletesW  # #C++C00I!! #  """ # #r)prefixr<c#K|r||n|j}|dD]A}|r+||j}t |VBdS)zGet an iterator over keys that match the given prefix. Args: prefix: The prefix to match. Yields: Keys that match the given prefix. *N)r!r rglobis_file relative_tor)rr< prefix_pathfile relative_paths r yield_keyszLocalFileStore.yield_keyss6<Od))&111 %%c** ) )D||~~ ) $ 0 0 @ @ -((((( ) )r)__name__ __module__ __qualname____doc__rrintboolrr!r&rlistbytesr4tupler8r;rrErrr r s<"& $" ))):)$J ) : )  ) ))))4#$0 / /$ / / / /#4 +=. 1HU3:->$? 1D 1 1 1 1 #HSM #d # # # #26 ) ) )C$J )(3- ) ) ) ) ) )rr ) rrr/collections.abcrrpathlibrlangchain_core.storesr$langchain_classic.storage.exceptionsrr rOrrrTs ........++++++DDDDDDX)X)X)X)X)YX)X)X)X)X)r