csaf-walker 0.17.0

A library to work with CSAF data
Documentation 
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

use crate::discover::{DiscoveredAdvisory, DiscoveredContext, DiscoveredVisitor};
use crate::report::{DocumentKey, Duplicates};
use std::sync::Arc;
use tokio::sync::Mutex;

/// An intercepting visitor, collecting duplicates
pub struct DetectDuplicatesVisitor<D: DiscoveredVisitor> {
    pub visitor: D,
    pub duplicates: Arc<Mutex<Duplicates>>,
}

impl<V: DiscoveredVisitor> DiscoveredVisitor for DetectDuplicatesVisitor<V> {
    type Error = V::Error;
    type Context = V::Context;

    async fn visit_context(
        &self,
        context: &DiscoveredContext<'_>,
    ) -> Result<Self::Context, Self::Error> {
        self.visitor.visit_context(context).await
    }

    async fn visit_advisory(
        &self,
        context: &Self::Context,
        advisory: DiscoveredAdvisory,
    ) -> Result<(), Self::Error> {
        {
            let key = DocumentKey::for_document(&advisory);

            let mut duplicates = self.duplicates.lock().await;
            if !duplicates.known.insert(key.clone()) {
                // add or get and increment by one
                *duplicates.duplicates.entry(key).or_default() += 1;
            }
        }

        self.visitor.visit_advisory(context, advisory).await
    }
}