পুশ নোটিফিকেশন

# একটি সত্যিকারের Broker -- টপিক-ভিত্তিক pub-sub, সরাসরি ডেলিভারি

class Broker:
    def __init__(self):
        self._subscribers = {}  # topic (str) -> callback-দের লিস্ট

    def subscribe(self, topic, callback):
        self._subscribers.setdefault(topic, []).append(callback)
        print(f"  [subscribe] topic={topic!r} -> {callback.__name__}")

    def publish(self, topic, payload):
        handlers = self._subscribers.get(topic, [])
        print(f"  [publish]   topic={topic!r} payload={payload} -> {len(handlers)}টি সাবস্ক্রাইবার")
        for callback in handlers:
            callback(payload)

def log_chat_analytics(payload):
    print(f"    [analytics] চ্যাট নোটিফিকেশন লগ হলো: id={payload['id']}")

broker = Broker()
broker.subscribe("chat_message", log_chat_analytics)

print("\n== একটি chat_message পাবলিশ করা হলো ==")
broker.publish("chat_message", {"id": 482, "preview": "তুমি কি কাল আসবে?"})

print("\n== একটি টপিক পাবলিশ করা হলো যার কোনো সাবস্ক্রাইবার নেই ==")
broker.publish("promo_offer", {"id": 1})

# একটি self-contained নেভিগেশন স্ট্যাক

class NavigationStack:
    def __init__(self, root):
        self._stack = [root]

    def push(self, screen):
        self._stack.append(screen)

    def current(self):
        return self._stack[-1]

    def __repr__(self):
        return " > ".join(self._stack)

nav_stack = NavigationStack("Home")

# Broker-কে নেভিগেশন স্ট্যাকের সাথে জুড়ে দেওয়া হচ্ছে -- ডেলিভারি -> push()
def on_chat_notification_tap(payload):
    """নোটিফিকেশনে ট্যাপ করলে -- payload অনুযায়ী নির্দিষ্ট স্ক্রিন নেভিগেশন স্ট্যাকে push হয়"""
    target_screen = f"ChatThread(id={payload['id']})"
    nav_stack.push(target_screen)
    print(f"    [handler:chat_message] push('{target_screen}')")

def on_friend_request_tap(payload):
    target_screen = f"FriendRequest(id={payload['id']})"
    nav_stack.push(target_screen)
    print(f"    [handler:friend_request] push('{target_screen}')")

nav_broker = Broker()
nav_broker.subscribe("chat_message", on_chat_notification_tap)
nav_broker.subscribe("friend_request", on_friend_request_tap)

print(f"\nট্যাপের আগে স্ট্যাক: {nav_stack}")

# একটি concrete নোটিফিকেশন পেলোড -- ইউজার এই চ্যাট নোটিফিকেশনে ট্যাপ করলো
chat_payload = {"id": 482, "preview": "তুমি কি কাল আসবে?"}
nav_broker.publish("chat_message", chat_payload)

print(f"\nট্যাপের পরে স্ট্যাক: {nav_stack}")
print(f"বর্তমান স্ক্রিন: {nav_stack.current()}")