TCP রিলায়েবল ডেলিভারি — সিকোয়েন্স নাম্বার ও ACK

# আউট-অফ-অর্ডার আগমন ও পুনর্গঠন সিমুলেশন — টয় ইন-মেমরি ডেটা, কোনো প্রকৃত নেটওয়ার্ক নয়

original_message = "TCP গ্যারান্টি দেয় যে সব বাইট সঠিক ক্রমে পৌঁছাবে।"
chunk_texts = ["TCP গ্যারান্টি দেয় ", "যে সব বাইট ", "সঠিক ক্রমে ", "পৌঁছাবে।"]

# প্রতিটি চাংকের seq_number = মূল স্ট্রিমে তার শুরুর বাইট-পজিশন
seq = 0
ordered_chunks = []
for text in chunk_texts:
    ordered_chunks.append((seq, text))
    seq += len(text)

# নেটওয়ার্কে IP কোনো অর্ডার গ্যারান্টি দেয় না -- ইচ্ছাকৃতভাবে এলোমেলো ক্রমে "গ্রহণ" করা হলো
received_chunks = [ordered_chunks[2], ordered_chunks[0], ordered_chunks[3], ordered_chunks[1]]

print("আউট-অফ-অর্ডার গ্রহণ করা চাংক (sequence_number, data):")
for seq_num, data in received_chunks:
    print(f"  seq={seq_num}: {data!r}")

def reassemble(chunks):
    """সিকোয়েন্স নাম্বার অনুযায়ী সাজিয়ে মূল বাইট-স্ট্রিম পুনর্গঠন করে।"""
    ordered = sorted(chunks, key=lambda c: c[0])
    return "".join(data for _, data in ordered)

reassembled = reassemble(received_chunks)
print("\nপুনর্গঠিত বার্তা:", reassembled)
print("মূল বার্তার সাথে মিলছে?", reassembled == original_message)
assert reassembled == original_message

def cumulative_ack_progress(arrival_order):
    """যেসব বাইট এ পর্যন্ত ধারাবাহিকভাবে (গ্যাপ ছাড়া) পাওয়া গেছে, তার ঠিক পরের বাইট-নাম্বারকে
    cumulative ACK হিসেবে রিপোর্ট করে -- আগমনের ঠিক ক্রম অনুযায়ী, একটি একটি করে চাংক বাফারে যোগ করে।"""
    buffer = {}
    next_expected = 0
    log = []
    for seq_num, data in arrival_order:
        buffer[seq_num] = data
        while next_expected in buffer:
            next_expected += len(buffer[next_expected])
        log.append((seq_num, next_expected))
    return log

print("\nকিউমুলেটিভ ACK-এর অগ্রগতি (আগমনের ক্রম অনুযায়ী):")
for arrived_seq, ack_after in cumulative_ack_progress(received_chunks):
    print(f"  chunk seq={arrived_seq} এলো -> cumulative ACK (পরবর্তী প্রত্যাশিত বাইট) = {ack_after}")