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: BTreeSet<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: BTreeSet::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) {
295 let normalized_hashes: BTreeMap<String, String> = self
296 .hashes
297 .iter()
298 .map(|(k, v)| (k.to_lowercase(), v.to_lowercase()))
299 .collect();
300 self.hashes = normalized_hashes;
301 }
302}
303
304pub fn parse_license_expression(license: &str) -> BTreeSet<String> {
319 match spdx::Expression::parse(license) {
320 Ok(expr) => {
321 let ids: BTreeSet<String> = expr
322 .requirements()
323 .filter_map(|r| r.req.license.id())
324 .map(|id| id.name.to_string())
325 .collect();
326 if ids.is_empty() {
327 BTreeSet::from([license.to_string()])
329 } else {
330 ids
331 }
332 }
333 Err(_) => {
334 BTreeSet::from([license.to_string()])
336 }
337 }
338}
339
340#[cfg(test)]
341mod tests {
342 use super::*;
343
344 #[test]
345 fn test_component_id_purl() {
346 let purl = "pkg:npm/left-pad@1.3.0";
347 let id = ComponentId::new(Some(purl), &[]);
348 assert_eq!(id.as_str(), purl);
349 }
350
351 #[test]
352 fn test_component_id_hash_stability() {
353 let props = [("name", "foo"), ("version", "1.0")];
354 let id1 = ComponentId::new(None, &props);
355 let id2 = ComponentId::new(None, &props);
356 assert_eq!(id1, id2);
357 assert!(id1.as_str().starts_with("h:"));
358 }
359
360 #[test]
361 fn test_normalization() {
362 let mut comp = Component::new("test".to_string(), Some("1.0".to_string()));
363 comp.licenses.insert("MIT".to_string());
364 comp.licenses.insert("Apache-2.0".to_string());
365 comp.hashes.insert("SHA-256".to_string(), "ABC".to_string());
366
367 comp.normalize();
368
369 assert_eq!(
371 comp.licenses,
372 BTreeSet::from(["Apache-2.0".to_string(), "MIT".to_string()])
373 );
374 assert_eq!(comp.hashes.get("sha-256").unwrap(), "abc");
375 }
376
377 #[test]
378 fn test_parse_license_expression() {
379 let ids = parse_license_expression("MIT OR Apache-2.0");
381 assert!(ids.contains("MIT"));
382 assert!(ids.contains("Apache-2.0"));
383 assert_eq!(ids.len(), 2);
384
385 let ids = parse_license_expression("MIT");
387 assert_eq!(ids, BTreeSet::from(["MIT".to_string()]));
388
389 let ids = parse_license_expression("MIT AND Apache-2.0");
391 assert!(ids.contains("MIT"));
392 assert!(ids.contains("Apache-2.0"));
393
394 let ids = parse_license_expression("Custom License");
396 assert_eq!(ids, BTreeSet::from(["Custom License".to_string()]));
397 }
398
399 #[test]
400 fn test_license_set_equality() {
401 let mut c1 = Component::new("test".into(), None);
403 c1.licenses.insert("MIT".into());
404 c1.licenses.insert("Apache-2.0".into());
405
406 let mut c2 = Component::new("test".into(), None);
407 c2.licenses.insert("Apache-2.0".into());
408 c2.licenses.insert("MIT".into());
409
410 assert_eq!(c1.licenses, c2.licenses);
411 }
412
413 #[test]
414 fn test_query_api() {
415 let mut sbom = Sbom::default();
416 let c1 = Component::new("a".into(), Some("1".into()));
417 let c2 = Component::new("b".into(), Some("1".into()));
418 let c3 = Component::new("c".into(), Some("1".into()));
419
420 let id1 = c1.id.clone();
421 let id2 = c2.id.clone();
422 let id3 = c3.id.clone();
423
424 sbom.components.insert(id1.clone(), c1);
425 sbom.components.insert(id2.clone(), c2);
426 sbom.components.insert(id3.clone(), c3);
427
428 sbom.dependencies
430 .entry(id1.clone())
431 .or_default()
432 .insert(id2.clone());
433 sbom.dependencies
434 .entry(id2.clone())
435 .or_default()
436 .insert(id3.clone());
437
438 assert_eq!(sbom.roots(), vec![id1.clone()]);
439 assert_eq!(sbom.deps(&id1), vec![id2.clone()]);
440 assert_eq!(sbom.rdeps(&id2), vec![id1.clone()]);
441
442 let transitive = sbom.transitive_deps(&id1);
443 assert!(transitive.contains(&id2));
444 assert!(transitive.contains(&id3));
445 assert_eq!(transitive.len(), 2);
446
447 assert_eq!(sbom.missing_hashes().len(), 3);
448 }
449}