mod bytes;
mod parse;
use crate::Command;
use console::{
network::prelude::*,
program::{Identifier, Register},
};
use std::collections::HashMap;
#[derive(Clone, PartialEq, Eq)]
pub struct ConstructorCore<N: Network> {
commands: Vec<Command<N>>,
num_writes: u16,
positions: HashMap<Identifier<N>, usize>,
}
impl<N: Network> ConstructorCore<N> {
pub fn commands(&self) -> &[Command<N>] {
&self.commands
}
pub const fn num_writes(&self) -> u16 {
self.num_writes
}
pub const fn positions(&self) -> &HashMap<Identifier<N>, usize> {
&self.positions
}
pub fn contains_external_struct(&self) -> bool {
self.commands.iter().any(|command| command.contains_external_struct())
}
pub fn contains_string_type(&self) -> bool {
self.commands.iter().any(|command| command.contains_string_type())
}
pub fn contains_identifier_type(&self) -> Result<bool> {
for command in &self.commands {
if command.contains_identifier_type()? {
return Ok(true);
}
}
Ok(false)
}
pub fn exceeds_max_array_size(&self, max_array_size: u32) -> bool {
self.commands.iter().any(|command| command.exceeds_max_array_size(max_array_size))
}
}
impl<N: Network> ConstructorCore<N> {
#[inline]
pub fn add_command(&mut self, command: Command<N>) -> Result<()> {
ensure!(self.commands.len() < N::MAX_COMMANDS, "Cannot add more than {} commands", N::MAX_COMMANDS);
if command.is_write() {
ensure!(
self.num_writes < N::LATEST_MAX_WRITES(),
"Cannot add more than {} 'set' & 'remove' commands",
N::LATEST_MAX_WRITES()
);
}
ensure!(!command.is_async(), "Forbidden operation: Constructor cannot invoke an 'async' instruction");
ensure!(!command.is_call(), "Forbidden operation: Constructor cannot invoke a 'call'");
ensure!(!command.is_cast_to_record(), "Forbidden operation: Constructor cannot cast to a record");
ensure!(!command.is_await(), "Forbidden operation: Constructor cannot 'await'");
for register in command.destinations() {
ensure!(matches!(register, Register::Locator(..)), "Destination register must be a locator");
}
if let Some(position) = command.branch_to() {
ensure!(!self.positions.contains_key(position), "Cannot branch to an earlier position '{position}'");
}
if let Some(position) = command.position() {
ensure!(!self.positions.contains_key(position), "Cannot redefine position '{position}'");
ensure!(self.positions.len() < N::MAX_POSITIONS, "Cannot add more than {} positions", N::MAX_POSITIONS);
self.positions.insert(*position, self.commands.len());
}
if command.is_write() {
self.num_writes += 1;
}
self.commands.push(command);
Ok(())
}
}
impl<N: Network> TypeName for ConstructorCore<N> {
#[inline]
fn type_name() -> &'static str {
"constructor"
}
}
#[cfg(test)]
mod tests {
use super::*;
use crate::{Command, Constructor};
type CurrentNetwork = console::network::MainnetV0;
#[test]
fn test_add_command() {
let mut constructor = Constructor::<CurrentNetwork> {
commands: Default::default(),
num_writes: 0,
positions: Default::default(),
};
let command = Command::<CurrentNetwork>::from_str("add r0 r1 into r2;").unwrap();
assert!(constructor.add_command(command).is_ok());
for i in 3..CurrentNetwork::MAX_COMMANDS * 2 {
let command = Command::<CurrentNetwork>::from_str(&format!("add r0 r1 into r{i};")).unwrap();
match constructor.commands.len() < CurrentNetwork::MAX_COMMANDS {
true => assert!(constructor.add_command(command).is_ok()),
false => assert!(constructor.add_command(command).is_err()),
}
}
let mut constructor = Constructor::<CurrentNetwork> {
commands: Default::default(),
num_writes: 0,
positions: Default::default(),
};
for _ in 0..CurrentNetwork::LATEST_MAX_WRITES() * 2 {
let command = Command::<CurrentNetwork>::from_str("remove object[r0];").unwrap();
match constructor.commands.len() < CurrentNetwork::LATEST_MAX_WRITES() as usize {
true => assert!(constructor.add_command(command).is_ok()),
false => assert!(constructor.add_command(command).is_err()),
}
}
}
#[test]
fn test_add_command_duplicate_positions() {
let mut constructor =
Constructor { commands: Default::default(), num_writes: 0, positions: Default::default() };
let command = Command::<CurrentNetwork>::from_str("position start;").unwrap();
assert!(constructor.add_command(command.clone()).is_ok());
assert!(constructor.add_command(command).is_err());
#[allow(clippy::cast_possible_truncation)]
fn to_unique_string(mut n: usize) -> String {
let mut s = String::new();
while n > 0 {
s.push((b'A' + (n % 26) as u8) as char);
n /= 26;
}
s.chars().rev().collect::<String>()
}
for i in 1..u8::MAX as usize * 2 {
let position = to_unique_string(i);
println!("position: {position}");
let command = Command::<CurrentNetwork>::from_str(&format!("position {position};")).unwrap();
match constructor.commands.len() < u8::MAX as usize {
true => assert!(constructor.add_command(command).is_ok()),
false => assert!(constructor.add_command(command).is_err()),
}
}
}
}