leo_interpreter/

lib.rs

// Copyright (C) 2019-2025 Provable Inc.
// This file is part of the Leo library.

// The Leo library is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.

// The Leo library is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.

// You should have received a copy of the GNU General Public License
// along with the Leo library. If not, see <https://www.gnu.org/licenses/>.

use leo_ast::{
    Ast,
    CallExpression,
    ExpressionStatement,
    Location,
    NetworkName,
    Node as _,
    NodeBuilder,
    Path,
    Statement,
    interpreter_value::Value,
};
use leo_errors::{InterpreterHalt, LeoError, Result};
use leo_span::{Span, Symbol, source_map::FileName, sym, with_session_globals};

use snarkvm::prelude::{Program, TestnetV0};

use indexmap::IndexMap;
use itertools::Itertools;
use std::{
    collections::HashMap,
    fmt::{Display, Write as _},
    fs,
    path::PathBuf,
};

#[cfg(test)]
mod test;

#[cfg(test)]
mod test_interpreter;

mod util;
use util::*;

mod cursor;
use cursor::*;

mod interpreter;
use interpreter::*;

mod cursor_aleo;

mod ui;
use ui::Ui;

mod dialoguer_input;

mod ratatui_ui;

const INTRO: &str = "This is the Leo Interpreter. Try the command `#help`.";

const HELP: &str = "
You probably want to start by running a function or transition.
For instance
#into program.aleo/main()
Once a function is running, commands include
#into    to evaluate into the next expression or statement;
#step    to take one step towards evaluating the current expression or statement;
#over    to complete evaluating the current expression or statement;
#run     to finish evaluating
#quit    to quit the interpreter.

You can set a breakpoint with
#break program_name line_number

When executing Aleo VM code, you can print the value of a register like this:
#print 2

Some of the commands may be run with one letter abbreviations, such as #i.

Note that this interpreter is not line oriented as in many common debuggers;
rather it is oriented around expressions and statements.
As you step into code, individual expressions or statements will
be evaluated one by one, including arguments of function calls.

You may simply enter Leo expressions or statements on the command line
to evaluate. For instance, if you want to see the value of a variable w:
w
If you want to set w to a new value:
w = z + 2u8;

Note that statements (like the assignment above) must end with a semicolon.

If there are futures available to be executed, they will be listed by
numerical index, and you may run them using `#future` (or `#f`); for instance
#future 0

The interpreter begins in a global context, not in any Leo program. You can set
the current program with

#set_program program_name

This allows you to refer to structs and other items in the indicated program.

The interpreter may enter an invalid state, often due to Leo code entered at the
REPL. In this case, you may use the command

#restore

Which will restore to the last saved state of the interpreter. Any time you
enter Leo code at the prompt, interpreter state is saved.

Input history is available - use the up and down arrow keys.
";

fn parse_breakpoint(s: &str) -> Option<Breakpoint> {
    let strings: Vec<&str> = s.split_whitespace().collect();
    if strings.len() == 2
        && let Ok(line) = strings[1].parse::<usize>()
    {
        let program = strings[0].strip_suffix(".aleo").unwrap_or(strings[0]).to_string();
        return Some(Breakpoint { program, line });
    }
    None
}

pub struct TestFunction {
    pub program: String,
    pub function: String,
    pub should_fail: bool,
    pub private_key: Option<String>,
}

/// Run interpreter tests and return data about native tests.
// It's slightly goofy to have this function responsible for both of these tasks, but
// it's expedient as the `Interpreter` will already parse all the files and collect
// all the functions with annotations.
#[allow(clippy::type_complexity)]
pub fn find_and_run_tests(
    leo_filenames: &[(PathBuf, Vec<PathBuf>)], // Leo source files and their modules
    aleo_filenames: &[PathBuf],
    private_key: String,
    block_height: u32,
    block_timestamp: i64,
    match_str: &str,
    network: NetworkName,
) -> Result<(Vec<TestFunction>, IndexMap<Location, Result<()>>)> {
    let mut interpreter =
        Interpreter::new(leo_filenames, aleo_filenames, private_key, block_height, block_timestamp, network)?;

    let mut native_test_functions = Vec::new();

    let private_key_symbol = Symbol::intern("private_key");

    let mut result = IndexMap::new();

    for (id, function) in interpreter.cursor.functions.clone().into_iter() {
        // Only Leo functions may be tests.
        let FunctionVariant::Leo(function) = function else {
            continue;
        };

        let should_fail = function.annotations.iter().any(|annotation| annotation.identifier.name == sym::should_fail);

        let str_matches = || id.to_string().contains(match_str);

        // If this function is not annotated with @test, skip it.
        let Some(annotation) = function.annotations.iter().find(|annotation| annotation.identifier.name == sym::test)
        else {
            continue;
        };

        // If the name doesn't match, skip it.
        if !str_matches() {
            continue;
        }

        assert!(function.input.is_empty(), "Type checking should ensure test functions have no inputs.");

        if function.variant.is_transition() {
            // It's a native test; just store it and move on.
            let private_key = annotation.map.get(&private_key_symbol).cloned();
            native_test_functions.push(TestFunction {
                program: id.program.to_string(),
                function: id.path.iter().format("::").to_string(),
                should_fail,
                private_key,
            });
            continue;
        }

        assert!(function.variant.is_script(), "Type checking should ensure test functions are transitions or scripts.");

        let call = CallExpression {
            function: function.identifier.into(),
            const_arguments: vec![], // scripts don't have const parameters for now
            arguments: Vec::new(),
            program: Some(id.program),
            span: Default::default(),
            id: interpreter.node_builder.next_id(),
        };

        let statement: Statement = ExpressionStatement {
            expression: call.into(),
            span: Default::default(),
            id: interpreter.node_builder.next_id(),
        }
        .into();

        interpreter.cursor.frames.push(Frame {
            step: 0,
            element: Element::Statement(statement),
            user_initiated: false,
        });

        let run_result = interpreter.cursor.over();

        match (run_result, should_fail) {
            (Ok(..), true) => {
                result.insert(
                    id,
                    Err(InterpreterHalt::new("Test succeeded when failure was expected.".to_string()).into()),
                );
            }
            (Ok(..), false) => {
                result.insert(id, Ok(()));
            }
            (Err(..), true) => {
                result.insert(id, Ok(()));
            }
            (Err(err), false) => {
                result.insert(id, Err(err));
            }
        }

        // Clear the state for the next test.
        interpreter.cursor.clear();
    }

    Ok((native_test_functions, result))
}

