from fastapi import Depends

async def get_db():
    db = Database()
    yield db
    db.close()

async def get_current_user(token: str, db=Depends(get_db)):
    return verify_token(token, db)

@app.get("/products")
async def list_products(user=Depends(get_current_user), db=Depends(get_db)):
    # user و db يتم حقنهما تلقائيًا
    ...

from fastapi import FastAPI, Depends

app = FastAPI()

def common_parameters(
    q: str | None = None,
    skip: int = 0,
    limit: int = 100,
):
    return {"q": q, "skip": skip, "limit": limit}

@app.get("/products")
async def list_products(commons: dict = Depends(common_parameters)):
    return commons

@app.get("/prices")
async def list_prices(commons: dict = Depends(common_parameters)):
    return commons

# تم تعريف الدالة بنجاح

from fastapi import FastAPI, Depends, Query

class CommonQueryParams:
    def __init__(
        self,
        q: str | None = Query(None),
        skip: int = Query(0, ge=0),
        limit: int = Query(100, ge=1, le=200),
    ):
        self.q = q
        self.skip = skip
        self.limit = limit

app = FastAPI()

@app.get("/products")
async def list_products(commons: CommonQueryParams = Depends(CommonQueryParams)):
    return {"q": commons.q, "skip": commons.skip, "limit": commons.limit}

# تم تعريف الدالة بنجاح

from fastapi import FastAPI, Depends, HTTPException, Header

app = FastAPI()

# المستوى 1: جلسة قاعدة البيانات
async def get_db():
    db = {"connection": "active"}
    try:
        yield db
    finally:
        db["connection"] = "closed"

# المستوى 2: الحصول على المستخدم الحالي (يعتمد على DB)
async def get_current_user(
    authorization: str = Header(...),
    db: dict = Depends(get_db),
):
    if not authorization.startswith("Bearer "):
        raise HTTPException(status_code=401, detail="Invalid token")
    token = authorization.replace("Bearer ", "")
    # مبسط: في الإنتاج، تحقق من JWT
    user = {"id": 1, "username": "alice", "role": "admin"}
    return user

# المستوى 3: يتطلب صلاحيات المسؤول (يعتمد على المستخدم الحالي)
async def require_admin(user: dict = Depends(get_current_user)):
    if user["role"] != "admin":
        raise HTTPException(status_code=403, detail="Admin required")
    return user

@app.get("/admin/stats")
async def admin_stats(admin: dict = Depends(require_admin)):
    return {"admin": admin["username"], "total_products": 1000000}

# تم تعريف الدالة بنجاح

from fastapi import FastAPI, Depends

app = FastAPI()

# تبعية بنطاق الطلب مع التنظيف
async def get_db_session():
    # الإعداد: إنشاء الجلسة
    session = {"id": "session-123", "active": True}
    print(f"DB session opened: {session['id']}")
    try:
        yield session  # يتم حقن هذا في نقطة النهاية
    finally:
        # التنظيف: إغلاق الجلسة (يعمل بعد الاستجابة)
        session["active"] = False
        print(f"DB session closed: {session['id']}")

@app.get("/products")
async def list_products(db: dict = Depends(get_db_session)):
    print(f"Using DB session: {db['id']}")
    return {"session_id": db["id"]}

DB session opened: session-123
Using DB session: session-123
DB session closed: session-123

from fastapi import FastAPI, Depends, APIRouter, Header, HTTPException

async def verify_api_key(x_api_key: str = Header(...)):
    if x_api_key != "secret-key-123":
        raise HTTPException(status_code=401, detail="Invalid API key")
    return x_api_key

app = FastAPI()

# المسارات العامة - لا حاجة لمصادقة
public_router = APIRouter()

@public_router.get("/health")
async def health():
    return {"status": "healthy"}

# المسارات المحمية - مفتاح API مطلوب لجميع المسارات في هذه المجموعة
protected_router = APIRouter(dependencies=[Depends(verify_api_key)])

@protected_router.get("/products")
async def list_products():
    return [{"id": 1, "name": "Widget"}]

@protected_router.post("/products")
async def create_product():
    return {"id": 2, "name": "New Product"}

# تسجيل الموجهات
app.include_router(public_router)
app.include_router(protected_router, prefix="/api/v1")

# تم تعريف الدالة بنجاح

from fastapi.testclient import TestClient
from fastapi import FastAPI, Depends

app = FastAPI()

# التبعية الحقيقية
async def get_db():
    return {"type": "postgresql", "host": "prod-db"}

# تبعية وهمية للاختبار
def get_mock_db():
    return {"type": "sqlite", "host": "memory"}

@app.get("/db-info")
async def db_info(db: dict = Depends(get_db)):
    return db

# في الاختبارات:
def test_db_info():
    app.dependency_overrides[get_db] = get_mock_db
    client = TestClient(app)
    response = client.get("/db-info")
    assert response.json() == {"type": "sqlite", "host": "memory"}
    # تنظيف
    app.dependency_overrides.clear()

# تم تعريف الدالة بنجاح