1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
920
921
922
923
924
925
926
927
928
929
930
931
932
933
934
935
936
937
938
939
940
941
942
943
944
945
946
947
948
949
950
951
952
953
954
955
956
957
958
959
960
961
962
963
964
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
984
985
986
987
988
989
990
991
992
993
994
995
996
997
998
999
1000
1001
1002
1003
1004
1005
1006
1007
1008
1009
1010
1011
1012
1013
1014
1015
1016
1017
1018
1019
1020
1021
1022
1023
1024
1025
1026
1027
1028
1029
1030
1031
1032
1033
1034
1035
1036
1037
1038
1039
1040
1041
1042
1043
1044
1045
1046
1047
1048
1049
1050
1051
1052
1053
1054
1055
1056
1057
1058
1059
1060
1061
1062
1063
1064
1065
1066
1067
1068
1069
1070
1071
1072
1073
1074
1075
1076
1077
1078
1079
1080
1081
1082
1083
1084
1085
1086
1087
1088
1089
1090
1091
1092
1093
1094
1095
1096
1097
1098
1099
1100
1101
1102
1103
1104
1105
1106
1107
1108
1109
1110
1111
1112
1113
1114
1115
1116
1117
1118
1119
1120
1121
1122
1123
1124
1125
1126
1127
1128
1129
1130
1131
1132
1133
1134
1135
1136
1137
1138
1139
1140
1141
1142
1143
1144
1145
1146
1147
1148
1149
1150
1151
1152
1153
1154
1155
1156
1157
1158
1159
1160
1161
1162
1163
1164
1165
1166
1167
1168
1169
1170
1171
1172
1173
1174
1175
1176
1177
1178
1179
1180
1181
1182
1183
1184
1185
1186
1187
1188
1189
1190
1191
1192
1193
1194
1195
1196
1197
1198
1199
1200
1201
1202
1203
1204
1205
1206
1207
1208
1209
1210
1211
1212
1213
1214
1215
1216
1217
1218
1219
1220
1221
1222
1223
1224
1225
1226
1227
1228
1229
1230
1231
1232
1233
1234
1235
1236
1237
1238
1239
1240
1241
1242
1243
1244
1245
1246
1247
1248
1249
1250
1251
1252
1253
1254
1255
1256
1257
1258
1259
1260
1261
1262
1263
1264
1265
1266
1267
1268
1269
1270
1271
1272
1273
1274
1275
1276
1277
1278
1279
1280
1281
1282
1283
1284
1285
1286
1287
1288
1289
1290
1291
1292
1293
1294
1295
1296
1297
1298
1299
1300
1301
1302
1303
1304
1305
1306
1307
1308
1309
1310
1311
1312
1313
1314
1315
1316
1317
1318
1319
1320
1321
1322
1323
1324
//! `layer.toml` → assembler inputs (REQ-LAYERREPO-001).
//!
//! A realm's contents belong in the realm's own repository, not in varve's
//! workflow file: bumping `rivet` to v0.34.0 should be a one-line reviewed diff
//! in `pulseengine-layers`, not a commit to the tool that signs it. This module
//! is the adapter that makes that possible — it reads the manifest and produces
//! the environment `tools/build-deposit-spec.sh` already consumes.
//!
//! It lives HERE, next to the assembler it feeds, rather than in the layers
//! repository, because a realm running a *copy* of the assembler gets none of
//! the system testing varve does on it (REQ-PEL-ASSEMBLER-001). One writer, one
//! set of tests, every realm.
//!
//! ## Why this refuses so much
//!
//! The assembler's inputs are space-separated lists of colon-separated fields.
//! That encoding cannot represent a value containing a space or a colon, and
//! the shell will not complain — it will silently split one tool into two, or
//! truncate a version. A layer assembled from a mangled list is still signed,
//! still verifies, and carries the wrong bytes. So every field that lands in
//! the encoding is checked against the encoding's own alphabet BEFORE it gets
//! there, and anything the assembler cannot faithfully carry is an error rather
//! than a best-effort translation. This is the same reasoning that made
//! `UNVERIFIED_INGEST` line-separated instead of punctuation-separated.
use std::collections::BTreeSet;
use std::fmt;
/// The pinned varve release that builds this layer.
#[derive(Debug, Clone, PartialEq, Eq, serde::Deserialize)]
#[serde(deny_unknown_fields)]
pub struct VarvePin {
pub version: String,
}
/// Which realm this layer belongs to, and where it is published.
#[derive(Debug, Clone, PartialEq, Eq, serde::Deserialize)]
#[serde(deny_unknown_fields)]
pub struct ManifestRealm {
pub name: String,
pub channel: String,
pub registry: String,
}
/// How a tool's release presents its binaries.
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum Layout {
/// One `.tar.gz` per target triple — the PulseEngine norm.
Tarball,
/// Bare per-platform binaries with no archive (sigil ships `wsc` this way).
RawPerPlatform,
/// A TREE: the archive itself is the payload (REQ-SDKDEPOSIT-001).
///
/// The other two layouts mine one binary out of an archive and discard the
/// rest. An SDK is the opposite shape — a compiler, its binutils, its
/// headers and its sysroot are one thing, and taking a binary out of it
/// destroys it. The archive is stored exactly as upstream published it;
/// unpacking and relocating is `varve export-sdk`'s job, on the consumer's
/// machine, per REQ-SDK-001 clause 3.
Sdk,
}
impl Layout {
fn parse(s: &str) -> Option<Layout> {
match s {
"tarball" => Some(Layout::Tarball),
"raw-per-platform" => Some(Layout::RawPerPlatform),
"sdk" => Some(Layout::Sdk),
_ => None,
}
}
}
#[derive(Debug, Clone, PartialEq, Eq, serde::Deserialize)]
#[serde(deny_unknown_fields)]
pub struct ManifestTool {
pub name: String,
pub version: String,
/// `owner/repo`. Absent = `pulseengine/<name>`.
#[serde(default)]
pub repo: Option<String>,
/// The executable's name, when it differs from the tool's (kiln ships
/// `kilnd`). Absent = `<name>`.
#[serde(default)]
pub binary: Option<String>,
/// Release asset name template; `%V` bare version, `%T` Rust target triple,
/// `%U` short upstream platform tag. Absent = the assembler's default.
#[serde(default)]
pub asset: Option<String>,
/// Absent = `tarball`.
#[serde(default)]
pub layout: Option<String>,
/// Why this tool is ingested with NO proof of origin (REQ-INGEST-001
/// clause 3). Present only for a release that offers neither a
/// cosign-signed sums file nor a build attestation.
///
/// The reason is not paperwork: it is signed into the layer and shown by
/// `varve inspect`, so every consumer reads the operator's words next to
/// the bytes they were written about. "We could not verify this" must
/// never be the silent path, which is why the field carries prose rather
/// than a boolean.
#[serde(rename = "unverified-reason", default)]
pub unverified_reason: Option<String>,
/// The RELEASE tag to fetch, when it differs from the payload's version
/// (REQ-PAYLOADID-001).
///
/// `version` is what the payload IS — the number it answers to, and the
/// one signed into the layer. For almost every tool that is also its
/// release tag, so `release` is absent and `version` serves both.
///
/// A hub repository breaks that: `pulseengine/jess` tags `v0.7.2` and ships
/// `with-device` at `0.2.2`. Without this field the manifest can say one or
/// the other — sign a version the binary contradicts, or name a tag that
/// does not exist — and the env encoding could already express it while
/// layer.toml could not, so porting a realm to layer.toml LOST the payload.
#[serde(rename = "release", default)]
pub release: Option<String>,
/// The asset carrying this release's UNSIGNED digest list, when it
/// publishes one (REQ-UPSTREAMSUMS-001).
///
/// Upstreams do not agree on a name — zephyrproject-rtos/sdk-ng calls it
/// `sha256.sum` — so the realm states it rather than varve guessing.
/// Guessing would be the worse failure: a file that is not the digest
/// manifest, parsed as one, vouches for nothing while looking like it does.
#[serde(rename = "upstream-sums", default)]
pub upstream_sums: Option<String>,
/// A path that must exist inside a `sdk` payload once unpacked
/// (REQ-SDKDEPOSIT-001 clause 5).
///
/// A tree payload cannot be architecture-checked the way a binary can — an
/// SDK holds executables for several architectures and checking its first
/// ELF proves nothing. What CAN be checked is shape, and the failure this
/// catches is concrete: a 14 GB download that turns out to be an HTML
/// error page hashes and signs perfectly well.
#[serde(rename = "contains", default)]
pub contains: Option<String>,
/// Asset name for one target triple, when no template can derive it.
///
/// Some upstreams ship a musl binary as their only Linux build —
/// `wac-cli-x86_64-unknown-linux-musl` — and a static musl binary is the
/// right payload for a gnu platform even though nothing in the platform
/// name says so. Inventing a `%MUSL` placeholder would guess at a
/// convention; naming the file is exact, and wrong-by-typo rather than
/// wrong-by-inference.
#[serde(rename = "asset-for", default)]
pub asset_for: std::collections::BTreeMap<String, String>,
}
#[derive(Debug, Clone, PartialEq, Eq, serde::Deserialize)]
#[serde(deny_unknown_fields)]
pub struct ManifestVsix {
pub name: String,
pub version: String,
#[serde(default)]
pub repo: Option<String>,
/// Asset template; `%V` bare version, `%P` VS Code platform tag. A template
/// with no `%P` is one portable package.
pub asset: String,
}
/// The whole manifest. `deny_unknown_fields` throughout is load-bearing: a
/// mistyped `verison = "v0.34.0"` would otherwise leave the real `version`
/// missing or stale, and the layer would ship the wrong release under a good
/// signature.
#[derive(Debug, Clone, PartialEq, Eq, serde::Deserialize)]
#[serde(deny_unknown_fields)]
pub struct LayerManifest {
pub varve: VarvePin,
pub realm: ManifestRealm,
#[serde(default, rename = "tool")]
pub tools: Vec<ManifestTool>,
#[serde(default, rename = "vsix")]
pub vsix: Vec<ManifestVsix>,
}
#[derive(Debug, Clone, PartialEq, Eq)]
pub enum LayerSpecError {
/// The TOML did not parse, or carried a field the schema does not define.
Parse(String),
/// A value cannot survive the assembler's encoding.
Unencodable {
field: String,
value: String,
why: &'static str,
},
/// `layout = "..."` is not one the assembler implements.
UnknownLayout { tool: String, layout: String },
/// The assembler carries exactly one raw-per-platform tool, as
/// `WSC_VERSION`. A second one has nowhere to go.
ManyRawPerPlatform { first: String, second: String },
/// The assembler's single raw-per-platform slot is not generic: it fetches
/// `wsc` from `pulseengine/sigil`. Any other tool put in it becomes a
/// request for the wrong tool from the wrong repository.
RawPerPlatformNotWsc { tool: String, repo: String },
/// The assembler hardcodes `pulseengine/` for extension repositories.
VsixForeignOwner { name: String, repo: String },
/// The assembler derives a tarball tool's identity from its REPOSITORY
/// basename, so a manifest `name` that disagrees with it is discarded.
RepoNameMismatch {
name: String,
repo: String,
basename: String,
},
/// Two entries would land under one name.
Duplicate { kind: &'static str, name: String },
/// The env encoding has no field for this layout, so translating would
/// silently change what the payload IS (REQ-SDKDEPOSIT-001).
LayoutNotEncodable { tool: String, layout: String },
/// The entry's fields are POSITIONAL, so a payload version cannot be
/// carried past an absent binary or asset template.
ReleaseNeedsBinaryAndAsset { tool: String },
/// The encoding has no field for the upstream digest manifest, and losing
/// it downgrades how the release is verified rather than how it is named.
UpstreamSumsNotEncodable { tool: String, asset: String },
/// An opt-in that states no reason.
UnverifiedWithoutReason { tool: String },
/// Two tools from one repository disagree about why it is unverified.
ConflictingReason {
repo: String,
first: String,
second: String,
},
/// The manifest describes nothing to deposit.
Empty,
}
impl fmt::Display for LayerSpecError {
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
match self {
LayerSpecError::Parse(e) => write!(f, "layer.toml does not parse: {e}"),
LayerSpecError::Unencodable { field, value, why } => write!(
f,
"{field} = {value:?} cannot be passed to the assembler: {why}. \
The assembler reads space-separated entries of colon-separated \
fields, so such a value would be split or truncated silently \
and the layer would carry the wrong bytes under a good signature."
),
LayerSpecError::UnknownLayout { tool, layout } => write!(
f,
"tool {tool:?} declares layout = {layout:?}, which varve does not \
implement. Use \"tarball\" (one .tar.gz per target triple) or \
\"raw-per-platform\" (bare per-platform binaries)."
),
LayerSpecError::ManyRawPerPlatform { first, second } => write!(
f,
"tools {first:?} and {second:?} both declare \
layout = \"raw-per-platform\", and the assembler carries only \
one (as WSC_VERSION). Depositing would silently drop one of \
them. Teach the assembler a general raw-per-platform list \
before adding the second."
),
LayerSpecError::RawPerPlatformNotWsc { tool, repo } => write!(
f,
"tool {tool:?} from {repo:?} declares \
layout = \"raw-per-platform\", but the assembler's only slot \
for that layout is hardcoded to fetch `wsc` from \
`pulseengine/sigil` — it would emit WSC_VERSION and download \
the wrong tool, from the wrong repository, at this tool's \
version, and deposit it under the wrong name. Teach the \
assembler a general raw-per-platform list before carrying \
this."
),
LayerSpecError::VsixForeignOwner { name, repo } => write!(
f,
"vsix {name:?} names repo {repo:?}, but the assembler resolves \
extension repositories as pulseengine/<name> and would fetch \
the wrong release. Either publish it under pulseengine, or \
teach the assembler an owner field for extensions."
),
LayerSpecError::RepoNameMismatch {
name,
repo,
basename,
} => write!(
f,
"tool {name:?} names repo {repo:?}, but the assembler takes a \
tarball tool's identity from the repository basename — it \
would download, name the payload, and default the asset \
template as {basename:?}, and {name:?} would mean nothing. A \
consumer asking for {name:?} would then find no such tool in \
a layer that deposited and verified. Rename the entry to \
{basename:?}, or set `binary` if only the executable differs."
),
LayerSpecError::UpstreamSumsNotEncodable { tool, asset } => write!(
f,
"tool {tool:?} declares upstream-sums {asset:?}, which the \
environment encoding cannot express. Dropping it would not \
lose a hint: it is the MECHANISM that vouches for the \
release, so the shell assembler would look for a cosign \
bundle and an attestation, find neither, and ingest the \
payload with no proof at all — while every other field \
survives the trip and the entry looks ordinary.\n\n\
Deposit this realm with `varve-producer deposit --manifest \
layer.toml`, which reads the mechanism directly."
),
LayerSpecError::LayoutNotEncodable { tool, layout } => write!(
f,
"tool {tool:?} declares layout {layout:?}, which the environment \
encoding cannot express — it has fields for a repository, a \
version, a binary, an asset template and a payload version, \
and none for a LAYOUT. Translating would emit an ordinary \
tarball entry, and the shell assembler would mine the tree for \
a binary and destroy it, silently, because every other field \
survives the trip.\n\n\
Deposit this realm with `varve-producer deposit --manifest \
layer.toml`, which reads the layout directly. See `varve docs \
sdk`."
),
LayerSpecError::ReleaseNeedsBinaryAndAsset { tool } => write!(
f,
"tool {tool:?} sets `release` separately from `version`, which \
the environment encoding carries in its FIFTH positional \
field — so `binary` and `asset` must be set too, because a \
positional field cannot be skipped. Set them explicitly, or \
drop `release` if the tag and the version are the same."
),
LayerSpecError::Duplicate { kind, name } => {
write!(f, "two {kind} entries are both named {name:?}")
}
LayerSpecError::UnverifiedWithoutReason { tool } => write!(
f,
"tool {tool:?} sets an empty `unverified-reason`. \"We could \
not verify this\" must never be the silent path: the reason \
is what travels with the bytes into the signed layer, where \
every consumer reads it. Say why this is acceptable and what \
removes the need, or do not carry the tool."
),
LayerSpecError::ConflictingReason {
repo,
first,
second,
} => write!(
f,
"two tools from {repo:?} give different reasons for ingesting \
it unverified:\n {first:?}\n {second:?}\nThe opt-in is per \
RELEASE, not per tool, so one of these would be recorded and \
the other silently discarded. Give the repository one reason."
),
LayerSpecError::Empty => write!(
f,
"layer.toml declares no [[tool]] and no [[vsix]]: there is \
nothing to deposit. A layer with no payloads is signed, \
published, and useless."
),
}
}
}
impl std::error::Error for LayerSpecError {}
/// What the assembler needs in its environment, derived from the manifest.
///
/// Rendered as `KEY=value` lines so a workflow can append them to `$GITHUB_ENV`
/// — no `eval`, no quoting round-trip, and nothing that would let a manifest
/// value execute.
#[derive(Debug, Clone, PartialEq, Eq)]
pub struct AssemblerEnv {
pub layer_tools: String,
pub wsc_version: Option<String>,
pub vsix_packages: String,
pub realm: String,
pub channel: String,
pub registry: String,
pub varve_version: String,
/// `owner/repo=reason` lines for releases ingested with no proof.
pub unverified_ingest: Vec<(String, String)>,
}
impl AssemblerEnv {
/// `KEY=value` lines, newline-terminated, in a stable order.
pub fn render(&self) -> String {
let mut out = String::new();
out.push_str(&format!("TARBALL_TOOLS={}\n", self.layer_tools));
out.push_str(&format!(
"WSC_VERSION={}\n",
self.wsc_version.as_deref().unwrap_or("")
));
out.push_str(&format!("VSIX_PACKAGES={}\n", self.vsix_packages));
out.push_str(&format!("VARVE_REALM={}\n", self.realm));
out.push_str(&format!("VARVE_CHANNEL={}\n", self.channel));
out.push_str(&format!("VARVE_REGISTRY={}\n", self.registry));
out.push_str(&format!("VARVE_VERSION={}\n", self.varve_version));
// UNVERIFIED_INGEST is LINE-separated, because a reason is prose and
// any punctuation separator can occur inside it — the assembler
// documents that choice and the reason it made it. A `KEY=value` line
// cannot carry newlines, so this uses $GITHUB_ENV's heredoc form.
//
// The delimiter is checked against the content rather than assumed: an
// operator's reason that happened to contain the delimiter would end
// the block early and inject whatever followed as further environment,
// which is the shape of an actual injection rather than a typo.
if !self.unverified_ingest.is_empty() {
let body: String = self
.unverified_ingest
.iter()
.map(|(repo, why)| format!("{repo}={why}\n"))
.collect();
let mut delim = String::from("VARVE_UNVERIFIED_EOF");
while body.contains(&delim) {
delim.push('_');
}
out.push_str(&format!("UNVERIFIED_INGEST<<{delim}\n{body}{delim}\n"));
}
out
}
}
pub fn parse_layer_manifest(text: &str) -> Result<LayerManifest, LayerSpecError> {
toml::from_str(text).map_err(|e| LayerSpecError::Parse(e.to_string()))
}
/// Reject anything the assembler's encoding cannot carry intact.
///
/// `%` is allowed: it is the asset templates' own metacharacter. `:` and
/// whitespace are the encoding's separators, and an empty value would collapse
/// a field position.
fn encodable(field: &str, value: &str) -> Result<(), LayerSpecError> {
let unencodable = |why| LayerSpecError::Unencodable {
field: field.to_string(),
value: value.to_string(),
why,
};
if value.is_empty() {
return Err(unencodable("it is empty"));
}
if value.contains(':') {
return Err(unencodable("it contains ':', which separates fields"));
}
if value.chars().any(char::is_whitespace) {
return Err(unencodable(
"it contains whitespace, which separates entries",
));
}
Ok(())
}
/// `owner/repo` → (owner, repo), defaulting the owner to `pulseengine`.
fn split_repo(repo: &str, default_name: &str) -> (String, String) {
match repo.split_once('/') {
Some((owner, name)) => (owner.to_string(), name.to_string()),
None => ("pulseengine".to_string(), default_name.to_string()),
}
}
pub fn assembler_env(m: &LayerManifest) -> Result<AssemblerEnv, LayerSpecError> {
if m.tools.is_empty() && m.vsix.is_empty() {
return Err(LayerSpecError::Empty);
}
encodable("realm.name", &m.realm.name)?;
encodable("realm.channel", &m.realm.channel)?;
encodable("varve.version", &m.varve.version)?;
let mut unverified: Vec<(String, String)> = Vec::new();
let mut tarballs: Vec<String> = Vec::new();
let mut wsc_version: Option<String> = None;
let mut raw_owner: Option<String> = None;
let mut seen_tools: BTreeSet<&str> = BTreeSet::new();
for t in &m.tools {
encodable("tool.name", &t.name)?;
encodable("tool.version", &t.version)?;
// Keyed on the name the payload is DEPOSITED under — what a consumer
// resolves — rather than on the repository it came from
// (REQ-PAYLOADID-001). Keying it on the repo meant one repository could
// contribute at most one payload, which refused
// zephyrproject-rtos/sdk-ng's 140 host×target toolchains outright and
// would have refused any monorepo upstream.
if !seen_tools.insert(t.name.as_str()) {
return Err(LayerSpecError::Duplicate {
kind: "tool",
name: t.name.clone(),
});
}
let layout = match t.layout.as_deref() {
None => Layout::Tarball,
Some(s) => Layout::parse(s).ok_or_else(|| LayerSpecError::UnknownLayout {
tool: t.name.clone(),
layout: s.to_string(),
})?,
};
// A layout the encoding cannot carry must stop here, not arrive at the
// shell as something else. `sdk` is the case: the tree IS the payload,
// and a tarball entry would have a binary extracted from it.
if layout == Layout::Sdk {
return Err(LayerSpecError::LayoutNotEncodable {
tool: t.name.clone(),
layout: "sdk".into(),
});
}
// Same rule, and the reason is stronger: `upstream-sums` is not a name
// but an ingestion MECHANISM (REQ-UPSTREAMSUMS-001). Translating it
// away leaves an entry that assembles happily with less proof than the
// realm asked for, which is the failure the ladder exists to prevent.
if let Some(sums) = &t.upstream_sums {
return Err(LayerSpecError::UpstreamSumsNotEncodable {
tool: t.name.clone(),
asset: sums.clone(),
});
}
// The opt-in is per RELEASE, so it is keyed by repository; two tools
// from one repo must agree about why it is unverified, or one reason
// would be recorded and the other silently dropped.
if let Some(why) = &t.unverified_reason {
let why = why.trim();
if why.is_empty() {
return Err(LayerSpecError::UnverifiedWithoutReason {
tool: t.name.clone(),
});
}
let full = match &t.repo {
Some(r) => r.clone(),
None => format!("pulseengine/{}", t.name),
};
if let Some((_, prev)) = unverified.iter().find(|(r, _)| *r == full) {
if prev != why {
return Err(LayerSpecError::ConflictingReason {
repo: full,
first: prev.clone(),
second: why.to_string(),
});
}
} else {
unverified.push((full, why.to_string()));
}
}
let (owner, repo_name) = match &t.repo {
Some(r) => {
encodable("tool.repo", r)?;
split_repo(r, &t.name)
}
None => ("pulseengine".to_string(), t.name.clone()),
};
if layout == Layout::RawPerPlatform {
if let Some(first) = &raw_owner {
return Err(LayerSpecError::ManyRawPerPlatform {
first: first.clone(),
second: t.name.clone(),
});
}
// The slot is not generic. `wsc` is what the assembler fetches,
// from `pulseengine/sigil`; anything else silently becomes a
// request for that tool at this tool's version.
if t.name != "wsc" || owner != "pulseengine" || repo_name != "sigil" {
return Err(LayerSpecError::RawPerPlatformNotWsc {
tool: t.name.clone(),
repo: format!("{owner}/{repo_name}"),
});
}
raw_owner = Some(t.name.clone());
wsc_version = Some(t.version.clone());
continue;
}
// The assembler does `tool="${f_tool##*/}"` and then uses that name for
// the payload, the extract directory and the default asset template. A
// manifest whose `name` disagrees with the repository basename is
// therefore not translated — it is DISCARDED, and the layer deposits a
// payload under a name nobody asked for. `raw-per-platform` is exempt
// because the assembler hardcodes that one pairing (`wsc` from
// `pulseengine/sigil`) instead of deriving it.
// The property this protects is real and survives: a payload deposited
// under a name nobody asked for is a defect — a consumer looking for it
// finds nothing in a layer that deposited and verified.
//
// But the CAUSE is the env encoding, not the manifest. The shell
// assembler takes a tool's identity from its repository basename and
// has no field for a deposited name, so it can only ever deposit under
// the basename or under `binary`. That is the encoding's limit, and
// pinning `name` to the repository to respect it made one repository
// able to contribute exactly one payload.
//
// So the check moves to where the loss would actually happen — this
// translation — and states what to do instead, rather than forbidding
// a manifest the Rust assembler reads correctly.
if repo_name != t.name && t.binary.is_none() {
return Err(LayerSpecError::RepoNameMismatch {
name: t.name.clone(),
repo: t.repo.clone().unwrap_or_else(|| repo_name.clone()),
basename: repo_name.clone(),
});
}
// `[owner/]tool:version[:binary[:asset-template]]`. The owner prefix is
// omitted when it is the default, so a manifest that names no repos
// produces exactly the list the pre-migration workflow carried.
// This USED to read `if owner == "pulseengine" { t.name }`, with a
// comment explaining that `repo_name == t.name` held by the check
// above, so testing it here would be a condition no input could vary —
// and cargo-mutants had proved it dead by flipping it and killing
// nothing.
//
// That was true, and it stopped being true the moment a payload's name
// was allowed to differ from its repository (REQ-PAYLOADID-001). A
// branch is only dead relative to an invariant, and removing the
// invariant brings it back to life: with the shortcut left in,
// `name = "with-device"` from `pulseengine/jess` emitted
// `with-device:v0.7.2:…`, and the shell would have fetched
// `pulseengine/with-device` — a repository that does not exist.
//
// So the bare form is now used only when the name really is the
// repository, which is what made it safe in the first place.
let head = if owner == "pulseengine" && repo_name == t.name {
t.name.clone()
} else {
format!("{owner}/{repo_name}")
};
// The tag to FETCH; `version` is what the payload is. They differ for
// a hub repo, and the entry carries both — the fifth positional field
// is the payload's own version.
let fetch_tag = t.release.as_deref().unwrap_or(&t.version);
let mut entry = format!("{head}:{fetch_tag}");
// A template cannot be given without a binary: they are positional.
match (&t.binary, &t.asset) {
(None, None) => {}
(Some(b), None) => {
encodable("tool.binary", b)?;
entry.push(':');
entry.push_str(b);
}
(b, Some(a)) => {
encodable("tool.asset", a)?;
let bin = b.clone().unwrap_or_else(|| t.name.clone());
encodable("tool.binary", &bin)?;
entry.push(':');
entry.push_str(&bin);
entry.push(':');
entry.push_str(a);
}
}
// The fifth positional field: the payload's OWN version, emitted only
// when it differs from the tag. Omitted otherwise so every existing
// entry translates to exactly the string it did before.
if t.release.is_some() {
// Positional, so the earlier optional fields must be present.
if t.binary.is_none() || t.asset.is_none() {
return Err(LayerSpecError::ReleaseNeedsBinaryAndAsset {
tool: t.name.clone(),
});
}
entry.push(':');
entry.push_str(t.version.trim_start_matches('v'));
}
tarballs.push(entry);
}
let mut vsix_entries: Vec<String> = Vec::new();
let mut seen_vsix: BTreeSet<&str> = BTreeSet::new();
for v in &m.vsix {
encodable("vsix.name", &v.name)?;
encodable("vsix.version", &v.version)?;
encodable("vsix.asset", &v.asset)?;
if !seen_vsix.insert(v.name.as_str()) {
return Err(LayerSpecError::Duplicate {
kind: "vsix",
name: v.name.clone(),
});
}
// The assembler builds `pulseengine/<repo_name>` itself, so a foreign
// owner cannot be expressed — and quietly dropping the owner would
// fetch a DIFFERENT repository's release of the same name.
let repo_name = match &v.repo {
Some(r) => {
encodable("vsix.repo", r)?;
let (owner, name) = split_repo(r, &v.name);
if owner != "pulseengine" {
return Err(LayerSpecError::VsixForeignOwner {
name: v.name.clone(),
repo: r.clone(),
});
}
name
}
None => v.name.clone(),
};
vsix_entries.push(format!("{repo_name}:{}:{}:{}", v.version, v.name, v.asset));
}
Ok(AssemblerEnv {
layer_tools: tarballs.join(" "),
wsc_version,
vsix_packages: vsix_entries.join(" "),
realm: m.realm.name.clone(),
channel: m.realm.channel.clone(),
registry: m.realm.registry.clone(),
varve_version: m.varve.version.clone(),
unverified_ingest: unverified,
})
}
#[cfg(test)]
mod tests {
use super::*;
/// The manifest `pulseengine-layers` actually carries, trimmed to the
/// shapes that differ from one another. Kept as one literal so the tests
/// exercise a document that could really be committed, not a fragment.
const REAL: &str = r#"
[varve]
version = "v0.28.0"
[realm]
name = "pulseengine"
channel = "rolling"
registry = "oci://ghcr.io/pulseengine/layers"
[[tool]]
name = "rivet"
version = "v0.34.0"
[[tool]]
name = "kiln"
version = "v0.4.4"
binary = "kilnd"
[[tool]]
name = "wsc"
repo = "pulseengine/sigil"
version = "v0.11.0"
layout = "raw-per-platform"
[[vsix]]
name = "rivet-sdlc"
repo = "pulseengine/rivet"
version = "v0.34.0"
asset = "rivet-sdlc-%V.vsix"
[[vsix]]
name = "spar-aadl"
repo = "pulseengine/spar"
version = "v0.40.0"
asset = "spar-aadl-%P-%V.vsix"
"#;
fn env_of(text: &str) -> AssemblerEnv {
assembler_env(&parse_layer_manifest(text).expect("parses")).expect("converts")
}
// rivet: verifies REQ-LAYERADAPT-001
#[test]
fn a_plain_tool_becomes_name_and_version() {
assert!(env_of(REAL).layer_tools.starts_with("rivet:v0.34.0 "));
}
// rivet: verifies REQ-LAYERADAPT-001
#[test]
fn a_differing_binary_name_is_carried_as_the_third_field() {
assert!(env_of(REAL).layer_tools.contains("kiln:v0.4.4:kilnd"));
}
/// The one raw-per-platform tool leaves TARBALL_TOOLS entirely — putting it
/// there would have the assembler look for a tarball that does not exist.
// rivet: verifies REQ-LAYERADAPT-001
#[test]
fn the_raw_per_platform_tool_becomes_wsc_version_and_not_a_tarball() {
let e = env_of(REAL);
assert_eq!(e.wsc_version.as_deref(), Some("v0.11.0"));
assert!(!e.layer_tools.contains("wsc"), "{}", e.layer_tools);
assert!(!e.layer_tools.contains("sigil"), "{}", e.layer_tools);
}
// rivet: verifies REQ-LAYERADAPT-001
#[test]
fn vsix_entries_drop_the_default_owner_the_assembler_re_adds() {
let e = env_of(REAL);
assert_eq!(
e.vsix_packages,
"rivet:v0.34.0:rivet-sdlc:rivet-sdlc-%V.vsix \
spar:v0.40.0:spar-aadl:spar-aadl-%P-%V.vsix"
);
}
/// The manifest is the only place a version is written, so a typo there
/// must not be able to leave the real key at its previous value.
// rivet: verifies REQ-LAYERADAPT-001
#[test]
fn a_mistyped_key_is_refused_rather_than_ignored() {
let text = REAL.replace("name = \"rivet\"", "nmae = \"rivet\"");
let err = parse_layer_manifest(&text).unwrap_err();
assert!(
matches!(&err, LayerSpecError::Parse(m) if m.contains("nmae")),
"{err}"
);
}
// rivet: verifies REQ-LAYERADAPT-001
#[test]
fn an_unknown_layout_is_refused_and_names_the_two_that_work() {
let text = REAL.replace("raw-per-platform", "zipfile");
let err = assembler_env(&parse_layer_manifest(&text).unwrap()).unwrap_err();
let msg = err.to_string();
assert!(
msg.contains("zipfile") && msg.contains("raw-per-platform"),
"{msg}"
);
}
/// The assembler has exactly one slot. A second raw-per-platform tool would
/// otherwise be dropped from a layer that still signs and publishes.
// rivet: verifies REQ-LAYERADAPT-001
#[test]
fn a_second_raw_per_platform_tool_is_refused_rather_than_dropped() {
let text = format!(
"{REAL}\n[[tool]]\nname = \"other\"\nversion = \"v1.0.0\"\nlayout = \"raw-per-platform\"\n"
);
let err = assembler_env(&parse_layer_manifest(&text).unwrap()).unwrap_err();
assert_eq!(
err,
LayerSpecError::ManyRawPerPlatform {
first: "wsc".into(),
second: "other".into()
}
);
}
/// Found by actually trying to assemble a bytecodealliance manifest: the
/// assembler's one raw-per-platform slot fetches `wsc` from
/// `pulseengine/sigil`, so putting any other tool in it emitted
/// WSC_VERSION = that tool's version and would have downloaded wsc at
/// v0.10.1 — wrong tool, wrong repo, wrong version, deposited under the
/// wrong name, silently.
// rivet: verifies REQ-LAYERADAPT-001
#[test]
fn a_raw_per_platform_tool_that_is_not_wsc_is_refused() {
let text = format!(
"{REAL}\n[[tool]]\nname = \"wac\"\nrepo = \"bytecodealliance/wac\"\n\
version = \"v0.10.1\"\nlayout = \"raw-per-platform\"\n"
);
// The FIRST raw tool in REAL is wsc, so this trips the many-slot rule;
// remove wsc to isolate the identity rule.
let only = text.replace(
"[[tool]]\nname = \"wsc\"\nrepo = \"pulseengine/sigil\"\nversion = \"v0.11.0\"\nlayout = \"raw-per-platform\"\n",
"",
);
assert!(!only.contains("wsc"), "the wsc block must be gone: {only}");
let err = assembler_env(&parse_layer_manifest(&only).unwrap()).unwrap_err();
assert_eq!(
err,
LayerSpecError::RawPerPlatformNotWsc {
tool: "wac".into(),
repo: "bytecodealliance/wac".into()
},
"{err}"
);
assert!(err.to_string().contains("wrong repository"), "{err}");
}
/// One wrong field is enough. The slot fetches `wsc` from
/// `pulseengine/sigil`, so a tool that matches two of those three and
/// misses the third still becomes a request for something else — and a
/// test that only varies all three at once cannot tell the guard from a
/// much weaker one. cargo-mutants proved that by narrowing it.
// rivet: verifies REQ-LAYERADAPT-001
#[test]
fn the_wsc_slot_rejects_a_tool_that_differs_in_any_single_field() {
let base = REAL.replace(
"[[tool]]\nname = \"wsc\"\nrepo = \"pulseengine/sigil\"\nversion = \"v0.11.0\"\nlayout = \"raw-per-platform\"\n",
"",
);
for (name, repo, what) in [
("wsc", "acme/sigil", "a different OWNER"),
("wsc", "pulseengine/other", "a different REPOSITORY"),
("other", "pulseengine/sigil", "a different TOOL NAME"),
] {
let text = format!(
"{base}\n[[tool]]\nname = \"{name}\"\nrepo = \"{repo}\"\n\
version = \"v1.0.0\"\nlayout = \"raw-per-platform\"\n"
);
let err = assembler_env(&parse_layer_manifest(&text).unwrap()).expect_err(what);
assert!(
matches!(err, LayerSpecError::RawPerPlatformNotWsc { .. }),
"{what} ({name} from {repo}) was not refused as a wsc-slot \
mismatch: {err:?}"
);
}
}
/// Dropping the owner would fetch pulseengine's release of the same name —
/// a different repository's bytes, deposited under a good signature.
// rivet: verifies REQ-LAYERADAPT-001
#[test]
fn a_foreign_owner_on_an_extension_is_refused() {
let text = REAL.replace(
"repo = \"pulseengine/rivet\"",
"repo = \"acme/rivet\"",
);
let err = assembler_env(&parse_layer_manifest(&text).unwrap()).unwrap_err();
assert_eq!(
err,
LayerSpecError::VsixForeignOwner {
name: "rivet-sdlc".into(),
repo: "acme/rivet".into()
}
);
}
/// The encoding's separators cannot appear in the data. Both of these would
/// be split by the shell rather than reported.
// rivet: verifies REQ-LAYERADAPT-001
#[test]
fn a_value_carrying_a_separator_is_refused() {
for (bad, why) in [("v1.0 rc1", "whitespace"), ("v1.0:rc1", "':'")] {
let text = REAL.replace("v0.34.0\"\n\n[[tool]]", &format!("{bad}\"\n\n[[tool]]"));
let err = assembler_env(&parse_layer_manifest(&text).unwrap()).unwrap_err();
let msg = err.to_string();
assert!(msg.contains(why), "{bad}: {msg}");
}
}
/// `tarball` is the default, but the docs say you may write it, so writing
/// it must not be refused. cargo-mutants found this by deleting the match
/// arm: every test used the default or `raw-per-platform`, so nothing
/// noticed that spelling it out stopped working.
// rivet: verifies REQ-LAYERADAPT-001
#[test]
fn an_explicit_tarball_layout_means_the_same_as_omitting_it() {
let explicit = REAL.replace(
"name = \"rivet\"\nversion = \"v0.34.0\"",
"name = \"rivet\"\nversion = \"v0.34.0\"\nlayout = \"tarball\"",
);
assert_ne!(explicit, REAL, "the fixture substitution must apply");
assert_eq!(env_of(&explicit).layer_tools, env_of(REAL).layer_tools);
}
/// A foreign OWNER is fine — `bytecodealliance/wasm-tools` is the whole
/// point of the second realm — as long as the basename still identifies
/// the tool.
// rivet: verifies REQ-LAYERADAPT-001
#[test]
fn a_foreign_owner_is_carried_as_a_qualified_repository() {
let text = format!(
"{REAL}\n[[tool]]\nname = \"wasm-tools\"\nrepo = \"bytecodealliance/wasm-tools\"\nversion = \"v1.257.1\"\n"
);
assert!(
env_of(&text)
.layer_tools
.contains("bytecodealliance/wasm-tools:v1.257.1"),
"{}",
env_of(&text).layer_tools
);
}
/// The assembler names the payload from the repository basename, so a
/// disagreeing `name` is discarded rather than translated — the layer would
/// deposit and verify while carrying a tool under a name nobody asked for.
/// cargo-mutants found this too: no fixture had a tarball tool whose repo
/// basename differed, because the only differing repo was exempt.
// rivet: verifies REQ-LAYERADAPT-001
#[test]
fn a_tool_whose_repo_basename_disagrees_with_its_name_is_refused() {
let text = format!(
"{REAL}\n[[tool]]\nname = \"wsc2\"\nrepo = \"pulseengine/sigil\"\nversion = \"v0.11.0\"\n"
);
let err = assembler_env(&parse_layer_manifest(&text).unwrap()).unwrap_err();
assert_eq!(
err,
LayerSpecError::RepoNameMismatch {
name: "wsc2".into(),
repo: "pulseengine/sigil".into(),
basename: "sigil".into(),
},
"{err}"
);
}
// rivet: verifies REQ-LAYERADAPT-001
#[test]
fn two_tools_of_one_name_are_refused() {
let text = format!("{REAL}\n[[tool]]\nname = \"rivet\"\nversion = \"v0.1.0\"\n");
let err = assembler_env(&parse_layer_manifest(&text).unwrap()).unwrap_err();
assert_eq!(
err,
LayerSpecError::Duplicate {
kind: "tool",
name: "rivet".into()
}
);
}
/// A release offering neither mechanism can be carried only with a stated
/// reason, and the reason is signed into the layer where every consumer
/// reads it. It belongs in the manifest beside the tool it excuses, not in
/// a workflow variable — split definitions are how versions drift (#106).
// rivet: verifies REQ-LAYERADAPT-001
// rivet: verifies REQ-INGEST-001
#[test]
fn an_unverified_reason_reaches_the_assembler_intact() {
let text = format!(
"{REAL}\n[[tool]]\nname = \"wac\"\nrepo = \"bytecodealliance/wac\"\n\
version = \"v0.10.1\"\nunverified-reason = \"publishes no sums, no cosign \
bundle and no attestation; tracked upstream, re-check each cut\"\n"
);
let env = env_of(&text);
assert_eq!(env.unverified_ingest.len(), 1);
assert_eq!(env.unverified_ingest[0].0, "bytecodealliance/wac");
assert!(env.unverified_ingest[0].1.contains("re-check each cut"));
// Rendered in $GITHUB_ENV's heredoc form, because the value is
// line-separated and a KEY=value line cannot carry newlines.
let r = env.render();
assert!(r.contains("UNVERIFIED_INGEST<<"), "{r}");
assert!(r.contains("bytecodealliance/wac=publishes no sums"), "{r}");
}
/// A reason containing the delimiter would end the heredoc early and let
/// whatever followed be read as further environment. That is an injection,
/// not a typo, so the delimiter is chosen against the content.
// rivet: verifies REQ-LAYERADAPT-001
#[test]
fn a_reason_containing_the_delimiter_cannot_close_the_block_early() {
let text = format!(
"{REAL}\n[[tool]]\nname = \"wac\"\nrepo = \"bytecodealliance/wac\"\n\
version = \"v0.10.1\"\nunverified-reason = \"VARVE_UNVERIFIED_EOF\\nPATH=/evil\"\n"
);
let r = env_of(&text).render();
let opened = r
.lines()
.find(|l| l.starts_with("UNVERIFIED_INGEST<<"))
.expect("heredoc opened");
let delim = opened.trim_start_matches("UNVERIFIED_INGEST<<");
// The delimiter must not appear inside the body it delimits.
let body = r.split(&format!("<<{delim}\n")).nth(1).expect("body");
let body = body.split(&format!("\n{delim}")).next().expect("closes");
assert!(
!body.contains(delim),
"delimiter occurs inside its own body"
);
assert!(
body.contains("PATH=/evil"),
"the reason must survive verbatim"
);
}
/// "We could not verify this" must never be the silent path.
// rivet: verifies REQ-LAYERADAPT-001
#[test]
fn an_empty_unverified_reason_is_refused() {
for bad in ["\"\"", "\" \""] {
let text = format!(
"{REAL}\n[[tool]]\nname = \"wac\"\nversion = \"v1\"\nunverified-reason = {bad}\n"
);
let err = assembler_env(&parse_layer_manifest(&text).unwrap()).unwrap_err();
assert_eq!(
err,
LayerSpecError::UnverifiedWithoutReason { tool: "wac".into() },
"{bad}"
);
}
}
/// The opt-in is per RELEASE. Two tools from one repository giving
/// different reasons would record one and drop the other.
// rivet: verifies REQ-LAYERADAPT-001
#[test]
fn two_tools_from_one_repo_must_agree_on_the_reason() {
// `wsc` already comes from pulseengine/sigil as a raw-per-platform
// tool, which is exempt from the basename rule; a tarball tool named
// `sigil` from the same repo is the reachable way two payloads share
// one release. Two tarball tools cannot, by construction.
let text = REAL.replace(
"layout = \"raw-per-platform\"",
"layout = \"raw-per-platform\"\nunverified-reason = \"first\"",
) + "\n[[tool]]\nname = \"sigil\"\nrepo = \"pulseengine/sigil\"\nversion = \"v0.11.0\"\n\
unverified-reason = \"second\"\n";
let err = assembler_env(&parse_layer_manifest(&text).unwrap()).unwrap_err();
assert!(
matches!(err, LayerSpecError::ConflictingReason { .. }),
"{err:?}"
);
// Agreeing is fine, and recorded once.
let ok = text.replace("\"second\"", "\"first\"");
assert_eq!(env_of(&ok).unverified_ingest.len(), 1);
}
/// A manifest with nothing unverified must not emit the variable at all —
/// an empty opt-in list and an absent one are different statements.
// rivet: verifies REQ-LAYERADAPT-001
#[test]
fn a_manifest_with_nothing_unverified_emits_no_opt_in() {
let r = env_of(REAL).render();
assert!(!r.contains("UNVERIFIED_INGEST"), "{r}");
}
// rivet: verifies REQ-LAYERADAPT-001
#[test]
fn a_manifest_with_no_payloads_is_refused() {
let text = "[varve]\nversion = \"v0.28.0\"\n\n[realm]\nname = \"p\"\nchannel = \"rolling\"\nregistry = \"oci://x\"\n";
assert_eq!(
assembler_env(&parse_layer_manifest(text).unwrap()).unwrap_err(),
LayerSpecError::Empty
);
}
/// VSIX_PACKAGES must be SET-but-empty rather than absent: the assembler
/// distinguishes "this layer carries no extensions" from "someone forgot".
// rivet: verifies REQ-LAYERADAPT-001
#[test]
fn a_layer_with_no_extensions_still_sets_the_variable() {
let text = REAL
.split("[[vsix]]")
.next()
.expect("has a tools section")
.to_string();
let rendered = env_of(&text).render();
assert!(rendered.contains("\nVSIX_PACKAGES=\n"), "{rendered}");
}
// rivet: verifies REQ-LAYERADAPT-001
#[test]
fn render_emits_one_key_per_line_in_a_stable_order() {
let rendered = env_of(REAL).render();
let keys: Vec<&str> = rendered
.lines()
.map(|l| l.split('=').next().unwrap_or(""))
.collect();
assert_eq!(
keys,
[
"TARBALL_TOOLS",
"WSC_VERSION",
"VSIX_PACKAGES",
"VARVE_REALM",
"VARVE_CHANNEL",
"VARVE_REGISTRY",
"VARVE_VERSION"
]
);
}
}
#[cfg(test)]
mod payload_identity_tests {
use super::*;
fn env_of(text: &str) -> Result<AssemblerEnv, LayerSpecError> {
assembler_env(&parse_layer_manifest(text).expect("parses"))
}
const HEAD: &str = "[varve]\nversion = \"v0.33.0\"\n[realm]\nname=\"pulseengine\"\n\
channel=\"rolling\"\nregistry=\"oci://x/y\"\n";
/// The wall this removes. sdk-ng publishes 140 host×target toolchains and
/// any monorepo upstream has the same shape; identity keyed on the
/// repository allowed each repo exactly one payload.
// rivet: verifies REQ-PAYLOADID-001
#[test]
fn one_repository_can_contribute_more_than_one_payload() {
let env = env_of(&format!(
"{HEAD}\n[[tool]]\nname=\"with-device\"\nrepo=\"pulseengine/jess\"\n\
binary=\"with-device\"\nversion=\"v0.7.2\"\nasset=\"with-device-0.2.2-%T.tar.gz\"\n\
\n[[tool]]\nname=\"bench-report\"\nrepo=\"pulseengine/jess\"\nbinary=\"bench-report\"\n\
version=\"v0.7.2\"\nasset=\"bench-report-0.1.0-%T.tar.gz\"\n"
))
.expect("two payloads from one repository must be expressible");
assert_eq!(env.layer_tools.split(' ').count(), 2, "{}", env.layer_tools);
}
/// The repository must survive translation. The old code shortened the
/// entry to the bare NAME whenever the owner was the default — safe only
/// while name == repo basename, which this requirement stops enforcing.
/// With the shortcut left in, `with-device` from `pulseengine/jess` emitted
/// `with-device:…` and the shell would fetch `pulseengine/with-device`.
// rivet: verifies REQ-PAYLOADID-001
#[test]
fn a_payload_named_differently_from_its_repo_still_names_its_repo() {
let env = env_of(&format!(
"{HEAD}\n[[tool]]\nname=\"with-device\"\nrepo=\"pulseengine/jess\"\n\
binary=\"with-device\"\nversion=\"v0.7.2\"\nasset=\"w-%T.tar.gz\"\n"
))
.expect("parses");
assert!(
env.layer_tools.starts_with("pulseengine/jess:"),
"the repository was lost: {}",
env.layer_tools
);
}
/// A hub repository tags a release and ships a tool at a DIFFERENT
/// version. `pulseengine/jess` tags v0.7.2 and ships with-device 0.2.2.
/// Without `release`, the manifest could only sign a version the binary
/// contradicts or name a tag that does not exist — and the env encoding
/// could already express it, so porting a realm to layer.toml LOST the
/// payload entirely. Found by the agent porting pulseengine-layers.
// rivet: verifies REQ-PAYLOADID-001
#[test]
fn a_hub_repos_tag_and_its_payloads_version_can_differ() {
let env = env_of(&format!(
"{HEAD}\n[[tool]]\nname=\"with-device\"\nrepo=\"pulseengine/jess\"\n\
binary=\"with-device\"\nrelease=\"v0.7.2\"\nversion=\"0.2.2\"\n\
asset=\"with-device-%V-%T.tar.gz\"\n"
))
.expect("a hub repo's payload must be expressible");
assert_eq!(
env.layer_tools, "pulseengine/jess:v0.7.2:with-device:with-device-%V-%T.tar.gz:0.2.2",
"the tag is fetched, the payload version is recorded"
);
}
/// The fifth field is POSITIONAL, so it cannot be carried past an absent
/// binary or template — that would shift the template into the binary slot
/// and fetch nonsense.
// rivet: verifies REQ-PAYLOADID-001
#[test]
fn a_payload_version_cannot_skip_the_positional_fields_before_it() {
// `name` matches the basename here, so the name guard cannot fire and
// this isolates the positional one.
let e = env_of(&format!(
"{HEAD}\n[[tool]]\nname=\"jess\"\nrepo=\"pulseengine/jess\"\n\
release=\"v0.7.2\"\nversion=\"0.2.2\"\n"
))
.expect_err("must refuse");
assert!(
matches!(e, LayerSpecError::ReleaseNeedsBinaryAndAsset { .. }),
"{e:?}"
);
assert!(e.to_string().contains("positional"), "{e}");
// EITHER one missing is enough, and this is the case that actually
// corrupts: with `binary` set and `asset` absent, appending the payload
// version would put it in the TEMPLATE slot, and the assembler would
// look for an asset literally named "0.2.2".
let e = env_of(&format!(
"{HEAD}\n[[tool]]\nname=\"jess\"\nrepo=\"pulseengine/jess\"\n\
binary=\"with-device\"\nrelease=\"v0.7.2\"\nversion=\"0.2.2\"\n"
))
.expect_err("binary without asset must still refuse");
assert!(
matches!(e, LayerSpecError::ReleaseNeedsBinaryAndAsset { .. }),
"{e:?}"
);
// ...and the mirror case.
let e = env_of(&format!(
"{HEAD}\n[[tool]]\nname=\"jess\"\nrepo=\"pulseengine/jess\"\n\
asset=\"a-%T.tar.gz\"\nrelease=\"v0.7.2\"\nversion=\"0.2.2\"\n"
))
.expect_err("asset without binary must still refuse");
assert!(
matches!(e, LayerSpecError::ReleaseNeedsBinaryAndAsset { .. }),
"{e:?}"
);
}
/// Clause 5. Every existing entry translates to exactly what it did before.
// rivet: verifies REQ-PAYLOADID-001
#[test]
fn an_ordinary_entry_is_unchanged() {
let env = env_of(&format!(
"{HEAD}\n[[tool]]\nname=\"rivet\"\nversion=\"v0.35.0\"\n"
))
.expect("parses");
assert_eq!(env.layer_tools, "rivet:v0.35.0");
}
/// Clause 4. The property the old guard protected survives: a payload that
/// would land under a name nobody asked for is still refused — a consumer
/// looking for it finds nothing in a layer that deposited and verified.
// rivet: verifies REQ-PAYLOADID-001
#[test]
fn a_name_the_encoding_would_silently_discard_is_still_refused() {
let e = env_of(&format!(
"{HEAD}\n[[tool]]\nname=\"zephyr-sdk\"\nrepo=\"zephyrproject-rtos/sdk-ng\"\n\
version=\"v1.0.1\"\n"
))
.expect_err("no binary means the shell deposits under the basename");
assert!(
matches!(e, LayerSpecError::RepoNameMismatch { .. }),
"{e:?}"
);
}
/// Two payloads that would land under ONE deposited name is still a
/// collision — the check moved, it did not go away.
// rivet: verifies REQ-PAYLOADID-001
#[test]
fn two_payloads_under_one_deposited_name_still_collide() {
let e = env_of(&format!(
"{HEAD}\n[[tool]]\nname=\"dup\"\nrepo=\"pulseengine/a\"\nbinary=\"dup\"\n\
version=\"v1\"\nasset=\"a-%T.tar.gz\"\n\n[[tool]]\nname=\"dup\"\nrepo=\"pulseengine/b\"\n\
binary=\"dup\"\nversion=\"v2\"\nasset=\"b-%T.tar.gz\"\n"
))
.expect_err("must refuse");
assert!(matches!(e, LayerSpecError::Duplicate { .. }), "{e:?}");
}
/// A layout the encoding cannot carry must stop at the boundary rather
/// than arrive at the shell as something else.
// rivet: verifies REQ-SDKDEPOSIT-001
#[test]
fn an_sdk_entry_refuses_to_translate_into_the_env_encoding() {
let e = env_of(&format!(
"{HEAD}\n[[tool]]\nname=\"zephyr-sdk\"\nrepo=\"zephyrproject-rtos/sdk-ng\"\n\
binary=\"zephyr-sdk\"\nversion=\"v1.0.1\"\nlayout=\"sdk\"\n\
asset=\"toolchain_gnu_%U_arm-zephyr-eabi.tar.xz\"\n"
))
.expect_err("must refuse");
let msg = e.to_string();
assert!(msg.contains("none for a LAYOUT"), "{msg}");
assert!(msg.contains("varve-producer deposit"), "{msg}");
}
/// `upstream-sums` names the mechanism that vouches for a release. The
/// encoding has no field for it, and dropping it is not a lost hint: the
/// shell assembler would look for a cosign bundle and an attestation,
/// find neither, and ingest the payload with NO proof — the declared
/// verification silently downgraded, with every other field surviving the
/// trip so the entry looks perfectly ordinary.
///
/// The sdk case above already established the rule: a field the encoding
/// cannot carry stops at the boundary. This one was dropped instead.
// rivet: verifies REQ-UPSTREAMSUMS-001
#[test]
fn an_upstream_sums_entry_refuses_rather_than_losing_the_mechanism() {
let e = env_of(&format!(
"{HEAD}\n[[tool]]\nname=\"wac\"\nrepo=\"bytecodealliance/wac\"\n\
binary=\"wac\"\nversion=\"v0.10.1\"\nasset=\"wac-%V-%T.tar.gz\"\n\
upstream-sums=\"sha256.sum\"\n"
))
.expect_err("must refuse");
let msg = e.to_string();
assert!(msg.contains("upstream-sums"), "{msg}");
assert!(msg.contains("varve-producer deposit"), "{msg}");
}
}