অফলাইন-ফার্স্ট ডেটা স্ট্র্যাটেজি

# ---------- লোকাল স্টোরেজ + পেন্ডিং সিঙ্ক কিউ ----------
local_notes = {}          # লোকাল "ডেটাবেস" -- key: note_id
pending_sync_queue = []   # প্রতিটি এন্ট্রি: {"op":.., "note_id":.., "data":..}
_next_id = 1

def create_note_locally(title, body):
    global _next_id
    note_id = _next_id
    _next_id += 1
    note = {"id": note_id, "title": title, "body": body, "synced": False}
    local_notes[note_id] = note                                     # লোকাল স্টেট সাথে সাথে আপডেট
    pending_sync_queue.append({"op": "create", "note_id": note_id, "data": dict(note)})
    print(f"[লোকাল] নোট #{note_id} তৈরি হলো: {note}")
    return note_id

def update_note_locally(note_id, **changes):
    local_notes[note_id].update(changes)                            # লোকাল স্টেট সাথে সাথে আপডেট
    pending_sync_queue.append({"op": "update", "note_id": note_id, "data": dict(changes)})
    print(f"[লোকাল] নোট #{note_id} আপডেট হলো: {local_notes[note_id]}")

# ---------- ইউজার অফলাইনে থাকলেও এই তিনটি রাইট তাৎক্ষণিক সফল হয় ----------
create_note_locally("Grocery list", "Milk, eggs")
create_note_locally("Trip plan", "Flights, hotel")
update_note_locally(1, pinned=True)

print(f"\nsync() কল করার আগেই লোকাল ডেটা সম্পূর্ণ ব্যবহারযোগ্য:")
print(f"  local_notes = {local_notes}")
print(f"  পেন্ডিং সিঙ্ক কিউতে অপেক্ষমান: {len(pending_sync_queue)}টি অপারেশন "
      f"{[e['op']+'#'+str(e['note_id']) for e in pending_sync_queue]}")

# ---------- সিমুলেটেড রিমোট সার্ভার + ডিটারমিনিস্টিক ফ্লেকি নেটওয়ার্ক ----------
remote_notes = {}
FAIL_PLAN = {2: 2}        # note_id 2 প্রথম ২ বার ব্যর্থ হবে, ৩য় চেষ্টায় সফল -- ডিটারমিনিস্টিক
_attempts_made = {}

def _send_to_remote(entry):
    note_id = entry["note_id"]
    must_fail = FAIL_PLAN.get(note_id, 0)
    _attempts_made[note_id] = _attempts_made.get(note_id, 0) + 1
    attempt = _attempts_made[note_id]
    if attempt <= must_fail:
        return False
    if entry["op"] == "create":
        remote_notes[note_id] = dict(entry["data"])
    elif entry["op"] == "update":
        remote_notes.setdefault(note_id, {}).update(entry["data"])
    return True

def sync(max_attempts=4, base_delay=0.5, max_delay=4.0):
    print("--- sync() শুরু ---")
    remaining = []
    for entry in pending_sync_queue:
        op_label = f"{entry['op']}#{entry['note_id']}"
        synced = False
        for attempt in range(max_attempts):
            ok = _send_to_remote(entry)
            if ok:
                print(f"  {op_label}: চেষ্টা {attempt + 1} -- সফল")
                synced = True
                break
            delay = min(base_delay * (2 ** attempt), max_delay)
            print(f"  {op_label}: চেষ্টা {attempt + 1} -- ব্যর্থ, {delay:.2f}s ব্যাকঅফের পর আবার চেষ্টা")
        if synced:
            local_notes[entry["note_id"]]["synced"] = True
        else:
            print(f"  {op_label}: সর্বোচ্চ {max_attempts} চেষ্টার পরও ব্যর্থ -- কিউতেই থেকে যাবে")
            remaining.append(entry)
    pending_sync_queue[:] = remaining
    print(f"--- sync() শেষ -- বাকি পেন্ডিং এন্ট্রি: {len(pending_sync_queue)}টি ---")

sync()

print(f"\nremote_notes = {remote_notes}")
print(f"local_notes  = {local_notes}")
print(f"পেন্ডিং সিঙ্ক কিউ (sync()-এর পর): {pending_sync_queue}")