merge check complete

app/bot/fsm_contexts/feedback_context.py

@@ -10,9 +10,9 @@
 from helpers import ask_next_question, start_inactivity_timer, get_user_id
 from loggers.log import setup_logging
 from bot.validators import is_valid_rating
-from crud.feedback import create_feedback
 from crud.users import get_id_by_tg_id
 from core.bot_setup import bot
+from crud.feedback_crud import feedback_crud
 
 
 router = Router()
@@ -81,7 +81,7 @@ async def process_description(
 
     feedback_data = await state.get_data()
 
-    await create_feedback(feedback_data, session)
+    await feedback_crud.create(feedback_data, session)
 
     logger.info(f'Запись создана в БД с ID: {feedback_data.get("user")}.')
 

app/crud/feedback_crud.py

@@ -13,15 +13,5 @@ async def get_multi(self, session: AsyncSession):
         )
         return db_objs.scalars().all()
 
-    async def bulk_create(
-        self,
-        objs_in: list,
-        session: AsyncSession,
-    ):
-        db_objs = [self.model(**obj) for obj in objs_in]
-        session.add_all(db_objs)
-        await session.commit()
-        return db_objs
-
 
 feedback_crud = FeedbackCRUD(Feedback)

app/main.py

@@ -30,14 +30,16 @@ async def main() -> None:
 
     dispatcher.include_router(fsm_context_router)
     dispatcher.include_router(feedback_context)
-    dispatcher.include_router(message_router)
-    dispatcher.include_router(callback_router)
     dispatcher.include_router(admin_router)
     dispatcher.include_router(user_router)
+    dispatcher.include_router(message_router)
+    dispatcher.include_router(callback_router)
 
     try:
         logger.info("Запуск бота...")
-        dispatcher.update.middleware(DataBaseSession(session_pool=AsyncSessionLocal))
+        dispatcher.update.middleware(
+            DataBaseSession(session_pool=AsyncSessionLocal)
+        )
         await add_portfolio()
         await set_admin()
         await dispatcher.start_polling(bot)