README.md

@@ -5,50 +5,29 @@ Fastapi веб приложение реализующее api для общеп
 Данный проект, это результат выполнения практических домашних заданий интенсива от YLAB Development. Проект реализован на фреймворке fastapi, с использованием sqlalchemy. В качестве базы данных используется postgresql.
 
 ## Техническое задание
-### Спринт 4 - Многопроцессорность, асинхронность
+### Спринт 3 - Паттерны и принципы разработки
-В этом домашнем задании необходимо:
-1.Переписать текущее FastAPI приложение на асинхронное выполнение
-2.Добавить в проект фоновую задачу с помощью Celery + RabbitMQ.
-3.Добавить эндпоинт (GET) для вывода всех меню со всеми связанными подменю и со всеми связанными блюдами.
-4.Реализовать инвалидация кэша в background task (встроено в FastAPI)
-5.* Обновление меню из google sheets раз в 15 сек.
-6.** Блюда по акции. Размер скидки (%) указывается в столбце G файла Menu.xlsx
 
-Фоновая задача: синхронизация Excel документа и БД.
+1.Вынести бизнес логику и запросы в БД в отдельные слои приложения.
-   В проекте создаем папку admin. В эту папку кладем файл Menu.xlsx (будет прикреплен к ДЗ). Не забываем запушить в гит.
-   При внесении изменений в файл все изменения должны отображаться в БД. Периодичность обновления 15 сек. Удалять БД при каждом обновлении – нельзя.
 
+2.Добавить кэширование запросов к API с использованием Redis. Не забыть про инвалидацию кэша.
+
+3.Добавить pre-commit хуки в проект. Файл yaml будет прикреплен к ДЗ.
+
+4.Покрыть проект type hints (тайпхинтами)
+
+5.* Описать ручки API в соответствий c OpenAPI
+
+6.** Реализовать в тестах аналог Django reverse() для FastAPI
 
 Требования:
-●Данные меню, подменю, блюд для нового эндпоинта должны доставаться одним ORM-запросом в БД (использовать подзапросы и агрегирующие функций SQL).
+●Код должен проходить все линтеры.
-●Проект должен запускаться одной командой
+●Код должен соответствовать принципам SOLID, DRY, KISS.
-●Проект должен соответствовать требованиям всех предыдущих вебинаров. (Не забыть добавить тесты для нового API эндпоинта)
+●Проект должен запускаться по одной команде (докер).
-
+●Проект должен проходить все Postman тесты (коллекция с Вебинара №1).
-### Выполненные доп задания со *
+●Тесты написанные вами после Вебинара №2, должны быть актуальны, запускать и успешно проходить
-Спринт 2
-    3.* Реализовать вывод количества подменю и блюд для Меню через один (сложный) ORM запрос.
-        `./fastfood/repository/menu.py` Метод `get_menu_item`
-
-    4.** Реализовать тестовый сценарий «Проверка кол-ва блюд и подменю в меню» из Postman с помощью pytest
-        `./tests/test_postman.py`
-
-Спринт 3
-    5.* Описать ручки API в соответствий c OpenAPI
-        './openapi.json'
-
-    6.** Реализовать в тестах аналог Django reverse() для FastAPI
-        './tests/urls.py'
-
-Спринт 4
-    5.* Обновление меню из google sheets раз в 15 сек.
-        `./bg_tasks/` Реализовано чтение как локальной, так и удаленной таблицы.
-        В зависимости какой compose поднять, тот и будет использоваться
-
-    6.** Блюда по акции. Размер скидки (%) указывается в столбце G файла Menu.xlsx
-        `./fastfood/service/dish.py`, метод _get_discont, подменяет сумму в выдаче,
-        скидка хранится в REDIS под ключами вида DISCONT:{UUID блюда}
-
 
+Дополнительно:
+Контейнеры с проектом и с тестами запускаются разными командами.
 
 ## Зависимости
 - docker
@@ -64,12 +43,8 @@ Fastapi веб приложение реализующее api для общеп
 
 Запуск/остановка образов:
 
-- Запуск FAstAPI приложения c локальным файлом для фоновой задачи
+- Запуск FAstAPI приложения
-> `$ docker-compose -f compose_app.yml up`
+> `$ docker-compose -f compose_app.yml up `
-
-- Запуск FAstAPI приложения c Google Sheets для фоновой задачи
-> `$ docker-compose -f compose_google.yml up`
-(ЧИТАЙТЕ СООБЩЕНИЕ В ЧАТЕ)
 
 После успешного запуска образов документация по API будет доступна по адресу <a href="http://localhost:8000/docs">http://localhost:8000</a>
 

