use crate::{FinalizeStoreTrait, Opcode, Operand, RegistersTrait, StackTrait};
use console::{
network::prelude::*,
program::{Identifier, Literal, Plaintext, PlaintextType, ProgramID, Register, Value},
};
#[derive(Clone, PartialEq, Eq, Hash)]
pub struct GetOrUseDynamic<N: Network> {
operands: [Operand<N>; 5],
destination: Register<N>,
destination_type: PlaintextType<N>,
}
impl<N: Network> GetOrUseDynamic<N> {
#[inline]
pub const fn opcode() -> Opcode {
Opcode::Command("get.or_use.dynamic")
}
#[inline]
pub fn operands(&self) -> &[Operand<N>] {
&self.operands
}
#[inline]
pub const fn program_name_operand(&self) -> &Operand<N> {
&self.operands[0]
}
#[inline]
pub const fn program_network_operand(&self) -> &Operand<N> {
&self.operands[1]
}
#[inline]
pub const fn mapping_name_operand(&self) -> &Operand<N> {
&self.operands[2]
}
#[inline]
pub const fn key_operand(&self) -> &Operand<N> {
&self.operands[3]
}
#[inline]
pub const fn default_operand(&self) -> &Operand<N> {
&self.operands[4]
}
#[inline]
pub const fn destination(&self) -> &Register<N> {
&self.destination
}
#[inline]
pub const fn destination_type(&self) -> &PlaintextType<N> {
&self.destination_type
}
}
impl<N: Network> GetOrUseDynamic<N> {
#[inline]
pub fn finalize(
&self,
stack: &impl StackTrait<N>,
store: &impl FinalizeStoreTrait<N>,
registers: &mut impl RegistersTrait<N>,
) -> Result<()> {
let program_name = match registers.load(stack, self.program_name_operand())? {
Value::Plaintext(Plaintext::Literal(Literal::Field(field), _)) => Identifier::from_field(&field)?,
Value::Plaintext(Plaintext::Literal(Literal::Identifier(id_lit), _)) => {
Identifier::from_field(&id_lit.to_field()?)?
}
_ => bail!("Expected the first operand of `get.or_use.dynamic` to be a field or identifier literal."),
};
let program_network = match registers.load(stack, self.program_network_operand())? {
Value::Plaintext(Plaintext::Literal(Literal::Field(field), _)) => Identifier::from_field(&field)?,
Value::Plaintext(Plaintext::Literal(Literal::Identifier(id_lit), _)) => {
Identifier::from_field(&id_lit.to_field()?)?
}
_ => bail!("Expected the second operand of `get.or_use.dynamic` to be a field or identifier literal."),
};
let program_id = ProgramID::try_from((program_name, program_network))?;
let mapping_name = match registers.load(stack, self.mapping_name_operand())? {
Value::Plaintext(Plaintext::Literal(Literal::Field(field), _)) => Identifier::from_field(&field)?,
Value::Plaintext(Plaintext::Literal(Literal::Identifier(id_lit), _)) => {
Identifier::from_field(&id_lit.to_field()?)?
}
_ => bail!("Expected the third operand of `get.or_use.dynamic` to be a field or identifier literal."),
};
if !store.contains_mapping_speculative(&program_id, &mapping_name)? {
bail!("Mapping '{program_id}/{mapping_name}' does not exist");
}
let key = registers.load_plaintext(stack, self.key_operand())?;
let mapping = stack.get_stack_global(&program_id)?.program().get_mapping(&mapping_name)?;
let mapping_key_type = mapping.key().plaintext_type();
ensure!(
stack.matches_plaintext(&key, mapping_key_type).is_ok(),
"Expected the key to be of type '{mapping_key_type}', found '{key}'."
);
let mapping_value_type = mapping.value().plaintext_type();
ensure!(
&self.destination_type == mapping_value_type,
"Expected the destination type to be '{mapping_value_type}', found '{}'.",
self.destination_type
);
let value = match store.get_value_speculative(program_id, mapping_name, &key)? {
Some(Value::Plaintext(plaintext)) => Value::Plaintext(plaintext),
Some(Value::Record(..)) => bail!("Cannot 'get.or_use.dynamic' a 'record'"),
Some(Value::Future(..)) => bail!("Cannot 'get.or_use.dynamic' a 'future'"),
Some(Value::DynamicRecord(..)) => bail!("Cannot 'get.or_use.dynamic' a 'dynamic.record'"),
Some(Value::DynamicFuture(..)) => bail!("Cannot 'get.or_use.dynamic' a 'dynamic.future'"),
None => Value::Plaintext(registers.load_plaintext(stack, self.default_operand())?),
};
match &value {
Value::Plaintext(plaintext) => {
ensure!(
stack.matches_plaintext(plaintext, self.destination_type()).is_ok(),
"Expected the value to be of type '{}', found '{plaintext}' in 'get.or_use.dynamic'",
self.destination_type()
)
}
_ => bail!("Expected a plaintext value in 'get.or_use.dynamic'"),
}
registers.store(stack, &self.destination, value)?;
Ok(())
}
}
impl<N: Network> Parser for GetOrUseDynamic<N> {
#[inline]
fn parse(string: &str) -> ParserResult<Self> {
let (string, _) = Sanitizer::parse(string)?;
let (string, _) = tag(*Self::opcode())(string)?;
let (string, _) = Sanitizer::parse_whitespaces(string)?;
let (string, program_name) = Operand::parse(string)?;
let (string, _) = Sanitizer::parse_whitespaces(string)?;
let (string, program_network) = Operand::parse(string)?;
let (string, _) = Sanitizer::parse_whitespaces(string)?;
let (string, mapping_name) = Operand::parse(string)?;
let (string, _) = Sanitizer::parse_whitespaces(string)?;
let (string, _) = tag("[")(string)?;
let (string, _) = Sanitizer::parse_whitespaces(string)?;
let (string, key) = Operand::parse(string)?;
let (string, _) = Sanitizer::parse_whitespaces(string)?;
let (string, _) = tag("]")(string)?;
let (string, _) = Sanitizer::parse_whitespaces(string)?;
let (string, default) = Operand::parse(string)?;
let (string, _) = Sanitizer::parse_whitespaces(string)?;
let (string, _) = tag("into")(string)?;
let (string, _) = Sanitizer::parse_whitespaces(string)?;
let (string, destination) = Register::parse(string)?;
let (string, _) = Sanitizer::parse_whitespaces(string)?;
let (string, _) = tag("as")(string)?;
let (string, _) = Sanitizer::parse_whitespaces(string)?;
let (string, destination_type) = PlaintextType::parse(string)?;
let (string, _) = Sanitizer::parse_whitespaces(string)?;
let (string, _) = tag(";")(string)?;
Ok((string, Self {
operands: [program_name, program_network, mapping_name, key, default],
destination,
destination_type,
}))
}
}
impl<N: Network> FromStr for GetOrUseDynamic<N> {
type Err = Error;
#[inline]
fn from_str(string: &str) -> Result<Self> {
match Self::parse(string) {
Ok((remainder, object)) => {
ensure!(remainder.is_empty(), "Failed to parse string. Found invalid character in: \"{remainder}\"");
Ok(object)
}
Err(error) => bail!("Failed to parse string. {error}"),
}
}
}
impl<N: Network> Debug for GetOrUseDynamic<N> {
fn fmt(&self, f: &mut Formatter) -> fmt::Result {
Display::fmt(self, f)
}
}
impl<N: Network> Display for GetOrUseDynamic<N> {
fn fmt(&self, f: &mut Formatter) -> fmt::Result {
write!(f, "{} ", Self::opcode())?;
write!(
f,
"{} {} {}[{}] {} into ",
self.program_name_operand(),
self.program_network_operand(),
self.mapping_name_operand(),
self.key_operand(),
self.default_operand()
)?;
write!(f, "{} as {};", self.destination, self.destination_type)
}
}
impl<N: Network> FromBytes for GetOrUseDynamic<N> {
fn read_le<R: Read>(mut reader: R) -> IoResult<Self> {
let program_name = Operand::read_le(&mut reader)?;
let program_network = Operand::read_le(&mut reader)?;
let mapping_name = Operand::read_le(&mut reader)?;
let key = Operand::read_le(&mut reader)?;
let default = Operand::read_le(&mut reader)?;
let destination = Register::read_le(&mut reader)?;
let destination_type = PlaintextType::read_le(&mut reader)?;
Ok(Self {
operands: [program_name, program_network, mapping_name, key, default],
destination,
destination_type,
})
}
}
impl<N: Network> ToBytes for GetOrUseDynamic<N> {
fn write_le<W: Write>(&self, mut writer: W) -> IoResult<()> {
self.program_name_operand().write_le(&mut writer)?;
self.program_network_operand().write_le(&mut writer)?;
self.mapping_name_operand().write_le(&mut writer)?;
self.key_operand().write_le(&mut writer)?;
self.default_operand().write_le(&mut writer)?;
self.destination.write_le(&mut writer)?;
self.destination_type.write_le(&mut writer)
}
}
#[cfg(test)]
mod tests {
use super::*;
use console::{network::MainnetV0, program::Register};
type CurrentNetwork = MainnetV0;
#[test]
fn test_parse() {
let (string, get) =
GetOrUseDynamic::<CurrentNetwork>::parse("get.or_use.dynamic r0 r1 r2[r3] r4 into r5 as boolean;").unwrap();
assert!(string.is_empty(), "Parser did not consume all of the string: '{string}'");
assert_eq!(get.operands().len(), 5, "The number of operands is incorrect");
assert_eq!(
get.program_name_operand(),
&Operand::Register(Register::Locator(0)),
"The first operand is incorrect"
);
assert_eq!(
get.program_network_operand(),
&Operand::Register(Register::Locator(1)),
"The second operand is incorrect"
);
assert_eq!(
get.mapping_name_operand(),
&Operand::Register(Register::Locator(2)),
"The third operand is incorrect"
);
assert_eq!(get.key_operand(), &Operand::Register(Register::Locator(3)), "The fourth operand is incorrect");
assert_eq!(get.default_operand(), &Operand::Register(Register::Locator(4)), "The fifth operand is incorrect");
assert_eq!(get.destination, Register::Locator(5), "The destination register is incorrect");
assert_eq!(
get.destination_type,
PlaintextType::Literal(console::program::LiteralType::Boolean),
"The destination type is incorrect"
);
}
#[test]
fn test_from_bytes() {
let (string, get) =
GetOrUseDynamic::<CurrentNetwork>::parse("get.or_use.dynamic r0 r1 r2[r3] r4 into r5 as Foo;").unwrap();
assert!(string.is_empty());
let bytes_le = get.to_bytes_le().unwrap();
let result = GetOrUseDynamic::<CurrentNetwork>::from_bytes_le(&bytes_le[..]);
assert!(result.is_ok())
}
#[test]
fn test_display_parse_roundtrip() {
let input = "get.or_use.dynamic r0 r1 r2[r3] r4 into r5 as boolean;";
let (string, original) = GetOrUseDynamic::<CurrentNetwork>::parse(input).unwrap();
assert!(string.is_empty());
let displayed = format!("{original}");
let (remainder, reparsed) = GetOrUseDynamic::<CurrentNetwork>::parse(&displayed).unwrap();
assert!(remainder.is_empty());
assert_eq!(original, reparsed);
}
}