fd443d85c4
* update config_api with initialization and recovery utilities * nits * move tests to config_tests to eliminate config_api solana_runtime dependency * fixups
104 lines
3.6 KiB
Rust
104 lines
3.6 KiB
Rust
//! Config program
|
|
|
|
use crate::ConfigKeys;
|
|
use bincode::deserialize;
|
|
use log::*;
|
|
use solana_sdk::account::KeyedAccount;
|
|
use solana_sdk::instruction::InstructionError;
|
|
use solana_sdk::pubkey::Pubkey;
|
|
|
|
pub fn process_instruction(
|
|
_program_id: &Pubkey,
|
|
keyed_accounts: &mut [KeyedAccount],
|
|
data: &[u8],
|
|
) -> Result<(), InstructionError> {
|
|
let key_list: ConfigKeys = deserialize(data).map_err(|err| {
|
|
error!("Invalid ConfigKeys data: {:?} {:?}", data, err);
|
|
InstructionError::InvalidInstructionData
|
|
})?;
|
|
|
|
let current_data: ConfigKeys = deserialize(&keyed_accounts[0].account.data).map_err(|err| {
|
|
error!("Invalid data in account[0]: {:?} {:?}", data, err);
|
|
InstructionError::InvalidAccountData
|
|
})?;
|
|
let current_signer_keys: Vec<Pubkey> = current_data
|
|
.keys
|
|
.iter()
|
|
.filter(|(_, is_signer)| *is_signer)
|
|
.map(|(pubkey, _)| *pubkey)
|
|
.collect();
|
|
|
|
if current_signer_keys.is_empty() {
|
|
// Config account keypair must be a signer on account initilization,
|
|
// or when no signers specified in Config data
|
|
if keyed_accounts[0].signer_key().is_none() {
|
|
error!("account[0].signer_key().is_none()");
|
|
Err(InstructionError::MissingRequiredSignature)?;
|
|
}
|
|
}
|
|
|
|
let mut counter = 0;
|
|
for (i, (signer, _)) in key_list
|
|
.keys
|
|
.iter()
|
|
.filter(|(_, is_signer)| *is_signer)
|
|
.enumerate()
|
|
{
|
|
counter += 1;
|
|
if signer != keyed_accounts[0].unsigned_key() {
|
|
let account_index = i + 1;
|
|
let signer_account = keyed_accounts.get(account_index);
|
|
if signer_account.is_none() {
|
|
error!("account {:?} is not in account list", signer);
|
|
Err(InstructionError::MissingRequiredSignature)?;
|
|
}
|
|
let signer_key = signer_account.unwrap().signer_key();
|
|
if signer_key.is_none() {
|
|
error!("account {:?} signer_key().is_none()", signer);
|
|
Err(InstructionError::MissingRequiredSignature)?;
|
|
}
|
|
if signer_key.unwrap() != signer {
|
|
error!(
|
|
"account[{:?}].signer_key() does not match Config data)",
|
|
account_index
|
|
);
|
|
Err(InstructionError::MissingRequiredSignature)?;
|
|
}
|
|
// If Config account is already initialized, update signatures must match Config data
|
|
if !current_data.keys.is_empty()
|
|
&& current_signer_keys
|
|
.iter()
|
|
.find(|&pubkey| pubkey == signer)
|
|
.is_none()
|
|
{
|
|
error!("account {:?} is not in stored signer list", signer);
|
|
Err(InstructionError::MissingRequiredSignature)?;
|
|
}
|
|
} else if keyed_accounts[0].signer_key().is_none() {
|
|
error!("account[0].signer_key().is_none()");
|
|
Err(InstructionError::MissingRequiredSignature)?;
|
|
}
|
|
}
|
|
|
|
// Check for Config data signers not present in incoming account update
|
|
if current_signer_keys.len() > counter {
|
|
error!(
|
|
"too few signers: {:?}; expected: {:?}",
|
|
counter,
|
|
current_signer_keys.len()
|
|
);
|
|
Err(InstructionError::MissingRequiredSignature)?;
|
|
}
|
|
|
|
if keyed_accounts[0].account.data.len() < data.len() {
|
|
error!("instruction data too large");
|
|
Err(InstructionError::InvalidInstructionData)?;
|
|
}
|
|
|
|
keyed_accounts[0].account.data[0..data.len()].copy_from_slice(&data);
|
|
Ok(())
|
|
}
|
|
|
|
#[cfg(test)]
|
|
mod tests {}
|