মোবাইলে রিয়েল-টাইম আপডেট — পুশ ও WebSocket

# পুশ বনাম WebSocket ডেলিভারি -- সব AppLifecycle স্টেটের বিপরীতে পরীক্ষা

class AppLifecycle:
    ALLOWED = {
        'not_running': {'foreground'},
        'foreground':  {'background'},
        'background':  {'foreground', 'killed'},
        'killed':      set(),
    }

    def __init__(self, state='foreground'):
        self.state = state


def deliver_push(app_state, payload):
    # OS-এর নিজস্ব পুশ সার্ভিস ডেলিভার করে -- অ্যাপ প্রসেস killed থাকলেও এটি ডেলিভার হতে পারে
    return {
        "delivered": True,
        "via": "OS push service",
        "app_state": app_state,
        "payload": payload,
    }


def deliver_websocket_message(app_state, payload, undelivered_queue):
    # অ্যাপের নিজস্ব প্রসেসের ভেতরে চলা সংযোগ -- killed অবস্থায় সংযোগও বেঁচে থাকে না
    if app_state in ("foreground", "background"):
        return {
            "delivered": True,
            "via": "in-app WebSocket",
            "app_state": app_state,
            "payload": payload,
        }
    undelivered_queue.append(payload)
    return {
        "delivered": False,
        "via": "in-app WebSocket",
        "app_state": app_state,
        "reason": "সংযোগ killed অবস্থায় বেঁচে থাকে না -- মেসেজ ডেলিভার করা যায়নি",
    }


states_to_test = ["foreground", "background", "killed"]
undelivered_queue = []

print("-- পুশ নোটিফিকেশন ডেলিভারি --")
for state in states_to_test:
    result = deliver_push(state, "নতুন মেসেজ এসেছে")
    print(f"state={state:10s} -> delivered={result['delivered']}  via={result['via']}")

print("\n-- WebSocket মেসেজ ডেলিভারি --")
for state in states_to_test:
    result = deliver_websocket_message(state, f"চ্যাট আপডেট ({state})", undelivered_queue)
    print(f"state={state:10s} -> delivered={result['delivered']}  via={result['via']}")

print(f"\nkilled অবস্থায় ডেলিভার না হয়ে জমে থাকা WebSocket মেসেজ: {undelivered_queue}")