refactor routers, add test endpoint

Author: sumaro2101

api_v1/__init__.py

@@ -1,3 +1,3 @@
-from .routers import router
+from .routers import register_routers
 
-__all__ = ('router',)
+__all__ = ('register_routers',)

api_v1/routers.py

@@ -1,4 +1,11 @@
-from fastapi import APIRouter
+from fastapi import FastAPI
 
+from config import settings
+from api_v1.users.views import router
 
-router = APIRouter(prefix='/api/v1')
+
+def register_routers(app: FastAPI) -> None:
+    app.include_router(
+        router=router,
+        prefix=settings.API_PREFIX,
+        )

config/rabbitmq/__init__.py api_v1/users/__init__.pyconfig/rabbitmq/__init__.py renamed to api_v1/users/__init__.py

@@ -0,0 +1,20 @@
+from fastapi import APIRouter, Depends
+
+from sqlalchemy.ext.asyncio import AsyncSession
+
+from config import db_connection
+
+
+router = APIRouter(prefix='/users',
+                   tags=['Users'],
+                   )
+
+
+@router.get(path='/get',
+            description='Test end point',
+            )
+async def get_user(
+    session: AsyncSession = Depends(db_connection.session_geter),
+    ):
+    session = session
+    return {'user': 'is_work'}

api_v1/users/views.py

@@ -1,7 +1,7 @@
 from .config import settings
-from .rabbitmq.connection import app as celery_app
+from .celery.connection import app as celery_app
 from .database.db_helper import db_helper as db_connection
-from .database.base import Base as BaseModel
+from .models.base import Base as BaseModel
 
 
 __all__ = ('settings',

config/__init__.py

@@ -46,6 +46,7 @@ class Settings(BaseSettings):
     db: DBSettings = DBSettings()
     rabbit: RabbitSettings = RabbitSettings()
     debug: bool = bool(int(config('DEBUG')))
+    API_PREFIX: str = '/api/v1'
 
 
 settings = Settings()

config/celery/__init__.py

@@ -4,7 +4,7 @@ set -o errexit
 set -o nounset
 
 worker_ready() {
-    celery -A config.rabbitmq.connection.app --broker=amqp://"${RABBITMQ_DEFAULT_USER}":"${RABBITMQ_DEFAULT_PASS}"@"${RMQ_HOST}":"${RMQ_PORT}" inspect ping
+    celery -A config.celery.connection.app --broker=amqp://"${RABBITMQ_DEFAULT_USER}":"${RABBITMQ_DEFAULT_PASS}"@"${RMQ_HOST}":"${RMQ_PORT}" inspect ping
 }
 
 until worker_ready; do
@@ -13,6 +13,6 @@ until worker_ready; do
 done
 >&2 echo 'Celery workers is available'
 
-celery -A config.rabbitmq.connection.app \
+celery -A config.celery.connection.app \
  --broker=amqp://"${RABBITMQ_DEFAULT_USER}":"${RABBITMQ_DEFAULT_PASS}"@"${RMQ_HOST}":"${RMQ_PORT}" \
  flower