ইভেন্ট-ড্রিভেন আর্কিটেকচার

class EventBus:
    def __init__(self):
        self.subscribers = {}  # event_type -> handler function-দের লিস্ট

    def subscribe(self, event_type, handler):
        self.subscribers.setdefault(event_type, []).append(handler)

    def publish(self, event_type, data):
        for handler in self.subscribers.get(event_type, []):
            handler(data)


class OrderService:
    def __init__(self, bus):
        self.bus = bus  # OrderService শুধু bus-কে চেনে, কোনো consumer-কে সরাসরি চেনে না

    def place_order(self, order_id, item):
        print(f"OrderService: অর্ডার #{order_id} তৈরি হলো ({item})")
        self.bus.publish("OrderPlaced", {"order_id": order_id, "item": item})


class EmailService:
    def handle_order_placed(self, data):
        print(f"  EmailService: কনফার্মেশন ইমেইল পাঠানো হলো -- অর্ডার #{data['order_id']}")


class InventoryService:
    def handle_order_placed(self, data):
        print(f"  InventoryService: স্টক থেকে '{data['item']}' বিয়োগ করা হলো")


class AnalyticsService:
    def handle_order_placed(self, data):
        print(f"  AnalyticsService: অর্ডার #{data['order_id']} অ্যানালিটিক্সে লগ করা হলো")


bus = EventBus()
order_service = OrderService(bus)
email_service = EmailService()
inventory_service = InventoryService()

# ধাপ ১: দুইজন consumer সাবস্ক্রাইব করছে
bus.subscribe("OrderPlaced", email_service.handle_order_placed)
bus.subscribe("OrderPlaced", inventory_service.handle_order_placed)

print("== প্রথম অর্ডার (২ জন consumer সাবস্ক্রাইবড) ==")
order_service.place_order(101, "ল্যাপটপ")

# ধাপ ২: তৃতীয় consumer যোগ -- OrderService-এর কোডে কোনো পরিবর্তন লাগেনি
analytics_service = AnalyticsService()
bus.subscribe("OrderPlaced", analytics_service.handle_order_placed)

print()
print("== দ্বিতীয় অর্ডার (৩ জন consumer সাবস্ক্রাইবড, OrderService অপরিবর্তিত) ==")
order_service.place_order(102, "মাউস")