Added TornadoRouter

Author: mr-fatalyst

CHANGELOG.md

@@ -8,6 +8,7 @@ FastOpenAPI follows the [Keep a Changelog](https://keepachangelog.com/en/1.0.0/)
 
 ### Added
 - `ReDoc UI` and default URL (`host:port/redoc`)
+- `TornadoRouter` for integration with the `Tornado` framework
 
 ## [0.3.1] - 2025-03-15
 

README.md

@@ -6,6 +6,10 @@
   <b>FastOpenAPI</b> is a library for generating and integrating OpenAPI schemas using Pydantic and various frameworks.
 </p>
 
+<p align="center">
+  This project was inspired by <a href="https://fastapi.tiangolo.com/">FastAPI</a> and aims to provide a similar developer-friendly experience.
+</p>
+
 <p align="center">
   <img src="https://img.shields.io/github/license/mr-fatalyst/fastopenapi">
   <img src="https://github.com/mr-fatalyst/fastopenapi/actions/workflows/master.yml/badge.svg">
@@ -37,6 +41,9 @@ pip install fastopenapi[sanic]
 ```bash
 pip install fastopenapi[starlette]
 ```
+```bash
+pip install fastopenapi[tornado]
+```
 
 ---
 
@@ -80,7 +87,7 @@ pip install fastopenapi[starlette]
     ```
   </details>
 
-- ![Flask](https://img.shields.io/badge/-Flask-000000?style=flat&logo=flask&logoColor=white)
+- ![Flask](https://img.shields.io/badge/-Flask-EEEEEE?style=flat&logo=flask&logoColor=black)
   <details>
     <summary>Click to expand the Flask Example</summary>
 
@@ -167,7 +174,7 @@ pip install fastopenapi[starlette]
     ```
   </details>
 
-- ![Starlette](https://img.shields.io/badge/-Starlette-4B0082?style=flat&logo=fastapi&logoColor=white)
+- ![Starlette](https://img.shields.io/badge/-Starlette-4B0082?style=flat&logo=python&logoColor=white)
   <details>
     <summary>Click to expand the Starlette Example</summary>
 
@@ -196,6 +203,45 @@ pip install fastopenapi[starlette]
     ```
   </details>
 
+- ![Tornado](https://img.shields.io/badge/-Tornado-2980B9?style=flat&logo=python&logoColor=white)
+  <details>
+    <summary>Click to expand the Tornado Example</summary>
+    
+    ```python
+    import asyncio
+  
+    from pydantic import BaseModel
+    from tornado.web import Application
+  
+    from fastopenapi.routers.tornado import TornadoRouter
+  
+    app = Application()
+  
+    router = TornadoRouter(
+        app=app, docs_url="/docs", openapi_url="/openapi.json", openapi_version="3.0.0"
+    )
+  
+  
+    class HelloResponse(BaseModel):
+        message: str
+  
+  
+    @router.get("/hello", tags=["Hello"], status_code=200, response_model=HelloResponse)
+    def hello(name: str):
+        """Say hello from Tornado"""
+        return HelloResponse(message=f"Hello, {name}! It's Tornado!")
+  
+  
+    async def main():
+        app.listen(8000)
+        await asyncio.Event().wait()
+  
+  
+    if __name__ == "__main__":
+        asyncio.run(main())
+    ```
+  </details>
+
 ### Step 2. Run the server
 
 Launch the application:
@@ -206,16 +252,21 @@ python main.py
 
 Once launched, the documentation will be available at:
 
+Swagger UI:
+```
+http://127.0.0.1:8000/docs
+```
+ReDoc UI:
 ```
-http://127.0.0.1:8000/docs/
+http://127.0.0.1:8000/redoc
 ```
 
 ---
 
 ## ⚙️ Features
 - **Generate OpenAPI schemas** with Pydantic v2.
 - **Data validation** using Pydantic models.
-- **Supports multiple frameworks:** Falcon, Flask, Quart, Sanic, Starlette.
+- **Supports multiple frameworks:** Falcon, Flask, Quart, Sanic, Starlette, Tornado.
 - **Proxy routing provides FastAPI-style routing**
 
 ---

examples/tornado/app/__init__.py

@@ -0,0 +1,6 @@
+from fastopenapi.routers import TornadoRouter
+
+from .v1 import v1_router
+
+api_router = TornadoRouter()
+api_router.include_router(v1_router, prefix="/v1")

examples/tornado/app/api/__init__.py

@@ -0,0 +1,8 @@
+from fastopenapi.routers import TornadoRouter
+
+from .authors import router as authors_router
+from .posts import router as posts_router
+
+v1_router = TornadoRouter()
+v1_router.include_router(authors_router)
+v1_router.include_router(posts_router)

examples/tornado/app/api/routes.py

@@ -0,0 +1,48 @@
+from tornado.web import HTTPError
+
+from fastopenapi.routers import TornadoRouter
+
+from ...schemas.authors import (
+    AuthorSchema,
+    CreateAuthorSchema,
+    FilterAuthorSchema,
+    UpdateAuthorSchema,
+)
+from ...services.authors import AuthorService
+
+author_service = AuthorService()
+
+router = TornadoRouter()
+
+
+@router.post("/authors", tags=["Authors"], status_code=201, response_model=AuthorSchema)
+async def create_author(body: CreateAuthorSchema) -> AuthorSchema:
+    return await author_service.create_author(body)
+
+
+@router.get("/authors/{author_id}", tags=["Authors"], response_model=AuthorSchema)
+async def get_author(author_id: int) -> AuthorSchema:
+    author = await author_service.get_author(author_id)
+    if not author:
+        raise HTTPError(status_code=404, log_message="Not Found")
+    return author
+
+
+@router.get("/authors/", tags=["Authors"], response_model=list[AuthorSchema])
+async def get_authors(body: FilterAuthorSchema) -> list[AuthorSchema]:
+    return await author_service.get_authors(body)
+
+
+@router.delete("/authors/{author_id}", tags=["Authors"], status_code=204)
+async def delete_author(author_id: int) -> None:
+    author = await author_service.delete_author(author_id)
+    if not author:
+        raise HTTPError(status_code=404, log_message="Not Found")
+
+
+@router.patch("/authors/{author_id}", tags=["Authors"], response_model=AuthorSchema)
+async def update_author(author_id: int, body: UpdateAuthorSchema) -> AuthorSchema:
+    author = await author_service.update_author(author_id, body)
+    if not author:
+        raise HTTPError(status_code=404, log_message="Not Found")
+    return author

examples/tornado/app/api/v1/__init__.py

@@ -0,0 +1,47 @@
+from tornado.web import HTTPError
+
+from fastopenapi.routers import TornadoRouter
+
+from ...schemas.posts import (
+    CreatePostSchema,
+    FilterPostSchema,
+    PostSchema,
+    UpdatePostSchema,
+)
+from ...services.posts import PostService
+
+post_service = PostService()
+router = TornadoRouter()
+
+
+@router.post("/posts", tags=["Posts"], status_code=201, response_model=PostSchema)
+async def create_post(body: CreatePostSchema) -> PostSchema:
+    return await post_service.create_post(body)
+
+
+@router.get("/posts/{post_id}", tags=["Posts"], response_model=PostSchema)
+async def get_post(post_id: int) -> PostSchema:
+    post = await post_service.get_post(post_id)
+    if not post:
+        raise HTTPError(status_code=404, log_message="Not Found")
+    return post
+
+
+@router.get("/posts/", tags=["Posts"], response_model=list[PostSchema])
+async def get_posts(body: FilterPostSchema) -> list[PostSchema]:
+    return await post_service.get_posts(body)
+
+
+@router.delete("/posts/{post_id}", tags=["Posts"], status_code=204)
+async def delete_post(post_id: int) -> None:
+    post = await post_service.delete_post(post_id)
+    if not post:
+        raise HTTPError(status_code=404, log_message="Not Found")
+
+
+@router.patch("/posts/{post_id}", tags=["Posts"], response_model=PostSchema)
+async def update_post(post_id: int, body: UpdatePostSchema) -> PostSchema:
+    post = await post_service.update_post(post_id, body)
+    if not post:
+        raise HTTPError(status_code=404, log_message="Not Found")
+    return post

examples/tornado/app/api/v1/authors.py

@@ -0,0 +1,22 @@
+from pydantic import BaseModel, Field
+
+
+class AuthorSchema(BaseModel):
+    id: int
+    name: str
+    bio: str | None = None
+
+
+class FilterAuthorSchema(BaseModel):
+    id: int = Field(default=None)
+    name: str = Field(default=None)
+
+
+class CreateAuthorSchema(BaseModel):
+    name: str = Field(..., max_length=50)
+    bio: str | None = Field(None, max_length=200)
+
+
+class UpdateAuthorSchema(BaseModel):
+    name: str = Field(default=None, max_length=50)
+    bio: str = Field(default=None, max_length=200)