from fastapi import APIRouter, Depends
from sqlalchemy import Index, select
from sqlalchemy.orm import Mapped, mapped_column
from app.db import Base, get_session
from app.auth import current_tenant
import redis.asyncio as redis

router = APIRouter(prefix="/api/v1")
bus = redis.from_url(settings.REDIS_URL)


class Order(Base):
    __tablename__ = "orders"
    id: Mapped[int] = mapped_column(primary_key=True)
    tenant_id: Mapped[int] = mapped_column(index=True)
    total: Mapped[int]
    __table_args__ = (
        Index("ix_orders_tenant_created", "tenant_id", "created_at"),
    )


@router.post("/orders")
async def create_order(
    payload: OrderIn,
    tenant=Depends(current_tenant),
    db=Depends(get_session),
):
    order = Order(tenant_id=tenant.id, total=payload.total)
    db.add(order)
    await db.commit()
    await bus.publish(f"tenant:{tenant.id}:orders", order.id)
    return {"id": order.id, "status": "created"}


@router.get("/health")
async def health(db=Depends(get_session)):
    await db.execute(select(1))
    return {"status": "ok", "db": "up", "bus": await bus.ping()}

from fastapi import APIRouter, Depends
from sqlalchemy import Index, select
from sqlalchemy.orm import Mapped, mapped_column
from app.db import Base, get_session
from app.auth import current_tenant
import redis.asyncio as redis

router = APIRouter(prefix="/api/v1")
bus = redis.from_url(settings.REDIS_URL)


class Order(Base):
    __tablename__ = "orders"
    id: Mapped[int] = mapped_column(primary_key=True)
    tenant_id: Mapped[int] = mapped_column(index=True)
    total: Mapped[int]
    __table_args__ = (
        Index("ix_orders_tenant_created", "tenant_id", "created_at"),
    )


@router.post("/orders")
async def create_order(
    payload: OrderIn,
    tenant=Depends(current_tenant),
    db=Depends(get_session),
):
    order = Order(tenant_id=tenant.id, total=payload.total)
    db.add(order)
    await db.commit()
    await bus.publish(f"tenant:{tenant.id}:orders", order.id)
    return {"id": order.id, "status": "created"}


@router.get("/health")
async def health(db=Depends(get_session)):
    await db.execute(select(1))
    return {"status": "ok", "db": "up", "bus": await bus.ping()}