Merge branch 'dev' into fix-test

Author: pavel-kirienko

README.md

@@ -1,4 +1,4 @@
-# Yakut
+# Yakut – Cyphal CLI tool
 
 <!--suppress CheckImageSize, HtmlDeprecatedAttribute -->
 <img src="/docs/opencyphal-favicon-512.png" alt="OpenCyphal logo" width=128 align=right>
@@ -23,8 +23,6 @@ Afterward do endeavor to read the docs: **`yakut --help`**
 
 Check for new versions every now and then: **`pip install --upgrade yakut`**
 
-Installation & configuration screencasts are available for [Windows](https://forum.opencyphal.org/t/screencast-of-installing-configuring-yakut/1197/2?u=pavel.kirienko), [GNU/Linux](https://forum.opencyphal.org/t/screencast-of-installing-configuring-yakut/1197/1?u=pavel.kirienko), and [macOS](https://www.youtube.com/watch?v=dQw4w9WgXcQ).
-
 ### Additional third-party tools
 
 Since Yakut heavily relies on YAML/JSON documents exchanged via stdin/stdout, [**`jq`**](https://stedolan.github.io/jq/) is often needed for any non-trivial usage of the tool, so consider installing it as well. Users of GNU/Linux will likely find it in the default software repositories (`pacman -S jq`, `apt install jq`, etc.).
@@ -33,9 +31,9 @@ Since Yakut heavily relies on YAML/JSON documents exchanged via stdin/stdout, [*
 
 Transport layer inspection tools:
 
+- [Wireshark](https://www.wireshark.org/) with [Cyphal plugins](https://github.com/OpenCyphal/wireshark_plugins)
+  (n.b.: some versions of Wireshark may label Cyphal/CAN captures as UAVCAN/CAN due to rebranding).
 - Cyphal/CAN on GNU/Linux (candump, canbusload, etc.): [`can-utils`](https://github.com/linux-can/can-utils)
-- Cyphal/UDP or Cyphal/CAN: [Wireshark](https://www.wireshark.org/)
-  (n.b.: Wireshark might label Cyphal captures as UAVCAN due to rebranding)
 
 ## Invoking commands
 

tests/cmd/file_server.py

@@ -48,7 +48,7 @@ async def _unittest_file_server_pnp(compiled_dsdl: typing.Any) -> None:
         ),
     )
     try:
-        fc = FileClient(cln_node, 42, response_timeout=15.0)
+        fc = FileClient(cln_node, 42, response_timeout=30.0)  # Large timeout is needed for Windows CI.
         await asyncio.sleep(3.0)  # Let the server initialize.
         assert srv_proc.alive
 

tests/cmd/pubsub.py

@@ -103,9 +103,9 @@ def _unittest_pub_sub_regular(transport_factory: TransportFactory, compiled_dsdl
     time.sleep(1.0)  # Time to sync up
 
     # Parse the output from the subscribers and validate it.
-    out_sub_heartbeat = proc_sub_heartbeat.wait(1.0, interrupt=True)[1].splitlines()
-    out_sub_diagnostic = proc_sub_diagnostic.wait(1.0, interrupt=True)[1].splitlines()
-    out_sub_temperature = proc_sub_temperature.wait(1.0, interrupt=True)[1].splitlines()
+    out_sub_heartbeat = proc_sub_heartbeat.wait(5, interrupt=True)[1].splitlines()
+    out_sub_diagnostic = proc_sub_diagnostic.wait(5, interrupt=True)[1].splitlines()
+    out_sub_temperature = proc_sub_temperature.wait(5, interrupt=True)[1].splitlines()
 
     heartbeats = list(map(json.loads, out_sub_heartbeat))
     diagnostics = list(map(json.loads, out_sub_diagnostic))
@@ -142,7 +142,7 @@ def _unittest_pub_sub_regular(transport_factory: TransportFactory, compiled_dsdl
     assert all(map(lambda mt: mt["555"]["kelvin"] == pytest.approx(123.456), temperatures))
 
     assert proc_sub_diagnostic_wrong_pid.alive
-    assert proc_sub_diagnostic_wrong_pid.wait(1.0, interrupt=True)[1].strip() == ""
+    assert proc_sub_diagnostic_wrong_pid.wait(5, interrupt=True)[1].strip() == ""
 
 
 def _unittest_slow_cli_pub_sub_anon(transport_factory: TransportFactory, compiled_dsdl: typing.Any) -> None:
@@ -187,9 +187,9 @@ def _unittest_slow_cli_pub_sub_anon(transport_factory: TransportFactory, compile
 
     time.sleep(2.0)  # Time to sync up
 
-    assert proc_sub_heartbeat.wait(1.0, interrupt=True)[1].strip() == "", "Anonymous nodes must not broadcast heartbeat"
+    assert proc_sub_heartbeat.wait(5, interrupt=True)[1].strip() == "", "Anonymous nodes must not broadcast heartbeat"
 
-    diagnostics = list(json.loads(s) for s in proc_sub_diagnostic_with_meta.wait(1.0, interrupt=True)[1].splitlines())
+    diagnostics = list(json.loads(s) for s in proc_sub_diagnostic_with_meta.wait(5, interrupt=True)[1].splitlines())
     print("diagnostics:", diagnostics)
     # Remember that anonymous transfers over redundant transports are NOT deduplicated.
     # Hence, to support the case of redundant transports, we use 'greater or equal' here.
@@ -201,7 +201,7 @@ def _unittest_slow_cli_pub_sub_anon(transport_factory: TransportFactory, compile
         assert m["8184"]["timestamp"]["microsecond"] == 0
         assert m["8184"]["text"] == ""
 
-    diagnostics = list(json.loads(s) for s in proc_sub_diagnostic_no_meta.wait(1.0, interrupt=True)[1].splitlines())
+    diagnostics = list(json.loads(s) for s in proc_sub_diagnostic_no_meta.wait(5, interrupt=True)[1].splitlines())
     print("diagnostics:", diagnostics)
     assert len(diagnostics) >= 2  # >= because see above
     for m in diagnostics: