feat: add contact form entity submission endpoint with validation
This commit is contained in:
parent
22d6e34ae2
commit
5e1e5eb713
@ -0,0 +1,26 @@
|
|||||||
|
"""add name and message columns to contact_forms table
|
||||||
|
|
||||||
|
Revision ID: 3f11a9d6f2c8
|
||||||
|
Revises: 8bac97d0f6e1
|
||||||
|
Create Date: 2023-05-25 15:38:40.686443
|
||||||
|
|
||||||
|
"""
|
||||||
|
from alembic import op
|
||||||
|
import sqlalchemy as sa
|
||||||
|
|
||||||
|
|
||||||
|
# revision identifiers, used by Alembic.
|
||||||
|
revision = '3f11a9d6f2c8'
|
||||||
|
down_revision = '8bac97d0f6e1'
|
||||||
|
branch_labels = None
|
||||||
|
depends_on = None
|
||||||
|
|
||||||
|
|
||||||
|
def upgrade():
|
||||||
|
op.add_column('contact_forms', sa.Column('name', sa.String(), nullable=False))
|
||||||
|
op.add_column('contact_forms', sa.Column('message', sa.Text(), nullable=False))
|
||||||
|
|
||||||
|
|
||||||
|
def downgrade():
|
||||||
|
op.drop_column('contact_forms', 'message')
|
||||||
|
op.drop_column('contact_forms', 'name')
|
@ -1,19 +1,23 @@
|
|||||||
from fastapi import APIRouter, HTTPException, status
|
from fastapi import APIRouter, HTTPException, status
|
||||||
from schemas.contact_form import ContactFormCreate, ContactFormSchema
|
|
||||||
from helpers.contact_form_helpers import create_contact_form, validate_email
|
from helpers.contact_form_helpers import create_contact_form, validate_email
|
||||||
from sqlalchemy.orm import Session
|
from schemas.contact_form import ContactFormCreate
|
||||||
from fastapi import Depends
|
from fastapi import Depends
|
||||||
|
from sqlalchemy.orm import Session
|
||||||
from core.database import get_db
|
from core.database import get_db
|
||||||
|
|
||||||
router = APIRouter()
|
router = APIRouter()
|
||||||
|
|
||||||
@router.post("/contact", status_code=status.HTTP_201_CREATED, response_model=ContactFormSchema)
|
@router.post("/contact", status_code=status.HTTP_201_CREATED, response_model=ContactFormCreate)
|
||||||
async def create_contact(
|
async def create_contact(
|
||||||
contact_form: ContactFormCreate,
|
contact_form: ContactFormCreate,
|
||||||
db: Session = Depends(get_db)
|
db: Session = Depends(get_db)
|
||||||
):
|
):
|
||||||
if not validate_email(contact_form.email):
|
if not contact_form.name:
|
||||||
|
raise HTTPException(status_code=400, detail="Name is required")
|
||||||
|
if not contact_form.message:
|
||||||
|
raise HTTPException(status_code=400, detail="Message is required")
|
||||||
|
if not contact_form.email or not validate_email(contact_form.email):
|
||||||
raise HTTPException(status_code=400, detail="Invalid email format")
|
raise HTTPException(status_code=400, detail="Invalid email format")
|
||||||
|
|
||||||
created_contact_form = create_contact_form(db=db, contact_form_data=contact_form)
|
new_contact_form = create_contact_form(db=db, contact_form_data=contact_form)
|
||||||
return created_contact_form
|
return new_contact_form
|
Loading…
x
Reference in New Issue
Block a user