# from fastapi import APIRouter, Depends
# from sqlalchemy.orm import Session
# from app.api.centralised_and_direct import schema
# from app.api.centralised_and_direct.service import CentralisedAndDirectService
# from app.database.main.mysql import get_db
# from app.dependency.authantication import JWTPayloadSchema, get_current_student

# centralised_and_direct_router = APIRouter()

# @centralised_and_direct_router.post("/create_centralised_and_direct", response_model_exclude_none=True)
# async def create_centralised_and_direct(request:schema.DistributionCreate, db:Session = Depends(get_db),token: JWTPayloadSchema = Depends(get_current_student)):
#     return await CentralisedAndDirectService(db,token).create_centralised_and_direct(request)

from fastapi import APIRouter, Depends
from sqlalchemy.orm import Session
from app.api.centralised_and_direct import schema
from app.api.centralised_and_direct.service import CentralisedAndDirectService
from app.database.main.mysql import get_db
from app.dependency.authantication import JWTPayloadSchema, get_current_student

centralised_and_direct_router = APIRouter()

@centralised_and_direct_router.post("/create_centralised_and_direct", response_model_exclude_none=True)
async def create_centralised_and_direct(
    request: schema.DistributionCreate,
    db: Session = Depends(get_db),
    token: JWTPayloadSchema = Depends(get_current_student),
):
    return await CentralisedAndDirectService(db, token).create_centralised_and_direct(request)