stoffel-vm 0.1.0

Register-based virtual machine runtime and MPC execution engine for Stoffel programs
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

use super::super::{MpcEngineResult, MpcPartyId, RbcSessionId};
use super::core::MpcEngine;

/// Extended MPC engine trait for consensus protocols (RBC).
///
/// RBC (Reliable Broadcast) ensures that:
/// - If the broadcaster is honest, all honest parties deliver the same message
/// - If any honest party delivers a message, all honest parties eventually
///   deliver it
pub trait MpcEngineConsensus: MpcEngine {
    /// Broadcast a message reliably to all parties using RBC.
    fn rbc_broadcast(&self, message: &[u8]) -> MpcEngineResult<RbcSessionId>;

    /// Receive a reliable broadcast from a specific party.
    fn rbc_receive(&self, from_party: MpcPartyId, timeout_ms: u64) -> MpcEngineResult<Vec<u8>>;

    /// Receive a reliable broadcast from any party.
    fn rbc_receive_any(&self, timeout_ms: u64) -> MpcEngineResult<(MpcPartyId, Vec<u8>)>;
}

/// Async version of `MpcEngineConsensus`.
#[async_trait::async_trait]
pub trait AsyncMpcEngineConsensus: MpcEngineConsensus {
    /// Broadcast a message reliably to all parties asynchronously.
    async fn rbc_broadcast_async(&self, message: &[u8]) -> MpcEngineResult<RbcSessionId>;

    /// Receive a reliable broadcast from a specific party asynchronously.
    async fn rbc_receive_async(
        &self,
        from_party: MpcPartyId,
        timeout_ms: u64,
    ) -> MpcEngineResult<Vec<u8>>;

    /// Receive a reliable broadcast from any party asynchronously.
    async fn rbc_receive_any_async(
        &self,
        timeout_ms: u64,
    ) -> MpcEngineResult<(MpcPartyId, Vec<u8>)>;
}