v2

README.md

@@ -80,4 +80,13 @@ uvicorn app.main:app --reload
 
 ```bash
 python -m unittest
+```
+
+# Upload File
+```bash
+curl -X 'POST' \
+  'http://localhost:8000/api/v1/transcribe/' \
+  -H 'accept: application/json' \
+  -H 'Content-Type: multipart/form-data' \
+  -F 'audio_file=@ElevenLabs_2023-08-10T13 53 05.000Z_VedVoice_bFrkzQsyKvReo52Q6712.mp3;type=audio/mpeg'
 ```

app/api/__init__.py

@@ -1,9 +1,10 @@
 # File: whisper.api/app/api/__init__.py
 
 from fastapi import APIRouter
-from .endpoints import items, users
+from .endpoints import items, users, transcribe
 
 api_router = APIRouter()
 
 api_router.include_router(items.router, prefix="/items", tags=["items"])
 api_router.include_router(users.router, prefix="/users", tags=["users"])
+api_router.include_router(transcribe.router, prefix="/transcribe", tags=["transcribe"])

app/api/endpoints/__init__.py

@@ -2,9 +2,10 @@
 
 from fastapi import APIRouter
 
-from . import items, users
+from . import items, users, transcribe
 
 router = APIRouter()
 
 router.include_router(items.router, prefix="/items", tags=["items"])
 router.include_router(users.router, prefix="/users", tags=["users"])
+router.include_router(transcribe.router, prefix="/transcribe", tags=["transcribe"])

app/api/endpoints/transcribe.py

@@ -0,0 +1,22 @@
+from fastapi import APIRouter, File, UploadFile, Request, Header
+from pydantic import BaseModel
+
+router = APIRouter()
+
+
+class AudioFile(BaseModel):
+    filename: str
+    content_type: str
+
+
+@router.post("/")
+async def post_audio(
+    request: Request, file: UploadFile = File(...), Authorization: str = Header(...)
+):
+    """Receive audio file and save it to disk."""
+    print(f"Authorization header: {Authorization}")
+
+    with open(file.filename, "wb") as f:
+        f.write(file.file.read())
+
+    return AudioFile(filename=file.filename, content_type=file.content_type)

app/api/endpoints/users.py

@@ -10,7 +10,7 @@ database = SessionLocal()
 users_router = router = APIRouter()
 
 
