dig_node_control_interface/results.rs
1//! Typed result payloads for the control methods.
2//!
3//! Each struct is field-for-field identical to what dig-node emits (snake_case wire fields), so a
4//! client deserializes the node's real response and re-serializes the same bytes — the property the
5//! conformance KATs pin. Genuinely open/proxied shapes (the updater beacon's status, the peer-pool
6//! snapshot, the pairing list) stay [`serde_json::Value`] on the call's `Output` rather than being
7//! frozen into a struct that would drift from the proxied source.
8
9use serde::{Deserialize, Serialize};
10
11/// The on-disk content-cache view (`control.cache.get`, and embedded in [`StatusResult`]).
12#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
13pub struct CacheView {
14 /// The configured cache size cap, in bytes.
15 pub cap_bytes: u64,
16 /// Bytes currently used on disk.
17 pub used_bytes: u64,
18 /// The cache directory.
19 pub dir: String,
20 /// Whether the cache directory is the machine-wide shared cache.
21 pub shared: bool,
22}
23
24/// The §21 sync availability flag embedded in [`StatusResult`].
25#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
26pub struct SyncAvailability {
27 /// Whether authenticated §21 whole-store sync is available on this node.
28 pub available: bool,
29}
30
31/// How much of its own build a node reveals when it advertises (dig_ecosystem#2215).
32///
33/// Advertising an exact build is a fingerprinting aid — it tells an observer precisely which peers
34/// run a version with a publicly disclosed defect. This is the operator's dial between that cost
35/// and the diagnostic value of knowing what the network is running.
36///
37/// It lives here, beside [`PeerSoftware`], because rendering and parsing are two halves of one
38/// format: a node that hand-rolled its own `product/version` string would be re-implementing half
39/// the contract, and the two halves would drift. A node picks a mode; this type renders it.
40#[derive(Debug, Clone, Copy, PartialEq, Eq, Default, Serialize, Deserialize)]
41#[serde(rename_all = "lowercase")]
42pub enum SoftwareVersionDetail {
43 /// Advertise the exact build, e.g. `dig-node/0.99.1`. The default: the diagnostic value is why
44 /// the field exists, and an operator who disagrees opts down explicitly.
45 #[default]
46 Full,
47 /// Advertise only the major and minor level, e.g. `dig-node/0.99.0`. Hides the patch level, and
48 /// any pre-release or build metadata, while remaining READABLE at the far end.
49 Minor,
50 /// Advertise nothing. Indistinguishable from a peer built before this field existed, and reads
51 /// as [`PeerSoftware::Unknown`].
52 Off,
53}
54
55impl SoftwareVersionDetail {
56 /// Render the advertisement a node with this setting puts on its handshake.
57 ///
58 /// The result is ALWAYS either the empty string or a value [`PeerSoftware::parse`] reads back
59 /// as `Reported`. Coarsening reduces PRECISION; it never produces a value that reads as
60 /// Unknown while pretending to be a report. Two consequences follow, and both are tested:
61 ///
62 /// - [`Minor`](SoftwareVersionDetail::Minor) renders `MAJOR.MINOR.0`, never a bare
63 /// `MAJOR.MINOR` — two-part versions are not valid semver, so that spelling would read as
64 /// Unknown and become a second, confusing spelling of [`Off`](SoftwareVersionDetail::Off).
65 /// - `Minor` of a `0.0.x` build renders the EMPTY STRING, because its coarsening is version
66 /// zero and version zero is the "unknown" sentinel. There is no coarser representable value,
67 /// so it advertises nothing rather than advertising the sentinel as if it were a report.
68 ///
69 /// A coarsened `1.4.0` is indistinguishable from a genuine `1.4.0`. That is the point of
70 /// coarsening, not a defect in it.
71 pub fn render(self, product: &str, version: &semver::Version) -> String {
72 match self {
73 Self::Full => format!("{product}/{version}"),
74 // A pre-release identifier (`-nightly.20260805`) is more precisely identifying than the
75 // patch number beside it, so a "coarse" advertisement that kept it would coarsen
76 // nothing for exactly the builds that most want it. `Version::new` drops both it and
77 // any build metadata.
78 Self::Minor => {
79 let coarsened = semver::Version::new(version.major, version.minor, 0);
80 // Hiding the patch of a `0.0.x` build leaves version zero, which the wire reserves
81 // as the "unknown" sentinel. There is no coarser representable value, so advertise
82 // nothing rather than advertise the sentinel dressed up as a report. (This differs
83 // from the rejected two-part `MAJOR.MINOR` spelling: there a representable coarse
84 // value existed and the wrong one was chosen; here none exists.)
85 if is_version_zero(&coarsened) {
86 return String::new();
87 }
88 format!("{product}/{coarsened}")
89 }
90 Self::Off => String::new(),
91 }
92 }
93}
94
95/// A peer's advertised SOFTWARE build, as read from the gossip handshake (dig_ecosystem#2215).
96///
97/// dig-gossip carries the peer's `Handshake.software_version` as an opaque sanitized string and
98/// deliberately does not interpret it. This type is where that string becomes meaning, once, at the
99/// control boundary — so the interpretation is defined in one place and every client agrees.
100///
101/// # This is NOT the protocol version
102///
103/// Wire compatibility is a separate field that dig-gossip gates connections on. Two peers can speak
104/// the same protocol while running builds months apart; this type reports the latter. It MUST NOT
105/// be used to decide whether to talk to a peer.
106///
107/// # Why there is no `Ord` and no `Default`
108///
109/// [`Unknown`](PeerSoftware::Unknown) has no position on a version line: it is the absence of a
110/// measurement, not a low value. Deriving `Ord` would place it somewhere — and every peer built
111/// before #2215 is Unknown, so "somewhere" would silently become a verdict about most of the live
112/// network. Comparison is therefore reachable only by destructuring
113/// [`Reported`](PeerSoftware::Reported), which forces the caller to say what Unknown means for
114/// their question. There is no `Default` for the same reason: a defaulted Unknown that appears from
115/// nowhere is a different fact from one that was measured, and the two must not be confusable.
116///
117/// # JSON
118///
119/// ```json
120/// {"kind": "unknown"}
121/// {"kind": "reported", "product": "dig-node", "version": "0.99.1", "raw": "dig-node/0.99.1"}
122/// ```
123///
124/// Unknown carries no `version` member at all — never version zero, never `""`, never `null` in a
125/// field a consumer might read as a version.
126#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
127#[serde(tag = "kind", rename_all = "snake_case")]
128pub enum PeerSoftware {
129 /// The peer's build is not known: it advertised nothing, advertised VERSION ZERO — the legacy
130 /// sentinel, in any decoration (`0.0.0`, `0.0.0-rc.1`, `0.0.0+build`) — or advertised something
131 /// this contract cannot parse. See [`PeerSoftware::parse`] for why those three are one case.
132 Unknown,
133 /// The peer advertised a well-formed `product/semver` build.
134 Reported {
135 /// The product name, e.g. `dig-node`. Everything before the LAST `/`.
136 product: String,
137 /// The parsed semantic version, e.g. `0.99.1`. Serializes as its string form.
138 version: semver::Version,
139 /// Exactly what the peer advertised, after trimming.
140 ///
141 /// **Currently reconstructible, deliberately kept.** The grammar this parser accepts is
142 /// lossless — `semver::Version` re-renders every string it accepts byte-identically — so
143 /// today `raw` always equals `format!("{product}/{version}")`, and no test can distinguish
144 /// this field from that expression. It is retained as the honest source: the moment the
145 /// grammar accepts anything non-canonical (a `v` prefix, a two-part version, a vendor
146 /// suffix), a diagnostic reader must see what the peer actually sent rather than this
147 /// parser's opinion of it, and callers that already read `raw` will not need to change.
148 raw: String,
149 },
150}
151
152/// Is this VERSION ZERO — the legacy "no version" sentinel, whatever it is dressed in?
153///
154/// Three of dig-gossip's four handshake send sites hardcoded `"0.0.0"` before dig_ecosystem#2215,
155/// so version zero is not a hypothetical value: it is what the live fleet is sending right now. It
156/// means "this build predates the field", which is [`PeerSoftware::Unknown`]; mapping it to a
157/// *version* would make the whole existing network read as ancient.
158///
159/// The test is over the major/minor/patch TRIPLE, ignoring any pre-release or build metadata. A
160/// peer advertising `0.0.0-rc.1` is no more versioned than one advertising `0.0.0`, and matching
161/// the bare string would let the decorated forms through as real builds at version zero.
162fn is_version_zero(version: &semver::Version) -> bool {
163 version.major == 0 && version.minor == 0 && version.patch == 0
164}
165
166/// The separator between the product and the version in a `product/semver` advertisement.
167const PRODUCT_VERSION_SEPARATOR: char = '/';
168
169impl PeerSoftware {
170 /// Interpret a peer's advertised `software_version` string.
171 ///
172 /// Returns [`Unknown`](PeerSoftware::Unknown) for an empty or blank string, for anything that
173 /// is not `product/semver` with both parts non-empty and the version parsing as semver, and for
174 /// any advertisement whose version is VERSION ZERO.
175 ///
176 /// Version zero is the legacy sentinel and is matched as a CLASS, not as a string: the bare
177 /// `0.0.0`, a product-qualified `dig-node/0.0.0`, and every decorated form (`0.0.0-rc.1`,
178 /// `0.0.0+build`, `0.0.0-0`) all mean "unversioned". A peer advertising `0.0.0-rc.1` is no more
179 /// versioned than one advertising `0.0.0`.
180 ///
181 /// A product name may contain `/`; the split is at the LAST separator.
182 pub fn parse(advertised: &str) -> Self {
183 let raw = advertised.trim();
184
185 // No separator at all: an empty advertisement, a bare version, a product with no version,
186 // or a bare version-zero sentinel (`0.0.0`, `0.0.0-rc.1`) — none of which contain a `/`, so
187 // they land here rather than needing a clause of their own. None of them name a build.
188 let Some((product, version)) = raw.rsplit_once(PRODUCT_VERSION_SEPARATOR) else {
189 return Self::Unknown;
190 };
191 if product.is_empty() {
192 return Self::Unknown;
193 }
194 let Ok(version) = version.parse::<semver::Version>() else {
195 return Self::Unknown;
196 };
197 // The sentinel is VERSION ZERO, a class — not the three-character string. Comparing the
198 // PARSED version is what makes `0.0.0+build`, `0.0.0-rc.1`, and `0.0.0-0` Unknown too; a
199 // string comparison would report each of them as a real build at version zero.
200 if is_version_zero(&version) {
201 return Self::Unknown;
202 }
203
204 Self::Reported {
205 product: product.to_string(),
206 version,
207 raw: raw.to_string(),
208 }
209 }
210}
211
212/// `control.status` — a rich node status snapshot.
213#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
214pub struct StatusResult {
215 /// Always `true` for a responding node.
216 pub running: bool,
217 /// The service name (`"dig-node"`).
218 pub service: String,
219 /// The node binary's semantic version.
220 pub version: String,
221 /// The git commit the binary was built from (or `"unknown"`).
222 pub commit: String,
223 /// The DIG read protocol version the node speaks.
224 pub protocol: String,
225 /// Process uptime in seconds.
226 pub uptime_secs: u64,
227 /// The loopback `host:port` the node is bound to.
228 pub addr: String,
229 /// The upstream DIG RPC the node proxies/syncs to.
230 pub upstream: String,
231 /// The on-disk cache view.
232 pub cache: CacheView,
233 /// Distinct stores held (from the cache).
234 pub hosted_store_count: u64,
235 /// Cached capsule count.
236 pub cached_capsule_count: u64,
237 /// Pinned-store count.
238 pub pinned_store_count: u64,
239 /// §21 sync availability.
240 pub sync: SyncAvailability,
241}
242
243/// `control.config.get` — the node's effective configuration.
244#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
245pub struct ConfigResult {
246 /// The bound `host:port`.
247 pub addr: String,
248 /// The bound port, as a string.
249 pub port: String,
250 /// The effective upstream DIG RPC.
251 pub upstream: String,
252 /// The persisted upstream override, or `null` when unset.
253 pub upstream_override: Option<String>,
254 /// The cache directory.
255 pub cache_dir: String,
256 /// Whether the cache is the machine-wide shared cache.
257 pub cache_shared: bool,
258 /// The node's config.json path.
259 pub config_path: String,
260 /// Whether authenticated §21 sync is available.
261 pub sync_available: bool,
262}
263
264/// `control.config.setUpstream` — the persisted override + a restart hint.
265#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
266pub struct SetUpstreamResult {
267 /// The normalized upstream that was persisted.
268 pub upstream: String,
269 /// Always `true` — the change takes effect on next node start.
270 pub requires_restart: bool,
271}
272
273/// `control.log.setLevel` — the applied filter directive.
274#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
275pub struct SetLevelResult {
276 /// The EnvFilter directive now in effect.
277 pub filter: String,
278}
279
280/// `control.cache.setCap` — the applied cap (after the 64 MiB floor).
281#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
282pub struct SetCapResult {
283 /// The cache cap now in effect, in bytes.
284 pub cap_bytes: u64,
285}
286
287/// `control.cache.clear` — the clear acknowledgement.
288#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
289pub struct CacheClearResult {
290 /// Always `true`.
291 pub cleared: bool,
292}
293
294/// One cached capsule of a store, as listed by the hosted-stores methods.
295#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
296pub struct CapsuleEntry {
297 /// The capsule reference (`storeId:rootHash`).
298 pub capsule: String,
299 /// The capsule root hash.
300 pub root: String,
301 /// The capsule size on disk, in bytes.
302 pub size_bytes: u64,
303 /// When the capsule was last served, in unix milliseconds.
304 pub last_used_unix_ms: u64,
305}
306
307/// One hosted/pinned store (`control.hostedStores.list`).
308#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
309pub struct HostedStore {
310 /// The canonical lowercase 64-hex store id.
311 pub store_id: String,
312 /// Whether the operator has pinned this store.
313 pub pinned: bool,
314 /// The number of cached capsules of this store.
315 pub capsule_count: u64,
316 /// The total cached bytes across this store's capsules.
317 pub total_bytes: u64,
318 /// The cached capsules of this store.
319 pub capsules: Vec<CapsuleEntry>,
320}
321
322/// `control.hostedStores.list` — every held/pinned store.
323#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
324pub struct HostedStoresListResult {
325 /// The stores, one entry per distinct store id.
326 pub stores: Vec<HostedStore>,
327}
328
329/// `control.hostedStores.pin` — the pin acknowledgement + the pre-fetch outcome.
330#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
331pub struct PinResult {
332 /// The store id that was pinned.
333 pub store_id: String,
334 /// The pinned root, or `null` when pinned at store level.
335 pub root: Option<String>,
336 /// Always `true`.
337 pub pinned: bool,
338 /// The in-band pre-fetch outcome (`{status, …}`) — its shape varies with the fetch path.
339 pub fetch: serde_json::Value,
340}
341
342/// `control.hostedStores.unpin` — the unpin acknowledgement + eviction count.
343#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
344pub struct UnpinResult {
345 /// The store id that was unpinned.
346 pub store_id: String,
347 /// Whether a pin registry entry was actually removed.
348 pub unpinned: bool,
349 /// How many cached capsules of the store were evicted.
350 pub evicted_capsules: u64,
351}
352
353/// `control.hostedStores.status` — per-store pinned flag + cached capsules.
354#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
355pub struct HostedStoreStatusResult {
356 /// The store id queried.
357 pub store_id: String,
358 /// Whether the store is pinned.
359 pub pinned: bool,
360 /// The number of cached capsules.
361 pub capsule_count: u64,
362 /// The total cached bytes.
363 pub total_bytes: u64,
364 /// The cached capsules.
365 pub capsules: Vec<CapsuleEntry>,
366}
367
368/// `control.sync.status` — §21 sync availability + pin coverage.
369#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
370pub struct SyncStatusResult {
371 /// Whether authenticated §21 whole-store sync is available.
372 pub available: bool,
373 /// The sync method name.
374 pub method: String,
375 /// The number of pinned stores.
376 pub pinned_total: u64,
377 /// How many pinned stores currently have a cached capsule.
378 pub pinned_synced: u64,
379 /// Whether whole-store (root-less) sync is supported by this build.
380 pub whole_store_trigger_supported: bool,
381}
382
383/// `control.sync.trigger` — the synced-capsule outcome.
384#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
385pub struct SyncTriggerResult {
386 /// The store id synced.
387 pub store_id: String,
388 /// The capsule root synced.
389 pub root: String,
390 /// The outcome status (`"synced"`).
391 pub status: String,
392 /// The synced capsule size, in bytes.
393 pub size_bytes: u64,
394 /// The served root the node verified against.
395 pub served_root: String,
396}
397
398/// `control.pairing.approve` — the mint acknowledgement + the new token's id.
399#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
400pub struct PairingApproveResult {
401 /// Always `true`.
402 pub approved: bool,
403 /// The requesting client's declared name.
404 pub client_name: String,
405 /// The short id of the minted paired token (used to revoke it).
406 pub token_id: String,
407}
408
409/// `control.pairing.revoke` — the revoke acknowledgement.
410#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
411pub struct PairingRevokeResult {
412 /// Whether a token was actually removed.
413 pub revoked: bool,
414 /// The token id that was targeted.
415 pub token_id: String,
416}
417
418/// `control.peers.connect` — the connected peer's id.
419#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
420pub struct PeersConnectResult {
421 /// Always `true` on success.
422 pub connected: bool,
423 /// The connected peer's id.
424 pub peer_id: String,
425}
426
427/// `control.peers.disconnect` — the dropped peer's id.
428#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
429pub struct PeersDisconnectResult {
430 /// Always `true` (idempotent — dropping an absent peer still succeeds).
431 pub disconnected: bool,
432 /// The peer id that was targeted (trimmed + lower-cased).
433 pub peer_id: String,
434}
435
436/// `control.subscribe` — the subscription acknowledgement.
437#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
438pub struct SubscribeResult {
439 /// Always `true`.
440 pub subscribed: bool,
441 /// Whether the store was newly added (vs already subscribed).
442 pub added: bool,
443 /// The canonical persisted store id (trimmed + lower-cased).
444 pub store_id: String,
445}
446
447/// `control.unsubscribe` — the unsubscription acknowledgement.
448#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
449pub struct UnsubscribeResult {
450 /// Always `false`.
451 pub subscribed: bool,
452 /// Whether the store was actually removed.
453 pub removed: bool,
454 /// The canonical store id.
455 pub store_id: String,
456}
457
458/// `control.listSubscriptions` — the node's persisted subscription set.
459#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
460pub struct ListSubscriptionsResult {
461 /// The subscribed store ids.
462 pub subscriptions: Vec<String>,
463 /// The subscription count.
464 pub count: u64,
465}
466
467/// `control.wallet.balance` — an address's balance for one asset, as the node's chain read saw it.
468///
469/// A READ-only result: this reports chain state, it never moves funds. It is a strict SUPERSET of
470/// dig-app's frozen `BalanceResponse { balance }` — the node emits the richer shape, and because
471/// dig-app's struct does not deny unknown fields it reads [`balance`](Self::balance) losslessly and
472/// ignores the rest. That superset relationship is the "no dig-app code change" guarantee, pinned by
473/// the conformance KAT.
474#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
475pub struct WalletBalanceResult {
476 /// The CONFIRMED, spendable balance in the asset's base unit (mojos for XCH, base units for DIG).
477 /// The only field dig-app 3.x reads.
478 pub balance: u64,
479 /// Incoming funds seen but not yet confirmed (asset base units); not yet spendable.
480 pub pending: u64,
481 /// Which tier produced these figures, or `None` from a node too old to disclose it.
482 ///
483 /// See [`WalletReadSource`]. Absent (`null` / omitted) is a THIRD state, not a default tier:
484 /// it means the answering node predates tier disclosure, so the caller knows the tier is
485 /// unknown rather than being told a tier that was never reported.
486 ///
487 /// The [`Option`] carries the backwards compatibility on its own — serde treats a missing
488 /// `Option` field as `None` — so no `#[serde(default)]` is needed and none is written; a
489 /// REQUIRED field here would reject an older node's payload outright.
490 pub source: Option<WalletReadSource>,
491 /// Whether THESE figures reflect a caught-up local view. When `false`, they are STALE or came
492 /// from the fallback tier.
493 ///
494 /// This describes the ANSWER, not the node: a [`WalletReadSource::Fallback`] answer is always
495 /// `false`, however caught-up the node's own replica happens to be.
496 pub synced: bool,
497 /// The peak block height the reported figures reflect, or `null` when no height applies —
498 /// including every [`WalletReadSource::Fallback`] answer, whose figures came from the oracle's
499 /// chain view rather than the node's.
500 pub peak_height: Option<u32>,
501}
502
503/// Which tier answered a wallet read (dig_ecosystem#2233).
504///
505/// A node serves a wallet read either from its own chain replica or from a third-party HTTP
506/// oracle, and the two are not interchangeable to a caller: the oracle path is a network round
507/// trip that **discloses the queried address off-node**, which a user on a metered or private
508/// connection has a legitimate interest in knowing about. Reporting the tier is also what makes
509/// "the node answered from its own chain state" a falsifiable claim — a sync-progress flag is not,
510/// since a flag can flip while the oracle keeps answering.
511#[derive(Debug, Clone, Copy, PartialEq, Eq, Serialize, Deserialize)]
512#[serde(rename_all = "lowercase")]
513pub enum WalletReadSource {
514 /// The node's own local chain replica. No third party was consulted.
515 Db,
516 /// A third-party coinset HTTP oracle. The queried value — an address, or a COIN ID on
517 /// `control.wallet.coinById` — was disclosed off-node.
518 ///
519 /// The coin-id case is the more sensitive of the two, and the less obvious: an address is
520 /// disclosed on every routine balance poll, whereas querying a freshly created coin id, from the
521 /// spender's IP, at the moment of the spend, hands the oracle a `{IP, timestamp, coin id}` tuple
522 /// that ties a network identity to a specific new on-chain identity.
523 Fallback,
524}
525
526/// One coin, as the node's chain read saw it (`control.wallet.coins` / `control.wallet.coinById`).
527///
528/// The first three fields are byte-identical to dig-app's frozen `CoinRecord`, so its
529/// `CoinsResponse` deserializes this losslessly and ignores the rest. The rest is what a spend
530/// actually needs: a coin cannot be spent from an id and an amount alone — the parent and the
531/// puzzle hash are what reconstruct the `Coin` — and the heights are how a caller tells a confirmed
532/// coin from one it only saw in the mempool.
533///
534/// ONE record type serves both reads deliberately. A second coin shape would be a second thing to
535/// keep in step with dig-app's frozen struct, and the two would drift byte-wise the first time only
536/// one of them was touched.
537#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
538pub struct WalletCoinRecord {
539 /// The coin id, lowercase 64-hex, unprefixed.
540 pub coin_id: String,
541 /// The asset this coin is denominated in, or `null` when THIS READ DID NOT CLASSIFY THE COIN.
542 ///
543 /// `null` never means "no asset" and never means XCH by default. It means the answering read
544 /// had no basis to say: a singleton, a CAT and a plain XCH coin are indistinguishable from a
545 /// coin id alone — telling them apart requires inspecting the puzzle, and the node reads only
546 /// the coin record. So `control.wallet.coinById` MUST report `null` here — emitting a concrete
547 /// asset on an unclassified read would make the node assert a classification it never verified,
548 /// which a caller would then spend against.
549 ///
550 /// `control.wallet.coins` MUST report the concrete asset it was SCOPED to and MUST NOT emit
551 /// `null`. This field is optional only to serve the by-id read; the coins read has no
552 /// unclassified case, and dig-app's frozen `CoinRecord` requires a non-null asset there, so a
553 /// `null` breaks that read outright rather than degrading it. The type cannot enforce the split
554 /// because ONE record shape deliberately serves both reads (see the type docs), which is why the
555 /// rule is stated here and pinned by a KAT.
556 pub asset: Option<crate::params::Asset>,
557 /// The coin's amount, in the asset's base unit.
558 pub amount: u64,
559 /// The parent coin's id, lowercase 64-hex, unprefixed.
560 pub parent_coin_info: String,
561 /// The coin's puzzle hash, lowercase 64-hex, unprefixed.
562 pub puzzle_hash: String,
563 /// The height the coin was created at, or `null` while it is still only in the mempool.
564 pub created_height: Option<u32>,
565 /// The height the coin was spent at, or `null` when it is unspent.
566 pub spent_height: Option<u32>,
567}
568
569/// `control.wallet.coins` — an address's spendable coins for one asset.
570///
571/// # An empty list is an ANSWER, never a fallback
572///
573/// `coins: []` means the node consulted a chain and that address holds nothing. It is NEVER what a
574/// caller gets when the chain could not be reached: those are catalogued errors
575/// ([`crate::error::ControlErrorCode::WalletNoChainSource`] / `WalletNotSynced` /
576/// `WalletReadFailed` / `WalletRateLimited`). The distinction is the whole point of the method —
577/// a well-shaped empty result on an unreachable chain would tell somebody who holds funds that they
578/// hold nothing, and a spend built on that answer refuses with a shortfall that is not true.
579#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
580pub struct WalletCoinsResult {
581 /// The spendable coins found at the address, possibly empty (see the type docs).
582 pub coins: Vec<WalletCoinRecord>,
583 /// Which tier answered, or `None` from a node too old to disclose it. See [`WalletReadSource`].
584 pub source: Option<WalletReadSource>,
585 /// Whether THESE coins reflect a caught-up local view; always `false` for a fallback answer.
586 pub synced: bool,
587 /// The peak height these coins reflect, or `null` when none applies (every fallback answer).
588 pub peak_height: Option<u32>,
589}
590
591/// Deserialize an `Option<T>` that is nullable but NOT omittable.
592///
593/// Serde special-cases a missing field of type `Option<T>` into `None`, so a required-but-nullable
594/// field is not expressible by the derive alone. Naming a `deserialize_with` suppresses that
595/// special case: an absent key becomes a `missing field` error, while an explicit `null` still
596/// decodes to `None`.
597fn required_option<'de, D, T>(deserializer: D) -> Result<Option<T>, D::Error>
598where
599 D: serde::Deserializer<'de>,
600 T: Deserialize<'de>,
601{
602 Option::<T>::deserialize(deserializer)
603}
604
605/// `control.wallet.coinById` — ONE coin, named by its own id, spent or unspent.
606///
607/// # An absent coin is an ANSWER; an unreachable chain is an ERROR
608///
609/// `coin: null` means a chain WAS consulted and holds no such coin. It is NEVER what a caller gets
610/// when the chain could not be reached: those are the catalogued errors
611/// ([`crate::error::ControlErrorCode::WalletNoChainSource`] / `WalletReadFailed` /
612/// `WalletRateLimited`). Collapsing the two turns "your wifi dropped" into "your mint never
613/// happened", and the remedies are opposite: retry the read, versus stop waiting.
614///
615/// # Why this method exists — observing a mint
616///
617/// `control.wallet.broadcast`'s `accepted: true` reports mempool admission only; only a buried
618/// confirmation of the CREATED COIN is evidence that a mint happened. `control.wallet.coins`
619/// cannot supply it — it answers by ADDRESS and lists UNSPENT coins only, so it can see neither the
620/// created DID coin nor the funding coin the mint spent. This method is how that evidence is
621/// obtained: read the created coin's id for a `created_height`, and the funding coin's id for a
622/// [`spent_height`](WalletCoinRecord::spent_height). Without it a mint can be pushed, real XCH can
623/// leave the wallet, and the outcome stays permanently "pending".
624///
625/// # The freshness fields are honest, not decorative
626///
627/// [`source`](Self::source) discloses which tier answered, and every freshness field describes THAT
628/// tier — the same rule the by-address reads carry. A `fallback` answer MUST report
629/// [`synced`](Self::synced) `false` and [`peak_height`](Self::peak_height) `null` however caught-up
630/// the node's own replica is, because the oracle produced the figures and the replica neither
631/// produced them nor bounds their freshness. A `db` answer means the node's OWN replica answered, so
632/// it MUST report `synced: true` and the replica's peak.
633///
634/// # A negative answer requires a view that could have held the coin
635///
636/// `coin: null` is a VERDICT — it says stop waiting — so it MUST NOT be served from a view that
637/// could not have seen the coin in the first place. A node whose replica is still catching up, or
638/// whose local index is address-scoped rather than a full chain view, has NOT established that the
639/// coin is absent; it has only established that IT cannot see it. Such a node MUST return
640/// [`WalletNoChainSource`](crate::error::ControlErrorCode::WalletNoChainSource) or
641/// [`WalletReadFailed`](crate::error::ControlErrorCode::WalletReadFailed) and MUST NOT answer
642/// `coin: null`.
643///
644/// This matters precisely for the two coins this method exists to observe. A created coin sits at no
645/// wallet address and a spent funding coin is gone from every unspent list, so an address-scoped
646/// replica is guaranteed to miss both — and a `coin: null` from it would report a mint that DID
647/// happen as never-having-happened, with the funds already gone. `control.wallet.peak` is no escape
648/// hatch here: it reports that same replica's height, which can bound a positive confirmation but
649/// can never license a negative one.
650#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
651pub struct WalletCoinByIdResult {
652 /// The coin, or `null` when the consulted chain holds no coin with that id (see the type docs).
653 ///
654 /// The key MUST be present. `null` is a verdict here, so an ABSENT key must not decode into one:
655 /// serde's default treatment of `Option` makes a missing field indistinguishable from an
656 /// explicit `null`, which would let an unrelated or truncated payload — anything at all carrying
657 /// a `synced` field — decode into a confident "the chain holds no such coin". `deserialize_with`
658 /// suppresses that default so the field is genuinely required.
659 #[serde(deserialize_with = "required_option")]
660 pub coin: Option<WalletCoinRecord>,
661 /// Which tier answered, or `None` from a node too old to disclose it. See [`WalletReadSource`].
662 pub source: Option<WalletReadSource>,
663 /// Whether this answer reflects a caught-up local view; `false` for every fallback answer.
664 pub synced: bool,
665 /// The peak height this answer reflects, or `null` when none applies (every fallback answer).
666 pub peak_height: Option<u32>,
667}
668
669/// `control.wallet.peak` — the node's current chain peak height.
670///
671/// `peak_height: null` is an honest "this node tracks no height yet", not a zero. A caller bounding
672/// a claimed confirmation MUST treat it as unknown rather than as height 0, which every block is
673/// trivially above.
674#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
675pub struct WalletPeakResult {
676 /// The peak block height the node's chain view has reached, or `null` when it has none.
677 pub peak_height: Option<u32>,
678 /// Whether the node's own chain replica is caught up to that peak.
679 pub synced: bool,
680}
681
682/// `control.wallet.broadcast` — the outcome of pushing an already-signed bundle.
683///
684/// # A rejection is a VALUE; an unreachable network is an ERROR
685///
686/// A mempool that looked at the bundle and said no is a successful call with `accepted: false` and
687/// a [`rejection`](Self::rejection) reason — the bundle was seen and judged. Failing to REACH a
688/// mempool is a catalogued error instead. Collapsing the two turns "your wifi dropped" into "your
689/// mint failed", and the remedies are opposite: retry the same bundle, versus build a new one.
690///
691/// # Accepted is not confirmed
692///
693/// `accepted: true` says the mempool took the bundle. It is not evidence that anything reached a
694/// block, and a caller must never record an outcome from it — only a buried confirmation of the
695/// created coin is evidence.
696#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
697pub struct WalletBroadcastResult {
698 /// Whether the network accepted the bundle into its mempool.
699 pub accepted: bool,
700 /// The transaction id (the spend bundle's name), lowercase 64-hex, when accepted.
701 pub transaction_id: Option<String>,
702 /// Why the mempool refused, when it refused. `null` on acceptance.
703 pub rejection: Option<String>,
704}
705
706/// `pairing.request` — the pairing handshake bootstrap (OPEN, no token).
707#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
708pub struct PairingRequestResult {
709 /// The opaque pairing id to poll with.
710 pub pairing_id: String,
711 /// A short numeric code the operator compares before approving.
712 pub pairing_code: String,
713 /// When the pending pairing expires, in unix milliseconds.
714 pub expires_ms: u64,
715}
716
717/// `pairing.poll` — the pairing poll outcome (OPEN, no token).
718#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
719pub struct PairingPollResult {
720 /// The pairing status (`"pending"` / `"approved"` / …).
721 pub status: String,
722 /// The minted scoped token, present exactly once after approval.
723 #[serde(skip_serializing_if = "Option::is_none", default)]
724 pub token: Option<String>,
725}
726
727#[cfg(test)]
728mod tests {
729 use super::*;
730 use serde_json::json;
731
732 #[test]
733 fn status_result_round_trips_the_node_shape() {
734 let v = json!({
735 "running": true, "service": "dig-node", "version": "0.30.0", "commit": "abc",
736 "protocol": "21", "uptime_secs": 5, "addr": "127.0.0.1:9256", "upstream": "https://rpc.dig.net",
737 "cache": {"cap_bytes": 1024, "used_bytes": 10, "dir": "/c", "shared": false},
738 "hosted_store_count": 2, "cached_capsule_count": 3, "pinned_store_count": 1,
739 "sync": {"available": true}
740 });
741 let parsed: StatusResult = serde_json::from_value(v.clone()).unwrap();
742 assert_eq!(serde_json::to_value(&parsed).unwrap(), v);
743 }
744
745 #[test]
746 fn config_result_keeps_upstream_override_null_when_unset() {
747 let parsed = ConfigResult {
748 addr: "127.0.0.1:9256".into(),
749 port: "9256".into(),
750 upstream: "https://rpc.dig.net".into(),
751 upstream_override: None,
752 cache_dir: "/c".into(),
753 cache_shared: false,
754 config_path: "/c/config.json".into(),
755 sync_available: true,
756 };
757 let v = serde_json::to_value(&parsed).unwrap();
758 assert_eq!(v["upstream_override"], json!(null));
759 assert!(v.as_object().unwrap().contains_key("upstream_override"));
760 }
761
762 #[test]
763 fn pairing_poll_omits_token_until_approved() {
764 let pending = PairingPollResult {
765 status: "pending".into(),
766 token: None,
767 };
768 let v = serde_json::to_value(&pending).unwrap();
769 assert_eq!(v, json!({"status": "pending"}));
770 let approved = PairingPollResult {
771 status: "approved".into(),
772 token: Some("deadbeef".into()),
773 };
774 assert_eq!(
775 serde_json::to_value(&approved).unwrap(),
776 json!({"status": "approved", "token": "deadbeef"})
777 );
778 }
779
780 // ---- PeerSoftware (dig_ecosystem#2215) ----
781
782 /// The mapping that matters most. Every peer built before #2215 advertises the LITERAL
783 /// `"0.0.0"` — three of dig-gossip's four handshake send sites hardcoded it. A parser that
784 /// maps only `""` to Unknown would therefore read the entire live fleet as "software version
785 /// 0.0.0", which any later `>=` comparison treats as ancient. `""`, `"0.0.0"`, and anything
786 /// unparseable must all be Unknown, and this test is that mapping's guard.
787 #[test]
788 fn unknown_covers_empty_the_legacy_sentinel_and_garbage() {
789 for raw in [
790 "", // a peer advertising nothing, or `off` coarsening
791 "0.0.0", // the pre-#2215 legacy sentinel
792 " ", // whitespace only
793 "dig-node", // no version part
794 "dig-node/", // empty version part
795 "dig-node/not-a-version", // unparseable version
796 "/1.2.3", // empty product part
797 "1.2.3", // bare version, no product
798 "dig-node/0.0.0", // the sentinel, however it is dressed up
799 ] {
800 assert_eq!(
801 PeerSoftware::parse(raw),
802 PeerSoftware::Unknown,
803 "{raw:?} must map to Unknown"
804 );
805 }
806 }
807
808 /// A well-formed `product/semver` advertisement is reported with all three parts, and `raw`
809 /// preserves exactly what the peer sent so a diagnostic reader is never shown a value the peer
810 /// did not actually advertise.
811 #[test]
812 fn reported_carries_product_version_and_the_raw_advertisement() {
813 let parsed = PeerSoftware::parse("dig-node/0.99.1");
814 let PeerSoftware::Reported {
815 product,
816 version,
817 raw,
818 } = parsed
819 else {
820 panic!("a well-formed advertisement must be Reported");
821 };
822 assert_eq!(product, "dig-node");
823 assert_eq!(version, semver::Version::new(0, 99, 1));
824 assert_eq!(raw, "dig-node/0.99.1");
825 }
826
827 /// A product name may itself contain a `/`; only the LAST separator splits product from
828 /// version. Pinning this stops a future reader from switching to a first-separator split,
829 /// which would silently reclassify such a peer as Unknown.
830 #[test]
831 fn product_is_split_at_the_last_separator() {
832 let PeerSoftware::Reported {
833 product, version, ..
834 } = PeerSoftware::parse("acme/dig-node/1.2.3")
835 else {
836 panic!("expected Reported");
837 };
838 assert_eq!(product, "acme/dig-node");
839 assert_eq!(version, semver::Version::new(1, 2, 3));
840 }
841
842 /// Surrounding whitespace is trimmed before parsing, and `raw` records the TRIMMED
843 /// advertisement. CON-008 sanitization strips Unicode Cc/Cf from the wire value but not
844 /// spaces, so a padded advertisement reaches this parser intact and must not be classified as
845 /// unparseable merely for having been padded.
846 #[test]
847 fn surrounding_whitespace_is_trimmed_before_parsing() {
848 let PeerSoftware::Reported {
849 product,
850 version,
851 raw,
852 } = PeerSoftware::parse(" dig-node/1.2.3 ")
853 else {
854 panic!("a padded advertisement must still be Reported");
855 };
856 assert_eq!(product, "dig-node");
857 assert_eq!(version, semver::Version::new(1, 2, 3));
858 assert_eq!(raw, "dig-node/1.2.3", "raw must record the trimmed value");
859 }
860
861 /// A pre-release/build-metadata semver survives intact, because that is what a nightly build
862 /// advertises and dropping it would make every nightly indistinguishable from its release.
863 #[test]
864 fn prerelease_versions_are_preserved() {
865 let PeerSoftware::Reported { version, raw, .. } =
866 PeerSoftware::parse("dig-node/1.0.0-nightly.20260805")
867 else {
868 panic!("expected Reported");
869 };
870 assert_eq!(version.to_string(), "1.0.0-nightly.20260805");
871 assert_eq!(raw, "dig-node/1.0.0-nightly.20260805");
872 }
873
874 /// Unknown's JSON is a tagged object — never `"0.0.0"`, never `""`, never a null sitting in a
875 /// version field where a consumer might read it as a number.
876 #[test]
877 fn unknown_serializes_as_a_tagged_object_with_no_version_field() {
878 let v = serde_json::to_value(PeerSoftware::Unknown).unwrap();
879 assert_eq!(v, json!({"kind": "unknown"}));
880 assert!(
881 v.get("version").is_none(),
882 "Unknown must not carry a version field at all"
883 );
884 }
885
886 /// Both variants round-trip byte-identically, which is what lets a client re-encode a node's
887 /// response unchanged.
888 #[test]
889 fn both_variants_round_trip_byte_identically() {
890 for wire in [
891 json!({"kind": "unknown"}),
892 json!({
893 "kind": "reported",
894 "product": "dig-node",
895 "version": "0.99.1",
896 "raw": "dig-node/0.99.1"
897 }),
898 ] {
899 let parsed: PeerSoftware = serde_json::from_value(wire.clone()).unwrap();
900 assert_eq!(serde_json::to_value(&parsed).unwrap(), wire);
901 }
902 }
903
904 /// Parsing a wire string and serializing the result produces the documented JSON, so the two
905 /// halves of the contract cannot drift from each other.
906 #[test]
907 fn parse_then_serialize_matches_the_documented_json() {
908 assert_eq!(
909 serde_json::to_value(PeerSoftware::parse("dig-node/0.99.1")).unwrap(),
910 json!({
911 "kind": "reported",
912 "product": "dig-node",
913 "version": "0.99.1",
914 "raw": "dig-node/0.99.1"
915 })
916 );
917 assert_eq!(
918 serde_json::to_value(PeerSoftware::parse("0.0.0")).unwrap(),
919 json!({"kind": "unknown"})
920 );
921 }
922
923 // ---- Trait-absence probes (dig_ecosystem#2215) ----
924 //
925 // `PeerSoftware` deriving `Ord` or `Default` would be a silent correctness regression rather
926 // than a compile error anywhere, so it is pinned here. The probe exploits inherent-impl
927 // precedence: `Probe::<T>::has_it()` resolves to the inherent impl (returning `true`) only when
928 // `T` satisfies the bound, and otherwise falls back to the blanket trait impl (`false`).
929 //
930 // Each probe carries a CONTROL on a type that DOES implement the trait. Without the control, a
931 // probe broken so that it always answers `false` would pass while proving nothing.
932
933 struct Probe<T>(core::marker::PhantomData<T>);
934
935 trait ProbeFallback {
936 fn is_ord() -> bool {
937 false
938 }
939 }
940 impl<T> ProbeFallback for Probe<T> {}
941
942 impl<T: Ord> Probe<T> {
943 fn is_ord() -> bool {
944 true
945 }
946 }
947
948 struct PartialOrdProbe<T>(core::marker::PhantomData<T>);
949 trait PartialOrdFallback {
950 fn is_partial_ord() -> bool {
951 false
952 }
953 }
954 impl<T> PartialOrdFallback for PartialOrdProbe<T> {}
955 impl<T: PartialOrd> PartialOrdProbe<T> {
956 fn is_partial_ord() -> bool {
957 true
958 }
959 }
960
961 /// A version comparison must be unreachable without first destructuring `Reported`, so that a
962 /// caller cannot order `Unknown` against a real version — which, since every pre-#2215 peer is
963 /// Unknown, would quietly become a verdict about most of the live network.
964 #[test]
965 fn peer_software_is_not_ordered() {
966 assert!(
967 Probe::<u32>::is_ord(),
968 "control: the probe must detect a type that IS Ord, or it proves nothing"
969 );
970 assert!(
971 !Probe::<PeerSoftware>::is_ord(),
972 "PeerSoftware must not implement Ord — comparison belongs after destructuring Reported"
973 );
974 }
975
976 /// A defaulted `Unknown` appearing from nowhere is a different fact from a measured one, and
977 /// `Default` would make the two indistinguishable at the point of construction.
978 #[test]
979 fn peer_software_has_no_default() {
980 struct DefaultProbe<T>(core::marker::PhantomData<T>);
981 trait DefaultFallback {
982 fn is_default() -> bool {
983 false
984 }
985 }
986 impl<T> DefaultFallback for DefaultProbe<T> {}
987 impl<T: Default> DefaultProbe<T> {
988 fn is_default() -> bool {
989 true
990 }
991 }
992
993 assert!(
994 DefaultProbe::<String>::is_default(),
995 "control: the probe must detect a type that IS Default, or it proves nothing"
996 );
997 assert!(
998 !DefaultProbe::<PeerSoftware>::is_default(),
999 "PeerSoftware must not implement Default"
1000 );
1001 }
1002
1003 // ---- SoftwareVersionDetail (dig_ecosystem#2215) ----
1004
1005 /// Each mode renders a value the PARSER reads back at the intended level of detail.
1006 ///
1007 /// The fixture uses a version with a non-zero minor AND a non-zero patch, because that is the
1008 /// only shape where `Full` and `Minor` differ — a `1.0.0` fixture would let a renderer that
1009 /// ignores the mode entirely pass.
1010 #[test]
1011 fn each_detail_mode_round_trips_to_the_intended_precision() {
1012 let v = semver::Version::new(0, 99, 1);
1013
1014 let full = SoftwareVersionDetail::Full.render("dig-node", &v);
1015 assert_eq!(full, "dig-node/0.99.1");
1016 assert_eq!(
1017 PeerSoftware::parse(&full),
1018 PeerSoftware::parse("dig-node/0.99.1")
1019 );
1020
1021 let minor = SoftwareVersionDetail::Minor.render("dig-node", &v);
1022 assert_ne!(minor, full, "Minor must actually coarsen");
1023 let PeerSoftware::Reported { version, .. } = PeerSoftware::parse(&minor) else {
1024 panic!("a coarsened advertisement must still be READABLE, not Unknown");
1025 };
1026 assert_eq!(version.major, 0);
1027 assert_eq!(version.minor, 99);
1028 assert_eq!(version.patch, 0, "the patch level is what Minor hides");
1029
1030 let off = SoftwareVersionDetail::Off.render("dig-node", &v);
1031 assert_eq!(off, "");
1032 assert_eq!(PeerSoftware::parse(&off), PeerSoftware::Unknown);
1033 }
1034
1035 /// `Minor` renders `MAJOR.MINOR.0`, NOT `MAJOR.MINOR`.
1036 ///
1037 /// A bare two-part `0.99` is not valid semver, so the parser would classify a peer that
1038 /// coarsened its build as Unknown — turning "tell them less" into "tell them nothing", which
1039 /// is what `Off` is for. This test is the guard on that distinction.
1040 #[test]
1041 fn minor_mode_stays_valid_semver_rather_than_collapsing_to_unknown() {
1042 let rendered =
1043 SoftwareVersionDetail::Minor.render("dig-node", &semver::Version::new(1, 4, 7));
1044 assert_eq!(rendered, "dig-node/1.4.0");
1045 assert_ne!(
1046 PeerSoftware::parse(&rendered),
1047 PeerSoftware::Unknown,
1048 "a coarsened build must remain readable; `product/1.4` would not be"
1049 );
1050 }
1051
1052 /// Coarsening strips pre-release and build metadata. A nightly's identifier is more precisely
1053 /// identifying than the patch number it accompanies, so leaving it in place would make `Minor`
1054 /// coarsen nothing at all for exactly the builds that most want it.
1055 #[test]
1056 fn minor_mode_strips_prerelease_and_build_metadata() {
1057 let v: semver::Version = "1.0.0-nightly.20260805+sha.abc123".parse().unwrap();
1058 let rendered = SoftwareVersionDetail::Minor.render("dig-node", &v);
1059 assert_eq!(rendered, "dig-node/1.0.0");
1060 assert!(
1061 !rendered.contains("nightly"),
1062 "the nightly identifier must not survive coarsening"
1063 );
1064 assert!(
1065 !rendered.contains("abc123"),
1066 "build metadata must not survive coarsening"
1067 );
1068 }
1069
1070 /// `Off` renders the empty string for ANY version, which is what makes it indistinguishable
1071 /// from a peer built before the field existed.
1072 #[test]
1073 fn off_mode_reveals_nothing_for_any_version() {
1074 for v in ["0.0.1", "1.2.3", "99.99.99-rc.1"] {
1075 let rendered = SoftwareVersionDetail::Off.render("dig-node", &v.parse().unwrap());
1076 assert_eq!(
1077 rendered, "",
1078 "Off must reveal nothing, including the product name"
1079 );
1080 }
1081 }
1082
1083 /// The default is the most informative setting: the diagnostic value is the reason the field
1084 /// exists, and an operator who disagrees opts down explicitly.
1085 #[test]
1086 fn detail_defaults_to_full() {
1087 assert_eq!(
1088 SoftwareVersionDetail::default(),
1089 SoftwareVersionDetail::Full
1090 );
1091 }
1092
1093 /// The wire tokens are the lowercase words an operator writes in a config file, and they are a
1094 /// published contract once a config carries them.
1095 #[test]
1096 fn detail_uses_lowercase_wire_tokens() {
1097 for (mode, token) in [
1098 (SoftwareVersionDetail::Full, "\"full\""),
1099 (SoftwareVersionDetail::Minor, "\"minor\""),
1100 (SoftwareVersionDetail::Off, "\"off\""),
1101 ] {
1102 assert_eq!(serde_json::to_string(&mode).unwrap(), token);
1103 assert_eq!(
1104 serde_json::from_str::<SoftwareVersionDetail>(token).unwrap(),
1105 mode
1106 );
1107 }
1108 }
1109
1110 // ---- Gate round 1 regressions (dig_ecosystem#2215) ----
1111
1112 /// **`PartialOrd` is the hazard the `Ord` probe misses.** `Ord: PartialOrd`, so a type can
1113 /// derive only `PartialOrd` — satisfying an `Ord`-only probe — while `Unknown < Reported(..)`
1114 /// still compiles and evaluates. That one-word derive would sort `Unknown` below every real
1115 /// version, which is the verdict-about-the-live-network the contract forbids. SPEC §4.1 names
1116 /// all three traits; this pins the weakest of them, which subsumes `Ord`.
1117 #[test]
1118 fn peer_software_is_not_partially_ordered_either() {
1119 assert!(
1120 PartialOrdProbe::<f64>::is_partial_ord(),
1121 "control: the probe must detect a type that IS PartialOrd but NOT Ord, or it proves nothing about the gap between the two"
1122 );
1123 assert!(
1124 PartialOrdProbe::<u32>::is_partial_ord(),
1125 "control: a fully-ordered type must also be detected"
1126 );
1127 assert!(
1128 !PartialOrdProbe::<PeerSoftware>::is_partial_ord(),
1129 "PeerSoftware must implement neither PartialOrd nor Ord"
1130 );
1131 }
1132
1133 /// **The sentinel is VERSION ZERO, a class — not the three-character string `\"0.0.0\"`.**
1134 /// The constant's doc, `parse`'s doc, and SPEC §4.1 all state the rule over the class, so a
1135 /// string comparison lets `0.0.0+build`, `0.0.0-rc.1`, and `0.0.0-0` through as a *reported*
1136 /// version zero — the exact reading every one of those three prose statements forbids.
1137 #[test]
1138 fn version_zero_is_unknown_however_it_is_decorated() {
1139 for raw in [
1140 "dig-node/0.0.0",
1141 "dig-node/0.0.0+build",
1142 "dig-node/0.0.0-rc.1",
1143 "x/0.0.0-0",
1144 "dig-node/0.0.0-alpha+sha.abc123",
1145 ] {
1146 assert_eq!(
1147 PeerSoftware::parse(raw),
1148 PeerSoftware::Unknown,
1149 "{raw:?} is version zero and must be Unknown"
1150 );
1151 }
1152 }
1153
1154 /// A version that is merely CLOSE to zero is still a real build and must be reported — without
1155 /// this, a parser that mapped everything below `0.1.0` to Unknown would pass the test above.
1156 #[test]
1157 fn a_nonzero_version_near_zero_is_still_reported() {
1158 for raw in ["dig-node/0.0.1", "dig-node/0.1.0", "dig-node/0.0.1-rc.1"] {
1159 assert_ne!(
1160 PeerSoftware::parse(raw),
1161 PeerSoftware::Unknown,
1162 "{raw:?} is a real build, not the sentinel"
1163 );
1164 }
1165 }
1166
1167 /// **`render`'s stated invariant, tested over the class it is stated over.**
1168 ///
1169 /// The doc promises: every rendering is either the empty string or a value `parse` reads back
1170 /// as `Reported`. A `1.4.7` fixture cannot see the case that breaks it — a `0.0.x` build, whose
1171 /// `MAJOR.MINOR.0` coarsening IS version zero and therefore reads as Unknown. That is the same
1172 /// Minor-collapses-into-Off defect as the two-part spelling, arriving through the other door.
1173 #[test]
1174 fn every_rendering_is_empty_or_readable() {
1175 let versions = [
1176 "0.0.1",
1177 "0.0.7",
1178 "0.0.99", // the class the 1.4.7 fixture cannot see
1179 "0.1.0",
1180 "0.99.1",
1181 "1.0.0",
1182 "1.4.7",
1183 "10.20.30",
1184 "1.0.0-nightly.20260805+sha.abc123",
1185 "0.0.1-rc.1",
1186 ];
1187 for mode in [
1188 SoftwareVersionDetail::Full,
1189 SoftwareVersionDetail::Minor,
1190 SoftwareVersionDetail::Off,
1191 ] {
1192 for v in versions {
1193 let rendered = mode.render("dig-node", &v.parse().unwrap());
1194 if rendered.is_empty() {
1195 continue;
1196 }
1197 assert_ne!(
1198 PeerSoftware::parse(&rendered),
1199 PeerSoftware::Unknown,
1200 "{mode:?} rendered {rendered:?} for {v}, which reads back as Unknown — a non-empty rendering must always be readable"
1201 );
1202 }
1203 }
1204 }
1205
1206 /// `Minor` on a `0.0.x` build advertises NOTHING, deliberately.
1207 ///
1208 /// Hiding the patch of a `0.0.x` version leaves only version zero, which the wire reserves as
1209 /// the "unknown" sentinel. There is no coarser representable value, so the honest rendering is
1210 /// the empty string rather than the sentinel dressed up as a report. This differs from the
1211 /// `0.99` case: there a representable coarse value existed and the wrong spelling was chosen;
1212 /// here none exists.
1213 #[test]
1214 fn minor_of_a_zero_zero_build_advertises_nothing_rather_than_the_sentinel() {
1215 let rendered = SoftwareVersionDetail::Minor.render("dig-node", &"0.0.7".parse().unwrap());
1216 assert_eq!(rendered, "");
1217 assert_ne!(
1218 rendered, "dig-node/0.0.0",
1219 "the sentinel must never be ADVERTISED; it is only ever received from a legacy peer"
1220 );
1221 }
1222
1223 /// **Tripwire, not a guard.** `raw` is reconstructible from `product` + `version` for every
1224 /// string the current grammar accepts, because `semver::Version` re-renders losslessly. This
1225 /// asserts that equivalence deliberately.
1226 ///
1227 /// **When this test FAILS, `raw` has become load-bearing** — the grammar has started accepting
1228 /// something non-canonical (a `v` prefix, a two-part version, a vendor suffix) and `raw` is now
1229 /// the only record of what the peer actually sent. Do not "fix" it by deleting the field;
1230 /// replace this test with real assertions on the divergent inputs.
1231 #[test]
1232 fn raw_is_still_reconstructible_from_the_parsed_parts() {
1233 for advertised in [
1234 "dig-node/0.0.1",
1235 "dig-node/0.99.1",
1236 "dig-node/1.0.0-nightly.20260805",
1237 "dig-node/1.0.0+sha.abc123",
1238 "dig-node/1.0.0-rc.1+build.7",
1239 "acme/dig-node/1.2.3",
1240 ] {
1241 let PeerSoftware::Reported {
1242 product,
1243 version,
1244 raw,
1245 } = PeerSoftware::parse(advertised)
1246 else {
1247 panic!("{advertised:?} must be Reported");
1248 };
1249 assert_eq!(
1250 raw,
1251 format!("{product}/{version}"),
1252 "raw diverged from the parsed parts for {advertised:?} — `raw` is now load-bearing; see this test's doc comment before changing anything"
1253 );
1254 }
1255 }
1256}