mirror of
https://github.com/logos-blockchain/logos-execution-zone.git
synced 2026-05-12 02:59:29 +00:00
remove stale files
This commit is contained in:
Sergio Chouhy
parent
fda862f5bc
commit
b05da5b426
@ -1,165 +0,0 @@
|
|||||||
use common::{HashType, transaction::NSSATransaction};
|
|
||||||
use sequencer_service_rpc::RpcClient as _;
|
|
||||||
use key_protocol::key_management::ephemeral_key_holder::EphemeralKeyHolder;
|
|
||||||
use nssa::{AccountId, privacy_preserving_transaction::circuit};
|
|
||||||
use nssa_core::{MembershipProof, SharedSecretKey, account::AccountWithMetadata};
|
|
||||||
|
|
||||||
use crate::{
|
|
||||||
ExecutionFailureKind, WalletCore, helperfunctions::produce_random_nonces,
|
|
||||||
transaction_utils::AccountPreparedData,
|
|
||||||
};
|
|
||||||
|
|
||||||
impl WalletCore {
|
|
||||||
pub async fn claim_pinata(
|
|
||||||
&self,
|
|
||||||
pinata_account_id: AccountId,
|
|
||||||
winner_account_id: AccountId,
|
|
||||||
solution: u128,
|
|
||||||
) -> Result<HashType, ExecutionFailureKind> {
|
|
||||||
let account_ids = vec![pinata_account_id, winner_account_id];
|
|
||||||
let program_id = nssa::program::Program::pinata().id();
|
|
||||||
let message =
|
|
||||||
nssa::public_transaction::Message::try_new(program_id, account_ids, vec![], solution)
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
let witness_set = nssa::public_transaction::WitnessSet::for_message(&message, &[]);
|
|
||||||
let tx = nssa::PublicTransaction::new(message, witness_set);
|
|
||||||
|
|
||||||
Ok(self.sequencer_client.send_transaction(NSSATransaction::Public(tx).into()).await?)
|
|
||||||
}
|
|
||||||
|
|
||||||
pub async fn claim_pinata_private_owned_account_already_initialized(
|
|
||||||
&self,
|
|
||||||
pinata_account_id: AccountId,
|
|
||||||
winner_account_id: AccountId,
|
|
||||||
solution: u128,
|
|
||||||
winner_proof: MembershipProof,
|
|
||||||
) -> Result<(HashType, [SharedSecretKey; 1]), ExecutionFailureKind> {
|
|
||||||
let AccountPreparedData {
|
|
||||||
nsk: winner_nsk,
|
|
||||||
npk: winner_npk,
|
|
||||||
vpk: winner_vpk,
|
|
||||||
auth_acc: winner_pre,
|
|
||||||
proof: _,
|
|
||||||
} = self
|
|
||||||
.private_acc_preparation(winner_account_id, true, false)
|
|
||||||
.await?;
|
|
||||||
|
|
||||||
let pinata_acc = self.get_account_public(pinata_account_id).await.unwrap();
|
|
||||||
|
|
||||||
let program = nssa::program::Program::pinata();
|
|
||||||
|
|
||||||
let pinata_pre = AccountWithMetadata::new(pinata_acc.clone(), false, pinata_account_id);
|
|
||||||
|
|
||||||
let eph_holder_winner = EphemeralKeyHolder::new(&winner_npk);
|
|
||||||
let shared_secret_winner = eph_holder_winner.calculate_shared_secret_sender(&winner_vpk);
|
|
||||||
|
|
||||||
let (output, proof) = circuit::execute_and_prove(
|
|
||||||
&[pinata_pre, winner_pre],
|
|
||||||
&nssa::program::Program::serialize_instruction(solution).unwrap(),
|
|
||||||
&[0, 1],
|
|
||||||
&produce_random_nonces(1),
|
|
||||||
&[(winner_npk, shared_secret_winner.clone())],
|
|
||||||
&[(winner_nsk.unwrap())],
|
|
||||||
&[winner_proof],
|
|
||||||
&program.into(),
|
|
||||||
)
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
let message =
|
|
||||||
nssa::privacy_preserving_transaction::message::Message::try_from_circuit_output(
|
|
||||||
vec![pinata_account_id],
|
|
||||||
vec![],
|
|
||||||
vec![(
|
|
||||||
winner_npk,
|
|
||||||
winner_vpk.clone(),
|
|
||||||
eph_holder_winner.generate_ephemeral_public_key(),
|
|
||||||
)],
|
|
||||||
output,
|
|
||||||
)
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
let witness_set =
|
|
||||||
nssa::privacy_preserving_transaction::witness_set::WitnessSet::for_message(
|
|
||||||
&message,
|
|
||||||
proof,
|
|
||||||
&[],
|
|
||||||
);
|
|
||||||
let tx = nssa::privacy_preserving_transaction::PrivacyPreservingTransaction::new(
|
|
||||||
message,
|
|
||||||
witness_set,
|
|
||||||
);
|
|
||||||
|
|
||||||
Ok((
|
|
||||||
self.sequencer_client.send_transaction(NSSATransaction::PrivacyPreserving(tx).into()).await?,
|
|
||||||
[shared_secret_winner],
|
|
||||||
))
|
|
||||||
}
|
|
||||||
|
|
||||||
pub async fn claim_pinata_private_owned_account_not_initialized(
|
|
||||||
&self,
|
|
||||||
pinata_account_id: AccountId,
|
|
||||||
winner_account_id: AccountId,
|
|
||||||
solution: u128,
|
|
||||||
) -> Result<(HashType, [SharedSecretKey; 1]), ExecutionFailureKind> {
|
|
||||||
let AccountPreparedData {
|
|
||||||
nsk: _,
|
|
||||||
npk: winner_npk,
|
|
||||||
vpk: winner_vpk,
|
|
||||||
auth_acc: winner_pre,
|
|
||||||
proof: _,
|
|
||||||
} = self
|
|
||||||
.private_acc_preparation(winner_account_id, false, false)
|
|
||||||
.await?;
|
|
||||||
|
|
||||||
let pinata_acc = self.get_account_public(pinata_account_id).await.unwrap();
|
|
||||||
|
|
||||||
let program = nssa::program::Program::pinata();
|
|
||||||
|
|
||||||
let pinata_pre = AccountWithMetadata::new(pinata_acc.clone(), false, pinata_account_id);
|
|
||||||
|
|
||||||
let eph_holder_winner = EphemeralKeyHolder::new(&winner_npk);
|
|
||||||
let shared_secret_winner = eph_holder_winner.calculate_shared_secret_sender(&winner_vpk);
|
|
||||||
|
|
||||||
let (output, proof) = circuit::execute_and_prove(
|
|
||||||
&[pinata_pre, winner_pre],
|
|
||||||
&nssa::program::Program::serialize_instruction(solution).unwrap(),
|
|
||||||
&[0, 2],
|
|
||||||
&produce_random_nonces(1),
|
|
||||||
&[(winner_npk, shared_secret_winner.clone())],
|
|
||||||
&[],
|
|
||||||
&[],
|
|
||||||
&program.into(),
|
|
||||||
)
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
let message =
|
|
||||||
nssa::privacy_preserving_transaction::message::Message::try_from_circuit_output(
|
|
||||||
vec![pinata_account_id],
|
|
||||||
vec![],
|
|
||||||
vec![(
|
|
||||||
winner_npk,
|
|
||||||
winner_vpk.clone(),
|
|
||||||
eph_holder_winner.generate_ephemeral_public_key(),
|
|
||||||
)],
|
|
||||||
output,
|
|
||||||
)
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
let witness_set =
|
|
||||||
nssa::privacy_preserving_transaction::witness_set::WitnessSet::for_message(
|
|
||||||
&message,
|
|
||||||
proof,
|
|
||||||
&[],
|
|
||||||
);
|
|
||||||
let tx = nssa::privacy_preserving_transaction::PrivacyPreservingTransaction::new(
|
|
||||||
message,
|
|
||||||
witness_set,
|
|
||||||
);
|
|
||||||
|
|
||||||
Ok((
|
|
||||||
self.sequencer_client.send_transaction(NSSATransaction::PrivacyPreserving(tx).into()).await?,
|
|
||||||
[shared_secret_winner],
|
|
||||||
))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,594 +0,0 @@
|
|||||||
use common::{HashType, transaction::NSSATransaction};
|
|
||||||
use sequencer_service_rpc::RpcClient as _;
|
|
||||||
use key_protocol::key_management::ephemeral_key_holder::EphemeralKeyHolder;
|
|
||||||
use nssa::{
|
|
||||||
Account, AccountId, PrivacyPreservingTransaction,
|
|
||||||
privacy_preserving_transaction::{circuit, message::Message, witness_set::WitnessSet},
|
|
||||||
program::Program,
|
|
||||||
};
|
|
||||||
use nssa_core::{
|
|
||||||
Commitment, MembershipProof, NullifierPublicKey, NullifierSecretKey, SharedSecretKey,
|
|
||||||
account::AccountWithMetadata, encryption::ViewingPublicKey, program::InstructionData,
|
|
||||||
};
|
|
||||||
|
|
||||||
use crate::{ExecutionFailureKind, WalletCore, helperfunctions::produce_random_nonces};
|
|
||||||
|
|
||||||
pub(crate) struct AccountPreparedData {
|
|
||||||
pub nsk: Option<NullifierSecretKey>,
|
|
||||||
pub npk: NullifierPublicKey,
|
|
||||||
pub vpk: ViewingPublicKey,
|
|
||||||
pub auth_acc: AccountWithMetadata,
|
|
||||||
pub proof: Option<MembershipProof>,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl WalletCore {
|
|
||||||
pub(crate) async fn private_acc_preparation(
|
|
||||||
&self,
|
|
||||||
account_id: AccountId,
|
|
||||||
is_authorized: bool,
|
|
||||||
needs_proof: bool,
|
|
||||||
) -> Result<AccountPreparedData, ExecutionFailureKind> {
|
|
||||||
let Some((from_keys, from_acc)) = self
|
|
||||||
.storage
|
|
||||||
.user_data
|
|
||||||
.get_private_account(&account_id)
|
|
||||||
.cloned()
|
|
||||||
else {
|
|
||||||
return Err(ExecutionFailureKind::KeyNotFoundError);
|
|
||||||
};
|
|
||||||
|
|
||||||
let mut nsk = None;
|
|
||||||
let mut proof = None;
|
|
||||||
|
|
||||||
let from_npk = from_keys.nullifier_public_key;
|
|
||||||
let from_vpk = from_keys.viewing_public_key;
|
|
||||||
|
|
||||||
let sender_commitment = Commitment::new(&from_npk, &from_acc);
|
|
||||||
|
|
||||||
let sender_pre = AccountWithMetadata::new(from_acc.clone(), is_authorized, &from_npk);
|
|
||||||
|
|
||||||
if is_authorized {
|
|
||||||
nsk = Some(from_keys.private_key_holder.nullifier_secret_key);
|
|
||||||
}
|
|
||||||
|
|
||||||
if needs_proof {
|
|
||||||
proof = Some(
|
|
||||||
self.sequencer_client
|
|
||||||
.get_proof_for_commitment(sender_commitment)
|
|
||||||
.await
|
|
||||||
.unwrap(),
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
Ok(AccountPreparedData {
|
|
||||||
nsk,
|
|
||||||
npk: from_npk,
|
|
||||||
vpk: from_vpk,
|
|
||||||
auth_acc: sender_pre,
|
|
||||||
proof,
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
pub(crate) async fn private_tx_two_accs_all_init(
|
|
||||||
&self,
|
|
||||||
from: AccountId,
|
|
||||||
to: AccountId,
|
|
||||||
instruction_data: InstructionData,
|
|
||||||
tx_pre_check: impl FnOnce(&Account, &Account) -> Result<(), ExecutionFailureKind>,
|
|
||||||
program: Program,
|
|
||||||
to_proof: MembershipProof,
|
|
||||||
) -> Result<(HashType, [SharedSecretKey; 2]), ExecutionFailureKind> {
|
|
||||||
let AccountPreparedData {
|
|
||||||
nsk: from_nsk,
|
|
||||||
npk: from_npk,
|
|
||||||
vpk: from_vpk,
|
|
||||||
auth_acc: sender_pre,
|
|
||||||
proof: from_proof,
|
|
||||||
} = self.private_acc_preparation(from, true, true).await?;
|
|
||||||
|
|
||||||
let AccountPreparedData {
|
|
||||||
nsk: to_nsk,
|
|
||||||
npk: to_npk,
|
|
||||||
vpk: to_vpk,
|
|
||||||
auth_acc: recipient_pre,
|
|
||||||
proof: _,
|
|
||||||
} = self.private_acc_preparation(to, true, false).await?;
|
|
||||||
|
|
||||||
tx_pre_check(&sender_pre.account, &recipient_pre.account)?;
|
|
||||||
|
|
||||||
let eph_holder_from = EphemeralKeyHolder::new(&from_npk);
|
|
||||||
let shared_secret_from = eph_holder_from.calculate_shared_secret_sender(&from_vpk);
|
|
||||||
|
|
||||||
let eph_holder_to = EphemeralKeyHolder::new(&to_npk);
|
|
||||||
let shared_secret_to = eph_holder_to.calculate_shared_secret_sender(&to_vpk);
|
|
||||||
|
|
||||||
let (output, proof) = circuit::execute_and_prove(
|
|
||||||
&[sender_pre, recipient_pre],
|
|
||||||
&instruction_data,
|
|
||||||
&[1, 1],
|
|
||||||
&produce_random_nonces(2),
|
|
||||||
&[
|
|
||||||
(from_npk, shared_secret_from.clone()),
|
|
||||||
(to_npk, shared_secret_to.clone()),
|
|
||||||
],
|
|
||||||
&[
|
|
||||||
(from_nsk.unwrap(), from_proof.unwrap()),
|
|
||||||
(to_nsk.unwrap(), to_proof),
|
|
||||||
],
|
|
||||||
&program.into(),
|
|
||||||
)
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
let message = Message::try_from_circuit_output(
|
|
||||||
vec![],
|
|
||||||
vec![],
|
|
||||||
vec![
|
|
||||||
(
|
|
||||||
from_npk,
|
|
||||||
from_vpk.clone(),
|
|
||||||
eph_holder_from.generate_ephemeral_public_key(),
|
|
||||||
),
|
|
||||||
(
|
|
||||||
to_npk,
|
|
||||||
to_vpk.clone(),
|
|
||||||
eph_holder_to.generate_ephemeral_public_key(),
|
|
||||||
),
|
|
||||||
],
|
|
||||||
output,
|
|
||||||
)
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
let witness_set = WitnessSet::for_message(&message, proof, &[]);
|
|
||||||
let tx = PrivacyPreservingTransaction::new(message, witness_set);
|
|
||||||
|
|
||||||
Ok((
|
|
||||||
self.sequencer_client.send_transaction(NSSATransaction::PrivacyPreserving(tx).into()).await?,
|
|
||||||
[shared_secret_from, shared_secret_to],
|
|
||||||
))
|
|
||||||
}
|
|
||||||
|
|
||||||
pub(crate) async fn private_tx_two_accs_receiver_uninit(
|
|
||||||
&self,
|
|
||||||
from: AccountId,
|
|
||||||
to: AccountId,
|
|
||||||
instruction_data: InstructionData,
|
|
||||||
tx_pre_check: impl FnOnce(&Account, &Account) -> Result<(), ExecutionFailureKind>,
|
|
||||||
program: Program,
|
|
||||||
) -> Result<(HashType, [SharedSecretKey; 2]), ExecutionFailureKind> {
|
|
||||||
let AccountPreparedData {
|
|
||||||
nsk: from_nsk,
|
|
||||||
npk: from_npk,
|
|
||||||
vpk: from_vpk,
|
|
||||||
auth_acc: sender_pre,
|
|
||||||
proof: from_proof,
|
|
||||||
} = self.private_acc_preparation(from, true, true).await?;
|
|
||||||
|
|
||||||
let AccountPreparedData {
|
|
||||||
nsk: _,
|
|
||||||
npk: to_npk,
|
|
||||||
vpk: to_vpk,
|
|
||||||
auth_acc: recipient_pre,
|
|
||||||
proof: _,
|
|
||||||
} = self.private_acc_preparation(to, false, false).await?;
|
|
||||||
|
|
||||||
tx_pre_check(&sender_pre.account, &recipient_pre.account)?;
|
|
||||||
|
|
||||||
let eph_holder_from = EphemeralKeyHolder::new(&from_npk);
|
|
||||||
let shared_secret_from = eph_holder_from.calculate_shared_secret_sender(&from_vpk);
|
|
||||||
|
|
||||||
let eph_holder_to = EphemeralKeyHolder::new(&to_npk);
|
|
||||||
let shared_secret_to = eph_holder_to.calculate_shared_secret_sender(&to_vpk);
|
|
||||||
|
|
||||||
let (output, proof) = circuit::execute_and_prove(
|
|
||||||
&[sender_pre, recipient_pre],
|
|
||||||
&instruction_data,
|
|
||||||
&[1, 2],
|
|
||||||
&produce_random_nonces(2),
|
|
||||||
&[
|
|
||||||
(from_npk, shared_secret_from.clone()),
|
|
||||||
(to_npk, shared_secret_to.clone()),
|
|
||||||
],
|
|
||||||
&[(from_nsk.unwrap(), from_proof.unwrap())],
|
|
||||||
&program.into(),
|
|
||||||
)
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
let message = Message::try_from_circuit_output(
|
|
||||||
vec![],
|
|
||||||
vec![],
|
|
||||||
vec![
|
|
||||||
(
|
|
||||||
from_npk,
|
|
||||||
from_vpk.clone(),
|
|
||||||
eph_holder_from.generate_ephemeral_public_key(),
|
|
||||||
),
|
|
||||||
(
|
|
||||||
to_npk,
|
|
||||||
to_vpk.clone(),
|
|
||||||
eph_holder_to.generate_ephemeral_public_key(),
|
|
||||||
),
|
|
||||||
],
|
|
||||||
output,
|
|
||||||
)
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
let witness_set = WitnessSet::for_message(&message, proof, &[]);
|
|
||||||
let tx = PrivacyPreservingTransaction::new(message, witness_set);
|
|
||||||
|
|
||||||
Ok((
|
|
||||||
self.sequencer_client.send_transaction(NSSATransaction::PrivacyPreserving(tx).into()).await?,
|
|
||||||
[shared_secret_from, shared_secret_to],
|
|
||||||
))
|
|
||||||
}
|
|
||||||
|
|
||||||
pub(crate) async fn private_tx_two_accs_receiver_outer(
|
|
||||||
&self,
|
|
||||||
from: AccountId,
|
|
||||||
to_npk: NullifierPublicKey,
|
|
||||||
to_vpk: ViewingPublicKey,
|
|
||||||
instruction_data: InstructionData,
|
|
||||||
tx_pre_check: impl FnOnce(&Account, &Account) -> Result<(), ExecutionFailureKind>,
|
|
||||||
program: Program,
|
|
||||||
) -> Result<(HashType, [SharedSecretKey; 2]), ExecutionFailureKind> {
|
|
||||||
let AccountPreparedData {
|
|
||||||
nsk: from_nsk,
|
|
||||||
npk: from_npk,
|
|
||||||
vpk: from_vpk,
|
|
||||||
auth_acc: sender_pre,
|
|
||||||
proof: from_proof,
|
|
||||||
} = self.private_acc_preparation(from, true, true).await?;
|
|
||||||
|
|
||||||
let to_acc = nssa_core::account::Account::default();
|
|
||||||
|
|
||||||
tx_pre_check(&sender_pre.account, &to_acc)?;
|
|
||||||
|
|
||||||
let recipient_pre = AccountWithMetadata::new(to_acc.clone(), false, &to_npk);
|
|
||||||
|
|
||||||
let eph_holder = EphemeralKeyHolder::new(&to_npk);
|
|
||||||
|
|
||||||
let shared_secret_from = eph_holder.calculate_shared_secret_sender(&from_vpk);
|
|
||||||
let shared_secret_to = eph_holder.calculate_shared_secret_sender(&to_vpk);
|
|
||||||
|
|
||||||
let (output, proof) = circuit::execute_and_prove(
|
|
||||||
&[sender_pre, recipient_pre],
|
|
||||||
&instruction_data,
|
|
||||||
&[1, 2],
|
|
||||||
&produce_random_nonces(2),
|
|
||||||
&[
|
|
||||||
(from_npk, shared_secret_from.clone()),
|
|
||||||
(to_npk, shared_secret_to.clone()),
|
|
||||||
],
|
|
||||||
&[(from_nsk.unwrap(), from_proof.unwrap())],
|
|
||||||
&program.into(),
|
|
||||||
)
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
let message = Message::try_from_circuit_output(
|
|
||||||
vec![],
|
|
||||||
vec![],
|
|
||||||
vec![
|
|
||||||
(
|
|
||||||
from_npk,
|
|
||||||
from_vpk.clone(),
|
|
||||||
eph_holder.generate_ephemeral_public_key(),
|
|
||||||
),
|
|
||||||
(
|
|
||||||
to_npk,
|
|
||||||
to_vpk.clone(),
|
|
||||||
eph_holder.generate_ephemeral_public_key(),
|
|
||||||
),
|
|
||||||
],
|
|
||||||
output,
|
|
||||||
)
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
let witness_set = WitnessSet::for_message(&message, proof, &[]);
|
|
||||||
|
|
||||||
let tx = PrivacyPreservingTransaction::new(message, witness_set);
|
|
||||||
|
|
||||||
Ok((
|
|
||||||
self.sequencer_client.send_transaction(NSSATransaction::PrivacyPreserving(tx).into()).await?,
|
|
||||||
[shared_secret_from, shared_secret_to],
|
|
||||||
))
|
|
||||||
}
|
|
||||||
|
|
||||||
pub(crate) async fn deshielded_tx_two_accs(
|
|
||||||
&self,
|
|
||||||
from: AccountId,
|
|
||||||
to: AccountId,
|
|
||||||
instruction_data: InstructionData,
|
|
||||||
tx_pre_check: impl FnOnce(&Account, &Account) -> Result<(), ExecutionFailureKind>,
|
|
||||||
program: Program,
|
|
||||||
) -> Result<(HashType, [nssa_core::SharedSecretKey; 1]), ExecutionFailureKind> {
|
|
||||||
let AccountPreparedData {
|
|
||||||
nsk: from_nsk,
|
|
||||||
npk: from_npk,
|
|
||||||
vpk: from_vpk,
|
|
||||||
auth_acc: sender_pre,
|
|
||||||
proof: from_proof,
|
|
||||||
} = self.private_acc_preparation(from, true, true).await?;
|
|
||||||
|
|
||||||
let Ok(to_acc) = self.get_account_public(to).await else {
|
|
||||||
return Err(ExecutionFailureKind::KeyNotFoundError);
|
|
||||||
};
|
|
||||||
|
|
||||||
tx_pre_check(&sender_pre.account, &to_acc)?;
|
|
||||||
|
|
||||||
let recipient_pre = AccountWithMetadata::new(to_acc.clone(), false, to);
|
|
||||||
|
|
||||||
let eph_holder = EphemeralKeyHolder::new(&from_npk);
|
|
||||||
let shared_secret = eph_holder.calculate_shared_secret_sender(&from_vpk);
|
|
||||||
|
|
||||||
let (output, proof) = circuit::execute_and_prove(
|
|
||||||
&[sender_pre, recipient_pre],
|
|
||||||
&instruction_data,
|
|
||||||
&[1, 0],
|
|
||||||
&produce_random_nonces(1),
|
|
||||||
&[(from_npk, shared_secret.clone())],
|
|
||||||
&[(from_nsk.unwrap(), from_proof.unwrap())],
|
|
||||||
&program.into(),
|
|
||||||
)
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
let message = Message::try_from_circuit_output(
|
|
||||||
vec![to],
|
|
||||||
vec![],
|
|
||||||
vec![(
|
|
||||||
from_npk,
|
|
||||||
from_vpk.clone(),
|
|
||||||
eph_holder.generate_ephemeral_public_key(),
|
|
||||||
)],
|
|
||||||
output,
|
|
||||||
)
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
let witness_set = WitnessSet::for_message(&message, proof, &[]);
|
|
||||||
|
|
||||||
let tx = PrivacyPreservingTransaction::new(message, witness_set);
|
|
||||||
|
|
||||||
Ok((
|
|
||||||
self.sequencer_client.send_transaction(NSSATransaction::PrivacyPreserving(tx).into()).await?,
|
|
||||||
[shared_secret],
|
|
||||||
))
|
|
||||||
}
|
|
||||||
|
|
||||||
pub(crate) async fn shielded_two_accs_all_init(
|
|
||||||
&self,
|
|
||||||
from: AccountId,
|
|
||||||
to: AccountId,
|
|
||||||
instruction_data: InstructionData,
|
|
||||||
tx_pre_check: impl FnOnce(&Account, &Account) -> Result<(), ExecutionFailureKind>,
|
|
||||||
program: Program,
|
|
||||||
to_proof: MembershipProof,
|
|
||||||
) -> Result<(HashType, [SharedSecretKey; 1]), ExecutionFailureKind> {
|
|
||||||
let Ok(from_acc) = self.get_account_public(from).await else {
|
|
||||||
return Err(ExecutionFailureKind::KeyNotFoundError);
|
|
||||||
};
|
|
||||||
|
|
||||||
let AccountPreparedData {
|
|
||||||
nsk: to_nsk,
|
|
||||||
npk: to_npk,
|
|
||||||
vpk: to_vpk,
|
|
||||||
auth_acc: recipient_pre,
|
|
||||||
proof: _,
|
|
||||||
} = self.private_acc_preparation(to, true, false).await?;
|
|
||||||
|
|
||||||
tx_pre_check(&from_acc, &recipient_pre.account)?;
|
|
||||||
|
|
||||||
let sender_pre = AccountWithMetadata::new(from_acc.clone(), true, from);
|
|
||||||
|
|
||||||
let eph_holder = EphemeralKeyHolder::new(&to_npk);
|
|
||||||
let shared_secret = eph_holder.calculate_shared_secret_sender(&to_vpk);
|
|
||||||
|
|
||||||
let (output, proof) = circuit::execute_and_prove(
|
|
||||||
&[sender_pre, recipient_pre],
|
|
||||||
&instruction_data,
|
|
||||||
&[0, 1],
|
|
||||||
&produce_random_nonces(1),
|
|
||||||
&[(to_npk, shared_secret.clone())],
|
|
||||||
&[(to_nsk.unwrap(), to_proof)],
|
|
||||||
&program.into(),
|
|
||||||
)
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
let message = Message::try_from_circuit_output(
|
|
||||||
vec![from],
|
|
||||||
vec![from_acc.nonce],
|
|
||||||
vec![(
|
|
||||||
to_npk,
|
|
||||||
to_vpk.clone(),
|
|
||||||
eph_holder.generate_ephemeral_public_key(),
|
|
||||||
)],
|
|
||||||
output,
|
|
||||||
)
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
let signing_key = self.storage.user_data.get_pub_account_signing_key(&from);
|
|
||||||
|
|
||||||
let Some(signing_key) = signing_key else {
|
|
||||||
return Err(ExecutionFailureKind::KeyNotFoundError);
|
|
||||||
};
|
|
||||||
|
|
||||||
let witness_set = WitnessSet::for_message(&message, proof, &[signing_key]);
|
|
||||||
|
|
||||||
let tx = PrivacyPreservingTransaction::new(message, witness_set);
|
|
||||||
|
|
||||||
Ok((
|
|
||||||
self.sequencer_client.send_transaction(NSSATransaction::PrivacyPreserving(tx).into()).await?,
|
|
||||||
[shared_secret],
|
|
||||||
))
|
|
||||||
}
|
|
||||||
|
|
||||||
pub(crate) async fn shielded_two_accs_receiver_uninit(
|
|
||||||
&self,
|
|
||||||
from: AccountId,
|
|
||||||
to: AccountId,
|
|
||||||
instruction_data: InstructionData,
|
|
||||||
tx_pre_check: impl FnOnce(&Account, &Account) -> Result<(), ExecutionFailureKind>,
|
|
||||||
program: Program,
|
|
||||||
) -> Result<(HashType, [SharedSecretKey; 1]), ExecutionFailureKind> {
|
|
||||||
let Ok(from_acc) = self.get_account_public(from).await else {
|
|
||||||
return Err(ExecutionFailureKind::KeyNotFoundError);
|
|
||||||
};
|
|
||||||
|
|
||||||
let AccountPreparedData {
|
|
||||||
nsk: _,
|
|
||||||
npk: to_npk,
|
|
||||||
vpk: to_vpk,
|
|
||||||
auth_acc: recipient_pre,
|
|
||||||
proof: _,
|
|
||||||
} = self.private_acc_preparation(to, false, false).await?;
|
|
||||||
|
|
||||||
tx_pre_check(&from_acc, &recipient_pre.account)?;
|
|
||||||
|
|
||||||
let sender_pre = AccountWithMetadata::new(from_acc.clone(), true, from);
|
|
||||||
|
|
||||||
let eph_holder = EphemeralKeyHolder::new(&to_npk);
|
|
||||||
let shared_secret = eph_holder.calculate_shared_secret_sender(&to_vpk);
|
|
||||||
|
|
||||||
let (output, proof) = circuit::execute_and_prove(
|
|
||||||
&[sender_pre, recipient_pre],
|
|
||||||
&instruction_data,
|
|
||||||
&[0, 2],
|
|
||||||
&produce_random_nonces(1),
|
|
||||||
&[(to_npk, shared_secret.clone())],
|
|
||||||
&[],
|
|
||||||
&program.into(),
|
|
||||||
)
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
let message = Message::try_from_circuit_output(
|
|
||||||
vec![from],
|
|
||||||
vec![from_acc.nonce],
|
|
||||||
vec![(
|
|
||||||
to_npk,
|
|
||||||
to_vpk.clone(),
|
|
||||||
eph_holder.generate_ephemeral_public_key(),
|
|
||||||
)],
|
|
||||||
output,
|
|
||||||
)
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
let signing_key = self.storage.user_data.get_pub_account_signing_key(&from);
|
|
||||||
|
|
||||||
let Some(signing_key) = signing_key else {
|
|
||||||
return Err(ExecutionFailureKind::KeyNotFoundError);
|
|
||||||
};
|
|
||||||
|
|
||||||
let witness_set = WitnessSet::for_message(&message, proof, &[signing_key]);
|
|
||||||
|
|
||||||
let tx = PrivacyPreservingTransaction::new(message, witness_set);
|
|
||||||
|
|
||||||
Ok((
|
|
||||||
self.sequencer_client.send_transaction(NSSATransaction::PrivacyPreserving(tx).into()).await?,
|
|
||||||
[shared_secret],
|
|
||||||
))
|
|
||||||
}
|
|
||||||
|
|
||||||
pub(crate) async fn shielded_two_accs_receiver_outer(
|
|
||||||
&self,
|
|
||||||
from: AccountId,
|
|
||||||
to_npk: NullifierPublicKey,
|
|
||||||
to_vpk: ViewingPublicKey,
|
|
||||||
instruction_data: InstructionData,
|
|
||||||
tx_pre_check: impl FnOnce(&Account, &Account) -> Result<(), ExecutionFailureKind>,
|
|
||||||
program: Program,
|
|
||||||
) -> Result<HashType, ExecutionFailureKind> {
|
|
||||||
let Ok(from_acc) = self.get_account_public(from).await else {
|
|
||||||
return Err(ExecutionFailureKind::KeyNotFoundError);
|
|
||||||
};
|
|
||||||
|
|
||||||
let to_acc = Account::default();
|
|
||||||
|
|
||||||
tx_pre_check(&from_acc, &to_acc)?;
|
|
||||||
|
|
||||||
let sender_pre = AccountWithMetadata::new(from_acc.clone(), true, from);
|
|
||||||
let recipient_pre = AccountWithMetadata::new(to_acc.clone(), false, &to_npk);
|
|
||||||
|
|
||||||
let eph_holder = EphemeralKeyHolder::new(&to_npk);
|
|
||||||
let shared_secret = eph_holder.calculate_shared_secret_sender(&to_vpk);
|
|
||||||
|
|
||||||
let (output, proof) = circuit::execute_and_prove(
|
|
||||||
&[sender_pre, recipient_pre],
|
|
||||||
&instruction_data,
|
|
||||||
&[0, 2],
|
|
||||||
&produce_random_nonces(1),
|
|
||||||
&[(to_npk, shared_secret.clone())],
|
|
||||||
&[],
|
|
||||||
&program.into(),
|
|
||||||
)
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
let message = Message::try_from_circuit_output(
|
|
||||||
vec![from],
|
|
||||||
vec![from_acc.nonce],
|
|
||||||
vec![(
|
|
||||||
to_npk,
|
|
||||||
to_vpk.clone(),
|
|
||||||
eph_holder.generate_ephemeral_public_key(),
|
|
||||||
)],
|
|
||||||
output,
|
|
||||||
)
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
let signing_key = self.storage.user_data.get_pub_account_signing_key(&from);
|
|
||||||
|
|
||||||
let Some(signing_key) = signing_key else {
|
|
||||||
return Err(ExecutionFailureKind::KeyNotFoundError);
|
|
||||||
};
|
|
||||||
|
|
||||||
let witness_set = WitnessSet::for_message(&message, proof, &[signing_key]);
|
|
||||||
let tx = PrivacyPreservingTransaction::new(message, witness_set);
|
|
||||||
|
|
||||||
Ok(self.sequencer_client.send_transaction(NSSATransaction::PrivacyPreserving(tx).into()).await?)
|
|
||||||
}
|
|
||||||
|
|
||||||
pub async fn register_account_under_authenticated_transfers_programs_private(
|
|
||||||
&self,
|
|
||||||
from: AccountId,
|
|
||||||
) -> Result<(HashType, [SharedSecretKey; 1]), ExecutionFailureKind> {
|
|
||||||
let AccountPreparedData {
|
|
||||||
nsk: _,
|
|
||||||
npk: from_npk,
|
|
||||||
vpk: from_vpk,
|
|
||||||
auth_acc: sender_pre,
|
|
||||||
proof: _,
|
|
||||||
} = self.private_acc_preparation(from, false, false).await?;
|
|
||||||
|
|
||||||
let eph_holder_from = EphemeralKeyHolder::new(&from_npk);
|
|
||||||
let shared_secret_from = eph_holder_from.calculate_shared_secret_sender(&from_vpk);
|
|
||||||
|
|
||||||
let instruction: u128 = 0;
|
|
||||||
|
|
||||||
let (output, proof) = circuit::execute_and_prove(
|
|
||||||
&[sender_pre],
|
|
||||||
&Program::serialize_instruction(instruction).unwrap(),
|
|
||||||
&[2],
|
|
||||||
&produce_random_nonces(1),
|
|
||||||
&[(from_npk, shared_secret_from.clone())],
|
|
||||||
&[],
|
|
||||||
&Program::authenticated_transfer_program().into(),
|
|
||||||
)
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
let message = Message::try_from_circuit_output(
|
|
||||||
vec![],
|
|
||||||
vec![],
|
|
||||||
vec![(
|
|
||||||
from_npk,
|
|
||||||
from_vpk.clone(),
|
|
||||||
eph_holder_from.generate_ephemeral_public_key(),
|
|
||||||
)],
|
|
||||||
output,
|
|
||||||
)
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
let witness_set = WitnessSet::for_message(&message, proof, &[]);
|
|
||||||
let tx = PrivacyPreservingTransaction::new(message, witness_set);
|
|
||||||
|
|
||||||
Ok((
|
|
||||||
self.sequencer_client.send_transaction(NSSATransaction::PrivacyPreserving(tx).into()).await?,
|
|
||||||
[shared_secret_from],
|
|
||||||
))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Loading…
x
Reference in New Issue
Block a user