1#![doc = include_str!("../readme.md")]
2
3use indexmap::IndexMap;
4use packageurl::PackageUrl;
5use serde::{Deserialize, Serialize};
6use sha2::{Digest, Sha256};
7use std::collections::{BTreeMap, BTreeSet};
8use std::str::FromStr;
9
10#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
25pub struct Sbom {
26 pub metadata: Metadata,
28 pub components: IndexMap<ComponentId, Component>,
30 pub dependencies: BTreeMap<ComponentId, BTreeSet<ComponentId>>,
32}
33
34impl Default for Sbom {
35 fn default() -> Self {
36 Self {
37 metadata: Metadata::default(),
38 components: IndexMap::new(),
39 dependencies: BTreeMap::new(),
40 }
41 }
42}
43
44#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize, Default)]
50pub struct Metadata {
51 pub timestamp: Option<String>,
53 pub tools: Vec<String>,
55 pub authors: Vec<String>,
57}
58
59#[derive(Debug, Clone, PartialEq, Eq, Hash, PartialOrd, Ord, Serialize, Deserialize)]
79pub struct ComponentId(String);
80
81impl ComponentId {
82 pub fn new(purl: Option<&str>, properties: &[(&str, &str)]) -> Self {
87 if let Some(purl) = purl {
88 if let Ok(parsed) = PackageUrl::from_str(purl) {
90 return ComponentId(parsed.to_string());
91 }
92 return ComponentId(purl.to_string());
93 }
94
95 let mut hasher = Sha256::new();
97 for (k, v) in properties {
98 hasher.update(k.as_bytes());
99 hasher.update(b":");
100 hasher.update(v.as_bytes());
101 hasher.update(b"|");
102 }
103 let hash = hex::encode(hasher.finalize());
104 ComponentId(format!("h:{}", hash))
105 }
106
107 pub fn as_str(&self) -> &str {
109 &self.0
110 }
111}
112
113impl std::fmt::Display for ComponentId {
114 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
115 write!(f, "{}", self.0)
116 }
117}
118
119#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
125pub struct Component {
126 pub id: ComponentId,
128 pub name: String,
130 pub version: Option<String>,
132 pub ecosystem: Option<String>,
134 pub supplier: Option<String>,
136 pub description: Option<String>,
138 pub purl: Option<String>,
140 pub licenses: Vec<String>,
142 pub hashes: BTreeMap<String, String>,
144 pub source_ids: Vec<String>,
146}
147
148impl Component {
149 pub fn new(name: String, version: Option<String>) -> Self {
154 let mut props = vec![("name", name.as_str())];
155 if let Some(v) = &version {
156 props.push(("version", v));
157 }
158 let id = ComponentId::new(None, &props);
159
160 Self {
161 id,
162 name,
163 version,
164 ecosystem: None,
165 supplier: None,
166 description: None,
167 purl: None,
168 licenses: Vec::new(),
169 hashes: BTreeMap::new(),
170 source_ids: Vec::new(),
171 }
172 }
173}
174
175impl Sbom {
176 pub fn normalize(&mut self) {
186 self.components.sort_keys();
188
189 for deps in self.dependencies.values_mut() {
191 let _ = deps;
194 }
195
196 for component in self.components.values_mut() {
198 component.normalize();
199 }
200
201 self.metadata.timestamp = None;
203 self.metadata.tools.clear();
204 self.metadata.authors.clear(); }
206
207 pub fn roots(&self) -> Vec<ComponentId> {
211 let targets: BTreeSet<_> = self.dependencies.values().flatten().collect();
212 self.components
213 .keys()
214 .filter(|id| !targets.contains(id))
215 .cloned()
216 .collect()
217 }
218
219 pub fn deps(&self, id: &ComponentId) -> Vec<ComponentId> {
221 self.dependencies
222 .get(id)
223 .map(|d| d.iter().cloned().collect())
224 .unwrap_or_default()
225 }
226
227 pub fn rdeps(&self, id: &ComponentId) -> Vec<ComponentId> {
229 self.dependencies
230 .iter()
231 .filter(|(_, children)| children.contains(id))
232 .map(|(parent, _)| parent.clone())
233 .collect()
234 }
235
236 pub fn transitive_deps(&self, id: &ComponentId) -> BTreeSet<ComponentId> {
240 let mut visited = BTreeSet::new();
241 let mut stack = vec![id.clone()];
242 while let Some(current) = stack.pop() {
243 if let Some(children) = self.dependencies.get(¤t) {
244 for child in children {
245 if visited.insert(child.clone()) {
246 stack.push(child.clone());
247 }
248 }
249 }
250 }
251 visited
252 }
253
254 pub fn ecosystems(&self) -> BTreeSet<String> {
256 self.components
257 .values()
258 .filter_map(|c| c.ecosystem.clone())
259 .collect()
260 }
261
262 pub fn licenses(&self) -> BTreeSet<String> {
264 self.components
265 .values()
266 .flat_map(|c| c.licenses.iter().cloned())
267 .collect()
268 }
269
270 pub fn missing_hashes(&self) -> Vec<ComponentId> {
274 self.components
275 .iter()
276 .filter(|(_, c)| c.hashes.is_empty())
277 .map(|(id, _)| id.clone())
278 .collect()
279 }
280
281 pub fn by_purl(&self, purl: &str) -> Option<&Component> {
283 self.components
284 .values()
285 .find(|c| c.purl.as_deref() == Some(purl))
286 }
287}
288
289impl Component {
290 pub fn normalize(&mut self) {
294 self.licenses.sort();
295 self.licenses.dedup();
296
297 let normalized_hashes: BTreeMap<String, String> = self
298 .hashes
299 .iter()
300 .map(|(k, v)| (k.to_lowercase(), v.to_lowercase()))
301 .collect();
302 self.hashes = normalized_hashes;
303 }
304}
305
306#[cfg(test)]
307mod tests {
308 use super::*;
309
310 #[test]
311 fn test_component_id_purl() {
312 let purl = "pkg:npm/left-pad@1.3.0";
313 let id = ComponentId::new(Some(purl), &[]);
314 assert_eq!(id.as_str(), purl);
315 }
316
317 #[test]
318 fn test_component_id_hash_stability() {
319 let props = [("name", "foo"), ("version", "1.0")];
320 let id1 = ComponentId::new(None, &props);
321 let id2 = ComponentId::new(None, &props);
322 assert_eq!(id1, id2);
323 assert!(id1.as_str().starts_with("h:"));
324 }
325
326 #[test]
327 fn test_normalization() {
328 let mut comp = Component::new("test".to_string(), Some("1.0".to_string()));
329 comp.licenses.push("MIT".to_string());
330 comp.licenses.push("MIT".to_string());
331 comp.licenses.push("Apache-2.0".to_string());
332 comp.hashes.insert("SHA-256".to_string(), "ABC".to_string());
333
334 comp.normalize();
335
336 assert_eq!(comp.licenses, vec!["Apache-2.0", "MIT"]);
337 assert_eq!(comp.hashes.get("sha-256").unwrap(), "abc");
338 }
339
340 #[test]
341 fn test_query_api() {
342 let mut sbom = Sbom::default();
343 let c1 = Component::new("a".into(), Some("1".into()));
344 let c2 = Component::new("b".into(), Some("1".into()));
345 let c3 = Component::new("c".into(), Some("1".into()));
346
347 let id1 = c1.id.clone();
348 let id2 = c2.id.clone();
349 let id3 = c3.id.clone();
350
351 sbom.components.insert(id1.clone(), c1);
352 sbom.components.insert(id2.clone(), c2);
353 sbom.components.insert(id3.clone(), c3);
354
355 sbom.dependencies
357 .entry(id1.clone())
358 .or_default()
359 .insert(id2.clone());
360 sbom.dependencies
361 .entry(id2.clone())
362 .or_default()
363 .insert(id3.clone());
364
365 assert_eq!(sbom.roots(), vec![id1.clone()]);
366 assert_eq!(sbom.deps(&id1), vec![id2.clone()]);
367 assert_eq!(sbom.rdeps(&id2), vec![id1.clone()]);
368
369 let transitive = sbom.transitive_deps(&id1);
370 assert!(transitive.contains(&id2));
371 assert!(transitive.contains(&id3));
372 assert_eq!(transitive.len(), 2);
373
374 assert_eq!(sbom.missing_hashes().len(), 3);
375 }
376}