mirror of
https://github.com/fluencelabs/aquavm
synced 2025-04-15 19:02:13 +00:00
8ce8af3823
* feat(avm-server)!: keypair and particle ID arguments Add `&fluence_keypair::KeyPair` argument to `AVM::call` and `AVMRunner::call`. This value is further forwarded in a deconstructed form to WASM Air interpreter, but is not used there yet. Also, `AVMRunner::call` gets `particle_id: String` argument. feat(air-interpreter)!: `invoke` methods have three new arguments: `key_format: u8`, `secret_key_bytes: Vec<u8>` and `paritcle_id: String`. feat(aquavm-air): `air::execute_air` has two three arguments: `key_format: u8`, `secret_key_bytes: Vec<u8>` and `paritcle_id: String`. feat(aquavm-air-cli)!: add `--random-key`/`--ed25519-key file` options to AIR CLI. * feat(avm-server)!: Add `RunnerError::KeypairError` * chore(bench): Add signature performance benchmarks These benchmarks contain valid signature, so they should work with verification out of the box. --------- Co-authored-by: Artsiom Shamsutdzinau <shamsartem@gmail.com> Co-authored-by: folex <0xdxdy@gmail.com>
77 lines
2.3 KiB
Rust
77 lines
2.3 KiB
Rust
/*
|
|
* Copyright 2022 Fluence Labs Limited
|
|
*
|
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
* you may not use this file except in compliance with the License.
|
|
* You may obtain a copy of the License at
|
|
*
|
|
* http://www.apache.org/licenses/LICENSE-2.0
|
|
*
|
|
* Unless required by applicable law or agreed to in writing, software
|
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
* See the License for the specific language governing permissions and
|
|
* limitations under the License.
|
|
*/
|
|
|
|
use crate::test_runner::AirRunner;
|
|
use air_interpreter_interface::RunParameters;
|
|
use avm_server::avm_runner::*;
|
|
use avm_server::into_raw_result;
|
|
use fluence_keypair::KeyPair;
|
|
|
|
pub struct NativeAirRunner {
|
|
current_peer_id: String,
|
|
}
|
|
|
|
impl AirRunner for NativeAirRunner {
|
|
fn new(current_peer_id: impl Into<String>) -> Self {
|
|
Self {
|
|
current_peer_id: current_peer_id.into(),
|
|
}
|
|
}
|
|
|
|
fn call(
|
|
&mut self,
|
|
air: impl Into<String>,
|
|
prev_data: impl Into<Vec<u8>>,
|
|
data: impl Into<Vec<u8>>,
|
|
init_peer_id: impl Into<String>,
|
|
timestamp: u64,
|
|
ttl: u32,
|
|
override_current_peer_id: Option<String>,
|
|
call_results: avm_server::CallResults,
|
|
keypair: &KeyPair,
|
|
particle_id: String,
|
|
) -> Result<RawAVMOutcome, Box<dyn std::error::Error>> {
|
|
// some inner parts transformations
|
|
let raw_call_results = into_raw_result(call_results);
|
|
let raw_call_results = serde_json::to_vec(&raw_call_results).unwrap();
|
|
|
|
let current_peer_id =
|
|
override_current_peer_id.unwrap_or_else(|| self.current_peer_id.clone());
|
|
|
|
let key_format = keypair.key_format().into();
|
|
let secret_key_bytes = keypair.secret().unwrap();
|
|
|
|
let outcome = air::execute_air(
|
|
air.into(),
|
|
prev_data.into(),
|
|
data.into(),
|
|
RunParameters {
|
|
init_peer_id: init_peer_id.into(),
|
|
current_peer_id,
|
|
timestamp,
|
|
ttl,
|
|
key_format,
|
|
secret_key_bytes,
|
|
particle_id,
|
|
},
|
|
raw_call_results,
|
|
);
|
|
let outcome = RawAVMOutcome::from_interpreter_outcome(outcome)?;
|
|
|
|
Ok(outcome)
|
|
}
|
|
}
|