keri-core 0.17.13

Core library for the Key Event Receipt Infrastructure
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 std::sync::Arc;

use crate::{
    database::{EscrowCreator, EscrowDatabase},
    error::Error,
    event_message::signed_event_message::SignedEventMessage,
    prefix::IdentifierPrefix,
    processor::notification::{Notification, NotificationBus, Notifier},
};

pub struct DuplicitousEvents<D: EscrowCreator> {
    pub(crate) events: D::EscrowDatabaseType,
}

impl<D: EscrowCreator> DuplicitousEvents<D> {
    pub fn new(db: Arc<D>) -> Self {
        let escrow_db = db.create_escrow_db("duplicitous_escrow");
        Self { events: escrow_db }
    }

    pub fn get(&self, id: &IdentifierPrefix) -> Result<Vec<SignedEventMessage>, Error> {
        self.events
            .get_from_sn(id, 0)
            .map_err(|_| Error::DbError)
            .map(|v| v.collect())
    }
}

impl<D: EscrowCreator> Notifier for DuplicitousEvents<D> {
    fn notify(&self, notification: &Notification, _bus: &NotificationBus) -> Result<(), Error> {
        match notification {
            Notification::DupliciousEvent(ev_message) => {
                self.events.insert(ev_message).map_err(|_| Error::DbError)?;
            }
            _ => return Err(Error::SemanticError("Wrong notification".into())),
        }

        Ok(())
    }
}