Server-Sent Events ও পোলিং বিকল্প

# ---------- একই ইভেন্ট সিকোয়েন্স -- নতুন ডেটা শুধু টিক ৩ ও ৭-এ ----------
updates_source = {
    3: "নতুন অর্ডার: #1042",
    7: "নতুন অর্ডার: #1043",
}


# ---------- পদ্ধতি ১ -- POLLING ----------
def check_for_updates(tick):
    """প্রতিটি কলই একটি প্রকৃত নেটওয়ার্ক রাউন্ড-ট্রিপ -- উত্তর None হলেও কলটা হয়েই গেছে।"""
    return updates_source.get(tick)  # নতুন কিছু না থাকলে None


poll_call_count = 0
poll_received = []

print("=== POLLING ===")
for tick in range(1, 11):
    poll_call_count += 1  # প্রতিটি টিকেই একটি কল হয়, ফলাফল যা-ই হোক
    result = check_for_updates(tick)
    if result is not None:
        poll_received.append((tick, result))
        print(f"[Polling] টিক {tick}: নতুন ডেটা -> {result}")
    else:
        print(f"[Polling] টিক {tick}: কল করা হলো, কিছুই নতুন নেই")

print(f"\nমোট পোলিং নেটওয়ার্ক কল: {poll_call_count}")
print(f"এর মধ্যে আসলে দরকারি ছিল (নতুন ডেটা পাওয়া গেছে): {len(poll_received)}")


# ---------- পদ্ধতি ২ -- PUSH (L45-এর Broker পুনরায় ব্যবহার) ----------
class Broker:
    def __init__(self):
        self.subscribers = {}

    def subscribe(self, channel, callback):
        self.subscribers.setdefault(channel, []).append(callback)

    def publish(self, channel, message):
        for callback in self.subscribers.get(channel, []):
            callback(message)


push_call_count = 0


def client_handler(message):
    global push_call_count
    push_call_count += 1
    print(f"[Push] সার্ভার push করলো -> {message}")


broker = Broker()
broker.subscribe("orders", client_handler)

print("\n=== PUSH (Broker) ===")
for tick in range(1, 11):
    if tick in updates_source:
        broker.publish("orders", updates_source[tick])  # শুধু তখনই কল, যখন সত্যিই ডেটা আছে
    # অন্য টিকগুলোতে broker.publish() একবারও কল করা হয়নি -- কোনো নেটওয়ার্ক কলই নেই

print(f"\nমোট push নেটওয়ার্ক কল (client_handler আসলে কতবার কল হয়েছে): {push_call_count}")

print(f"\n--- তুলনা ---")
print(f"Polling: {poll_call_count} টি কল, এর মধ্যে {len(poll_received)} টি দরকারি ছিল")
print(f"Push:    {push_call_count} টি কল, সবগুলোই দরকারি ছিল")