mirror of
https://github.com/permissionlesstech/bitchat.git
synced 2026-07-26 23:05:19 +00:00
Code is a better thing to argue with than prose, so the spec now has a working, tested base under it. Every number and context string is a concrete proposal you can reject by changing one function and watching a test vector move. What is implemented: - PeerIDRotation: hour epochs with a ±1 matching window, the rotation secret from the Noise static *private* key, per-epoch peer IDs, pairwise recognition keys and tags from an X25519 shared secret, the fixed-width tag block with CSPRNG padding and constant-time matching, and the canonical bytes for the identity binding. - AnnounceV2Packet (announceV2 = 0x05): TLV wire format carrying an epoch, a 64-byte tag block, capabilities and an optional bridge cell — and nothing else. No nickname, no public keys, no neighbour list. Rejects a wrong-width tag block on both encode and decode, since a short block would disclose how many mutual favourites someone has, and rejects non-canonical capability encodings the way AuthenticatedPeerStatePacket does. Unknown TLVs are skipped for forward compatibility. - 37 tests, three of which are hex vectors cross-checked against an independent implementation written from the spec alone (Python hmac/hashlib, HKDF extract-then-expand, empty salt) and matching byte for byte. That is the property Android needs: the document is sufficient to reproduce the numbers without reading this code. What is deliberately NOT implemented: nothing emits a v2 announce, and BLEService parses the type and explicitly ignores it. Consuming presence needs both the replacement identity binding and a decision on how unverified presence appears in the peer list, and accepting it now would put unauthenticated entries in front of people. Adding the message type forced three policy decisions, all reviewable: - Not gossip-synced. Syncing presence would defeat the point — a device never in radio range could collect tag blocks, turning a local beacon into a network-wide one. - Not padded. At ~75 bytes the smallest bucket would triple the airtime of the most frequent packet in the protocol; the format is already near-constant width, and fixing the capability and geohash field widths would be cheaper than padding. - Parsed but ignored on receive, as above. Notably the v2 announce is *smaller* than v1 (~75 vs ~229 bytes): dropping two 32-byte keys, the neighbour list and the signature more than pays for 64 bytes of tags, so unlinkability here costs less airtime rather than more. Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
154 lines
6.1 KiB
Swift
154 lines
6.1 KiB
Swift
import Foundation
|
|
import Testing
|
|
@testable import BitFoundation
|
|
|
|
/// Wire-format tests for the identity-free announce. These are the second half
|
|
/// of the cross-platform contract: Android must encode and decode byte-identical
|
|
/// packets, so anything asserted here is a promise, not an implementation detail.
|
|
struct AnnounceV2PacketTests {
|
|
private var block: Data {
|
|
Data(repeating: 0xAB, count: AnnounceV2Packet.tagBlockLength)
|
|
}
|
|
|
|
@Test func typeValueIsStable() {
|
|
// Changing this breaks every deployed decoder. 0x05 was free; 0x01-0x04,
|
|
// 0x10-0x11 and 0x20-0x29 were already taken.
|
|
#expect(MessageType.announceV2.rawValue == 0x05)
|
|
#expect(MessageType(rawValue: 0x05) == .announceV2)
|
|
#expect(MessageType.announceV2.description == "announceV2")
|
|
}
|
|
|
|
@Test func tagBlockIsSixtyFourBytes() {
|
|
#expect(AnnounceV2Packet.tagBlockLength == 64)
|
|
}
|
|
|
|
@Test func roundTripsWithEveryField() throws {
|
|
let packet = AnnounceV2Packet(
|
|
epoch: 495_555,
|
|
tagBlock: block,
|
|
capabilities: [.bridge, .prekeys],
|
|
bridgeGeohash: "u4pruy"
|
|
)
|
|
let encoded = try #require(packet.encode())
|
|
let decoded = try #require(AnnounceV2Packet.decode(from: encoded))
|
|
#expect(decoded == packet)
|
|
}
|
|
|
|
@Test func roundTripsWithOnlyRequiredFields() throws {
|
|
let packet = AnnounceV2Packet(epoch: 0, tagBlock: block)
|
|
let encoded = try #require(packet.encode())
|
|
let decoded = try #require(AnnounceV2Packet.decode(from: encoded))
|
|
#expect(decoded == packet)
|
|
#expect(decoded.capabilities == nil)
|
|
#expect(decoded.bridgeGeohash == nil)
|
|
}
|
|
|
|
@Test func epochIsBigEndianOnTheWire() throws {
|
|
let encoded = try #require(AnnounceV2Packet(epoch: 0x0102_0304, tagBlock: block).encode())
|
|
// TLV 0x01, length 4, then the epoch most-significant byte first.
|
|
#expect(Array(encoded.prefix(6)) == [0x01, 0x04, 0x01, 0x02, 0x03, 0x04])
|
|
}
|
|
|
|
/// The whole point of the format: none of the identifying v1 fields appear.
|
|
@Test func encodingCarriesNoIdentity() throws {
|
|
let noiseKey = Data(repeating: 0x11, count: 32)
|
|
let signingKey = Data(repeating: 0x22, count: 32)
|
|
let nickname = Data("alice".utf8)
|
|
|
|
let encoded = try #require(
|
|
AnnounceV2Packet(
|
|
epoch: 100,
|
|
tagBlock: block,
|
|
capabilities: [.bridge],
|
|
bridgeGeohash: "u4pruy"
|
|
).encode()
|
|
)
|
|
|
|
#expect(!encoded.contains(noiseKey))
|
|
#expect(!encoded.contains(signingKey))
|
|
#expect(encoded.range(of: nickname) == nil)
|
|
}
|
|
|
|
@Test func encodingIsSmallerThanAV1Announce() throws {
|
|
let v2 = try #require(
|
|
AnnounceV2Packet(epoch: 100, tagBlock: block, capabilities: [.bridge]).encode()
|
|
)
|
|
// v1 with a 10-byte nickname and a full neighbour list, before its
|
|
// 64-byte signature: nickname 12 + noise 34 + signing 34 + neighbours 82
|
|
// + capabilities 3.
|
|
let v1PayloadEstimate = 12 + 34 + 34 + 82 + 3
|
|
#expect(v2.count < v1PayloadEstimate)
|
|
}
|
|
|
|
// MARK: - Rejection
|
|
|
|
@Test func encodeRejectsAWrongWidthTagBlock() {
|
|
// A short block would disclose the favourite count, so it must never go
|
|
// on the wire.
|
|
#expect(AnnounceV2Packet(epoch: 1, tagBlock: Data(repeating: 0, count: 63)).encode() == nil)
|
|
#expect(AnnounceV2Packet(epoch: 1, tagBlock: Data(repeating: 0, count: 65)).encode() == nil)
|
|
#expect(AnnounceV2Packet(epoch: 1, tagBlock: Data()).encode() == nil)
|
|
}
|
|
|
|
@Test func encodeRejectsAnOversizedGeohash() {
|
|
#expect(AnnounceV2Packet(
|
|
epoch: 1,
|
|
tagBlock: block,
|
|
bridgeGeohash: String(repeating: "u", count: 13)
|
|
).encode() == nil)
|
|
}
|
|
|
|
@Test func decodeRequiresEpochAndTagBlock() throws {
|
|
// Capabilities alone is not a valid announce.
|
|
var onlyCapabilities = Data([0x03, 0x01])
|
|
onlyCapabilities.append(PeerCapabilities([.bridge]).encoded())
|
|
#expect(AnnounceV2Packet.decode(from: onlyCapabilities) == nil)
|
|
|
|
// Epoch without a tag block is not either.
|
|
let onlyEpoch = Data([0x01, 0x04, 0x00, 0x00, 0x00, 0x64])
|
|
#expect(AnnounceV2Packet.decode(from: onlyEpoch) == nil)
|
|
}
|
|
|
|
@Test func decodeRejectsTruncatedAndMalformedInput() {
|
|
#expect(AnnounceV2Packet.decode(from: Data()) == nil)
|
|
// Declares 4 bytes, supplies 2.
|
|
#expect(AnnounceV2Packet.decode(from: Data([0x01, 0x04, 0x00, 0x00])) == nil)
|
|
// Dangling type byte with no length.
|
|
#expect(AnnounceV2Packet.decode(from: Data([0x01])) == nil)
|
|
// Wrong epoch width.
|
|
#expect(AnnounceV2Packet.decode(from: Data([0x01, 0x02, 0x00, 0x64])) == nil)
|
|
}
|
|
|
|
@Test func decodeRejectsAWrongWidthTagBlock() {
|
|
var data = Data([0x01, 0x04, 0x00, 0x00, 0x00, 0x64])
|
|
data.append(0x02)
|
|
data.append(UInt8(63))
|
|
data.append(Data(repeating: 0xAB, count: 63))
|
|
#expect(AnnounceV2Packet.decode(from: data) == nil)
|
|
}
|
|
|
|
@Test func decodeRejectsNonCanonicalCapabilities() throws {
|
|
// Same capability set, non-minimal encoding: it must not be accepted, or
|
|
// one set could travel as several distinct byte strings.
|
|
var data = Data([0x01, 0x04, 0x00, 0x00, 0x00, 0x64])
|
|
data.append(0x02)
|
|
data.append(UInt8(AnnounceV2Packet.tagBlockLength))
|
|
data.append(block)
|
|
data.append(0x03)
|
|
data.append(UInt8(3))
|
|
data.append(Data([0x80, 0x00, 0x00])) // trailing zero bytes are non-minimal
|
|
#expect(AnnounceV2Packet.decode(from: data) == nil)
|
|
}
|
|
|
|
@Test func unknownTLVsAreSkippedForForwardCompatibility() throws {
|
|
var data = try #require(AnnounceV2Packet(epoch: 100, tagBlock: block).encode())
|
|
data.append(0x7F) // a type this build has never heard of
|
|
data.append(UInt8(3))
|
|
data.append(Data([0x01, 0x02, 0x03]))
|
|
|
|
let decoded = try #require(AnnounceV2Packet.decode(from: data))
|
|
#expect(decoded.epoch == 100)
|
|
#expect(decoded.tagBlock == block)
|
|
}
|
|
}
|