# Periyodik (saatlik veya günlük) hot cache rebuild
def rebuild_hot_cache():
    hot_docs = identify_hot_docs()
    hot_text = "\n\n---\n\n".join([
        f"# Doc: {d.title}\n\n{d.content}"
        for d in hot_docs
    ])
    # Total: ~30K-50K token
    return hot_text
 
HOT_CACHE_BLOCK = rebuild_hot_cache()  # global, periyodik update
 
def hybrid_query(user_query: str):
    # Retrieve top-5, hot olanları skip
    retrieved = vector_db.search(
        user_query,
        k=5,
        exclude_ids=set(d.id for d in get_hot_docs())
    )
 
    return client.messages.create(
        system=[
            {"text": GENERAL_KB, "cache_control": {"ttl": "1h"}},
            {"text": HOT_CACHE_BLOCK, "cache_control": {"ttl": "1h"}},  # ← hot doc'lar
        ],
        messages=[
            {"role": "user", "content": (
                f"# Ek belgeler (sorgu spesifik)\n\n"
                + "\n\n".join(retrieved)
                + f"\n\n# Soru\n\n{user_query}"
            )}
        ],
    )