1use std::path::{Path, PathBuf};
11
12use anyhow::{Context, Result};
13use chrono::{DateTime, Utc};
14use holger_update_bundle::core::{EvidenceKind, PolicyResult, SourceProvenance};
15use holger_update_bundle::digest::sha256_hex;
16use holger_update_bundle::finalize::{add_approval, finalize};
17use holger_update_bundle::prepare::{EvidenceInput, PayloadInput, Preparation};
18use holger_update_bundle::{pack_bundle, TrustPolicy, VerifyReport};
19
20use crate::set::AdvisorySet;
21use crate::{ADVISORIES_MEDIA_TYPE, ADVISORIES_REL, INTEL_PRODUCT, SOURCES_REL};
22
23pub struct SignerFiles {
26 pub cert_der: Vec<u8>,
27 pub key_pkcs8: Vec<u8>,
28}
29
30impl SignerFiles {
31 pub fn read(cert: &Path, key: &Path) -> Result<Self> {
32 Ok(Self {
33 cert_der: std::fs::read(cert).with_context(|| format!("read cert {}", cert.display()))?,
34 key_pkcs8: std::fs::read(key).with_context(|| format!("read key {}", key.display()))?,
35 })
36 }
37}
38
39pub struct BuildOptions {
41 pub sequence: u64,
44 pub created_at: DateTime<Utc>,
45 pub expires_at: Option<DateTime<Utc>>,
46 pub supplier: String,
47 pub producer: String,
48 pub policy: TrustPolicy,
51 pub approvals: Vec<(String, SignerFiles)>,
53 pub release: SignerFiles,
54 pub out: PathBuf,
55}
56
57pub struct BuiltBundle {
59 pub path: PathBuf,
60 pub bundle_id: String,
61 pub sequence: u64,
62 pub advisories: usize,
63 pub advisories_sha256: String,
64 pub report: VerifyReport,
65}
66
67pub fn sequence_for(t: DateTime<Utc>) -> u64 {
70 t.format("%Y%m%d%H%M%S").to_string().parse().unwrap_or(0)
71}
72
73pub fn build_bundle(set: &AdvisorySet, opts: BuildOptions) -> Result<BuiltBundle> {
75 let payload = set.to_json_bytes()?;
76 let sources = serde_json::to_vec_pretty(&set.sources)?;
77 let digest = sha256_hex(&payload);
78 let date = opts.created_at.format("%Y-%m-%d");
79 let bundle_id = format!("holger-intel-{}-{date}", opts.sequence);
80 let fetched_at = set.sources.iter().map(|s| s.fetched_at).max();
81 let policy_digest = sha256_hex(opts.policy.to_ron()?.as_bytes());
82
83 let prep = Preparation {
84 bundle_id: bundle_id.clone(),
85 sequence: opts.sequence,
86 created_at: opts.created_at,
87 expires_at: opts.expires_at,
88 producer: opts.producer.clone(),
89 supplier: opts.supplier.clone(),
90 product: INTEL_PRODUCT.to_string(),
91 release_version: format!("{date}.{}", opts.sequence),
92 supported_hardware_models: vec![],
93 supported_hardware_revisions: vec![],
94 source_provenance: SourceProvenance {
95 source_kind: "intel-feeds".into(),
96 source_uri: None,
97 source_repository: None,
98 source_asset_path: None,
99 fetched_at,
100 reported_size: Some(payload.len() as u64),
101 vendor_checksum: None,
102 vendor_signature_status: None,
103 tls_origin: None,
104 transfer_receipt_digest: None,
105 },
106 policy_result: PolicyResult {
107 policy_digest,
108 advisory_snapshot_digest: Some(digest.clone()),
109 verdict: "pass".into(),
110 non_production: false,
111 },
112 supersedes: vec![],
113 withdraws: vec![],
114 payloads: vec![PayloadInput {
115 relative_path: ADVISORIES_REL.into(),
116 bytes: payload,
117 media_type: ADVISORIES_MEDIA_TYPE.into(),
118 }],
119 evidence: vec![EvidenceInput {
120 relative_path: SOURCES_REL.into(),
121 bytes: sources,
122 media_type: "application/json".into(),
123 kind: EvidenceKind::Advisory,
124 }],
125 };
126 let candidate = prep.build().map_err(|e| anyhow::anyhow!("prepare intel bundle: {e}"))?;
127 let mut members = candidate.members;
128 let now = Utc::now();
129 for (role, s) in &opts.approvals {
130 add_approval(&mut members, role, &s.cert_der, &s.key_pkcs8, None, now)
131 .map_err(|e| anyhow::anyhow!("approve intel bundle as {role}: {e}"))?;
132 }
133 let report = finalize(&mut members, &opts.policy, &opts.release.cert_der, &opts.release.key_pkcs8, now)
134 .map_err(|e| anyhow::anyhow!("sign intel bundle: {e}"))?;
135 if let Some(p) = opts.out.parent().filter(|p| !p.as_os_str().is_empty()) {
136 std::fs::create_dir_all(p).ok();
137 }
138 pack_bundle(&members, &opts.out).map_err(|e| anyhow::anyhow!("pack intel bundle: {e}"))?;
139 Ok(BuiltBundle {
140 path: opts.out,
141 bundle_id,
142 sequence: opts.sequence,
143 advisories: set.advisories.len(),
144 advisories_sha256: digest,
145 report,
146 })
147}