From 9d6d7913ce8bf76717f75d7d4845a61f4889da80 Mon Sep 17 00:00:00 2001
From: tv <tv@krebsco.de>
Date: Fri, 6 Nov 2026 04:35:12 +0100
Subject: other wire versions warned

---
 src/transport/tor.rs | 6 ++++++
 1 file changed, 6 insertions(+)

(limited to 'src/transport/tor.rs')

diff --git a/src/transport/tor.rs b/src/transport/tor.rs
index a08a5d0..c194330 100644
--- a/src/transport/tor.rs
+++ b/src/transport/tor.rs
@@ -192,6 +192,7 @@ struct Shared {
     probes: mpsc::Sender<Inbound>,
     /// Whose messages may be large (`transport::Admission`).
     admission: std::sync::OnceLock<crate::transport::Admission>,
+    other_versions: wire::OtherVersions,
 }
 
 fn lock<T>(mutex: &Mutex<T>) -> MutexGuard<'_, T> {
@@ -303,6 +304,7 @@ impl TorTransport {
             inbound,
             probes,
             admission: std::sync::OnceLock::new(),
+            other_versions: wire::OtherVersions::default(),
         });
         let (stopping, stopped) = watch::channel(false);
         {
@@ -566,6 +568,10 @@ impl Shared {
             }
             let message = match wire::decode(&body) {
                 Ok(message) => message,
+                Err(wire::WireError::Version(version)) => {
+                    self.other_versions.note(SCHEME, location, version);
+                    continue;
+                }
                 Err(error) => {
                     debug!(peer = %Addressed(SCHEME, &location), error = %error, "Dropping a message that doesn't decode");
                     continue;
-- 
cgit v1.3.1