Update vectorstore.py

vectorstore.py

@@ -1,56 +1,53 @@
-"""
+"""Module for creating and loading a Chroma vector store with Ollama embeddings."""
-Vector store utilities for ChromaDB with Ollama embeddings.
-"""
 
-import os
 from pathlib import Path
+from typing import List
 
-from langchain_chroma import Chroma
 from langchain_ollama import OllamaEmbeddings
+from langchain_chroma import Chroma
 from langchain_text_splitters import RecursiveCharacterTextSplitter
 from langchain.docstore.document import Document
 
+
 def create_vectorstore(persist_directory: str = "./chroma_db") -> Chroma:
-    """Create or load a Chroma vector store.
+    """Create a Chroma vector store with Ollama embeddings.
 
     Parameters
     ----------
     persist_directory: str
-        Directory where the Chroma database is persisted.
+        Directory where the vector store will be persisted.
 
     Returns
     -------
     Chroma
-        A Chroma vector store instance.
+        The created Chroma vector store.
     """
     embeddings = OllamaEmbeddings(model="nomic-embed-text")
     return Chroma(persist_directory=persist_directory, embedding_function=embeddings)
 
-def load_documents(directory: str, vectorstore: Chroma) -> None:
+
-    """Load text and markdown files from *directory*, chunk them, and add to *vectorstore*.
+def load_documents(directory: str, vectorstore: Chroma, chunk_size: int = 1000, chunk_overlap: int = 200) -> None:
+    """Load .txt and .md files from a directory, split them into chunks, and add to the vector store.
 
     Parameters
     ----------
     directory: str
-        Path to the folder containing .txt and .md files.
+        Path to the directory containing documents.
     vectorstore: Chroma
-        The Chroma vector store to which documents will be added.
+        The vector store to add documents to.
+    chunk_size: int
+        Maximum size of each chunk.
+    chunk_overlap: int
+        Number of characters to overlap between chunks.
     """
-    docs = []
+    splitter = RecursiveCharacterTextSplitter(chunk_size=chunk_size, chunk_overlap=chunk_overlap)
-    for file_path in Path(directory).rglob("*.*"):
+    documents: List[Document] = []
-        if file_path.suffix.lower() in ".txt .md".split():
+    for file_path in Path(directory).glob("**/*"):
-            try:
+        if file_path.suffix.lower() in {".txt", ".md"}:
             text = file_path.read_text(encoding="utf-8")
-            except Exception as e:
+            chunks = splitter.split_text(text)
-                print(f"Failed to read {file_path}: {e}")
+            for chunk in chunks:
-                continue
+                documents.append(Document(page_content=chunk, metadata={"source": str(file_path)}))
-            docs.append(Document(page_content=text, metadata={"source": str(file_path)}))
+    if documents:
-
+        vectorstore.add_documents(documents)
-    if not docs:
+        vectorstore.persist()
-        print("No documents found to load.")
-        return
-
-    splitter = RecursiveCharacterTextSplitter(chunk_size=1000, chunk_overlap=200)
-    chunks = splitter.split_documents(docs)
-    vectorstore.add_documents(chunks)
-    print(f"Loaded {len(chunks)} chunks into the vector store.")