feat: Updated endpoint endpoints/contact.post.py via AI
This commit is contained in:
parent
3b7de1cecd
commit
46c049cb06
@ -11,6 +11,12 @@ async def create_contact_submission(
|
|||||||
contact_data: ContactCreate,
|
contact_data: ContactCreate,
|
||||||
db: Session = Depends(get_db)
|
db: Session = Depends(get_db)
|
||||||
):
|
):
|
||||||
|
"""Create a new contact submission with email validation"""
|
||||||
|
# Sanitize input data
|
||||||
sanitized_data = sanitize_contact_data(contact_data)
|
sanitized_data = sanitize_contact_data(contact_data)
|
||||||
|
|
||||||
|
# Create contact using helper function
|
||||||
contact = create_contact(db=db, contact_data=sanitized_data)
|
contact = create_contact(db=db, contact_data=sanitized_data)
|
||||||
|
|
||||||
|
# Format response
|
||||||
return format_contact_response(contact)
|
return format_contact_response(contact)
|
@ -1,12 +1,13 @@
|
|||||||
from typing import Dict
|
from typing import Dict
|
||||||
from sqlalchemy.orm import Session
|
from sqlalchemy.orm import Session
|
||||||
from fastapi import HTTPException
|
from fastapi import HTTPException
|
||||||
|
from email_validator import validate_email, EmailNotValidError
|
||||||
from models.contact import Contact
|
from models.contact import Contact
|
||||||
from schemas.contact import ContactCreate, ContactSchema
|
from schemas.contact import ContactCreate, ContactSchema
|
||||||
|
|
||||||
def validate_contact_data(contact_data: ContactCreate) -> Dict[str, str]:
|
def validate_contact_data(contact_data: ContactCreate) -> Dict[str, str]:
|
||||||
"""
|
"""
|
||||||
Validates contact form submission data.
|
Validates contact form submission data with enhanced email validation.
|
||||||
|
|
||||||
Args:
|
Args:
|
||||||
contact_data (ContactCreate): The contact form data to validate.
|
contact_data (ContactCreate): The contact form data to validate.
|
||||||
@ -24,6 +25,12 @@ def validate_contact_data(contact_data: ContactCreate) -> Dict[str, str]:
|
|||||||
|
|
||||||
if not contact_data.email:
|
if not contact_data.email:
|
||||||
errors["email"] = "Email is required"
|
errors["email"] = "Email is required"
|
||||||
|
else:
|
||||||
|
try:
|
||||||
|
# Validate email format using email-validator
|
||||||
|
validate_email(contact_data.email)
|
||||||
|
except EmailNotValidError as e:
|
||||||
|
errors["email"] = str(e)
|
||||||
|
|
||||||
if not contact_data.message or not contact_data.message.strip():
|
if not contact_data.message or not contact_data.message.strip():
|
||||||
errors["message"] = "Message is required"
|
errors["message"] = "Message is required"
|
||||||
@ -68,21 +75,34 @@ def create_contact(db: Session, contact_data: ContactCreate) -> Contact:
|
|||||||
|
|
||||||
def sanitize_contact_data(contact_data: ContactCreate) -> ContactCreate:
|
def sanitize_contact_data(contact_data: ContactCreate) -> ContactCreate:
|
||||||
"""
|
"""
|
||||||
Sanitizes contact form input data.
|
Sanitizes contact form input data and ensures email format.
|
||||||
|
|
||||||
Args:
|
Args:
|
||||||
contact_data (ContactCreate): The raw contact form data.
|
contact_data (ContactCreate): The raw contact form data.
|
||||||
|
|
||||||
Returns:
|
Returns:
|
||||||
ContactCreate: The sanitized contact form data.
|
ContactCreate: The sanitized contact form data.
|
||||||
|
|
||||||
|
Raises:
|
||||||
|
HTTPException: If email format is invalid after sanitization.
|
||||||
"""
|
"""
|
||||||
# Create a new dict with sanitized values
|
try:
|
||||||
sanitized_data = ContactCreate(
|
# Sanitize and validate email
|
||||||
name=contact_data.name.strip(),
|
email = contact_data.email.strip().lower()
|
||||||
email=contact_data.email.strip().lower(),
|
validate_email(email)
|
||||||
message=contact_data.message.strip()
|
|
||||||
)
|
# Create a new dict with sanitized values
|
||||||
return sanitized_data
|
sanitized_data = ContactCreate(
|
||||||
|
name=contact_data.name.strip(),
|
||||||
|
email=email,
|
||||||
|
message=contact_data.message.strip()
|
||||||
|
)
|
||||||
|
return sanitized_data
|
||||||
|
except EmailNotValidError as e:
|
||||||
|
raise HTTPException(
|
||||||
|
status_code=400,
|
||||||
|
detail={"message": "Invalid email format", "error": str(e)}
|
||||||
|
)
|
||||||
|
|
||||||
def format_contact_response(contact: Contact) -> ContactSchema:
|
def format_contact_response(contact: Contact) -> ContactSchema:
|
||||||
"""
|
"""
|
||||||
|
@ -5,7 +5,7 @@ from uuid import UUID
|
|||||||
|
|
||||||
class ContactBase(BaseModel):
|
class ContactBase(BaseModel):
|
||||||
name: str = Field(..., min_length=1, max_length=255, description="Contact name")
|
name: str = Field(..., min_length=1, max_length=255, description="Contact name")
|
||||||
email: EmailStr = Field(..., description="Contact email address")
|
email: EmailStr = Field(..., description="Contact email address", regex=r"^[a-zA-Z0-9._%+-]+@[a-zA-Z0-9.-]+\.[a-zA-Z]{2,}$")
|
||||||
message: str = Field(..., min_length=1, description="Contact message")
|
message: str = Field(..., min_length=1, description="Contact message")
|
||||||
|
|
||||||
class ContactCreate(ContactBase):
|
class ContactCreate(ContactBase):
|
||||||
@ -13,7 +13,7 @@ class ContactCreate(ContactBase):
|
|||||||
|
|
||||||
class ContactUpdate(BaseModel):
|
class ContactUpdate(BaseModel):
|
||||||
name: Optional[str] = Field(None, min_length=1, max_length=255, description="Contact name")
|
name: Optional[str] = Field(None, min_length=1, max_length=255, description="Contact name")
|
||||||
email: Optional[EmailStr] = Field(None, description="Contact email address")
|
email: Optional[EmailStr] = Field(None, description="Contact email address", regex=r"^[a-zA-Z0-9._%+-]+@[a-zA-Z0-9.-]+\.[a-zA-Z]{2,}$")
|
||||||
message: Optional[str] = Field(None, min_length=1, description="Contact message")
|
message: Optional[str] = Field(None, min_length=1, description="Contact message")
|
||||||
|
|
||||||
class ContactSchema(ContactBase):
|
class ContactSchema(ContactBase):
|
||||||
|
Loading…
x
Reference in New Issue
Block a user