Niveau 4 : Pipelines Transactionnels et Temps Réel

1from abc import ABC, abstractmethod
2from typing import List, Dict, Any
3import logging
4
5class SagaStep(ABC):
6    def __init__(self, name: str):
7        self.name = name
8        self.compensation = None
9    
10    @abstractmethod
11    def execute(self, context: Dict[str, Any]) -> bool:
12        pass
13    
14    @abstractmethod
15    def compensate(self, context: Dict[str, Any]) -> bool:
16        pass
17
18class InventoryReservationStep(SagaStep):
19    def __init__(self):
20        super().__init__("Inventory Reservation")
21    
22    def execute(self, context: Dict[str, Any]) -> bool:
23        try:
24            inventory_id = context.get('inventory_id')
25            quantity = context.get('quantity')
26            
27            if self._reserve_inventory(inventory_id, quantity):
28                context['inventory_reserved'] = True
29                return True
30            return False
31        except Exception as e:
32            logging.error(f"Failed to reserve inventory: {e}")
33            return False
34    
35    def compensate(self, context: Dict[str, Any]) -> bool:
36        try:
37            inventory_id = context.get('inventory_id')
38            quantity = context.get('quantity')
39            
40            if context.get('inventory_reserved'):
41                self._release_inventory(inventory_id, quantity)
42                context['inventory_reserved'] = False
43            return True
44        except Exception as e:
45            logging.error(f"Failed to compensate inventory: {e}")
46            return False