# ❌ KÖTÜ — Başlangıç durumu
import anthropic
from datetime import datetime
import uuid
 
client = anthropic.Anthropic()
 
def handle_user_query(user, query):
    session_id = uuid.uuid4()  # Hatamız 1
    current_time = datetime.now().isoformat()  # Hatamız 2
 
    system = f"""Bugün: {current_time}
Session: {session_id}
Kullanıcı: {user.name} ({user.account_type})
 
Sen XYZ Bankası'nın müşteri hizmetleri asistanısın. Görevin müşterilere
kart işlemleri, hesap sorguları ve genel banka soruları konusunda yardım
etmek.
 
KURALLAR:
1. Müşterinin TCKN'sini doğrulamadan hesap detaylarını paylaşma.
2. Her zaman saygılı ve net ol.
3. Şüpheli işlem varsa anında müşteri temsilcisine yönlendir.
 
BANKA BİLGİLERİ:
[10K token: ürün katalogu, faiz oranları, kampanyalar]
 
KART İŞLEM KURALLARI:
[5K token: limit artırma, taksitlendirme, iptal işlemleri]
"""
 
    tools = [
        {"name": "get_account_balance", "description": f"Hesap bakiyesi sorgular. Created: {current_time}", "input_schema": {...}},  # Hatamız 3
        # ... 5 tool daha (timestamp'leri var)
    ]
 
    response = client.messages.create(
        model="claude-sonnet-4-6",
        max_tokens=400,
        system=[{"type": "text", "text": system, "cache_control": {"type": "ephemeral"}}],
        tools=tools,
        messages=[{"role": "user", "content": query}],
    )
    return response
 
# 100 user sorgu için test
# Cache hit rate: ~5% (felaket)

# Multi-turn senaryoda history'yi cache'le
def handle_turn(user, conversation_history, new_query):
    if conversation_history:
        last = conversation_history[-1]
        history_with_cache = [
            *conversation_history[:-1],
            {
                **last,
                "content": [{
                    "type": "text",
                    "text": last["content"],
                    "cache_control": {"type": "ephemeral", "ttl": "5m"},  # ← Breakpoint 4
                }],
            },
        ]
    else:
        history_with_cache = []
 
    messages = [
        *history_with_cache,
        {"role": "user", "content": new_query}
    ]
    # ... rest of the call

# Cache miss alarmı: hit rate düşerse hemen bil
class CacheTelemetry:
    def __init__(self):
        self.cache_creation = 0
        self.cache_read = 0
        self.input = 0
        self.alert_threshold = 0.85  # %85 altına düşerse alarm
 
    def record(self, usage):
        self.cache_creation += usage.cache_creation_input_tokens or 0
        self.cache_read += usage.cache_read_input_tokens or 0
        self.input += usage.input_tokens
 
    @property
    def hit_rate(self) -> float:
        total = self.cache_read + self.cache_creation
        return self.cache_read / total if total > 0 else 0
 
    def check_alert(self):
        if self.hit_rate < self.alert_threshold:
            # Slack notification, Sentry, log, vb.
            print(f"🚨 Hit rate düştü: {self.hit_rate*100:.1f}%")
            print(f"   Cache create: {self.cache_creation}")
            print(f"   Cache read: {self.cache_read}")
 
# Kullanım
tel = CacheTelemetry()
for query in queries:
    response = handle_user_query(user, query)
    tel.record(response.usage)
print(f"Toplam hit rate: {tel.hit_rate*100:.1f}%")