2 files changed, 30 insertions, 3 deletions
diff --git a/src/transport/mod.rs b/src/transport/mod.rs
index 96f7651..b8b57af 100644
--- a/src/transport/mod.rs
+++ b/src/transport/mod.rs
@@ -409,8 +409,16 @@ pub(crate) struct LinksRequest {
     pub(crate) nonce: u64,
     /// For this long (seconds), a LINKS_REPLY again whenever the links change (a
     /// subscription; the next LINKS renews it). 0: this reply only, and a subscription
-    /// ends.
+    /// ends (a relayed one runs out instead).
     pub(crate) subscribe_secs: u32,
+    /// Members the receiver is to ask on the sender's behalf, which the sender can't
+    /// reach, passing their links on (relayed, `swarm::links`); none: the receiver's own.
+    pub(crate) of: Vec<String>,
+    /// How long relayed links may be held to send several in one LINKS_REPLY, by the
+    /// receiver and the hops after it together (milliseconds; `swarm::links`).
+    pub(crate) batch_ms: u32,
+    /// How many more nodes a relayed request may go through, after the receiver.
+    pub(crate) hops: u8,
 }
 
 /// LINKS_REPLY: how the sender is linked to its neighbours, as it measures them.
@@ -422,7 +430,18 @@ pub(crate) struct LinksReply {
     pub(crate) epoch_seq: u32,
     /// The request's.
     pub(crate) nonce: u64,
-    /// At most `swarm::links::MAX_LINKS`.
+    /// The sender's own, if asked for; at most `swarm::links::MAX_LINKS`.
+    pub(crate) links: Vec<Link>,
+    /// Other members' links, passed on (`LinksRequest::of`).
+    pub(crate) relayed: Vec<RelayedLinks>,
+}
+
+/// A member's links as a LINKS_REPLY passes them on.
+#[derive(Debug, Clone, Serialize, Deserialize)]
+pub(crate) struct RelayedLinks {
+    pub(crate) member: String,
+    /// How long ago the member reported them (milliseconds).
+    pub(crate) age_ms: u32,
     pub(crate) links: Vec<Link>,
 }
 
diff --git a/src/transport/wire.rs b/src/transport/wire.rs
index 7717200..0769e9a 100644
--- a/src/transport/wire.rs
+++ b/src/transport/wire.rs
@@ -14,7 +14,7 @@ use super::{EncodedMessage, MessageKind, ParsedMessage};
 
 /// The wire format's version, the first byte of every payload. Bump it with every change
 /// to a message type or a codec (`golden_bytes` fails then).
-pub(crate) const VERSION: u8 = 14;
+pub(crate) const VERSION: u8 = 15;
 
 /// What the second byte of a payload says.
 fn tag(kind: MessageKind) -> u8 {
@@ -428,6 +428,9 @@ pub(crate) fn samples() -> Vec<ParsedMessage> {
             epoch_seq: 1,
             nonce: 3,
             subscribe_secs: 60,
+            of: vec!["q".into()],
+            batch_ms: 250,
+            hops: 2,
         }),
         ParsedMessage::LinksReply(crate::transport::LinksReply {
             epoch,
@@ -450,6 +453,11 @@ pub(crate) fn samples() -> Vec<ParsedMessage> {
                     within_ms: 40,
                 }),
             }],
+            relayed: vec![crate::transport::RelayedLinks {
+                member: "q".into(),
+                age_ms: 1200,
+                links: Vec::new(),
+            }],
         }),
     ]
 }