payment id

app.py

@@ -12,7 +12,7 @@ from fastapi.middleware.cors import CORSMiddleware
 from fastapi.responses import JSONResponse
 
 from core.database import init_db
-from routers import auth, blink, credits, general, gemini, payments
+from routers import auth, blink, contact, credits, general, gemini, payments
 from services.drive_service import DriveService
 
 # Configure logging
@@ -88,6 +88,7 @@ app.include_router(blink.router)
 app.include_router(gemini.router)
 app.include_router(credits.router)
 app.include_router(payments.router)
+app.include_router(contact.router)
 
 
 @app.exception_handler(Exception)

core/models.py

@@ -190,3 +190,22 @@ class PaymentTransaction(Base):
 
     def __repr__(self):
         return f"<PaymentTransaction(id={self.transaction_id}, status={self.status}, amount={self.amount_paise})>"
+
+
+class Contact(Base):
+    """
+    Contact form submissions from authenticated users.
+    For customer support inquiries.
+    """
+    __tablename__ = "contacts"
+
+    id = Column(Integer, primary_key=True, autoincrement=True, index=True)
+    user_id = Column(String(50), index=True, nullable=False)  # Links to User.user_id
+    email = Column(String(255), nullable=False, index=True)  # User's email
+    subject = Column(String(500), nullable=True)
+    message = Column(Text, nullable=False)
+    ip_address = Column(String(45), nullable=True)  # IPv6 can be up to 45 chars
+    created_at = Column(DateTime(timezone=True), server_default=func.now())
+
+    def __repr__(self):
+        return f"<Contact(id={self.id}, user_id={self.user_id}, email={self.email})>"

routers/contact.py

@@ -0,0 +1,98 @@
+"""
+Contact Router - API endpoint for customer support contact form.
+
+Endpoints:
+- POST /contact - Submit a contact form (requires authentication)
+"""
+
+import logging
+from typing import Optional
+
+from fastapi import APIRouter, Depends, HTTPException, Request, status
+from pydantic import BaseModel, EmailStr
+from sqlalchemy.ext.asyncio import AsyncSession
+
+from core.database import get_db
+from core.models import User, Contact
+from dependencies import get_current_user
+
+logger = logging.getLogger(__name__)
+
+router = APIRouter(prefix="/contact", tags=["contact"])
+
+
+# =============================================================================
+# Request/Response Models
+# =============================================================================
+
+class ContactRequest(BaseModel):
+    """Request to submit a contact form."""
+    subject: Optional[str] = None
+    message: str
+
+
+class ContactResponse(BaseModel):
+    """Response after contact form submission."""
+    success: bool
+    message: str
+    email: str  # Return user's email for confirmation
+
+
+# =============================================================================
+# Endpoints
+# =============================================================================
+
+@router.post("", response_model=ContactResponse)
+async def submit_contact(
+    request_body: ContactRequest,
+    request: Request,
+    user: User = Depends(get_current_user),
+    db: AsyncSession = Depends(get_db)
+):
+    """
+    Submit a contact form for customer support.
+    
+    Requires authentication - user must be logged in.
+    """
+    # Validate message
+    if not request_body.message or not request_body.message.strip():
+        raise HTTPException(
+            status_code=status.HTTP_400_BAD_REQUEST,
+            detail="Message cannot be empty"
+        )
+    
+    # Get client IP
+    client_ip = request.headers.get("X-Forwarded-For", request.client.host if request.client else None)
+    if client_ip:
+        client_ip = client_ip.split(",")[0].strip()
+    
+    try:
+        # Create contact record
+        contact = Contact(
+            user_id=user.user_id,
+            email=user.email,
+            subject=request_body.subject.strip() if request_body.subject else None,
+            message=request_body.message.strip(),
+            ip_address=client_ip
+        )
+        db.add(contact)
+        await db.commit()
+        
+        logger.info(
+            f"Contact form submitted: user={user.user_id}, email={user.email}, "
+            f"subject={request_body.subject}"
+        )
+        
+        return ContactResponse(
+            success=True,
+            message="Your message has been received. We will get back to you shortly.",
+            email=user.email
+        )
+        
+    except Exception as e:
+        logger.error(f"Error saving contact form: {e}")
+        await db.rollback()
+        raise HTTPException(
+            status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
+            detail="Failed to submit contact form. Please try again."
+        )

routers/payments.py

@@ -14,9 +14,9 @@ import uuid
 from datetime import datetime
 from typing import List, Optional
 
-from fastapi import APIRouter, Depends, HTTPException, Request, status
+from fastapi import APIRouter, Depends, HTTPException, Query, Request, status
 from pydantic import BaseModel
-from sqlalchemy import select, desc
+from sqlalchemy import select, desc, func
 from sqlalchemy.ext.asyncio import AsyncSession
 
 from core.database import get_db
@@ -93,6 +93,7 @@ class VerifyPaymentResponse(BaseModel):
 class PaymentHistoryItem(BaseModel):
     """Single payment in history."""
     transaction_id: str
+    razorpay_payment_id: Optional[str] = None  # Razorpay payment ID
     package_id: str
     credits_amount: int
     amount_paise: int
@@ -105,9 +106,11 @@ class PaymentHistoryItem(BaseModel):
 
 
 class PaymentHistoryResponse(BaseModel):
-    """Payment history response."""
+    """Payment history response with pagination."""
     transactions: List[PaymentHistoryItem]
     total_count: int
+    page: int
+    limit: int
 
 
 # =============================================================================
@@ -454,18 +457,33 @@ async def razorpay_webhook(
 
 @router.get("/history", response_model=PaymentHistoryResponse)
 async def get_payment_history(
+    page: int = Query(1, ge=1, description="Page number"),
+    limit: int = Query(20, ge=1, le=100, description="Items per page"),
     user: User = Depends(get_current_user),
     db: AsyncSession = Depends(get_db)
 ):
     """
-    Get user's payment history.
+    Get user's payment history with pagination.
     
-    Returns all payment transactions ordered by newest first.
+    Returns payment transactions ordered by newest first.
     """
+    # Get total count
+    count_result = await db.execute(
+        select(func.count(PaymentTransaction.id))
+        .where(PaymentTransaction.user_id == user.user_id)
+    )
+    total_count = count_result.scalar() or 0
+    
+    # Calculate offset
+    offset = (page - 1) * limit
+    
+    # Get paginated transactions
     result = await db.execute(
         select(PaymentTransaction)
         .where(PaymentTransaction.user_id == user.user_id)
         .order_by(desc(PaymentTransaction.created_at))
+        .offset(offset)
+        .limit(limit)
     )
     transactions = result.scalars().all()
     
@@ -473,6 +491,7 @@ async def get_payment_history(
     for txn in transactions:
         history.append(PaymentHistoryItem(
             transaction_id=txn.transaction_id,
+            razorpay_payment_id=txn.gateway_payment_id,
             package_id=txn.package_id,
             credits_amount=txn.credits_amount,
             amount_paise=txn.amount_paise,
@@ -486,5 +505,7 @@ async def get_payment_history(
     
     return PaymentHistoryResponse(
         transactions=history,
-        total_count=len(history)
+        total_count=total_count,
+        page=page,
+        limit=limit
     )