Adding upstream version 115.7.0esr.upstream/115.7.0esr

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 73 insertions, 0 deletions

diff --git a/third_party/rust/prio/examples/sum.rs b/third_party/rust/prio/examples/sum.rs
new file mode 100644
index 0000000000..da1c74cf75
--- /dev/null
+++ b/third_party/rust/prio/examples/sum.rs
@@ -0,0 +1,73 @@
+// SPDX-License-Identifier: MPL-2.0
+
+use prio::client::*;
+use prio::encrypt::*;
+use prio::field::*;
+use prio::server::*;
+
+fn main() {
+    let priv_key1 = PrivateKey::from_base64(
+        "BIl6j+J6dYttxALdjISDv6ZI4/VWVEhUzaS05LgrsfswmbLOgN\
+         t9HUC2E0w+9RqZx3XMkdEHBHfNuCSMpOwofVSq3TfyKwn0NrftKisKKVSaTOt5seJ67P5QL4hxgPWvxw==",
+    )
+    .unwrap();
+    let priv_key2 = PrivateKey::from_base64(
+        "BNNOqoU54GPo+1gTPv+hCgA9U2ZCKd76yOMrWa1xTWgeb4LhF\
+         LMQIQoRwDVaW64g/WTdcxT4rDULoycUNFB60LER6hPEHg/ObBnRPV1rwS3nj9Bj0tbjVPPyL9p8QW8B+w==",
+    )
+    .unwrap();
+
+    let pub_key1 = PublicKey::from(&priv_key1);
+    let pub_key2 = PublicKey::from(&priv_key2);
+
+    let dim = 8;
+
+    let mut client1 = Client::new(dim, pub_key1.clone(), pub_key2.clone()).unwrap();
+    let mut client2 = Client::new(dim, pub_key1, pub_key2).unwrap();
+
+    let data1_u32 = [0, 0, 1, 0, 0, 0, 0, 0];
+    println!("Client 1 Input: {:?}", data1_u32);
+
+    let data1 = data1_u32
+        .iter()
+        .map(|x| Field32::from(*x))
+        .collect::<Vec<Field32>>();
+
+    let data2_u32 = [0, 0, 1, 0, 0, 0, 0, 0];
+    println!("Client 2 Input: {:?}", data2_u32);
+
+    let data2 = data2_u32
+        .iter()
+        .map(|x| Field32::from(*x))
+        .collect::<Vec<Field32>>();
+
+    let (share1_1, share1_2) = client1.encode_simple(&data1).unwrap();
+    let (share2_1, share2_2) = client2.encode_simple(&data2).unwrap();
+    let eval_at = Field32::from(12313);
+
+    let mut server1 = Server::new(dim, true, priv_key1).unwrap();
+    let mut server2 = Server::new(dim, false, priv_key2).unwrap();
+
+    let v1_1 = server1
+        .generate_verification_message(eval_at, &share1_1)
+        .unwrap();
+    let v1_2 = server2
+        .generate_verification_message(eval_at, &share1_2)
+        .unwrap();
+
+    let v2_1 = server1
+        .generate_verification_message(eval_at, &share2_1)
+        .unwrap();
+    let v2_2 = server2
+        .generate_verification_message(eval_at, &share2_2)
+        .unwrap();
+
+    let _ = server1.aggregate(&share1_1, &v1_1, &v1_2).unwrap();
+    let _ = server2.aggregate(&share1_2, &v1_1, &v1_2).unwrap();
+
+    let _ = server1.aggregate(&share2_1, &v2_1, &v2_2).unwrap();
+    let _ = server2.aggregate(&share2_2, &v2_1, &v2_2).unwrap();
+
+    server1.merge_total_shares(server2.total_shares()).unwrap();
+    println!("Final Publication: {:?}", server1.total_shares());
+}