diff options
| author | tv <tv@krebsco.de> | 2026-11-04 23:32:40 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-04 23:32:40 +0100 |
| commit | d9c61bd526fd83165d583cb5d75be66385611be4 (patch) | |
| tree | 639727ed0fd624b2607b4728995aca1edafaa054 /src/transport/wire.rs | |
| parent | 0203eeda95d31900dead926267e69575735e78c4 (diff) | |
time blob messages
Diffstat (limited to 'src/transport/wire.rs')
| -rw-r--r-- | src/transport/wire.rs | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/transport/wire.rs b/src/transport/wire.rs index d1b3353..b3a8ee9 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 = 26; +pub(crate) const VERSION: u8 = 27; /// What the second byte of a payload says. fn tag(kind: MessageKind) -> u8 { @@ -420,6 +420,7 @@ pub(crate) fn samples() -> Vec<ParsedMessage> { epoch_seq: 1, id: BlobId::Content([5; 32]), body: BlobBody::Missing, + sent: crate::clock::UnixMillis(9), }), ParsedMessage::Who(proof.clone()), ParsedMessage::Me(proof), @@ -603,6 +604,7 @@ mod tests { epoch_seq: 0, id: BlobId::Content([1; 32]), body: BlobBody::Missing, + sent: crate::clock::UnixMillis(2), }); let payload = encode(&blob).unwrap(); assert!(matches!(decode(&payload).unwrap(), ParsedMessage::Blob(_))); |
