sta-rs 0.3.3

//! End-to-end tests verifying the protocol implementation

use sta_rs::*;
use star_test_utils::{client_zipf, AggregationServer};

#[cfg(feature = "star2")]
use ppoprf::ppoprf::{end_to_end_evaluation, Server as PPOPRFServer};

// TODO implement star2 fully
#[cfg(not(feature = "star2"))]
pub struct PPOPRFServer;

#[test]
fn serialize_ciphertext() {
  let mg = MessageGenerator::new(
    SingleMeasurement::new(b"foobar"),
    0,
    "epoch".as_bytes(),
  );
  let mut rnd = [0u8; 32];
  mg.sample_local_randomness(&mut rnd);
  let triple = Message::generate(&mg, &rnd, None)
    .expect("Failed to generate message triplet");
  let bytes = triple.ciphertext.to_bytes();
  assert_eq!(Ciphertext::from_bytes(&bytes), triple.ciphertext);
}

#[test]
fn serialize_triple() {
  let mg = MessageGenerator::new(
    SingleMeasurement::new(b"foobar"),
    0,
    "epoch".as_bytes(),
  );
  let mut rnd = [0u8; 32];
  mg.sample_local_randomness(&mut rnd);
  let triple = Message::generate(&mg, &rnd, None)
    .expect("Failed to generate message triplet");
  let bytes = triple.to_bytes();
  assert_eq!(Message::from_bytes(&bytes), Some(triple));
}

#[test]
fn roundtrip() {
  let mg = MessageGenerator::new(
    SingleMeasurement::new(b"foobar"),
    1,
    "epoch".as_bytes(),
  );
  let mut rnd = [0u8; 32];
  mg.sample_local_randomness(&mut rnd);
  let triple = Message::generate(&mg, &rnd, None)
    .expect("Failed to generate message triplet");

  let commune = share_recover(&[triple.share]).unwrap();
  let message = commune.get_message();

  let mut enc_key_buf = vec![0u8; 16];
  derive_ske_key(&message, "epoch".as_bytes(), &mut enc_key_buf);
  let plaintext = triple.ciphertext.decrypt(&enc_key_buf, "star_encrypt");
  let mut slice = &plaintext[..];

  let measurement_bytes = load_bytes(slice).unwrap();
  slice = &slice[4 + measurement_bytes.len()..];

  if !slice.is_empty() {
    let aux_bytes = load_bytes(slice).unwrap();
    assert_eq!(aux_bytes.len(), 0);
  }

  assert_eq!(measurement_bytes, b"foobar");
}

#[test]
fn star1_no_aux_multiple_block() {
  star_no_aux_multiple_block(None);
}

#[test]
fn star1_no_aux_single_block() {
  star_no_aux_single_block(None);
}

#[test]
fn star1_with_aux_multiple_block() {
  star_with_aux_multiple_block(None);
}

#[test]
fn star1_rand_with_aux_multiple_block() {
  star_rand_with_aux_multiple_block(None);
}

#[cfg(feature = "star2")]
#[test]
fn star2_no_aux_multiple_block() {
  let mds: &[Vec<u8>] = &[b"t".to_vec()];
  star_no_aux_multiple_block(Some(PPOPRFServer::new(&mds)));
}

#[cfg(feature = "star2")]
#[test]
fn star2_no_aux_single_block() {
  let mds: &[Vec<u8>] = &[b"t".to_vec()];
  star_no_aux_single_block(Some(PPOPRFServer::new(&mds)));
}

#[cfg(feature = "star2")]
#[test]
fn star2_with_aux_multiple_block() {
  let mds: &[Vec<u8>] = &[b"t".to_vec()];
  star_with_aux_multiple_block(Some(PPOPRFServer::new(&mds)));
}

#[cfg(feature = "star2")]
#[test]
fn star2_rand_with_aux_multiple_block() {
  let mds: &[Vec<u8>] = &[b"t".to_vec()];
  star_rand_with_aux_multiple_block(Some(PPOPRFServer::new(&mds)));
}