bg_tasks/parser.py

@@ -1,5 +1,4 @@
 import os
-from typing import Any
 
 import gspread
 import openpyxl
@@ -44,9 +43,7 @@ async def local_xlsx_to_rows() -> list[list[str | int | float]]:
     return data
 
 
-async def rows_to_dict(
+async def rows_to_dict(rows: list[list]) -> tuple:
-    rows: list[list],
-) -> tuple[dict[int, Any], dict[Any, Any], dict[Any, Any]]:
     """Парсит строки полученные и источников в словарь"""
 
     menus = {}

bg_tasks/updater.py

@@ -1,6 +1,5 @@
 import os
 import pickle
-from typing import Any
 
 import redis.asyncio as redis  # type: ignore
 from sqlalchemy import delete, update
@@ -46,8 +45,7 @@ async def is_changed_xls() -> bool:
 
 async def on_menu_change(
     new_menu: dict, old_menu: dict, session: AsyncSession
-) -> dict[str, Any]:
+) -> dict | None:
-    """Изменение, удаление или создание меню"""
     if new_menu and not old_menu:
         # Создаем меню
         menu = Menu(
@@ -57,7 +55,6 @@ async def on_menu_change(
         session.add(menu)
         await session.flush()
         new_menu['id'] = str(menu.id)
-
     elif new_menu and old_menu:
         # Обновляем меню
         await session.execute(
@@ -70,6 +67,10 @@ async def on_menu_change(
         await session.execute(delete(Menu).where(Menu.id == old_menu['id']))
 
     await session.commit()
+    # Чистим кэш
+    await clear_cache('MENUS*')
+    await clear_cache('summary')
+
     return new_menu
 
 
@@ -107,9 +108,9 @@ async def menus_updater(menus: dict, session: AsyncSession) -> None:
 
 async def on_submenu_change(
     new_sub: dict, old_sub: dict, session: AsyncSession
-) -> dict[str, Any]:
+) -> dict:
     if new_sub and not old_sub:
-        # Создаем подменю
+        # Создаем меню
         submenu = SubMenu(
             title=new_sub['data']['title'],
             description=new_sub['data']['description'],
@@ -120,9 +121,8 @@ async def on_submenu_change(
         await session.flush()
         new_sub['id'] = str(submenu.id)
         new_sub['parent_menu'] = str(submenu.parent_menu)
-
     elif new_sub and old_sub:
-        # Обновляем подменю
+        # Обновляем меню
         await session.execute(
             update(SubMenu)
             .where(SubMenu.id == old_sub['id'])
@@ -132,9 +132,12 @@ async def on_submenu_change(
         new_sub['parent_menu'] = old_sub['parent_menu']
 
     else:
-        # Удаляем подменю
+        # Удаляем меню
         await session.execute(delete(SubMenu).where(SubMenu.id == old_sub['id']))
 
+    await clear_cache('MENUS*')
+    await clear_cache('summary')
+
     await session.commit()
     return new_sub
 
@@ -143,7 +146,7 @@ async def submenus_updater(submenus: dict, session: AsyncSession) -> None:
     """Проверяет пункты подменю на изменения
     При необходимости запускае обновление БД
     """
-    # Получаем меню из кэша для получения их ID по померу в таблице
+    # Получаем Меню из кэша для получения их ID по померу в таблице
     cached_menus = await redis.get('ALL_MENUS')
     if cached_menus is not None:
         cached_menus = pickle.loads(cached_menus)
@@ -186,9 +189,7 @@ async def submenus_updater(submenus: dict, session: AsyncSession) -> None:
     await redis.set('ALL_SUBMENUS', pickle.dumps(submenus))
 
 
-async def on_dish_change(
+async def on_dish_change(new_dish: dict, old_dish, session: AsyncSession) -> dict:
-    new_dish: dict, old_dish, session: AsyncSession
-) -> dict[str, Any]:
     if new_dish and not old_dish:
         dish = Dish(
             title=new_dish['data']['title'],
@@ -203,7 +204,7 @@ async def on_dish_change(
         new_dish['parent_submenu'] = str(dish.parent_submenu)
         new_dish['data']['price'] = str(dish.price)
     elif new_dish and old_dish:
-        # Обновляем блюдо
+        # Обновляем меню
         await session.execute(
             update(Dish).where(Dish.id == old_dish['id']).values(**(new_dish['data']))
         )
@@ -212,9 +213,12 @@ async def on_dish_change(
         new_dish['data']['price'] = old_dish['data']['price']
 
     else:
-        # Удаляем блюдо
+        # Удаляем меню
         await session.execute(delete(Dish).where(Dish.id == old_dish['id']))
 
+    await clear_cache('MENUS*')
+    await clear_cache('summary')
+
     await session.commit()
     return new_dish
 
@@ -229,7 +233,7 @@ async def dishes_updater(dishes: dict, session: AsyncSession) -> None:
     else:
         cached_submenus = {}
 
-    # Получаем блюда из кэша
+    # Получаем подмен из кэша
     cached_dishes = await redis.get('ALL_DISHES')
 
     if cached_dishes is not None:
@@ -240,21 +244,21 @@ async def dishes_updater(dishes: dict, session: AsyncSession) -> None:
     await clear_cache('DISCONT*')
 
     for key in {k: cached_dishes[k] for k in set(cached_dishes) - set(dishes)}:
-        # Проверяем на удаленные блюда и обновляемся
+        # Проверяем на удаленные меню
-        await on_dish_change({}, cached_dishes.pop(key), session)
+        await on_submenu_change({}, cached_dishes.pop(key), session)
 
     for key in dishes.keys():
         parent = cached_submenus[dishes[key]['parent_num']]['id']
         dishes[key]['parent_submenu'] = parent
 
         if key not in cached_dishes.keys():
-            # Получаем и ставим UUID parent_submenu
+            # Получаем и ставим UUID parent_menu
             dishes[key]['parent_submenu'] = parent
 
             dish = await on_dish_change(dishes[key], {}, session)
             dishes[key] = dish
         elif key in cached_dishes.keys():
-            # Обновление блюда
+            # Обновление меню
             if dishes[key].get('data') != cached_dishes[key].get('data'):
                 dish = await on_dish_change(dishes[key], cached_dishes[key], session)
                 dishes[key] = dish
@@ -270,15 +274,12 @@ async def dishes_updater(dishes: dict, session: AsyncSession) -> None:
         await redis.set('ALL_DISHES', pickle.dumps(dishes))
 
 
-async def updater(rows) -> None:
+async def updater(rows):
     menus, submenus, dishes = await rows_to_dict(rows)
     async with async_session_maker() as session:
         await menus_updater(menus, session)
         await submenus_updater(submenus, session)
         await dishes_updater(dishes, session)
-    # Чистим кэш
-    await clear_cache('MENUS*')
-    await clear_cache('summary')
 
 
 async def main() -> None:
@@ -290,6 +291,5 @@ async def main() -> None:
 
 
 async def main_gsheets() -> None:
-    """Главная функция фоновой задачи для работы с Google"""
     rows = await gsheets_to_rows()
     await updater(rows)

compose_test.yml

@@ -55,7 +55,6 @@ services:
       redis:
         condition: service_healthy
 
-    volumes:
+    restart: always
-      - .:/usr/src/fastfood
 
     command: /bin/bash -c 'poetry run pytest -vv'

creds.json

@@ -0,0 +1,13 @@
+{
+  "type": "service_account",
+  "project_id": "psyched-ceiling-413920",
+  "private_key_id": "d19492eea6a030092cf8ad767b62d7909734ccb1",
+  "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvQIBADANBgkqhkiG9w0BAQEFAASCBKcwggSjAgEAAoIBAQDPP2UrfDE+UOlD\nA761Jemy1IKKdIanRKXSziGvDYJ7zbY5gPFxY8Vo+9fsh1oumvROXqEH4+1LiR0J\nnUiy33R1KDOHETeP4H/FJ3u8+gHoL8wsA7SN5pIX9AR8AyBZCBjgSSp+KJchfrp/\nWN2qnFAbgp248QPvmG7/wLzBNnVsAQhQULLKqSc46hbiZ8Jt7t0ajJgOFRJSp2wP\nT5VE5k737w6b4OH8mUnhw7VK04Wk6DBmQhN1jrnxmMxmdG2hSM2zR824RIMBBs/O\n1dF+5Vkav0tgja/tVqm41Aaa2vgPRACP6bpF13YS+8C1lzw6s+7M/VdE5TH5NXRU\nvChuRknBAgMBAAECggEABmuckna0krVsawaXhLaQ30DsLf5w9hdLTvDy6CCuO9Aw\nPKb//9UNNmjMKD4rlQNY1YFS6jbxZNZRrIC7aftwQOGE2mKuIMBl6+tinuy0tLr/\nl3baS+22VZyyG36ILNrqZJ8epGm08CEsNVYRKKwS0x3aXZKFnnlnqaeYn2CUzdqa\na9iNZqrdXdRt4O7KVP7IfdNi11WuOL4epmHwBBYmCxiN0Z2KAIYvS6AcflYWtYTZ\npsBFjCQexqS37PdUyyQX9E/gKwqNZmahYwIC3vsCMCLdQQ93iODYni7LKsG0vvls\nwz03TtlMmZpMJJQGkALeqlv7jeyj+oRuqg6gjs2moQKBgQDxuDt3u1rDWhTJ50bD\nAp5T1LaiV0/+lu29ElTmYpa0RF1tlHvrndFm/MrdUjpzP4/VISmRkP3bmAgwPP6p\nYeALqQXCCGJtl44LG6D9VIOCOZxntytjLHogY8S3BLpwzKC+VMFsd56ay6wCl03S\nJEnvG10FQX8sFd+6j5qMy73OoQKBgQDbfc7hV4/r7PMaUVWFRqWjLry3dtTErxnM\nTdX30BDtuqMrm+hx0zC85ePcsbx+Zhwneyaxw2ICN5F954mJurBqs9cVaxitNSv1\nX5XjAoZqf3TevufkmSBXog6t/p4FHqAHftHYzwQvQXIINFrmT15PJkbx0lMYEYzw\nPyB7doBHIQKBgGiJi7ZpYYRw1eLH0fOOk1if+uhUqHTrYx/M6MjGRHTryBgXCkzI\n8QIAO9/hqwOirpq2/9pDgXZR1uC90EkC2jlQvPvAUokg7T5ikYpd3Y4ZSkoUjoAS\ngTK20yFvuw4DgVUvJIO7a+14PgjU1MQYC52MEPuv6sbvItX1Oxq/FnRhAoGAHWYK\ncbBSvJzuKtY+CC3gPa0i5cfq07VIVU8Pm7OosM7Q0CR/y88ntgVsscC0qJFwr/EU\ny7aJyBY9TInYqDPzMTeJVXsUwQ5gJut4ngFWk6kitDsJwFqqNFKmeLOj4repY5ee\n79U6kEHJzkOE8VgsH5nW4sjzDEQ9hmhOJ3tFz0ECgYEA8N+7yq1tK/99S8ThYW1J\n9mvUXRhAcFamBYp+8bIBdnQlrM9bGd9j8gYzQj+RBcvfCpVHFM20z8CC8oN0bitk\nh5MEjLBkw1vaywFlA/hcnA8A3g+5/IgHl03Y1tPWnyAtB77vE2M2ThklZ5l4E8eT\nP1vYw9RUSAPjtd43XDTqPNQ=\n-----END PRIVATE KEY-----\n",
+  "client_email": "tester@psyched-ceiling-413920.iam.gserviceaccount.com",
+  "client_id": "100697987276606879445",
+  "auth_uri": "https://accounts.google.com/o/oauth2/auth",
+  "token_uri": "https://oauth2.googleapis.com/token",
+  "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
+  "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/tester%40psyched-ceiling-413920.iam.gserviceaccount.com",
+  "universe_domain": "googleapis.com"
+}

fastfood/repository/dish.py

@@ -13,7 +13,7 @@ class DishRepository:
     def __init__(self, session: AsyncSession = Depends(get_async_session)) -> None:
         self.db = session
 
-    async def get_dishes(self, submenu_id: UUID) -> list[Dish]:
+    async def get_dishes(self, menu_id: UUID, submenu_id: UUID) -> list[Dish]:
         query = select(Dish).where(
             Dish.parent_submenu == submenu_id,
         )
@@ -22,6 +22,7 @@ class DishRepository:
 
     async def create_dish_item(
         self,
+        menu_id: UUID,
         submenu_id: UUID,
         dish_data: Dish_db,
     ) -> Dish:
@@ -34,6 +35,8 @@ class DishRepository:
 
     async def get_dish_item(
         self,
+        menu_id: UUID,
+        submenu_id: UUID,
         dish_id: UUID,
     ) -> Dish | None:
         query = select(Dish).where(Dish.id == dish_id)
@@ -42,6 +45,8 @@ class DishRepository:
 
     async def update_dish_item(
         self,
+        menu_id: UUID,
+        submenu_id: UUID,
         dish_id: UUID,
         dish_data: Dish_db,
     ) -> Dish | None:
@@ -54,6 +59,8 @@ class DishRepository:
 
     async def delete_dish_item(
         self,
+        menu_id: UUID,
+        submenu_id: UUID,
         dish_id: UUID,
     ) -> None:
         query = delete(Dish).where(Dish.id == dish_id)

fastfood/repository/submenu.py

@@ -32,13 +32,14 @@ class SubMenuRepository:
         await self.db.commit()
         await self.db.refresh(new_submenu)
 
-        full_sub = await self.get_submenu_item(new_submenu.id)
+        full_sub = await self.get_submenu_item(menu_id, new_submenu.id)
         if full_sub is None:
             raise TypeError
         return full_sub
 
     async def get_submenu_item(
         self,
+        menu_id: UUID,
         submenu_id: UUID,
     ) -> SubMenu | None:
         s = aliased(SubMenu)
@@ -55,6 +56,7 @@ class SubMenuRepository:
 
     async def update_submenu_item(
         self,
+        menu_id: UUID,
         submenu_id: UUID,
         submenu_data: MenuBase,
     ) -> SubMenu | None:
@@ -69,7 +71,7 @@ class SubMenuRepository:
         updated_submenu = await self.db.execute(qr)
         return updated_submenu.scalar_one_or_none()
 
-    async def delete_submenu_item(self, submenu_id: UUID) -> None:
+    async def delete_submenu_item(self, menu_id: UUID, submenu_id: UUID) -> None:
         query = delete(SubMenu).where(
             SubMenu.id == submenu_id,
         )

fastfood/repository/summary.py

@@ -1,5 +1,3 @@
-from typing import Any
-
 from fastapi import Depends
 from sqlalchemy import select
 from sqlalchemy.ext.asyncio import AsyncSession
@@ -13,7 +11,7 @@ class SummaryRepository:
     def __init__(self, session: AsyncSession = Depends(get_async_session)) -> None:
         self.db = session
 
-    async def get_data(self) -> list[Any]:
+    async def get_data(self):
         query = select(Menu).options(
             selectinload(Menu.submenus).selectinload(SubMenu.dishes)
         )

fastfood/routers/dish.py

@@ -1,6 +1,6 @@
 from uuid import UUID
 
-from fastapi import APIRouter, Depends, HTTPException
+from fastapi import APIRouter, BackgroundTasks, Depends, HTTPException
 
 from fastfood.schemas import Dish, DishBase
 from fastfood.service.dish import DishService
@@ -19,6 +19,7 @@ async def get_dishes(
     menu_id: UUID,
     submenu_id: UUID,
     dish: DishService = Depends(),
+    background_tasks: BackgroundTasks = BackgroundTasks(),
 ) -> list[Dish]:
     result = await dish.read_dishes(menu_id, submenu_id)
     return result
@@ -34,6 +35,7 @@ async def create_dish(
     submenu_id: UUID,
     dish_data: DishBase,
     dish: DishService = Depends(),
+    background_tasks: BackgroundTasks = BackgroundTasks(),
 ) -> Dish:
     return await dish.create_dish(
         menu_id,
@@ -51,6 +53,7 @@ async def get_dish(
     submenu_id: UUID,
     dish_id: UUID,
     dish: DishService = Depends(),
+    background_tasks: BackgroundTasks = BackgroundTasks(),
 ) -> Dish | None:
     result = await dish.read_dish(
         menu_id,
@@ -75,6 +78,7 @@ async def update_dish(
     dish_id: UUID,
     dish_data: DishBase,
     dish: DishService = Depends(),
+    background_tasks: BackgroundTasks = BackgroundTasks(),
 ) -> Dish:
     result = await dish.update_dish(
         menu_id,
@@ -98,5 +102,6 @@ async def delete_dish(
     submenu_id: UUID,
     dish_id: UUID,
     dish: DishService = Depends(),
+    background_tasks: BackgroundTasks = BackgroundTasks(),
 ) -> None:
-    await dish.del_dish(menu_id, dish_id)
+    await dish.del_dish(menu_id, submenu_id, dish_id)

fastfood/routers/menu.py

@@ -1,6 +1,6 @@
 from uuid import UUID
 
-from fastapi import APIRouter, Depends, HTTPException
+from fastapi import APIRouter, BackgroundTasks, Depends, HTTPException
 
 from fastfood.schemas import MenuBase, MenuRead
 from fastfood.service.menu import MenuService
@@ -18,6 +18,7 @@ router = APIRouter(
 )
 async def get_menus(
     menu: MenuService = Depends(),
+    background_tasks: BackgroundTasks = BackgroundTasks(),
 ) -> list[MenuRead]:
     return await menu.read_menus()
 
@@ -30,6 +31,7 @@ async def get_menus(
 async def add_menu(
     menu: MenuBase,
     responce: MenuService = Depends(),
+    background_tasks: BackgroundTasks = BackgroundTasks(),
 ) -> MenuRead:
     return await responce.create_menu(menu)
 
@@ -41,6 +43,7 @@ async def add_menu(
 async def get_menu(
     menu_id: UUID,
     responce: MenuService = Depends(),
+    background_tasks: BackgroundTasks = BackgroundTasks(),
 ) -> MenuRead:
     result = await responce.read_menu(menu_id=menu_id)
 
@@ -60,6 +63,7 @@ async def update_menu(
     menu_id: UUID,
     menu: MenuBase,
     responce: MenuService = Depends(),
+    background_tasks: BackgroundTasks = BackgroundTasks(),
 ) -> MenuRead:
     result = await responce.update_menu(
         menu_id=menu_id,
@@ -81,5 +85,6 @@ async def update_menu(
 async def delete_menu(
     menu_id: UUID,
     menu: MenuService = Depends(),
+    background_tasks: BackgroundTasks = BackgroundTasks(),
 ) -> None:
     await menu.del_menu(menu_id)

fastfood/routers/submenu.py

@@ -1,6 +1,6 @@
 from uuid import UUID
 
-from fastapi import APIRouter, Depends, HTTPException
+from fastapi import APIRouter, BackgroundTasks, Depends, HTTPException
 
 from fastfood.schemas import MenuBase, SubMenuRead
 from fastfood.service.submenu import SubmenuService
@@ -18,6 +18,7 @@ router = APIRouter(
 async def get_submenus(
     menu_id: UUID,
     submenu: SubmenuService = Depends(),
+    background_tasks: BackgroundTasks = BackgroundTasks(),
 ) -> list[SubMenuRead]:
     result = await submenu.read_submenus(menu_id=menu_id)
     return result
@@ -32,6 +33,7 @@ async def create_submenu_item(
     menu_id: UUID,
     submenu_data: MenuBase,
     submenu: SubmenuService = Depends(),
+    background_tasks: BackgroundTasks = BackgroundTasks(),
 ) -> SubMenuRead:
     result = await submenu.create_submenu(
         menu_id=menu_id,
@@ -48,6 +50,7 @@ async def get_submenu(
     menu_id: UUID,
     submenu_id: UUID,
     submenu: SubmenuService = Depends(),
+    background_tasks: BackgroundTasks = BackgroundTasks(),
 ) -> SubMenuRead:
     result = await submenu.read_menu(
         menu_id=menu_id,
@@ -70,6 +73,7 @@ async def update_submenu(
     submenu_id: UUID,
     submenu_data: MenuBase,
     submenu: SubmenuService = Depends(),
+    background_tasks: BackgroundTasks = BackgroundTasks(),
 ) -> SubMenuRead:
     result = await submenu.update_submenu(
         menu_id=menu_id,
@@ -92,5 +96,6 @@ async def delete_submenu(
     menu_id: UUID,
     submenu_id: UUID,
     submenu: SubmenuService = Depends(),
+    background_tasks: BackgroundTasks = BackgroundTasks(),
 ) -> None:
     await submenu.del_menu(menu_id=menu_id, submenu_id=submenu_id)

fastfood/routers/summary.py

@@ -1,4 +1,4 @@
-from fastapi import APIRouter, Depends
+from fastapi import APIRouter, BackgroundTasks, Depends
 
 from fastfood.schemas import MenuSummary
 from fastfood.service.summary import SummaryService
@@ -12,5 +12,6 @@ router = APIRouter(
 @router.get('/', response_model=list[MenuSummary])
 async def get_summary(
     sum: SummaryService = Depends(),
+    background_tasks: BackgroundTasks = BackgroundTasks(),
 ) -> list[MenuSummary]:
     return await sum.read_data()

fastfood/service/dish.py

@@ -42,7 +42,7 @@ class DishService:
         if cached_dishes is not None:
             return cached_dishes
 
-        data = await self.dish_repo.get_dishes(submenu_id)
+        data = await self.dish_repo.get_dishes(menu_id, submenu_id)
         response = []
         for row in data:
             dish = await self._convert_dish_to_dict(row)
@@ -67,6 +67,7 @@ class DishService:
     ) -> Dish:
         dish_db = Dish_db(**dish_data.model_dump())
         data = await self.dish_repo.create_dish_item(
+            menu_id,
             submenu_id,
             dish_db,
         )
@@ -94,7 +95,7 @@ class DishService:
         if cached_dish is not None:
             return cached_dish
 
-        data = await self.dish_repo.get_dish_item(dish_id)
+        data = await self.dish_repo.get_dish_item(menu_id, submenu_id, dish_id)
         if data is None:
             return None
         dish = await self._convert_dish_to_dict(data)
@@ -115,7 +116,9 @@ class DishService:
         self, menu_id: UUID, submenu_id: UUID, dish_id, dish_data: DishBase
     ) -> Dish | None:
         dish_db = Dish_db(**dish_data.model_dump())
-        data = await self.dish_repo.update_dish_item(dish_id, dish_db)
+        data = await self.dish_repo.update_dish_item(
+            menu_id, submenu_id, dish_id, dish_db
+        )
 
         if data is None:
             return None
@@ -136,8 +139,10 @@ class DishService:
 
         return dish
 
-    async def del_dish(self, menu_id: UUID, dish_id: UUID) -> None:
+    async def del_dish(self, menu_id: UUID, submenu_id: UUID, dish_id: UUID) -> None:
         await self.dish_repo.delete_dish_item(
+            menu_id,
+            submenu_id,
             dish_id,
         )
         await self.cache.delete(key=str(menu_id), bg_task=self.bg_tasks)

fastfood/service/submenu.py

@@ -33,7 +33,7 @@ class SubmenuService:
         submenus = []
         for r in data:
             submenu = r.__dict__
-            subq = await self.submenu_repo.get_submenu_item(r.id)
+            subq = await self.submenu_repo.get_submenu_item(menu_id, r.id)
             if subq is not None:
                 submenu['dishes_count'] = len(subq.dishes)
             submenu = SubMenuRead(**submenu)
@@ -73,7 +73,7 @@ class SubmenuService:
         if cached_submenu is not None:
             return cached_submenu
 
-        data = await self.submenu_repo.get_submenu_item(submenu_id)
+        data = await self.submenu_repo.get_submenu_item(menu_id, submenu_id)
         if data is None:
             return None
         submenu = data.__dict__
@@ -90,7 +90,9 @@ class SubmenuService:
     async def update_submenu(
         self, menu_id: UUID, submenu_id: UUID, submenu_data: MenuBase
     ) -> SubMenuRead | None:
-        data = await self.submenu_repo.update_submenu_item(submenu_id, submenu_data)
+        data = await self.submenu_repo.update_submenu_item(
+            menu_id, submenu_id, submenu_data
+        )
         if data is None:
             return None
 
@@ -109,7 +111,7 @@ class SubmenuService:
         return submenu
 
     async def del_menu(self, menu_id: UUID, submenu_id: UUID) -> None:
-        await self.submenu_repo.delete_submenu_item(submenu_id)
+        await self.submenu_repo.delete_submenu_item(menu_id, submenu_id)
         await self.cache.delete(
             key=self.key(
                 'submenu',

fastfood/service/summary.py

@@ -19,7 +19,7 @@ class SummaryService:
         self.key = get_key
         self.bg_tasks = background_tasks
 
-    async def read_data(self) -> list[MenuSummary]:
+    async def read_data(self):
 
         result = []