waalge
/
aiken
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

preliminary work on execution

This commit is contained in:
alessandrokonrad 2022-09-11 14:16:53 +02:00 committed by rvcas
parent 080985b7c6
commit b1b9d3a5d4
No known key found for this signature in database
GPG Key ID: C09B64E263F7D68C
1 changed files with 85 additions and 48 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

133
crates/cli/src/utils.rs
View File

@ -698,6 +698,12 @@ fn slot_range_to_posix_time_range(slot_range: TimeRange, sc: &SlotConfig) -> Tim
} }
} }
#[derive(Debug, PartialEq, Clone)]
enum ExecutionPurpose {
WithDatum(Language, PlutusData), // Spending
NoDatum(Language), // Minting, Wdrl, DCert
}
fn get_tx_in_info( fn get_tx_in_info(
inputs: &MaybeIndefArray<TransactionInput>, inputs: &MaybeIndefArray<TransactionInput>,
utxos: &MaybeIndefArray<TxInInfo>, utxos: &MaybeIndefArray<TxInInfo>,
@ -713,10 +719,10 @@ fn get_tx_in_info(
fn get_script_purpose( fn get_script_purpose(
redeemer: &Redeemer, redeemer: &Redeemer,
inputs: &MaybeIndefArray<TxInInfo>, inputs: &MaybeIndefArray<TransactionInput>,
mint: &Mint, mint: &Option<Mint>,
dcert: &MaybeIndefArray<Certificate>, dcert: &Option<MaybeIndefArray<Certificate>>,
wdrl: &Withdrawals, wdrl: &Option<Withdrawals>,
) -> anyhow::Result<ScriptPurpose> { ) -> anyhow::Result<ScriptPurpose> {
// sorting according to specs section 4.1: https://hydra.iohk.io/build/18583827/download/1/alonzo-changes.pdf // sorting according to specs section 4.1: https://hydra.iohk.io/build/18583827/download/1/alonzo-changes.pdf
let tag = redeemer.tag.clone(); let tag = redeemer.tag.clone();
@ -725,10 +731,11 @@ fn get_script_purpose(
RedeemerTag::Mint => { RedeemerTag::Mint => {
// sort lexical by policy id // sort lexical by policy id
let mut policy_ids = mint let mut policy_ids = mint
.as_ref()
.unwrap()
.iter() .iter()
.map(|(policy_id, _)| policy_id) .map(|(policy_id, _)| policy_id.clone())
.collect::<Vec<&ByteVec>>() .collect::<Vec<ByteVec>>();
.clone();
policy_ids.sort(); policy_ids.sort();
let policy_id = policy_ids[index as usize].clone(); let policy_id = policy_ids[index as usize].clone();
Ok(ScriptPurpose::Minting(policy_id)) Ok(ScriptPurpose::Minting(policy_id))
@ -737,9 +744,8 @@ fn get_script_purpose(
// sort lexical by tx_hash and index // sort lexical by tx_hash and index
let mut inputs = inputs let mut inputs = inputs
.iter() .iter()
.map(|input| input.out_ref.clone()) .map(|input| input.clone())
.collect::<Vec<TransactionInput>>() .collect::<Vec<TransactionInput>>();
.clone();
// is this correct? Does this sort lexical from low to high? maybe get Ordering into pallas for TransactionInput? // is this correct? Does this sort lexical from low to high? maybe get Ordering into pallas for TransactionInput?
inputs.sort_by( inputs.sort_by(
|i_a, i_b| match i_a.transaction_id.cmp(&i_b.transaction_id) { |i_a, i_b| match i_a.transaction_id.cmp(&i_b.transaction_id) {
@ -754,12 +760,13 @@ fn get_script_purpose(
RedeemerTag::Reward => { RedeemerTag::Reward => {
// sort lexical by reward account // sort lexical by reward account
let mut reward_accounts = wdrl let mut reward_accounts = wdrl
.as_ref()
.unwrap()
.iter() .iter()
.map(|(policy_id, _)| policy_id) .map(|(policy_id, _)| policy_id.clone())
.collect::<Vec<&RewardAccount>>() .collect::<Vec<RewardAccount>>();
.clone();
reward_accounts.sort(); reward_accounts.sort();
let reward_account = reward_accounts[index as usize]; let reward_account = reward_accounts[index as usize].clone();
let addresss = Address::from_bytes(&reward_account)?; let addresss = Address::from_bytes(&reward_account)?;
let credential = match addresss { let credential = match addresss {
Address::Stake(stake_address) => match stake_address.payload() { Address::Stake(stake_address) => match stake_address.payload() {
@ -776,7 +783,7 @@ fn get_script_purpose(
} }
RedeemerTag::Cert => { RedeemerTag::Cert => {
// sort by order given in the tx (just take it as it is basically) // sort by order given in the tx (just take it as it is basically)
let cert = dcert[index as usize].clone(); let cert = dcert.as_ref().unwrap()[index as usize].clone();
Ok(ScriptPurpose::Certifying(cert)) Ok(ScriptPurpose::Certifying(cert))
} }
} }
@ -819,7 +826,14 @@ fn get_tx_info(
.iter() .iter()
.map(|r| { .map(|r| {
( (
get_script_purpose(&r, &inputs, &mint, &dcert, &wdrl).unwrap(), get_script_purpose(
&r,
&tx.transaction_body.inputs,
&tx.transaction_body.mint,
&tx.transaction_body.certificates,
&tx.transaction_body.withdrawals,
)
.unwrap(),
r.clone(), r.clone(),
) )
}) })
@ -852,47 +866,70 @@ fn get_tx_info(
}) })
} }
fn get_script_context( fn get_execution_purpose(
tx: &Tx,
utxos: &MaybeIndefArray<TxInInfo>,
script_purpose: &ScriptPurpose,
) -> ExecutionPurpose {
todo!()
}
fn eval_redeemer(
tx: &Tx, tx: &Tx,
utxos: &MaybeIndefArray<TxInInfo>, utxos: &MaybeIndefArray<TxInInfo>,
slot_config: &SlotConfig, slot_config: &SlotConfig,
redeemer: &Redeemer, redeemer: &Redeemer,
) -> anyhow::Result<ScriptContext> { ) -> anyhow::Result<Redeemer> {
let tx_info = get_tx_info(tx, utxos, slot_config)?;
let purpose = get_script_purpose( let purpose = get_script_purpose(
redeemer, redeemer,
&tx_info.inputs, &tx.transaction_body.inputs,
&tx_info.mint, &tx.transaction_body.mint,
&tx_info.dcert, &tx.transaction_body.certificates,
&tx_info.wdrl, &tx.transaction_body.withdrawals,
)?; )?;
Ok(ScriptContext { tx_info, purpose })
let execution_purpose: ExecutionPurpose = get_execution_purpose(&tx, &utxos, &purpose);
match execution_purpose {
ExecutionPurpose::WithDatum(language, datum) => match language {
Language::PlutusV1 => todo!(),
Language::PlutusV2 => {
let tx_info = get_tx_info(tx, utxos, slot_config)?;
let script_context = ScriptContext { tx_info, purpose };
// TODO: eval programm
Ok(redeemer.clone())
}
},
ExecutionPurpose::NoDatum(language) => match language {
Language::PlutusV1 => todo!(),
Language::PlutusV2 => {
let tx_info = get_tx_info(tx, utxos, slot_config)?;
let script_context = ScriptContext { tx_info, purpose };
// TODO: eval programm
Ok(redeemer.clone())
}
},
}
} }
// TODO: Maybe make ToPlutusData dependent on a Plutus Language so it works for V1 and V2? // TODO: Maybe make ToPlutusData dependent on a Plutus Language so it works for V1 and V2?
// fn eval_single_redeemer( // fn eval_tx(
// redeemer: &Redeemer, // tx_bytes: &Vec<u8>,
// tx: &Tx, // utxos: &Vec<(Vec<u8>, Vec<u8>)>,
// utxos: &Vec<(TransactionInput, TransactionOutput)>, // cost_model: &Vec<u8>,
// cost_model: &CostModel, // zero_time: u64,
// slot_config: &SlotConfig, // slot_length: u64,
// language: &Language, // ) -> anyhow::Result<bool> {
// ) -> anyhow::Result<Redeemer> { // let multi_tx = MultiEraTx::decode(Era::Babbage, &tx_bytes)
// .or_else(|_| MultiEraTx::decode(Era::Alonzo, &tx_bytes))
// .or_else(|_| MultiEraTx::decode(Era::Byron, &tx_bytes))?;
// let tx = multi_tx.as_babbage().unwrap();
// Ok(true)
// } // }
fn eval_tx(
tx_bytes: &Vec<u8>,
utxos: &Vec<(Vec<u8>, Vec<u8>)>,
cost_model: &Vec<u8>,
zero_time: u64,
slot_length: u64,
) -> anyhow::Result<bool> {
let multi_tx = MultiEraTx::decode(Era::Babbage, &tx_bytes)
.or_else(|_| MultiEraTx::decode(Era::Alonzo, &tx_bytes))
.or_else(|_| MultiEraTx::decode(Era::Byron, &tx_bytes))?;
let tx = multi_tx.as_babbage().unwrap();
Ok(true)
}