fn star_no_aux_multiple_block(oprf_server: Option<PPOPRFServer>) {
  let mut clients = Vec::new();
  let threshold = 2;
  let epoch = "t";
  let str1 = "hello world";
  let str2 = "goodbye sweet prince";
  for i in 0..10 {
    if i % 3 == 0 {
      clients.push(MessageGenerator::new(
        SingleMeasurement::new(str1.as_bytes()),
        threshold,
        epoch.as_bytes(),
      ));
    } else if i % 4 == 0 {
      clients.push(MessageGenerator::new(
        SingleMeasurement::new(str2.as_bytes()),
        threshold,
        epoch.as_bytes(),
      ));
    } else {
      clients.push(MessageGenerator::new(
        SingleMeasurement::new(&[i as u8]),
        threshold,
        epoch.as_bytes(),
      ));
    }
  }
  let agg_server = AggregationServer::new(threshold, epoch);

  let messages: Vec<Message> = clients
    .into_iter()
    .map(|mg| {
      let mut rnd = [0u8; 32];
      if oprf_server.is_none() {
        mg.sample_local_randomness(&mut rnd);
      } else {
        #[cfg(feature = "star2")]
        mg.sample_oprf_randomness(oprf_server, &mut rnd);
      }
      Message::generate(&mg, &rnd, None).unwrap()
    })
    .collect();
  let outputs = agg_server.retrieve_outputs(&messages[..]);
  for o in outputs {
    let tag_str = std::str::from_utf8(o.x.as_slice())
      .unwrap()
      .trim_end_matches(char::from(0));
    if tag_str == str1 {
      assert_eq!(o.aux.len(), 4);
    } else if tag_str == str2 {
      assert_eq!(o.aux.len(), 2);
    } else {
      panic!("Unexpected tag: {}", tag_str);
    }

    if let Some(b) = o.aux.into_iter().flatten().next() {
      panic!("Unexpected auxiliary data: {:?}", b);
    }
  }
}

fn star_no_aux_single_block(oprf_server: Option<PPOPRFServer>) {
  let mut clients = Vec::new();
  let threshold = 2;
  let epoch = "t";
  let str1 = "three";
  let str2 = "four";
  for i in 0..10 {
    if i % 3 == 0 {
      clients.push(MessageGenerator::new(
        SingleMeasurement::new(str1.as_bytes()),
        threshold,
        epoch.as_bytes(),
      ));
    } else if i % 4 == 0 {
      clients.push(MessageGenerator::new(
        SingleMeasurement::new(str2.as_bytes()),
        threshold,
        epoch.as_bytes(),
      ));
    } else {
      clients.push(MessageGenerator::new(
        SingleMeasurement::new(&[i as u8]),
        threshold,
        epoch.as_bytes(),
      ));
    }
  }
  let agg_server = AggregationServer::new(threshold, epoch);

  let messages: Vec<Message> = clients
    .into_iter()
    .map(|mg| {
      let mut rnd = [0u8; 32];
      if oprf_server.is_none() {
        mg.sample_local_randomness(&mut rnd);
      } else {
        #[cfg(feature = "star2")]
        mg.sample_oprf_randomness(oprf_server, &mut rnd);
      }
      Message::generate(&mg, &rnd, None)
        .expect("Failed to generate message triplet")
    })
    .collect();
  let outputs = agg_server.retrieve_outputs(&messages);
  for o in outputs {
    let tag_str = std::str::from_utf8(o.x.as_slice())
      .unwrap()
      .trim_end_matches(char::from(0));
    if tag_str == str1 {
      assert_eq!(o.aux.len(), 4);
    } else if tag_str == str2 {
      assert_eq!(o.aux.len(), 2);
    } else {
      panic!("Unexpected tag: {}", tag_str);
    }

    if let Some(b) = o.aux.into_iter().flatten().next() {
      panic!("Unexpected auxiliary data: {:?}", b);
    }
  }
}

