Function main

ciphercore-base/src/bin/ciphercore_split_parties.rs:89–146

This binary reads the inputs from the file and splits them (+ possibly secret-shares) between the parties according to a command line parameter. # Arguments `inputs_path` - path to file that contains the inputs `input_parties` - string comprising of either a comma separated list of input parties' IDs, valid ID values include `0`, `1`, `2` OR `public` OR `secret-shared` `inputs_path_0` - path to

()

///
/// < this_binary > <context_path> <inline_mode> <input_parties> <output_parties>
fn main() {
    env_logger::init();
    execute_main(|| -> Result<()> {
        let args = Args::parse();
        let json_inputs = fs::read_to_string(&args.inputs_path)?;
        let inputs = serde_json::from_str::<Vec<TypedValue>>(&json_inputs)?;
        let input_parties = get_tokens(args.input_parties)?;
        let mut split_inputs = vec![vec![], vec![], vec![]];
        if inputs.len() != input_parties.len() {
            return Err(runtime_error!(
                "Invalid number of inputs parties: {} expected, but {} found",
                inputs.len(),
                input_parties.len()
            ));
        }
        let mut prng = PRNG::new(None)?;
        for i in 0..inputs.len() {
            match input_parties[i] {
                IOStatus::Party(p) => {
                    for (j, result_item) in split_inputs.iter_mut().enumerate() {
                        if j as u64 == p {
                            result_item.push(inputs[i].clone());
                        } else {
                            result_item.push(TypedValue::new(
                                inputs[i].t.clone(),
                                Value::zero_of_type(inputs[i].t.clone()),
                            )?);
                        }
                    }
                }
                IOStatus::Public => {
                    for result_item in split_inputs.iter_mut() {
                        result_item.push(inputs[i].clone());
                    }
                }
                IOStatus::Shared => {
                    let parties_shares = inputs[i].get_local_shares_for_each_party(&mut prng)?;
                    for j in 0..3 {
                        split_inputs[j].push(parties_shares[j].clone());
                    }
                }
            }
        }
        fs::write(
            args.parties_inputs_0,
            serde_json::to_string(&split_inputs[0])?,
        )?;
        fs::write(
            args.parties_inputs_1,
            serde_json::to_string(&split_inputs[1])?,
        )?;
        fs::write(
            args.parties_inputs_2,
            serde_json::to_string(&split_inputs[2])?,
        )?;
        Ok(())
    });
}