feat: Add contact form submission endpoint with validation ✅ (auto-linted)
This commit is contained in:
parent
eb8fd157e7
commit
18983b178c
@ -0,0 +1,21 @@
|
|||||||
|
"""add name and message columns to contact_forms table
|
||||||
|
Revision ID: 8bac97d0f6e1
|
||||||
|
Revises: 1a2b3c4d5e6f
|
||||||
|
Create Date: 2023-05-25 15:38:44.692924
|
||||||
|
"""
|
||||||
|
from alembic import op
|
||||||
|
import sqlalchemy as sa
|
||||||
|
|
||||||
|
# revision identifiers, used by Alembic
|
||||||
|
revision = '8bac97d0f6e1'
|
||||||
|
down_revision = '1a2b3c4d5e6f'
|
||||||
|
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,13 +1,16 @@
|
|||||||
from fastapi import APIRouter, HTTPException
|
from fastapi import APIRouter, HTTPException, status
|
||||||
from helpers.contact_form_helpers import create_contact_form, validate_email
|
from helpers.contact_form_helpers import create_contact_form, validate_email
|
||||||
from schemas.contact_form import ContactFormCreate
|
from schemas.contact_form import ContactFormCreate
|
||||||
|
from sqlalchemy.orm import Session
|
||||||
|
from fastapi import Depends
|
||||||
|
from database import get_db
|
||||||
|
|
||||||
router = APIRouter()
|
router = APIRouter()
|
||||||
|
|
||||||
@router.post("/form", status_code=201)
|
@router.post("/form", status_code=status.HTTP_201_CREATED, response_model=ContactFormCreate)
|
||||||
async def submit_contact_form(contact_form_data: ContactFormCreate):
|
async def create_form(contact_form_data: ContactFormCreate, db: Session = Depends(get_db)):
|
||||||
if not validate_email(contact_form_data.email):
|
if not contact_form_data.name or not contact_form_data.message or not contact_form_data.email or not validate_email(contact_form_data.email):
|
||||||
raise HTTPException(status_code=400, detail="Invalid email format")
|
raise HTTPException(status_code=400, detail="One or more required fields are missing or invalid")
|
||||||
|
|
||||||
new_contact_form = create_contact_form(contact_form_data=contact_form_data)
|
new_contact_form = create_contact_form(db=db, contact_form_data=contact_form_data)
|
||||||
return new_contact_form
|
return new_contact_form
|
Loading…
x
Reference in New Issue
Block a user