Minor fixes

This commit is contained in:
Sosthene 2024-11-25 22:32:56 +01:00
parent 0aa0c6817a
commit ff47da3083

View File

@ -812,11 +812,7 @@ fn handle_prd(
std::collections::hash_map::Entry::Occupied(entry) => entry.into_mut(), std::collections::hash_map::Entry::Occupied(entry) => entry.into_mut(),
std::collections::hash_map::Entry::Vacant(entry) => { std::collections::hash_map::Entry::Vacant(entry) => {
debug!("Creating new process for outpoint: {}", outpoint); debug!("Creating new process for outpoint: {}", outpoint);
let empty_state = ProcessState { entry.insert(Process::new(outpoint))
commited_in: outpoint,
..Default::default()
};
entry.insert(Process::new(vec![empty_state], vec![]))
} }
}; };
@ -1085,6 +1081,10 @@ pub fn create_connect_transaction(members_str: Vec<String>, fee_rate: u32) -> Ap
addresses.extend(member.get_addresses().into_iter()); addresses.extend(member.get_addresses().into_iter());
} }
if addresses.is_empty() {
return Err(ApiError::new("No addresses to connect to".to_owned()));
}
let psbt = create_transaction_for_addresses(addresses.clone(), fee_rate)?; let psbt = create_transaction_for_addresses(addresses.clone(), fee_rate)?;
let new_secrets = get_shared_secrets_in_transaction(&psbt, addresses)?; let new_secrets = get_shared_secrets_in_transaction(&psbt, addresses)?;
@ -1149,6 +1149,8 @@ pub fn create_new_process(
// We now need a hash that commits to the clear value of each field + the process id (or outpoint) // We now need a hash that commits to the clear value of each field + the process id (or outpoint)
let fields_commitment = pcd.hash_fields(outpoint)?; let fields_commitment = pcd.hash_fields(outpoint)?;
let mut process = Process::new(outpoint);
// We now create the first process state with all that data // We now create the first process state with all that data
let process_state = ProcessState { let process_state = ProcessState {
commited_in: outpoint, commited_in: outpoint,
@ -1156,9 +1158,9 @@ pub fn create_new_process(
encrypted_pcd: Value::Object(fields2cipher.clone()), encrypted_pcd: Value::Object(fields2cipher.clone()),
keys: fields2keys.clone(), keys: fields2keys.clone(),
validation_tokens: vec![], validation_tokens: vec![],
}; };
let process = Process::new(vec![process_state], vec![]); process.insert_concurrent_state(process_state)?;
{ {
let mut processes = lock_processes()?; let mut processes = lock_processes()?;