src: lib: Parse messages using the message's protocol, not the preferred protocol

joaoantoniocardoso · patrickelectric · commit 2d6d875b09b9 · 2026-01-05T15:25:42.000-03:00
diff --git a/src/lib/protocol.rs b/src/lib/protocol.rs
@@ -65,12 +65,9 @@ impl Protocol {
     {
         let mut reader = mavlink::async_peek_reader::AsyncPeekReader::new(self.as_slice());
 
-        match cli::mavlink_version() {
-            1 => mavlink::read_v1_msg_async::<M, _>(&mut reader).await,
-            2 => mavlink::read_v2_msg_async::<M, _>(&mut reader).await,
-            _ => unreachable!(),
-        }
-        .map_err(anyhow::Error::msg)
+        mavlink::read_any_msg_async(&mut reader)
+            .await
+            .map_err(anyhow::Error::msg)
     }
 
     pub async fn to_mavlink_json<M>(&self) -> Result<MAVLinkJSON<M>>

Original file line number	Diff line number	Diff line change
`@@ -65,12 +65,9 @@ impl Protocol {`
`65`	`65`	`{`
`66`	`66`	`let mut reader = mavlink::async_peek_reader::AsyncPeekReader::new(self.as_slice());`
`67`	`67`
`68`		`- match cli::mavlink_version() {`
`69`		`- 1 => mavlink::read_v1_msg_async::<M, _>(&mut reader).await,`
`70`		`- 2 => mavlink::read_v2_msg_async::<M, _>(&mut reader).await,`
`71`		`- _ => unreachable!(),`
`72`		`- }`
`73`		`- .map_err(anyhow::Error::msg)`
	`68`	`+ mavlink::read_any_msg_async(&mut reader)`
	`69`	`+ .await`
	`70`	`+ .map_err(anyhow::Error::msg)`
`74`	`71`	`}`
`75`	`72`
`76`	`73`	`pub async fn to_mavlink_json<M>(&self) -> Result<MAVLinkJSON<M>>`