feat: Blog Read API Endpoint [Issue #4]

Author: Pythonian

api/v1/routes/blog.py

@@ -8,10 +8,10 @@
 from api.db.database import get_db
 from api.v1.models.blog import Blog
 from api.v1.schemas.blog import (
-    BlogCreateResponseSchema,
     BlogCreateSchema,
     BlogListItemResponseSchema,
     BlogListResponseSchema,
+    BlogResponseSchema,
 )
 
 blog = APIRouter(prefix="/blogs", tags=["Blog"])
@@ -21,13 +21,13 @@
 
 @blog.post(
     "",
-    response_model=BlogCreateResponseSchema,
+    response_model=BlogResponseSchema,
     status_code=status.HTTP_201_CREATED,
 )
 async def create_blog(
     blog: BlogCreateSchema,
     db: Session = Depends(get_db),
-) -> BlogCreateResponseSchema:
+) -> BlogResponseSchema:
     try:
         existing_blog = db.query(Blog).filter(Blog.title == blog.title).first()
         if existing_blog:
@@ -48,7 +48,7 @@ async def create_blog(
         db.refresh(new_blog)
         logger.info(f"Blog post '{new_blog.title}' created successfully.")
 
-        return BlogCreateResponseSchema.model_validate(new_blog.__dict__)
+        return BlogResponseSchema.model_validate(new_blog.__dict__)
 
     except HTTPException as http_err:
         logger.warning(f"HTTP error occurred: {http_err.detail}")
@@ -127,3 +127,51 @@ async def list_blog(
             status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
             detail="Internal server error.",
         )
+
+
+@blog.get(
+    "/{id}",
+    response_model=BlogResponseSchema,
+    status_code=status.HTTP_200_OK,
+)
+async def read_blog(
+    id: int,
+    db: Session = Depends(get_db),
+) -> BlogResponseSchema:
+    try:
+        blog = (
+            db.query(Blog)
+            .filter(
+                Blog.id == id,
+                not_(Blog.is_deleted),
+            )
+            .first()
+        )
+        if not blog:
+            logger.warning(f"Blog post with ID '{id}' not found.")
+            raise HTTPException(
+                status_code=status.HTTP_404_NOT_FOUND,
+                detail="Blog post not found.",
+            )
+
+        logger.info(f"Blog post with ID '{id}' retrieved successfully.")
+        return BlogResponseSchema.model_validate(blog.__dict__)
+
+    except SQLAlchemyError as e:
+        logger.error(f"Database error occurred: {e}")
+        raise HTTPException(
+            status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
+            detail="Database error occurred.",
+        )
+    except ValueError as e:
+        logger.error(f"Invalid blog post ID '{id}': {e}")
+        raise HTTPException(
+            status_code=status.HTTP_400_BAD_REQUEST,
+            detail="Invalid blog post ID.",
+        )
+    except Exception as e:
+        logger.error(f"Unexpected error occurred: {e}")
+        raise HTTPException(
+            status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
+            detail="Unexpected error occurred.",
+        )

api/v1/schemas/blog.py

@@ -6,8 +6,8 @@
 from pydantic import BaseModel, Field
 
 
-class BlogCreateResponseSchema(BaseModel):
-    """Schema for representing a created blog post in the API response."""
+class BlogResponseSchema(BaseModel):
+    """Schema for representing a blog post in the API response."""
 
     id: int
     title: str

tests/v1/blog/test_read_blog.py

@@ -0,0 +1,59 @@
+from datetime import datetime
+from unittest.mock import MagicMock
+
+import pytest
+from fastapi.testclient import TestClient
+
+from api.db.database import get_db
+from api.v1.models.blog import Blog
+from main import app
+
+client = TestClient(app)
+
+
+@pytest.fixture
+def db_session_mock():
+    return MagicMock()
+
+
+@pytest.fixture(autouse=True)
+def override_get_db(db_session_mock):
+    app.dependency_overrides[get_db] = lambda: db_session_mock
+    yield
+    app.dependency_overrides[get_db] = None
+
+
+def test_successful_retrieval_of_blog_post(db_session_mock):
+    blog = Blog(
+        id=1,
+        title="Sample Blog Post",
+        excerpt="This is a sample excerpt.",
+        content="Sample content for the blog post.",
+        image_url="https://example.com/sample.jpg",
+        created_at=datetime(2024, 7, 22, 12, 0, 0),
+        updated_at=datetime(2024, 7, 22, 12, 30, 0),
+    )
+
+    db_session_mock.query().filter().first.return_value = blog
+
+    response = client.get("/api/v1/blogs/1")
+
+    assert response.status_code == 200
+    data = response.json()
+    assert data["id"] == 1
+    assert data["title"] == "Sample Blog Post"
+    assert data["excerpt"] == "This is a sample excerpt."
+    assert data["content"] == "Sample content for the blog post."
+    assert data["image_url"] == "https://example.com/sample.jpg"
+    assert data["created_at"] == "2024-07-22T12:00:00"
+    assert data["updated_at"] == "2024-07-22T12:30:00"
+
+
+def test_invalid_blog_post_id():
+    response = client.get("/api/v1/blogs/abc")
+
+    assert response.status_code == 422
+    data = response.json()
+    assert "detail" in data
+    assert isinstance(data["detail"], list)
+    assert any("msg" in error for error in data["detail"])