-@router.post("/", response_model=UserResponse, status_code=201)
+@router.post("/", status_code=201)
 async def create_user(user: User):
     db_user = UserInDB(
         username=user.username,
@@ -20,7 +20,8 @@ async def create_user(user: User):
     database.add(db_user)
     database.commit()
     database.refresh(db_user)
-    return {**user.dict(), "id": db_user.id, "hashed_password": None}
+    print(db_user)
+    return {**db_user.data()}
 
 
 @router.get("/{user_id}/", response_model=UserResponse)
@@ -50,7 +51,7 @@ async def update_user(user_id: UUID, user: UpdateUser):
     return {**user.dict(), "id": db_user.id, "hashed_password": None}
 
 
-@router.delete("/{user_id}/", response_model=int)
+@router.delete("/{user_id}/")
 async def delete_user(user_id: UUID):
     db_user = database.query(UserInDB).filter(UserInDB.id == user_id).first()
     database.delete(db_user)

app/core/config.py

@@ -24,7 +24,11 @@ class Settings(BaseSettings):
     POSTGRES_DATABASE_URL: str = env.get("POSTGRES_DATABASE_URL")
     TEST_DATABASE_URL: str = env.get("POSTGRES_DATABASE_URL")
 
-    BACKEND_CORS_ORIGINS: List[AnyHttpUrl] = ["http://localhost:3000"]
+    BACKEND_CORS_ORIGINS: List[AnyHttpUrl] = [
+        "http://localhost:3000",
+        "http://localhost:8080",
+        "http://localhost:8000",
+    ]
 
     @validator("SECRET_KEY", pre=True)
     def secret_key_must_be_set(cls, v: Optional[str], values: Dict[str, Any]) -> str:

app/core/errors.py

@@ -1,39 +1,21 @@
-from fastapi import Request
+from fastapi import Request, Response
 from fastapi.responses import JSONResponse
 from fastapi.exceptions import HTTPException, RequestValidationError
 
 
-async def http_exception_handler(request: Request, exc: HTTPException):
+async def error_handler(request: Request, exc: Exception) -> JSONResponse:
     """
-    Exception handler for HTTP errors
-    """
-    return JSONResponse(
-        status_code=exc.status_code,
-        content={"message": exc.detail},
-    )
+    Error handler function for FastAPI.
 
+    Args:
+        request: The HTTP request that caused the error.
+        exc: The exception that was raised.
 
-async def http_error_handler(request: Request, exc: Exception):
+    Returns:
+        The error response.
     """
-    Exception handler for HTTP errors
-    """
-    if isinstance(exc, HTTPException):
-        detail = exc.detail
-        status_code = exc.status_code
-    else:
-        detail = "Internal server error"
-        status_code = 500
-    return JSONResponse(
-        status_code=status_code,
-        content={"message": detail},
-    )
-
 
-def http422_error_handler(request: Request, exc: RequestValidationError):
-    """
-    Exception handler for HTTP 422 errors
-    """
     return JSONResponse(
-        status_code=422,
-        content={"message": "Validation error", "details": exc.errors()},
+        status_code=500,
+        content={"detail": "Error Occurs"},
     )

app/core/models/AuthToken.py

@@ -9,7 +9,7 @@ from sqlalchemy.dialects.postgresql import UUID
 from sqlalchemy import Column, String, Boolean, ForeignKey, DateTime
 from sqlalchemy.sql import func
 
-from app.core.database import Base, engine
+from app.core.database import Base
 
 
 class AuthToken(Base):
@@ -29,10 +29,14 @@ class AuthToken(Base):
         return token
 
     def generate_bearer_token(self):
-        token_prefix = str(self.id).replace("-", "")  # Remove hyphens from UUID
-        token_suffix = str(uuid.uuid4().hex)  # Generate a random UUID string
+        token_prefix = str(uuid.uuid4()).replace("-", "")
+        token_suffix = "".join(
+            random.choices(
+                string.ascii_uppercase + string.ascii_lowercase + string.digits, k=32
+            )
+        )
         return f"{token_prefix}{token_suffix}"
 
     @staticmethod
-    def validate_bearer_token(request_token):
+    def validate_bearer_token(request_token: str):
         ...

app/core/models/Transcribe.py

@@ -1,6 +1,5 @@
 from datetime import datetime, timedelta
 
-
 import uuid
 from app.core.config import settings
 
@@ -19,3 +18,4 @@ class TranscibeInDB(Base):
     text = Column(String)
     user_id = Column(UUID(as_uuid=True), ForeignKey("users.id"))
     user = relationship("UserInDB", back_populates="transcribes")
+    created_at = Column(DateTime(timezone=True), server_default=func.now())

app/core/models/User.py

@@ -4,10 +4,11 @@ import uuid
 from app.core.config import settings
 
 from sqlalchemy.dialects.postgresql import UUID
-from sqlalchemy import Column, String, Boolean
+from sqlalchemy import Column, String, Boolean, DateTime
 from sqlalchemy.orm import relationship
+from sqlalchemy.sql import func
 
-from app.core.database import Base, engine
+from app.core.database import Base
 
 
 class UserInDB(Base):
@@ -19,8 +20,17 @@ class UserInDB(Base):
     hashed_password = Column(String)
     is_active = Column(Boolean, default=True)
     transcribes = relationship("TranscibeInDB", back_populates="user")
+    created_at = Column(DateTime(timezone=True), server_default=func.now())
 
     def __init__(self, username: str, email: str, hashed_password: str):
         self.username = username
         self.email = email
         self.hashed_password = hashed_password
+
+    def data(self):
+        return {
+            "id": self.id,
+            "username": self.username,
+            "email": self.email,
+            "created_at": self.created_at,
+        }

app/main.py

@@ -1,8 +1,7 @@
 from fastapi import FastAPI
 from app.api import api_router
 from app.core.config import settings
-from app.core.errors import http_error_handler
-from app.core.errors import http422_error_handler
+from app.core.errors import error_handler
 from fastapi.middleware.cors import CORSMiddleware
 
 from app.utils import print_routes
@@ -25,8 +24,8 @@ if settings.BACKEND_CORS_ORIGINS:
 app.include_router(api_router, prefix=settings.API_V1_STR)
 
 # # Error handlers
-app.add_exception_handler(422, http422_error_handler)
-app.add_exception_handler(500, http_error_handler)
+app.add_exception_handler(422, error_handler)
+app.add_exception_handler(500, error_handler)
 
 # Print all routes
 print_routes(app)

requirements.txt

@@ -9,4 +9,5 @@ faker
 requests-mock
 passlib
 httpx
-PyJWT
+PyJWT
+python-multipart