breaking: the effect-stack lifecycle (#58): transports own their link, options, and sizing

examples/ble/helloworld.py

@@ -16,7 +16,8 @@ async def main() -> None:
     print(f"Found {len(smp_servers)} SMP servers: {smp_servers}")
 
     print("Connecting to the first SMP server...", end="", flush=True)
-    async with SMPClient(SMPBLETransport(), smp_servers[0].address) as client:
+    async with SMPBLETransport().connected(smp_servers[0].address) as transport:
+        client = SMPClient(transport)
         print("OK")
 
         print("Sending request...", end="", flush=True)

examples/ble/imagestate.py

@@ -16,7 +16,8 @@ async def main() -> None:
     print(f"Found {len(smp_servers)} SMP servers: {smp_servers}")
 
     print("Connecting to the first SMP server...", end="", flush=True)
-    async with SMPClient(SMPBLETransport(), smp_servers[0].address) as client:
+    async with SMPBLETransport().connected(smp_servers[0].address) as transport:
+        client = SMPClient(transport)
         print("OK")
 
         print("Sending request...", end="", flush=True)

examples/ble/mcumgrparameters.py

@@ -16,7 +16,8 @@ async def main() -> None:
     print(f"Found {len(smp_servers)} SMP servers: {smp_servers}")
 
     print("Connecting to the first SMP server...", end="", flush=True)
-    async with SMPClient(SMPBLETransport(), smp_servers[0].address) as client:
+    async with SMPBLETransport().connected(smp_servers[0].address) as transport:
+        client = SMPClient(transport)
         print("OK")
         print(f"Client MTU is {client._transport.mtu}B")
         print(f"Client max unencoded size is {client._transport.max_unencoded_size}B")

examples/ble/upgrade.py

@@ -64,7 +64,8 @@ async def main() -> None:
     print("OK")
 
     print("Connecting to A SMP DUT...", end="", flush=True)
-    async with SMPClient(SMPBLETransport(), a_smp_dut.name or a_smp_dut.address) as client:
+    async with SMPBLETransport().connected(a_smp_dut.name or a_smp_dut.address) as transport:
+        client = SMPClient(transport)
         print("OK")
 
         async def ensure_request(request: SMPRequest[TRep, TEr1, TEr2]) -> TRep:
@@ -119,7 +120,8 @@ async def ensure_request(request: SMPRequest[TRep, TEr1, TEr2]) -> TRep:
     b_smp_dut = cast(BLEDevice, b_smp_dut)
 
     print("Connecting to B SMP DUT...", end="", flush=True)
-    async with SMPClient(SMPBLETransport(), b_smp_dut.name or b_smp_dut.address) as client:
+    async with SMPBLETransport().connected(b_smp_dut.name or b_smp_dut.address) as transport:
+        client = SMPClient(transport)
         print("OK")
 
         print()

examples/ble/upload.py

@@ -30,9 +30,10 @@ async def main() -> None:
     print(f"Found {len(smp_servers)} SMP servers: {smp_servers}")
 
     print("Connecting to the first SMP server...", end="", flush=True)
-    async with SMPClient(
-        SMPBLETransport(), smp_servers[0].name or smp_servers[0].address
-    ) as client:
+    async with SMPBLETransport().connected(
+        smp_servers[0].name or smp_servers[0].address
+    ) as transport:
+        client = SMPClient(transport)
         print("OK")
 
         print("Sending request...", end="", flush=True)

examples/udp/helloworld.py

@@ -18,7 +18,8 @@ async def main() -> None:
     parser.add_argument("address", help="The IP address to connect to")
     address = parser.parse_args().address
 
-    async with SMPClient(SMPUDPTransport(), address) as client:
+    async with SMPUDPTransport().connected(address) as transport:
+        client = SMPClient(transport)
         print("OK")
 
         print("Sending request...", end="", flush=True)

examples/usb/download_file.py

@@ -16,7 +16,8 @@ async def main() -> None:
     port = args.port
     file_location = args.file_location
 
-    async with SMPClient(SMPSerialTransport(), port) as client:
+    async with SMPSerialTransport().connected(port) as transport:
+        client = SMPClient(transport)
         start_s = time.time()
         file_data = await client.download_file(file_location)
         end_s = time.time()

examples/usb/helloworld.py

@@ -15,7 +15,8 @@ async def main() -> None:
     parser.add_argument("port", help="The serial port to connect to")
     port = parser.parse_args().port
 
-    async with SMPClient(SMPSerialTransport(), port) as client:
+    async with SMPSerialTransport().connected(port) as transport:
+        client = SMPClient(transport)
         print("OK")
 
         print("Sending request...", end="", flush=True)

examples/usb/upgrade.py

@@ -105,15 +105,10 @@ async def main() -> None:
     await asyncio.sleep(1)
 
     print("Connecting to SMP DUT...", end="", flush=True)
-    async with SMPClient(
-        SMPSerialTransport(
-            fragmentation_strategy=BufferParams(
-                line_length=line_length,
-                line_buffers=line_buffers,
-            )
-        ),
-        port_a.device,
-    ) as client:
+    async with SMPSerialTransport(
+        BufferParams(line_length=line_length, line_buffers=line_buffers)
+    ).connected(port_a.device) as transport:
+        client = SMPClient(transport)
         print("OK")
 
         async def ensure_request(request: SMPRequest[TRep, TEr1, TEr2]) -> TRep:
@@ -185,15 +180,10 @@ async def ensure_request(request: SMPRequest[TRep, TEr1, TEr2]) -> TRep:
     print(f"OK - found DUT B at {port_b.device}")
 
     print("Connecting to B SMP DUT...", end="", flush=True)
-    async with SMPClient(
-        SMPSerialTransport(
-            fragmentation_strategy=BufferParams(
-                line_length=line_length,
-                line_buffers=line_buffers,
-            )
-        ),
-        port_b.device,
-    ) as client:
+    async with SMPSerialTransport(
+        BufferParams(line_length=line_length, line_buffers=line_buffers)
+    ).connected(port_b.device) as transport:
+        client = SMPClient(transport)
         print("OK")
 
         print()

examples/usb/upload_file.py

@@ -64,7 +64,8 @@ async def main() -> None:
 Etiam elit velit, posuere ut pulvinar ac, condimentum eget justo. Fusce a erat velit. Vivamus
 imperdiet ultrices orci in hendrerit.
 """
-    async with SMPClient(SMPSerialTransport(), port) as client:
+    async with SMPSerialTransport().connected(port) as transport:
+        client = SMPClient(transport)
         start_s = time.time()
         async for offset in client.upload_file(file_data=file_data, file_path=file_path):
             print(

pyproject.toml

@@ -25,7 +25,7 @@ dependencies = [
 "smp @ git+https://github.com/JPHutchins/smp@screaming-goblin",
 "msgspec>=0.21.1",
 "intelhex>=2.3.0",
-# `TypeIs` landed in 4.10; `override`/`assert_never`/`deprecated` are older
+# `TypeIs` landed in 4.10; `override`/`assert_never` are older
 "typing-extensions>=4.10",
 "async-timeout>=5.0.1; python_version < '3.11'",
 ]