1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222
// Copyright (C) 2019-2023 Aleo Systems Inc.
// This file is part of the snarkVM library.
// 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::{
prelude::{FromBytes, Network, ProgramID, ToBytes},
synthesizer::Program,
};
use anyhow::{anyhow, ensure, Result};
use std::{
fs::{self, File},
io::Write,
path::Path,
};
static AVM_FILE_EXTENSION: &str = "avm";
pub struct AVMFile<N: Network> {
/// The file name (without the extension).
file_name: String,
/// The program.
program: Program<N>,
}
impl<N: Network> AVMFile<N> {
/// Creates a new AVM program file, given the directory path, program ID, and `is_main` indicator.
pub fn create(directory: &Path, program: Program<N>, is_main: bool) -> Result<Self> {
// Ensure the directory path exists.
ensure!(directory.exists(), "The program directory does not exist: '{}'", directory.display());
// Ensure the program name is valid.
ensure!(
!Program::is_reserved_keyword(program.id().name()),
"Program name is invalid (reserved): {}",
program.id()
);
// Create the file.
let file_name = if is_main { Self::main_file_name() } else { format!("{}.{AVM_FILE_EXTENSION}", program.id()) };
// Construct the file path.
let path = directory.join(file_name);
// Write the file (overwriting if it already exists).
File::create(&path)?.write_all(&program.to_bytes_le()?)?;
Self::from_filepath(&path)
}
/// Opens the AVM program file, given the directory path, program ID, and `is_main` indicator.
pub fn open(directory: &Path, program_id: &ProgramID<N>, is_main: bool) -> Result<Self> {
// Ensure the directory path exists.
ensure!(directory.exists(), "The build directory does not exist: '{}'", directory.display());
// Create the file.
let file_name = if is_main { Self::main_file_name() } else { format!("{program_id}.{AVM_FILE_EXTENSION}") };
// Construct the file path.
let path = directory.join(file_name);
// Ensure the file path exists.
ensure!(path.exists(), "The AVM file is missing: '{}'", path.display());
// Load the AVM file.
let avm_file = Self::from_filepath(&path)?;
Ok(avm_file)
}
/// Returns `true` if the file exists at the given path.
pub fn exists_at(&self, file_path: &Path) -> bool {
// Ensure the path is well-formed.
Self::check_path(file_path).is_ok() && file_path.exists()
}
/// Returns `true` if the main program file exists at the given directory path.
pub fn main_exists_at(directory: &Path) -> bool {
// Construct the file path.
let path = directory.join(Self::main_file_name());
// Return the result.
path.is_file() && path.exists()
}
/// Returns the main AVM program file name.
pub fn main_file_name() -> String {
format!("main.{AVM_FILE_EXTENSION}")
}
/// Returns the file name.
pub fn file_name(&self) -> &str {
&self.file_name
}
/// Returns the program.
pub const fn program(&self) -> &Program<N> {
&self.program
}
/// Removes the file at the given path, if it exists.
pub fn remove(&self, path: &Path) -> Result<()> {
// If the path does not exist, do nothing.
if !path.exists() {
Ok(())
} else {
// Ensure the path is well-formed.
Self::check_path(path)?;
// If the path exists, remove it.
if path.exists() {
// Remove the file.
fs::remove_file(path)?;
}
Ok(())
}
}
}
impl<N: Network> AVMFile<N> {
/// Checks that the given path has the correct file extension.
fn check_path(path: &Path) -> Result<()> {
// Ensure the given path is a file.
ensure!(path.is_file(), "The path is not a file.");
// Ensure the given path has the correct file extension.
let extension = path.extension().ok_or_else(|| anyhow!("File extension not found."))?;
ensure!(extension == AVM_FILE_EXTENSION, "File extension is incorrect.");
Ok(())
}
/// Reads the AVM program from the given file path, if it exists.
fn from_filepath(file: &Path) -> Result<Self> {
// Ensure the path is well-formed.
Self::check_path(file)?;
// Ensure the given path exists.
ensure!(file.exists(), "File does not exist: {}", file.display());
// Retrieve the file name.
let file_name = file
.file_stem()
.ok_or_else(|| anyhow!("File name not found."))?
.to_str()
.ok_or_else(|| anyhow!("File name not found."))?
.to_string();
// Read the program bytes.
let program_bytes = fs::read(file)?;
// Parse the program bytes.
let program = Program::from_bytes_le(&program_bytes)?;
Ok(Self { file_name, program })
}
/// Writes the AVM program to the file.
pub fn write_to(&self, path: &Path) -> Result<()> {
// Ensure the path is well-formed.
Self::check_path(path)?;
// Retrieve the file name.
let file_name = path
.file_stem()
.ok_or_else(|| anyhow!("File name not found."))?
.to_str()
.ok_or_else(|| anyhow!("File name not found."))?
.to_string();
// Ensure the file name matches the expected file name.
ensure!(file_name == self.file_name, "File name does not match.");
Ok(File::create(path)?.write_all(&self.program.to_bytes_le()?)?)
}
}
#[cfg(test)]
mod tests {
use super::*;
use crate::prelude::Parser;
type CurrentNetwork = snarkvm_console::network::Testnet3;
fn temp_dir() -> std::path::PathBuf {
tempfile::tempdir().expect("Failed to open temporary directory").into_path()
}
#[test]
fn test_from_path() {
// Initialize a temporary directory.
let directory = temp_dir();
let program_string = r"
program token.aleo;
record token:
owner as address.private;
token_amount as u64.private;
function compute:
input r0 as token.record;
add r0.token_amount r0.token_amount into r1;
output r1 as u64.private;";
// Initialize a new program.
let (string, program) = Program::<CurrentNetwork>::parse(program_string).unwrap();
assert!(string.is_empty(), "Parser did not consume all of the string: '{string}'");
// Write the program bytes to a file in the temporary directory.
let path = directory.join("token.avm");
let mut file = File::create(&path).unwrap();
file.write_all(&program.to_bytes_le().unwrap()).unwrap();
// Read the program from the path.
let file = AVMFile::from_filepath(&path).unwrap();
assert_eq!("token", file.file_name());
assert_eq!(&program, file.program());
}
}