purchase fix

Author: ilyarolf

repositories/item.py

@@ -58,10 +58,11 @@ async def get_by_id_map(item_ids: list[int], session: AsyncSession | Session) ->
         return {item.id: item for item in items if item.id is not None}
 
     @staticmethod
-    async def get_purchased_items(category_id: int, subcategory_id: int, quantity: int,
+    async def get_purchased_items(item_type: ItemType, category_id: int, subcategory_id: int, quantity: int,
                                   session: Session | AsyncSession) -> list[ItemDTO]:
         stmt = (select(Item)
-                .where(Item.category_id == category_id,
+                .where(Item.item_type == item_type,
+                       Item.category_id == category_id,
                        Item.subcategory_id == subcategory_id,
                        Item.is_sold == False)
                 .limit(quantity)

services/cart.py

@@ -350,7 +350,8 @@ async def buy_processing(callback: CallbackQuery,
                              status=BuyStatus.PAID if shipping_option else BuyStatus.COMPLETED)
             buy_dto = await BuyRepository.create(buy_dto, session)
             for cart_item in cart_items:
-                purchased_items = await ItemRepository.get_purchased_items(cart_item.category_id,
+                purchased_items = await ItemRepository.get_purchased_items(cart_item.item_type,
+                                                                           cart_item.category_id,
                                                                            cart_item.subcategory_id, cart_item.quantity,
                                                                            session)
                 item_ids = [item.id for item in purchased_items]