vectorstore_cloud.py

# vectorstore_cloud.py
from pymongo import MongoClient
import json

def _load_config():
    with open("config.json", "r", encoding="utf-8") as f:
        return json.load(f)

def _get_collection():
    cfg = _load_config()
    if not cfg["cloud"]["enabled"]:
        return None
    client = MongoClient(cfg["cloud"]["mongo_uri"])
    db = client[cfg["cloud"]["db_name"]]
    return db[cfg["cloud"]["collection"]]

def cloud_upsert_chunks(chunks):
    """
    chunks: list of dicts: {id, text, meta}
    (we do not store raw embeddings in cloud here; just the text + meta for sync)
    """
    col = _get_collection()
    if col is None:
        return
    for ch in chunks:
        col.update_one({"_id": ch["id"]},
                       {"$set": {"text": ch["text"], "meta": ch["meta"]}},
                       upsert=True)