use std::path::PathBuf;
use std::rc::Rc;
use rustc_hash::FxHashMap;
use rustyline::{error::ReadlineError, Editor};
use smol_str::SmolStr;
use tvix_eval::{GlobalsMap, SourceCode, Value};
use tvix_glue::tvix_store_io::TvixStoreIO;
use crate::{
assignment::Assignment, evaluate, interpret, AllowIncomplete, Args, IncompleteInput,
InterpretResult,
};
fn state_dir() -> Option<PathBuf> {
let mut path = dirs::data_dir();
if let Some(p) = path.as_mut() {
p.push("tvix")
}
path
}
#[derive(Debug, Clone, PartialEq, Eq)]
pub(crate) enum ReplCommand<'a> {
Expr(&'a str),
Assign(Assignment<'a>),
Explain(&'a str),
Print(&'a str),
Quit,
Help,
}
impl<'a> ReplCommand<'a> {
const HELP: &'static str = "
Welcome to the Tvix REPL!
The following commands are supported:
<expr> Evaluate a Nix language expression and print the result, along with its inferred type
<x> = <expr> Bind the result of an expression to a variable
:d <expr> Evaluate a Nix language expression and print a detailed description of the result
:p <expr> Evaluate a Nix language expression and print the result recursively
:q Exit the REPL
:?, :h Display this help text
";
pub fn parse(input: &'a str) -> Self {
if input.starts_with(':') {
if let Some(without_prefix) = input.strip_prefix(":d ") {
return Self::Explain(without_prefix);
} else if let Some(without_prefix) = input.strip_prefix(":p ") {
return Self::Print(without_prefix);
}
let input = input.trim_end();
match input {
":q" => return Self::Quit,
":h" | ":?" => return Self::Help,
_ => {}
}
}
if let Some(assignment) = Assignment::parse(input) {
return Self::Assign(assignment);
}
Self::Expr(input)
}
}
pub struct CommandResult {
output: String,
continue_: bool,
}
impl CommandResult {
pub fn finalize(self) -> bool {
print!("{}", self.output);
self.continue_
}
pub fn output(&self) -> &str {
&self.output
}
}
pub struct Repl<'a> {
multiline_input: Option<String>,
rl: Editor<()>,
env: FxHashMap<SmolStr, Value>,
io_handle: Rc<TvixStoreIO>,
args: &'a Args,
source_map: SourceCode,
globals: Option<Rc<GlobalsMap>>,
}
impl<'a> Repl<'a> {
pub fn new(io_handle: Rc<TvixStoreIO>, args: &'a Args) -> Self {
let rl = Editor::<()>::new().expect("should be able to launch rustyline");
Self {
multiline_input: None,
rl,
env: FxHashMap::default(),
io_handle,
args,
source_map: Default::default(),
globals: None,
}
}
pub fn run(&mut self) {
if self.args.compile_only {
eprintln!("warning: `--compile-only` has no effect on REPL usage!");
}
let history_path = match state_dir() {
Some(mut path) => {
let _ = std::fs::create_dir_all(&path);
path.push("history.txt");
let _ = self.rl.load_history(&path);
Some(path)
}
None => None,
};
loop {
let prompt = if self.multiline_input.is_some() {
" > "
} else {
"tvix-repl> "
};
let readline = self.rl.readline(prompt);
match readline {
Ok(line) => {
if !self.send(line).finalize() {
break;
}
}
Err(ReadlineError::Interrupted) | Err(ReadlineError::Eof) => break,
Err(err) => {
eprintln!("error: {}", err);
break;
}
}
}
if let Some(path) = history_path {
self.rl.save_history(&path).unwrap();
}
}
pub fn send(&mut self, line: String) -> CommandResult {
if line.is_empty() {
return CommandResult {
output: String::new(),
continue_: true,
};
}
let input = if let Some(mi) = &mut self.multiline_input {
mi.push('\n');
mi.push_str(&line);
mi
} else {
&line
};
let res = match ReplCommand::parse(input) {
ReplCommand::Quit => {
return CommandResult {
output: String::new(),
continue_: false,
};
}
ReplCommand::Help => {
println!("{}", ReplCommand::HELP);
Ok(InterpretResult::empty_success(None))
}
ReplCommand::Expr(input) => interpret(
Rc::clone(&self.io_handle),
input,
None,
self.args,
false,
AllowIncomplete::Allow,
Some(&self.env),
self.globals.clone(),
Some(self.source_map.clone()),
),
ReplCommand::Assign(Assignment { ident, value }) => {
match evaluate(
Rc::clone(&self.io_handle),
&value.to_string(), None,
self.args,
AllowIncomplete::Allow,
Some(&self.env),
self.globals.clone(),
Some(self.source_map.clone()),
) {
Ok(result) => {
if let Some(value) = result.value {
self.env.insert(ident.into(), value);
}
Ok(InterpretResult::empty_success(Some(result.globals)))
}
Err(incomplete) => Err(incomplete),
}
}
ReplCommand::Explain(input) => interpret(
Rc::clone(&self.io_handle),
input,
None,
self.args,
true,
AllowIncomplete::Allow,
Some(&self.env),
self.globals.clone(),
Some(self.source_map.clone()),
),
ReplCommand::Print(input) => interpret(
Rc::clone(&self.io_handle),
input,
None,
&Args {
strict: true,
..(self.args.clone())
},
false,
AllowIncomplete::Allow,
Some(&self.env),
self.globals.clone(),
Some(self.source_map.clone()),
),
};
match res {
Ok(InterpretResult {
output,
globals,
success: _,
}) => {
self.rl.add_history_entry(input);
self.multiline_input = None;
if globals.is_some() {
self.globals = globals;
}
CommandResult {
output,
continue_: true,
}
}
Err(IncompleteInput) => {
if self.multiline_input.is_none() {
self.multiline_input = Some(line);
}
CommandResult {
output: String::new(),
continue_: true,
}
}
}
}
}