bitwarden_ipc/traits/
crypto_provider.rs

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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
use super::{CommunicationBackend, SessionRepository};
use crate::{
    error::{ReceiveError, SendError},
    message::{IncomingMessage, OutgoingMessage},
};

pub trait CryptoProvider<Com, Ses>
where
    Com: CommunicationBackend,
    Ses: SessionRepository<Session = Self::Session>,
{
    type Session;
    type SendError;
    type ReceiveError;

    fn send(
        &self,
        communication: &Com,
        sessions: &Ses,
        message: OutgoingMessage,
    ) -> impl std::future::Future<Output = Result<(), SendError<Self::SendError, Com::SendError>>>;
    fn receive(
        &self,
        communication: &Com,
        sessions: &Ses,
    ) -> impl std::future::Future<
        Output = Result<IncomingMessage, ReceiveError<Self::ReceiveError, Com::ReceiveError>>,
    >;
}

pub struct NoEncryptionCryptoProvider;

impl<Com, Ses> CryptoProvider<Com, Ses> for NoEncryptionCryptoProvider
where
    Com: CommunicationBackend,
    Ses: SessionRepository<Session = ()>,
{
    type Session = ();
    type SendError = Com::SendError;
    type ReceiveError = Com::ReceiveError;

    async fn send(
        &self,
        communication: &Com,
        _sessions: &Ses,
        message: OutgoingMessage,
    ) -> Result<(), SendError<Self::SendError, Com::SendError>> {
        communication
            .send(message)
            .await
            .map_err(SendError::CommunicationError)
    }

    async fn receive(
        &self,
        communication: &Com,
        _sessions: &Ses,
    ) -> Result<IncomingMessage, ReceiveError<Self::ReceiveError, Com::ReceiveError>> {
        communication
            .receive()
            .await
            .map_err(ReceiveError::CommunicationError)
    }
}