diff options
| author | tv <tv@krebsco.de> | 2026-11-02 23:07:14 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-02 23:07:14 +0100 |
| commit | 173005a254f04e22c2a7049032fe5e993ac28a74 (patch) | |
| tree | 34bc85959ddd3783ef21fc5932b96a25d9807c35 /src/transport/wire.rs | |
| parent | f76a4e835071d8c88b7db49641d5b5e35a6dcdd8 (diff) | |
swarm: relay links messages
Diffstat (limited to 'src/transport/wire.rs')
| -rw-r--r-- | src/transport/wire.rs | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/src/transport/wire.rs b/src/transport/wire.rs index 26d8f32..d72fba4 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(), + }], }), ] } |
