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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
use crate::{
errors::Error,
ot::{Receiver as OtReceiver, Sender as OtSender},
};
use rand::{CryptoRng, Rng};
use scuttlebutt::{AbstractChannel, Block};
pub struct Sender {}
pub struct Receiver {}
impl OtSender for Sender {
type Msg = Block;
fn init<C: AbstractChannel, RNG: CryptoRng + Rng>(
_: &mut C,
_: &mut RNG,
) -> Result<Self, Error> {
Ok(Self {})
}
fn send<C: AbstractChannel, RNG: CryptoRng + Rng>(
&mut self,
channel: &mut C,
inputs: &[(Block, Block)],
_: &mut RNG,
) -> Result<(), Error> {
let mut bs = Vec::with_capacity(inputs.len());
for _ in 0..inputs.len() {
let b = channel.read_bool()?;
bs.push(b);
}
for (b, m) in bs.into_iter().zip(inputs.iter()) {
let m = if b { m.1 } else { m.0 };
channel.write_block(&m)?;
}
channel.flush()?;
Ok(())
}
}
impl std::fmt::Display for Sender {
fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result {
write!(f, "Dummy Sender")
}
}
impl OtReceiver for Receiver {
type Msg = Block;
fn init<C: AbstractChannel, RNG: CryptoRng + Rng>(
_: &mut C,
_: &mut RNG,
) -> Result<Self, Error> {
Ok(Self {})
}
fn receive<C: AbstractChannel, RNG: CryptoRng + Rng>(
&mut self,
channel: &mut C,
inputs: &[bool],
_: &mut RNG,
) -> Result<Vec<Block>, Error> {
for b in inputs.iter() {
channel.write_bool(*b)?;
}
channel.flush()?;
let mut out = Vec::with_capacity(inputs.len());
for _ in 0..inputs.len() {
let m = channel.read_block()?;
out.push(m);
}
Ok(out)
}
}
impl std::fmt::Display for Receiver {
fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result {
write!(f, "Dummy Receiver")
}
}