fastapi upgrade, CRUDBase replaced with fastcrud

Author: igorbenav

src/app/api/v1/posts.py

@@ -36,7 +36,8 @@ async def write_post(
     post_internal_dict["created_by_user_id"] = db_user["id"]
 
     post_internal = PostCreateInternal(**post_internal_dict)
-    return await crud_posts.create(db=db, object=post_internal)
+    created_post: PostRead = await crud_posts.create(db=db, object=post_internal)
+    return created_post
 
 
 @router.get("/{username}/posts", response_model=PaginatedListResponse[PostRead])
@@ -77,7 +78,7 @@ async def read_post(
     if db_user is None:
         raise NotFoundException("User not found")
 
-    db_post = await crud_posts.get(
+    db_post: PostRead | None = await crud_posts.get(
         db=db, schema_to_select=PostRead, id=id, created_by_user_id=db_user["id"], is_deleted=False
     )
     if db_post is None:

src/app/api/v1/rate_limits.py

@@ -31,7 +31,8 @@ async def write_rate_limit(
         raise DuplicateValueException("Rate Limit Name not available")
 
     rate_limit_internal = RateLimitCreateInternal(**rate_limit_internal_dict)
-    return await crud_rate_limits.create(db=db, object=rate_limit_internal)
+    created_rate_limit: RateLimitRead = await crud_rate_limits.create(db=db, object=rate_limit_internal)
+    return created_rate_limit
 
 
 @router.get("/tier/{tier_name}/rate_limits", response_model=PaginatedListResponse[RateLimitRead])
@@ -65,7 +66,9 @@ async def read_rate_limit(
     if not db_tier:
         raise NotFoundException("Tier not found")
 
-    db_rate_limit = await crud_rate_limits.get(db=db, schema_to_select=RateLimitRead, tier_id=db_tier["id"], id=id)
+    db_rate_limit: dict | None = await crud_rate_limits.get(
+        db=db, schema_to_select=RateLimitRead, tier_id=db_tier["id"], id=id
+    )
     if db_rate_limit is None:
         raise NotFoundException("Rate Limit not found")
 

src/app/api/v1/tiers.py

@@ -24,7 +24,8 @@ async def write_tier(
         raise DuplicateValueException("Tier Name not available")
 
     tier_internal = TierCreateInternal(**tier_internal_dict)
-    return await crud_tiers.create(db=db, object=tier_internal)
+    created_tier: TierRead = await crud_tiers.create(db=db, object=tier_internal)
+    return created_tier
 
 
 @router.get("/tiers", response_model=PaginatedListResponse[TierRead])
@@ -40,7 +41,7 @@ async def read_tiers(
 
 @router.get("/tier/{name}", response_model=TierRead)
 async def read_tier(request: Request, name: str, db: Annotated[AsyncSession, Depends(async_get_db)]) -> dict:
-    db_tier = await crud_tiers.get(db=db, schema_to_select=TierRead, name=name)
+    db_tier: TierRead | None = await crud_tiers.get(db=db, schema_to_select=TierRead, name=name)
     if db_tier is None:
         raise NotFoundException("Tier not found")
 

src/app/api/v1/users.py

@@ -36,7 +36,8 @@ async def write_user(
     del user_internal_dict["password"]
 
     user_internal = UserCreateInternal(**user_internal_dict)
-    return await crud_users.create(db=db, object=user_internal)
+    created_user: UserRead = await crud_users.create(db=db, object=user_internal)
+    return created_user
 
 
 @router.get("/users", response_model=PaginatedListResponse[UserRead])
@@ -61,7 +62,9 @@ async def read_users_me(request: Request, current_user: Annotated[UserRead, Depe
 
 @router.get("/user/{username}", response_model=UserRead)
 async def read_user(request: Request, username: str, db: Annotated[AsyncSession, Depends(async_get_db)]) -> dict:
-    db_user = await crud_users.get(db=db, schema_to_select=UserRead, username=username, is_deleted=False)
+    db_user: UserRead | None = await crud_users.get(
+        db=db, schema_to_select=UserRead, username=username, is_deleted=False
+    )
     if db_user is None:
         raise NotFoundException("User not found")
 
@@ -168,7 +171,7 @@ async def read_user_tier(
     if not db_tier:
         raise NotFoundException("Tier not found")
 
-    joined = await crud_users.get_joined(
+    joined: dict = await crud_users.get_joined(
         db=db,
         join_model=Tier,
         join_prefix="tier_",

src/app/core/exceptions/http_exceptions.py

@@ -0,0 +1,11 @@
+# ruff: noqa
+from fastcrud.exceptions.http_exceptions import (
+    CustomException,
+    BadRequestException,
+    NotFoundException,
+    ForbiddenException,
+    UnauthorizedException,
+    UnprocessableEntityException,
+    DuplicateValueException,
+    RateLimitException,
+)

src/app/core/worker/functions.py

@@ -17,7 +17,7 @@ async def sample_background_task(ctx: Worker, name: str) -> str:
 
 # -------- base functions --------
 async def startup(ctx: Worker) -> None:
-    logging.info('Worker Started')
+    logging.info("Worker Started")
 
 
 async def shutdown(ctx: Worker) -> None: