app/routers/meeting_status.py

from fastapi import APIRouter, Depends, HTTPException, status
from sqlalchemy.orm import Session
from typing import List

from app.database.database import get_db
from app.models.models import MeetingStatus, VisitorLog
from app.schemas.schemas import MeetingStatusCreate, MeetingStatusUpdate, MeetingStatusResponse

router = APIRouter(
    prefix="/meeting-status",
    tags=["meeting-status"]
)

# Create meeting status
@router.post("/", response_model=MeetingStatusResponse, status_code=status.HTTP_201_CREATED)
def create_meeting_status(meeting_status: MeetingStatusCreate, db: Session = Depends(get_db)):
    # Check if visitor log exists
    visitor_log = db.query(VisitorLog).filter(VisitorLog.reference_number == meeting_status.reference_number).first()
    if not visitor_log:
        raise HTTPException(status_code=404, detail="Visitor log not found")
    
    # Check if meeting status already exists
    existing_status = db.query(MeetingStatus).filter(MeetingStatus.reference_number == meeting_status.reference_number).first()
    if existing_status:
        raise HTTPException(status_code=400, detail="Meeting status already exists for this reference number")
    
    db_meeting_status = MeetingStatus(
        reference_number=meeting_status.reference_number,
        status=meeting_status.status,
        email_send=meeting_status.email_send
    )
    db.add(db_meeting_status)
    db.commit()
    db.refresh(db_meeting_status)
    return db_meeting_status

# Get all meeting statuses
@router.get("/", response_model=List[MeetingStatusResponse])
def get_all_meeting_statuses(skip: int = 0, limit: int = 100, db: Session = Depends(get_db)):
    return db.query(MeetingStatus).offset(skip).limit(limit).all()

# Get meeting status by reference number
@router.get("/{reference_number}", response_model=MeetingStatusResponse)
def get_meeting_status(reference_number: str, db: Session = Depends(get_db)):
    db_meeting_status = db.query(MeetingStatus).filter(MeetingStatus.reference_number == reference_number).first()
    if db_meeting_status is None:
        raise HTTPException(status_code=404, detail="Meeting status not found")
    return db_meeting_status

# Update meeting status
@router.put("/{reference_number}", response_model=MeetingStatusResponse)
def update_meeting_status(reference_number: str, meeting_status: MeetingStatusUpdate, db: Session = Depends(get_db)):
    db_meeting_status = db.query(MeetingStatus).filter(MeetingStatus.reference_number == reference_number).first()
    if db_meeting_status is None:
        raise HTTPException(status_code=404, detail="Meeting status not found")
    
    # Update meeting status fields
    for key, value in meeting_status.dict().items():
        setattr(db_meeting_status, key, value)
    
    db.commit()
    db.refresh(db_meeting_status)
    return db_meeting_status

# Delete meeting status
@router.delete("/{reference_number}", status_code=status.HTTP_204_NO_CONTENT)
def delete_meeting_status(reference_number: str, db: Session = Depends(get_db)):
    db_meeting_status = db.query(MeetingStatus).filter(MeetingStatus.reference_number == reference_number).first()
    if db_meeting_status is None:
        raise HTTPException(status_code=404, detail="Meeting status not found")
    
    db.delete(db_meeting_status)
    db.commit()
    return None