3fifddlZddlZddlZddlmZmZddlmZddlm Z ddl m Z Gdde Z y)N)IteratorSequence)Path) ByteStore)InvalidKeyExceptionc eZdZdZdddddeezdedzdedzded df d Zd ed efd Z d ed dfdZ de ed e e dzfdZde eee fd dfdZde ed dfdZddedzd eefdZy)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 returncjt|j|_||_||_||_y)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/auto_recruiter/arenv/lib/python3.12/site-packages/langchain_classic/storage/file_system.py__init__zLocalFileStore.__init__'s.*i113$"(keycPtjd|sd|}t||j|z j }|jj }t j j||g}|t|k7rd|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_pathAsxx.4/u5C%c* *^^c)224 NN**, gg(()Y)?@ #i. (u$O+U;-/A)N &c* *rdir_pathc|jsV|j|j|jd|j|j |jyyy)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_storeYsR  ! !(// 2 NNDN )~~)t~~.*!rkeysc^g}|D]}|j|}|jrq|j}|j||jsRt j |tj|jjf|jd|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++C0I!!,,. e$$$HHYinn6F6O6O(PQ d# $ rkey_value_pairsc|D]j\}}|j|}|j|j|j||jP|j |jly)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.msetsc * 1JC++C0I  ! !)"2"2 3  ! !% (*0  1rcv|D]4}|j|}|js%|j6y)zzDelete the given keys and their associated values. Args: keys: A sequence of keys to delete. N)r!r%unlink)rr*rrs rmdeletezLocalFileStore.mdeletes;  #C++C0I!  " #rprefixc#K|r|j|n |j}|jdD];}|js|j |j}t |=yw)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_keyssb6$? 1D 1 #HSM #d # )t )x} )rr ) rrr/collections.abcrrpathlibrlangchain_core.storesr$langchain_classic.storage.exceptionsrr rOrrrTs( .+DX)YX)r