fn star_with_aux_multiple_block(oprf_server: Option<PPOPRFServer>) {
  // Generate an assortment of client messages.
  let mut clients = Vec::new();
  let threshold = 2;
  let epoch = "t";
  let str1 = "hello world";
  let str2 = "goodbye sweet prince";
  let message_count = 10;
  for i in 0..message_count {
    if i % 3 == 0 {
      // Periodically generate the same message.
      clients.push(MessageGenerator::new(
        SingleMeasurement::new(str1.as_bytes()),
        threshold,
        epoch.as_bytes(),
      ));
    } else if i % 4 == 0 {
      // Another periodically-generated message.
      clients.push(MessageGenerator::new(
        SingleMeasurement::new(str2.as_bytes()),
        threshold,
        epoch.as_bytes(),
      ));
    } else {
      // Unique measurements which will not meet threshold.
      clients.push(MessageGenerator::new(
        SingleMeasurement::new(&[i]),
        threshold,
        epoch.as_bytes(),
      ));
    }
  }

  // Append some associated data and generate submissions.
  let messages: Vec<Message> = clients
    .into_iter()
    .zip(0..)
    .map(|(mg, counter)| {
      let mut rnd = [0u8; 32];
      if oprf_server.is_none() {
        mg.sample_local_randomness(&mut rnd);
      } else {
        #[cfg(feature = "star2")]
        mg.sample_oprf_randomness(oprf_server, &mut rnd)
      }
      Message::generate(&mg, &rnd, Some(AssociatedData::new(&[counter; 1])))
        .unwrap()
    })
    .collect();

  // Aggregate and recover messages meeting threshold.
  let agg_server = AggregationServer::new(threshold, epoch);
  let outputs = agg_server.retrieve_outputs(&messages);
  for o in outputs {
    // Confirm the expected messages met threshold and no others.
    let tag_str = std::str::from_utf8(o.x.as_slice())
      .unwrap()
      .trim_end_matches(char::from(0));
    if tag_str == str1 {
      assert_eq!(o.aux.len(), 4);
    } else if tag_str == str2 {
      assert_eq!(o.aux.len(), 2);
    } else {
      panic!("Unexpected tag: {}", tag_str);
    }

    // Confirm the expected AssociatedData values are recovered.
    assert!(
      o.aux.iter().all(|v| v.is_some()),
      "Expected auxiliary data from all submissions!"
    );
    for b in o.aux.iter().flatten() {
      let v = b.as_slice();
      assert_eq!(v.len(), 1, "Expected auxiliary data to be a single byte!");
      assert!(
        v[0] < message_count,
        "Auxiliary data should be the in range of the message count!"
      );
      if tag_str == str1 {
        assert!(v[0] % 3 == 0);
      } else if tag_str == str2 {
        assert!(v[0] % 4 == 0);
      } else {
        panic!("Auxiliary data has unexpected value: {}", v[0]);
      }
    }
  }
}

fn star_rand_with_aux_multiple_block(oprf_server: Option<PPOPRFServer>) {
  let mut clients = Vec::new();
  let threshold = 5;
  let epoch = "t";
  for _ in 0..254 {
    clients.push(client_zipf(1000, 1.03, threshold, epoch.as_bytes()));
  }
  let agg_server = AggregationServer::new(threshold, epoch);

  let messages: Vec<Message> = clients
    .into_iter()
    .zip(0..)
    .map(|(mg, counter)| {
      let mut rnd = [0u8; 32];
      if oprf_server.is_none() {
        mg.sample_local_randomness(&mut rnd);
      } else {
        #[cfg(feature = "star2")]
        mg.sample_oprf_randomness(oprf_server, &mut rnd);
      }
      Message::generate(&mg, &rnd, Some(AssociatedData::new(&[counter; 4])))
        .unwrap()
    })
    .collect();
  let outputs = agg_server.retrieve_outputs(&messages[..]);
  for o in outputs {
    for aux in o.aux {
      if aux.is_none() {
        panic!("Expected auxiliary data");
      } else if let Some(a) = aux {
        let val = a.as_slice()[0];
        assert!(val < 255);
        for i in 1..3 {
          assert_eq!(a.as_slice()[i], val);
        }
      }
    }
  }
}