Retrieval Tools

# Filter by namespace
result = await retrieval_query(
    query="How do I reset my password?",
    namespace="support"
)

# Nach Metadaten filtern: dieselben Operatoren im MongoDB-Stil wie bei den Datenbank-Tools
# (\$eq, \$ne, \$gt, \$gte, \$lt, \$lte, \$in, \$nin, \$exists,
#  \$regex, \$contains, \$elemMatch, \$and, \$or, \$nor, \$not).
# Werte ohne Operator stehen als Kurzform für Gleichheit.
result = await retrieval_query(
    query="product availability",
    namespace="products",
    metadata_filter={
        "product_id": "X",
        "status": {"$in": ["active", "pending"]},
    },
)

# Adjust score threshold and result count
result = await retrieval_query(
    query="pricing information",
    min_score=0.2,    # Lower threshold = more results
    max_results=10    # Return up to 10 results
)

# Store with custom ID for later updates
result = await retrieval_store(
    content="Q1 sales target is $1M with focus on enterprise.",
    entry_id="q1-sales-target",
    namespace="planning",
    metadata={"quarter": "Q1", "year": "2024"}
)

# Store user preferences
result = await retrieval_store(
    content="User prefers dark mode and metric units.",
    entry_id="user-preferences",
    namespace="user_data"
)

# Delete a single entry by id
result = await retrieval_delete(entry_id="old-product-info")

# Delete a single entry scoped to a namespace
result = await retrieval_delete(
    entry_id="q1-sales-target",
    namespace="planning",
)

# Mehrere Einträge nach Metadaten löschen: dieselbe Filtersyntax im MongoDB-Stil verwenden
# wie bei den Datenbank-Tools; Operatoren wie \$ne, \$in und \$not werden unterstützt
result = await retrieval_delete(
    namespace="products",
    metadata_filter={"product_id": "X"},
)

# Orphan cleanup pattern: re-ingest a source, then delete every entry
# in scope from previous runs (everything that isn't the current run_id).
# Run the delete only after the re-ingest jobs have completed: entries
# still being indexed keep their previous run_id and would be deleted.
result = await retrieval_delete(
    namespace="confluence",
    metadata_filter={
        "root_page_id": page_id,
        "run_id": {"$ne": current_run_id},
    },
)

# Wipe an entire namespace subtree (sub-namespaces included)
result = await retrieval_delete(namespace="meetings")