CoAP প্রোটোকল

class CoapServer:
    """একটি সরলীকৃত CoAP সার্ভার -- কিছু রিসোর্স পাথ ধরে রাখে।"""

    def __init__(self):
        self.resources = {
            "/sensors/temperature": 24.5,
            "/sensors/humidity": 61,
        }
        self._next_mid = 1

    def new_message_id(self):
        mid = self._next_mid
        self._next_mid += 1
        return mid


def simulate_con_request(server, path, ack_lost_count=0, ack_timeout=2.0, max_retransmit=4):
    """একটি CON GET রিকোয়েস্ট সিমুলেট করে। ack_lost_count = প্রথম কতগুলো
    চেষ্টার ACK হারিয়ে যাবে (সিমুলেটেড নেটওয়ার্ক লস)। প্রতিটি লসের পর
    টাইমআউট এক্সপোনেনশিয়ালি দ্বিগুণ হয় (RFC 7252-এর ব্যাকঅফ নিয়ম)।"""
    mid = server.new_message_id()
    log = [f"ক্লায়েন্ট -> সার্ভার: CON GET {path} (Message-ID={mid})"]
    timeout = ack_timeout
    total_wait = 0.0

    for attempt in range(max_retransmit + 1):  # attempt 0 = আসল পাঠানো, ১..৪ = রিট্রান্সমিট
        if attempt < ack_lost_count:
            log.append(f"  চেষ্টা #{attempt + 1}: {timeout:.1f}s অপেক্ষার পর কোনো ACK এলো না (হারিয়ে গেছে, সিমুলেটেড)")
            total_wait += timeout
            timeout *= 2  # এক্সপোনেনশিয়াল ব্যাকঅফ
            if attempt < max_retransmit:
                log.append(f"  ক্লায়েন্ট পুনরায় পাঠালো: CON GET {path} (Message-ID={mid}, চেষ্টা #{attempt + 2})")
            continue

        value = server.resources.get(path)
        if value is not None:
            log.append(f"  চেষ্টা #{attempt + 1}: ACK 2.05 Content প্রাপ্ত (Message-ID={mid}), payload={value!r}")
            return {"success": True, "attempts": attempt + 1, "total_wait_s": total_wait, "log": log}
        else:
            log.append(f"  চেষ্টা #{attempt + 1}: রিসোর্স পাওয়া যায়নি -> 4.04 Not Found (Message-ID={mid})")
            return {"success": False, "attempts": attempt + 1, "total_wait_s": total_wait, "log": log}

    log.append(f"MAX_RETRANSMIT ({max_retransmit}) অতিক্রান্ত, মোট অপেক্ষা {total_wait:.1f}s -> অনুরোধ ব্যর্থ")
    return {"success": False, "attempts": max_retransmit + 1, "total_wait_s": total_wait, "log": log}


server = CoapServer()

print("== দৃশ্য ১: কোনো লস নেই, সাথে সাথে ACK ==")
result1 = simulate_con_request(server, "/sensors/temperature", ack_lost_count=0)
for line in result1["log"]:
    print(line)
print(f"  ফলাফল: success={result1['success']}, মোট চেষ্টা={result1['attempts']}, মোট অপেক্ষা={result1['total_wait_s']}s")

print("\n== দৃশ্য ২: প্রথম ২টি ACK হারিয়ে যায়, তৃতীয় চেষ্টায় সফল ==")
result2 = simulate_con_request(server, "/sensors/temperature", ack_lost_count=2)
for line in result2["log"]:
    print(line)
print(f"  ফলাফল: success={result2['success']}, মোট চেষ্টা={result2['attempts']}, মোট অপেক্ষা={result2['total_wait_s']}s")

print("\n== দৃশ্য ৩: সবগুলো চেষ্টাই হারিয়ে যায় -> MAX_RETRANSMIT ছাড়িয়ে ব্যর্থ ==")
result3 = simulate_con_request(server, "/sensors/temperature", ack_lost_count=10)
for line in result3["log"]:
    print(line)
print(f"  ফলাফল: success={result3['success']}, মোট চেষ্টা={result3['attempts']}, মোট অপেক্ষা={result3['total_wait_s']}s")