/// Load all the Leo source files indicated and open the interpreter
/// to commands from the user.
pub fn interpret(
    leo_filenames: &[(PathBuf, Vec<PathBuf>)], // Leo source files and their modules
    aleo_filenames: &[PathBuf],
    private_key: String,
    block_height: u32,
    block_timestamp: i64,
    tui: bool,
    network: NetworkName,
) -> Result<()> {
    let mut interpreter =
        Interpreter::new(leo_filenames, aleo_filenames, private_key, block_height, block_timestamp, network)?;

    let mut user_interface: Box<dyn Ui> =
        if tui { Box::new(ratatui_ui::RatatuiUi::new()) } else { Box::new(dialoguer_input::DialoguerUi::new()) };

    let mut futures = Vec::new();
    let mut watchpoints = Vec::new();
    let mut message = INTRO.to_string();
    let mut result = String::new();

    loop {
        futures.clear();
        watchpoints.clear();

        let (code, highlight) = if let Some((code, lo, hi)) = interpreter.view_current_in_context() {
            (code.to_string(), Some((lo, hi)))
        } else if let Some(v) = interpreter.view_current() {
            (v.to_string(), None)
        } else {
            ("".to_string(), None)
        };

        futures.extend(interpreter.cursor.futures.iter().map(|f| f.to_string()));

        interpreter.update_watchpoints()?;

        watchpoints.extend(interpreter.watchpoints.iter().map(|watchpoint| {
            format!("{:>15} = {}", watchpoint.code, if let Some(s) = &watchpoint.last_result { &**s } else { "?" })
        }));

        let user_data = ui::UserData {
            code: &code,
            highlight,
            message: &message,
            futures: &futures,
            watchpoints: &watchpoints,
            result: if result.is_empty() { None } else { Some(&result) },
        };

        user_interface.display_user_data(&user_data);

        message.clear();
        result.clear();

        let user_input = user_interface.receive_user_input();

        let (command, rest) = tokenize_user_input(&user_input);

        let action = match (command, rest) {
            ("", "") => continue,
            ("#h" | "#help", "") => {
                message = HELP.to_string();
                continue;
            }
            ("#i" | "#into", "") => InterpreterAction::Into,
            ("#i" | "#into", rest) => InterpreterAction::LeoInterpretInto(rest.into()),
            ("#s" | "#step", "") => InterpreterAction::Step,
            ("#o" | "#over", "") => InterpreterAction::Over,
            ("#r" | "#run", "") => InterpreterAction::Run,
            ("#q" | "#quit", "") => return Ok(()),
            ("#f" | "#future", rest) => {
                if let Ok(num) = rest.trim().parse::<usize>() {
                    if num >= interpreter.cursor.futures.len() {
                        message = "No such future.".to_string();
                        continue;
                    }
                    InterpreterAction::RunFuture(num)
                } else {
                    message = "Failed to parse future.".to_string();
                    continue;
                }
            }
            ("#restore", "") => {
                if !interpreter.restore_cursor() {
                    message = "No saved state to restore".to_string();
                }
                continue;
            }
            ("#b" | "#break", rest) => {
                let Some(breakpoint) = parse_breakpoint(rest) else {
                    message = "Failed to parse breakpoint".to_string();
                    continue;
                };
                InterpreterAction::Breakpoint(breakpoint)
            }
            ("#p" | "#print", rest) => {
                let without_r = rest.strip_prefix("r").unwrap_or(rest);
                if let Ok(num) = without_r.parse::<u64>() {
                    InterpreterAction::PrintRegister(num)
                } else {
                    message = "Failed to parse register number".to_string();
                    continue;
                }
            }
            ("#w" | "#watch", rest) => InterpreterAction::Watch(rest.to_string()),
            ("#set_program", rest) => {
                interpreter.cursor.set_program(rest);
                continue;
            }
            ("", rest) => InterpreterAction::LeoInterpretOver(rest.to_string()),
            _ => {
                message = "Failed to parse command".to_string();
                continue;
            }
        };

        if matches!(action, InterpreterAction::LeoInterpretInto(..) | InterpreterAction::LeoInterpretOver(..)) {
            interpreter.save_cursor();
        }

        match interpreter.action(action) {
            Ok(Some(value)) => {
                result = value.to_string();
            }
            Ok(None) => {}
            Err(LeoError::InterpreterHalt(interpreter_halt)) => {
                message = format!("Halted: {interpreter_halt}");
            }
            Err(e) => return Err(e),
        }
    }
}

fn tokenize_user_input(input: &str) -> (&str, &str) {
    let input = input.trim();

    if !input.starts_with("#") {
        return ("", input);
    }

    let Some((first, rest)) = input.split_once(' ') else {
        return (input, "");
    };

    (first.trim(), rest.trim())
}