python upgrade, CRUDBase replaced with fastcrud

Author: igorbenav

README.md

@@ -55,8 +55,8 @@
 - 🏬 Easy redis caching
 - 👜 Easy client-side caching
 - 🚦 ARQ integration for task queue
-- ⚙️ Efficient querying (only queries what's needed) with support for joins
-- ⎘ Out of the box pagination support
+- ⚙️ Efficient and robust queries with <a href="https://github.com/igorbenav/fastcrud">fastcrud</a>
+- ⎘ Out of the box offset and cursor pagination support with <a href="https://github.com/igorbenav/fastcrud">fastcrud</a>
 - 🛑 Rate Limiter dependency
 - 👮 FastAPI docs behind authentication and hidden based on the environment
 - 🦾 Easily extendable
@@ -749,14 +749,15 @@ poetry run alembic upgrade head
 
 ### 5.6 CRUD
 
-Inside `app/crud`, create a new `crud_entities.py` inheriting from `CRUDBase` for each new entity:
+Inside `app/crud`, create a new `crud_entities.py` inheriting from `FastCRUD` for each new entity:
 
 ```python
-from app.crud.crud_base import CRUDBase
+from fastcrud import FastCRUD
+
 from app.models.entity import Entity
 from app.schemas.entity import EntityCreateInternal, EntityUpdate, EntityUpdateInternal, EntityDelete
 
-CRUDEntity = CRUDBase[Entity, EntityCreateInternal, EntityUpdate, EntityUpdateInternal, EntityDelete]
+CRUDEntity = FastCRUD[Entity, EntityCreateInternal, EntityUpdate, EntityUpdateInternal, EntityDelete]
 crud_entity = CRUDEntity(Entity)
 ```
 
@@ -767,7 +768,7 @@ So, for users:
 from app.model.user import User
 from app.schemas.user import UserCreateInternal, UserUpdate, UserUpdateInternal, UserDelete
 
-CRUDUser = CRUDBase[User, UserCreateInternal, UserUpdate, UserUpdateInternal, UserDelete]
+CRUDUser = FastCRUD[User, UserCreateInternal, UserUpdate, UserUpdateInternal, UserDelete]
 crud_users = CRUDUser(User)
 ```
 

pyproject.toml

@@ -30,6 +30,7 @@ redis = "^5.0.1"
 arq = "^0.25.0"
 gunicorn = "^21.2.0"
 bcrypt = "^4.1.1"
+fastcrud = "^0.1.5"
 
 
 [build-system]

src/app/core/db/crud_token_blacklist.py

@@ -1,6 +1,7 @@
-from ...crud.crud_base import CRUDBase
+from fastcrud import FastCRUD
+
 from ..db.token_blacklist import TokenBlacklist
 from ..schemas import TokenBlacklistCreate, TokenBlacklistUpdate
 
-CRUDTokenBlacklist = CRUDBase[TokenBlacklist, TokenBlacklistCreate, TokenBlacklistUpdate, TokenBlacklistUpdate, None]
+CRUDTokenBlacklist = FastCRUD[TokenBlacklist, TokenBlacklistCreate, TokenBlacklistUpdate, TokenBlacklistUpdate, None]
 crud_token_blacklist = CRUDTokenBlacklist(TokenBlacklist)

src/app/core/exceptions/http_exceptions.py

@@ -1,45 +0,0 @@
-from http import HTTPStatus
-
-from fastapi import HTTPException, status
-
-
-class CustomException(HTTPException):
-    def __init__(self, status_code: int = status.HTTP_500_INTERNAL_SERVER_ERROR, detail: str | None = None):
-        if not detail:
-            detail = HTTPStatus(status_code).description
-        super().__init__(status_code=status_code, detail=detail)
-
-
-class BadRequestException(CustomException):
-    def __init__(self, detail: str | None = None):
-        super().__init__(status_code=status.HTTP_400_BAD_REQUEST, detail=detail)
-
-
-class NotFoundException(CustomException):
-    def __init__(self, detail: str | None = None):
-        super().__init__(status_code=status.HTTP_404_NOT_FOUND, detail=detail)
-
-
-class ForbiddenException(CustomException):
-    def __init__(self, detail: str | None = None):
-        super().__init__(status_code=status.HTTP_403_FORBIDDEN, detail=detail)
-
-
-class UnauthorizedException(CustomException):
-    def __init__(self, detail: str | None = None):
-        super().__init__(status_code=status.HTTP_401_UNAUTHORIZED, detail=detail)
-
-
-class UnprocessableEntityException(CustomException):
-    def __init__(self, detail: str | None = None):
-        super().__init__(status_code=status.HTTP_422_UNPROCESSABLE_ENTITY, detail=detail)
-
-
-class DuplicateValueException(CustomException):
-    def __init__(self, detail: str | None = None):
-        super().__init__(status_code=status.HTTP_422_UNPROCESSABLE_ENTITY, detail=detail)
-
-
-class RateLimitException(CustomException):
-    def __init__(self, detail: str | None = None):
-        super().__init__(status_code=status.HTTP_429_TOO_MANY_REQUESTS, detail=detail)

src/app/core/worker/functions.py

@@ -1,5 +1,6 @@
 import asyncio
 import logging
+
 import uvloop
 from arq.worker import Worker
 

src/app/core/worker/settings.py

@@ -1,6 +1,7 @@
 from arq.connections import RedisSettings
+
 from ...core.config import settings
-from .functions import sample_background_task, startup, shutdown
+from .functions import sample_background_task, shutdown, startup
 
 REDIS_QUEUE_HOST = settings.REDIS_QUEUE_HOST
 REDIS_QUEUE_PORT = settings.REDIS_QUEUE_PORT