feat: add reservations API with table management and email notifications

app/main.py

@@ -15,6 +15,7 @@ from .routes.youtube import router as youtube_router
 from .routes.data_processing import router as data_processing_router
 from .routes.analyze import router as analyze_router
 from .routes.commend import router as commend_router
+from .routes.reservations import router as reservations_router
 from .services.logging_config import setup_logging, get_logger
 
 
@@ -96,5 +97,6 @@ app.include_router(youtube_router)
 app.include_router(data_processing_router)
 app.include_router(analyze_router)
 app.include_router(commend_router)
+app.include_router(reservations_router)
 
 logger.info("CrownCode backend API initialized")

app/routes/reservations.py

@@ -0,0 +1,320 @@
+"""
+Noir & Grain rezervasyon demo API'si + admin masa paneli.
+
+Şablon vitrini için örnek uçtan uca akış:
+- POST  /api/reservations           → talep oluştur (masa otomatik atanır) + örnek SMTP bildirimi
+- GET   /api/reservations?date=     → gün listesi
+- GET   /api/reservations/tables    → date+time için masa durumu (dolu/boş)
+- PATCH /api/reservations/{id}      → durum güncelle (confirmed/cancelled/seated)
+- GET   /admin/reservations         → tek dosyalık karanlık admin paneli (masa haritası)
+
+Depolama: DATA_DIR/reservations.json (HF Spaces'te kalıcı /data'ya işaret edin).
+Mail: SMTP_HOST/USER/PASSWORD tanımlıysa gönderir; değilse sadece loglar (örnek entegrasyon).
+"""
+
+from __future__ import annotations
+
+import json
+import os
+import smtplib
+import threading
+import uuid
+from datetime import date as date_type
+from datetime import datetime, timezone
+from email.mime.text import MIMEText
+from pathlib import Path
+from typing import Literal
+
+from fastapi import APIRouter, HTTPException, Query
+from fastapi.responses import HTMLResponse
+from pydantic import BaseModel, Field, field_validator
+
+from ..services.logging_config import get_logger
+
+logger = get_logger(__name__)
+
+router = APIRouter(tags=["reservations"])
+
+DATA_DIR = Path(os.getenv("DATA_DIR", "data"))
+STORE_PATH = DATA_DIR / "reservations.json"
+TOTAL_TABLES = int(os.getenv("RESTAURANT_TOTAL_TABLES", "12"))
+
+_lock = threading.Lock()
+
+
+# ── Depolama ─────────────────────────────────────────────────────────
+
+def _load() -> list[dict]:
+    if not STORE_PATH.exists():
+        return []
+    try:
+        return json.loads(STORE_PATH.read_text(encoding="utf-8"))
+    except json.JSONDecodeError:
+        logger.error("reservations.json bozuk, boş listeyle devam ediliyor")
+        return []
+
+
+def _save(items: list[dict]) -> None:
+    DATA_DIR.mkdir(parents=True, exist_ok=True)
+    STORE_PATH.write_text(json.dumps(items, ensure_ascii=False, indent=2), encoding="utf-8")
+
+
+# ── Şemalar ──────────────────────────────────────────────────────────
+
+class ReservationIn(BaseModel):
+    name: str = Field(min_length=2, max_length=80)
+    phone: str = Field(min_length=10, max_length=20)
+    date: str  # YYYY-MM-DD
+    time: str  # HH:MM
+    guests: int = Field(ge=1, le=12)
+    note: str = Field(default="", max_length=500)
+
+    @field_validator("date")
+    @classmethod
+    def date_not_past(cls, v: str) -> str:
+        try:
+            picked = date_type.fromisoformat(v)
+        except ValueError as exc:
+            raise ValueError("Tarih YYYY-MM-DD formatında olmalı") from exc
+        if picked < date_type.today():
+            raise ValueError("Geçmiş bir tarih seçilemez")
+        return v
+
+    @field_validator("time")
+    @classmethod
+    def time_format(cls, v: str) -> str:
+        try:
+            datetime.strptime(v, "%H:%M")
+        except ValueError as exc:
+            raise ValueError("Saat HH:MM formatında olmalı") from exc
+        return v
+
+
+class Reservation(ReservationIn):
+    id: str
+    table: int
+    status: Literal["pending", "confirmed", "seated", "cancelled"]
+    created_at: str
+
+
+class StatusUpdate(BaseModel):
+    status: Literal["pending", "confirmed", "seated", "cancelled"]
+
+
+# ── Örnek mail bildirimi ─────────────────────────────────────────────
+
+def _notify_by_mail(res: dict) -> None:
+    """SMTP env değişkenleri tanımlıysa restorana bildirim maili atar.
+
+    Tanımlı değilse sessizce loglar — demo ortamında kırılma olmaz.
+    """
+    host = os.getenv("SMTP_HOST")
+    user = os.getenv("SMTP_USER")
+    password = os.getenv("SMTP_PASSWORD")
+    to_addr = os.getenv("RESERVATION_MAIL_TO", user or "")
+    if not (host and user and password and to_addr):
+        logger.info("SMTP yapılandırılmamış — mail bildirimi atlandı (demo modu)")
+        return
+
+    body = (
+        f"Yeni rezervasyon talebi\n\n"
+        f"Ad: {res['name']}\nTelefon: {res['phone']}\n"
+        f"Tarih: {res['date']}  Saat: {res['time']}\n"
+        f"Kişi: {res['guests']}  Masa: {res['table']}\n"
+        f"Not: {res['note'] or '-'}"
+    )
+    msg = MIMEText(body, _charset="utf-8")
+    msg["Subject"] = f"Rezervasyon: {res['name']} — {res['date']} {res['time']}"
+    msg["From"] = os.getenv("SMTP_FROM", user)
+    msg["To"] = to_addr
+
+    try:
+        with smtplib.SMTP(host, int(os.getenv("SMTP_PORT", "587")), timeout=10) as smtp:
+            smtp.starttls()
+            smtp.login(user, password)
+            smtp.send_message(msg)
+        logger.info("Rezervasyon maili gönderildi: %s", res["id"])
+    except Exception as exc:  # demo: mail hatası rezervasyonu düşürmesin
+        logger.error("Mail gönderilemedi: %s", exc)
+
+
+# ── Yardımcılar ──────────────────────────────────────────────────────
+
+def _occupied_tables(items: list[dict], date: str, time: str) -> dict[int, dict]:
+    """Aynı gün + saat dilimindeki iptal edilmemiş rezervasyonların masaları."""
+    return {
+        r["table"]: r
+        for r in items
+        if r["date"] == date and r["time"] == time and r["status"] != "cancelled"
+    }
+
+
+# ── API ──────────────────────────────────────────────────────────────
+
+@router.post("/api/reservations", response_model=Reservation, status_code=201)
+async def create_reservation(payload: ReservationIn) -> Reservation:
+    with _lock:
+        items = _load()
+        occupied = _occupied_tables(items, payload.date, payload.time)
+        free = [n for n in range(1, TOTAL_TABLES + 1) if n not in occupied]
+        if not free:
+            raise HTTPException(status_code=409, detail="Bu saat için boş masa kalmadı")
+
+        record = {
+            **payload.model_dump(),
+            "id": uuid.uuid4().hex[:10],
+            "table": free[0],
+            "status": "pending",
+            "created_at": datetime.now(timezone.utc).isoformat(timespec="seconds"),
+        }
+        items.append(record)
+        _save(items)
+
+    _notify_by_mail(record)
+    return Reservation(**record)
+
+
+@router.get("/api/reservations", response_model=list[Reservation])
+async def list_reservations(date: str | None = Query(default=None)) -> list[Reservation]:
+    items = _load()
+    if date:
+        items = [r for r in items if r["date"] == date]
+    items.sort(key=lambda r: (r["date"], r["time"], r["table"]))
+    return [Reservation(**r) for r in items]
+
+
+@router.get("/api/reservations/tables")
+async def table_map(date: str, time: str) -> dict:
+    items = _load()
+    occupied = _occupied_tables(items, date, time)
+    return {
+        "date": date,
+        "time": time,
+        "total": TOTAL_TABLES,
+        "tables": [
+            {
+                "table": n,
+                "occupied": n in occupied,
+                "reservation": (
+                    {k: occupied[n][k] for k in ("id", "name", "guests", "status")}
+                    if n in occupied else None
+                ),
+            }
+            for n in range(1, TOTAL_TABLES + 1)
+        ],
+    }
+
+
+@router.patch("/api/reservations/{reservation_id}", response_model=Reservation)
+async def update_status(reservation_id: str, payload: StatusUpdate) -> Reservation:
+    with _lock:
+        items = _load()
+        for r in items:
+            if r["id"] == reservation_id:
+                r["status"] = payload.status
+                _save(items)
+                return Reservation(**r)
+    raise HTTPException(status_code=404, detail="Rezervasyon bulunamadı")
+
+
+# ── Admin paneli (tek dosyalık, Noir & Grain paletinde) ─────────────
+
+ADMIN_HTML = """<!doctype html>
+<html lang="tr">
+<head>
+<meta charset="utf-8">
+<meta name="viewport" content="width=device-width, initial-scale=1">
+<title>Noir &amp; Grain — Servis Paneli</title>
+<style>
+  :root { --bg:#0E0C09; --text:#F2E9DA; --accent:#C89B5A; --wine:#5C1F1A; --surface:#2A2620; }
+  * { box-sizing:border-box; margin:0; }
+  body { background:var(--bg); color:var(--text); font:15px/1.5 Georgia, serif; padding:2rem; }
+  h1 { font-weight:normal; letter-spacing:.2em; text-transform:uppercase; font-size:1.1rem; color:var(--accent); }
+  h1 span { color:var(--text); }
+  .bar { display:flex; gap:1rem; align-items:end; flex-wrap:wrap; margin:1.5rem 0 2rem; }
+  label { display:block; font-size:.7rem; letter-spacing:.15em; text-transform:uppercase; opacity:.6; margin-bottom:.3rem; }
+  input, select { background:var(--surface); color:var(--text); border:1px solid #3a352d; padding:.5rem .7rem; font:inherit; }
+  .grid { display:grid; grid-template-columns:repeat(auto-fill, minmax(110px,1fr)); gap:.8rem; margin-bottom:2.5rem; }
+  .table { border:1px solid #3a352d; padding: .9rem .8rem; text-align:center; }
+  .table .no { font-size:1.6rem; color:var(--accent); }
+  .table.free { border-color:#3a4d35; }
+  .table.free .state { color:#8fbf7f; }
+  .table.busy { background:var(--wine); border-color:var(--wine); }
+  .state { font-size:.7rem; letter-spacing:.15em; text-transform:uppercase; }
+  .who { font-size:.8rem; opacity:.85; margin-top:.2rem; min-height:1.2em; }
+  ul { list-style:none; display:flex; flex-direction:column; gap:.6rem; }
+  li { display:flex; gap:1rem; align-items:center; flex-wrap:wrap; border-bottom:1px solid #2a2620; padding-bottom:.6rem; }
+  li b { font-weight:normal; font-style:italic; }
+  .st { font-size:.65rem; letter-spacing:.12em; text-transform:uppercase; padding:.2rem .5rem; border:1px solid var(--accent); color:var(--accent); }
+  button { background:none; border:1px solid var(--accent); color:var(--accent); padding:.3rem .8rem; cursor:pointer; font:inherit; font-size:.75rem; letter-spacing:.1em; text-transform:uppercase; }
+  button:hover { background:var(--accent); color:var(--bg); }
+  .muted { opacity:.5; }
+</style>
+</head>
+<body>
+  <h1>Noir &amp; Grain <span>· Servis Paneli</span></h1>
+  <div class="bar">
+    <div><label for="d">Tarih</label><input type="date" id="d"></div>
+    <div><label for="t">Saat</label><select id="t"></select></div>
+    <div class="muted" id="summary"></div>
+  </div>
+
+  <div class="grid" id="tables"></div>
+
+  <h1 style="margin-bottom:1rem">Günün <span>Rezervasyonları</span></h1>
+  <ul id="list"></ul>
+
+<script>
+const TIMES = ['18:00','18:30','19:00','19:30','20:00','20:30','21:00','21:30','22:00'];
+const d = document.getElementById('d'), t = document.getElementById('t');
+d.value = new Date().toISOString().slice(0,10);
+TIMES.forEach(x => t.add(new Option(x, x)));
+t.value = '20:00';
+
+async function refresh() {
+  const [map, list] = await Promise.all([
+    fetch(`/api/reservations/tables?date=${d.value}&time=${t.value}`).then(r => r.json()),
+    fetch(`/api/reservations?date=${d.value}`).then(r => r.json()),
+  ]);
+
+  const free = map.tables.filter(x => !x.occupied).length;
+  document.getElementById('summary').textContent =
+    `${map.time} servisi · ${free}/${map.total} masa boş`;
+
+  document.getElementById('tables').innerHTML = map.tables.map(x => `
+    <div class="table ${x.occupied ? 'busy' : 'free'}">
+      <div class="no">${x.table}</div>
+      <div class="state">${x.occupied ? 'Dolu' : 'Boş'}</div>
+      <div class="who">${x.reservation ? x.reservation.name + ' · ' + x.reservation.guests + ' kişi' : ''}</div>
+    </div>`).join('');
+
+  document.getElementById('list').innerHTML = list.length ? list.map(r => `
+    <li>
+      <b>${r.time}</b> · Masa ${r.table} · ${r.name} · ${r.guests} kişi
+      <span class="st">${r.status}</span>
+      ${r.note ? `<span class="muted">“${r.note}”</span>` : ''}
+      ${r.status === 'pending'   ? `<button onclick="setSt('${r.id}','confirmed')">Onayla</button>` : ''}
+      ${r.status === 'confirmed' ? `<button onclick="setSt('${r.id}','seated')">Oturt</button>` : ''}
+      ${r.status !== 'cancelled' ? `<button onclick="setSt('${r.id}','cancelled')">İptal</button>` : ''}
+    </li>`).join('') : '<li class="muted">Bu gün için rezervasyon yok — servis sakin.</li>';
+}
+
+async function setSt(id, status) {
+  await fetch(`/api/reservations/${id}`, {
+    method: 'PATCH',
+    headers: { 'Content-Type': 'application/json' },
+    body: JSON.stringify({ status }),
+  });
+  refresh();
+}
+
+d.onchange = refresh; t.onchange = refresh;
+refresh();
+</script>
+</body>
+</html>"""
+
+
+@router.get("/admin/reservations", response_class=HTMLResponse, include_in_schema=False)
+async def admin_panel() -> HTMLResponse:
+    return HTMLResponse(ADMIN_HTML)

tests/test_reservations.py

@@ -0,0 +1,73 @@
+"""Rezervasyon API testleri — geçici DATA_DIR ile izole çalışır."""
+
+import importlib
+import os
+
+import pytest
+from fastapi import FastAPI
+from fastapi.testclient import TestClient
+
+
+@pytest.fixture()
+def client(tmp_path, monkeypatch):
+    monkeypatch.setenv("DATA_DIR", str(tmp_path))
+    monkeypatch.setenv("RESTAURANT_TOTAL_TABLES", "2")
+    from app.routes import reservations
+    importlib.reload(reservations)
+
+    app = FastAPI()
+    app.include_router(reservations.router)
+    return TestClient(app)
+
+
+PAYLOAD = {
+    "name": "Arda Yılmaz",
+    "phone": "05321112233",
+    "date": "2030-08-12",
+    "time": "20:00",
+    "guests": 4,
+    "note": "Pencere kenarı",
+}
+
+
+def test_create_assigns_table_and_lists(client):
+    r = client.post("/api/reservations", json=PAYLOAD)
+    assert r.status_code == 201
+    body = r.json()
+    assert body["table"] == 1
+    assert body["status"] == "pending"
+
+    listed = client.get("/api/reservations", params={"date": PAYLOAD["date"]}).json()
+    assert len(listed) == 1
+
+
+def test_table_map_and_capacity(client):
+    client.post("/api/reservations", json=PAYLOAD)
+    client.post("/api/reservations", json={**PAYLOAD, "name": "İkinci Misafir"})
+
+    tables = client.get(
+        "/api/reservations/tables",
+        params={"date": PAYLOAD["date"], "time": PAYLOAD["time"]},
+    ).json()
+    assert tables["total"] == 2
+    assert all(t["occupied"] for t in tables["tables"])
+
+    full = client.post("/api/reservations", json={**PAYLOAD, "name": "Üçüncü"})
+    assert full.status_code == 409
+
+
+def test_cancel_frees_table(client):
+    created = client.post("/api/reservations", json=PAYLOAD).json()
+    r = client.patch(f"/api/reservations/{created['id']}", json={"status": "cancelled"})
+    assert r.status_code == 200
+
+    tables = client.get(
+        "/api/reservations/tables",
+        params={"date": PAYLOAD["date"], "time": PAYLOAD["time"]},
+    ).json()
+    assert sum(t["occupied"] for t in tables["tables"]) == 0
+
+
+def test_past_date_rejected(client):
+    r = client.post("/api/reservations", json={**PAYLOAD, "date": "2020-01-01"})
+    assert r.status_code == 422