সব user RAM-এ → একে একে FCM call → request এখনো খোলা

API শুধু job তৈরি করবে, queue-তে রাখবে, log লিখবে, তারপর সঙ্গে সঙ্গে 200 OK.

Queue থেকে job → database থেকে user page-by-page → পুরো ৫ লাখ কখনো RAM-এ আসে না।

skip: 495000 মানে Postgres আগে সেই row-গুলো পড়ে, তারপর ফেলে। Cursor সরাসরি last ID থেকে শুরু করে।

FCM এক call-এ সর্বোচ্চ ৫০০ token। তাই ৫ লাখ device = প্রায় ১,০০০ batch call.

সর্বোচ্চ ১০ batch/sec → ১০ × ৫০০ = ৫,০০০ notification/sec.

Worker → FCM → হাজার হাজার ফোন। Offline device থাকলে FCM ধরে রাখে, online হলে পৌঁছে দেয়।

Admin double-click, retry, বা দুই worker একই job তুললেও SET key value NX EX — শুধু প্রথমজন ঢুকবে।

BullMQ: attempts 3 + exponential backoff → 10s → 20s → 40s. Poison job অসীম সময় worker দখল করে রাখে না।

FCM invalid / unregistered token ফেরত দিলে isValid=false. পরের campaign-এ সেগুলো query-তেই আসে না।

Cache expire-এর মুহূর্তে ১০,০০০ user একসাথে DB-তে গেলে database শেষ। তাই singleFlight + Redis distributed lock.