Document main and app_state

This commit is contained in:
mo8it 2024-04-29 17:01:47 +02:00
parent 7f73219041
commit b6f40f2ec8
3 changed files with 91 additions and 74 deletions

View file

@ -33,6 +33,7 @@ pub enum StateFileStatus {
NotRead, NotRead,
} }
// Parses parts of the output of `cargo metadata`.
#[derive(Deserialize)] #[derive(Deserialize)]
struct CargoMetadata { struct CargoMetadata {
target_directory: PathBuf, target_directory: PathBuf,
@ -41,14 +42,18 @@ struct CargoMetadata {
pub struct AppState { pub struct AppState {
current_exercise_ind: usize, current_exercise_ind: usize,
exercises: Vec<Exercise>, exercises: Vec<Exercise>,
// Caches the number of done exercises to avoid iterating over all exercises every time.
n_done: u16, n_done: u16,
final_message: String, final_message: String,
// Preallocated buffer for reading and writing the state file.
file_buf: Vec<u8>, file_buf: Vec<u8>,
official_exercises: bool, official_exercises: bool,
// Cargo's target directory.
target_dir: PathBuf, target_dir: PathBuf,
} }
impl AppState { impl AppState {
// Update the app state from the state file.
fn update_from_file(&mut self) -> StateFileStatus { fn update_from_file(&mut self) -> StateFileStatus {
self.file_buf.clear(); self.file_buf.clear();
self.n_done = 0; self.n_done = 0;
@ -98,6 +103,7 @@ impl AppState {
exercise_infos: Vec<ExerciseInfo>, exercise_infos: Vec<ExerciseInfo>,
final_message: String, final_message: String,
) -> Result<(Self, StateFileStatus)> { ) -> Result<(Self, StateFileStatus)> {
// Get the target directory from Cargo.
let metadata_output = Command::new("cargo") let metadata_output = Command::new("cargo")
.arg("metadata") .arg("metadata")
.arg("-q") .arg("-q")
@ -115,6 +121,7 @@ impl AppState {
)? )?
.target_directory; .target_directory;
// Build exercises from their metadata in the info file.
let exercises = exercise_infos let exercises = exercise_infos
.into_iter() .into_iter()
.map(|mut exercise_info| { .map(|mut exercise_info| {
@ -184,6 +191,36 @@ impl AppState {
&self.target_dir &self.target_dir
} }
// Write the state file.
// The file's format is very simple:
// - The first line is a comment.
// - The second line is an empty line.
// - The third line is the name of the current exercise. It must end with `\n` even if there
// are no done exercises.
// - The fourth line is an empty line.
// - All remaining lines are the names of done exercises.
fn write(&mut self) -> Result<()> {
self.file_buf.clear();
self.file_buf
.extend_from_slice(b"DON'T EDIT THIS FILE!\n\n");
self.file_buf
.extend_from_slice(self.current_exercise().name.as_bytes());
self.file_buf.push(b'\n');
for exercise in &self.exercises {
if exercise.done {
self.file_buf.push(b'\n');
self.file_buf.extend_from_slice(exercise.name.as_bytes());
}
}
fs::write(STATE_FILE_NAME, &self.file_buf)
.with_context(|| format!("Failed to write the state file {STATE_FILE_NAME}"))?;
Ok(())
}
pub fn set_current_exercise_ind(&mut self, ind: usize) -> Result<()> { pub fn set_current_exercise_ind(&mut self, ind: usize) -> Result<()> {
if ind >= self.exercises.len() { if ind >= self.exercises.len() {
bail!(BAD_INDEX_ERR); bail!(BAD_INDEX_ERR);
@ -218,6 +255,8 @@ impl AppState {
Ok(()) Ok(())
} }
// Official exercises: Dump the original file from the binary.
// Third-party exercises: Reset the exercise file with `git stash`.
fn reset(&self, ind: usize, dir_name: Option<&str>, path: &str) -> Result<()> { fn reset(&self, ind: usize, dir_name: Option<&str>, path: &str) -> Result<()> {
if self.official_exercises { if self.official_exercises {
return EMBEDDED_FILES return EMBEDDED_FILES
@ -271,6 +310,7 @@ impl AppState {
Ok(exercise.path) Ok(exercise.path)
} }
// Return the index of the next pending exercise or `None` if all exercises are done.
fn next_pending_exercise_ind(&self) -> Option<usize> { fn next_pending_exercise_ind(&self) -> Option<usize> {
if self.current_exercise_ind == self.exercises.len() - 1 { if self.current_exercise_ind == self.exercises.len() - 1 {
// The last exercise is done. // The last exercise is done.
@ -293,6 +333,8 @@ impl AppState {
} }
} }
// Official exercises: Dump the solution file form the binary and return its path.
// Third-party exercises: Check if a solution file exists and return its path in that case.
pub fn current_solution_path(&self) -> Result<Option<String>> { pub fn current_solution_path(&self) -> Result<Option<String>> {
if DEBUG_PROFILE { if DEBUG_PROFILE {
return Ok(None); return Ok(None);
@ -328,6 +370,9 @@ impl AppState {
} }
} }
// Mark the current exercise as done and move on to the next pending exercise if one exists.
// If all exercises are marked as done, run all of them to make sure that they are actually
// done. If an exercise which is marked as done fails, mark it as pending and continue on it.
pub fn done_current_exercise(&mut self, writer: &mut StdoutLock) -> Result<ExercisesProgress> { pub fn done_current_exercise(&mut self, writer: &mut StdoutLock) -> Result<ExercisesProgress> {
let exercise = &mut self.exercises[self.current_exercise_ind]; let exercise = &mut self.exercises[self.current_exercise_ind];
if !exercise.done { if !exercise.done {
@ -335,7 +380,12 @@ impl AppState {
self.n_done += 1; self.n_done += 1;
} }
let Some(ind) = self.next_pending_exercise_ind() else { if let Some(ind) = self.next_pending_exercise_ind() {
self.set_current_exercise_ind(ind)?;
return Ok(ExercisesProgress::Pending);
}
writer.write_all(RERUNNING_ALL_EXERCISES_MSG)?; writer.write_all(RERUNNING_ALL_EXERCISES_MSG)?;
let mut output = Vec::with_capacity(OUTPUT_CAPACITY); let mut output = Vec::with_capacity(OUTPUT_CAPACITY);
@ -371,42 +421,7 @@ impl AppState {
writer.write_all(b"\n")?; writer.write_all(b"\n")?;
} }
return Ok(ExercisesProgress::AllDone); Ok(ExercisesProgress::AllDone)
};
self.set_current_exercise_ind(ind)?;
Ok(ExercisesProgress::Pending)
}
// Write the state file.
// The file's format is very simple:
// - The first line is a comment.
// - The second line is an empty line.
// - The third line is the name of the current exercise. It must end with `\n` even if there
// are no done exercises.
// - The fourth line is an empty line.
// - All remaining lines are the names of done exercises.
fn write(&mut self) -> Result<()> {
self.file_buf.clear();
self.file_buf
.extend_from_slice(b"DON'T EDIT THIS FILE!\n\n");
self.file_buf
.extend_from_slice(self.current_exercise().name.as_bytes());
self.file_buf.push(b'\n');
for exercise in &self.exercises {
if exercise.done {
self.file_buf.push(b'\n');
self.file_buf.extend_from_slice(exercise.name.as_bytes());
}
}
fs::write(STATE_FILE_NAME, &self.file_buf)
.with_context(|| format!("Failed to write the state file {STATE_FILE_NAME}"))?;
Ok(())
} }
} }

View file

@ -15,7 +15,7 @@ pub enum DevCommands {
New { New {
/// The path to create the project in /// The path to create the project in
path: PathBuf, path: PathBuf,
/// Don't initialize a Git repository in the project directory /// Don't try to initialize a Git repository in the project directory
#[arg(long)] #[arg(long)]
no_git: bool, no_git: bool,
}, },

View file

@ -40,6 +40,11 @@ const DEBUG_PROFILE: bool = {
debug_profile debug_profile
}; };
// The current directory is the official Rustligns repository.
fn in_official_repo() -> bool {
Path::new("dev/rustlings-repo.txt").exists()
}
/// Rustlings is a collection of small exercises to get you used to writing and reading Rust code /// Rustlings is a collection of small exercises to get you used to writing and reading Rust code
#[derive(Parser)] #[derive(Parser)]
#[command(version)] #[command(version)]
@ -54,7 +59,7 @@ struct Args {
#[derive(Subcommand)] #[derive(Subcommand)]
enum Subcommands { enum Subcommands {
/// Initialize Rustlings /// Initialize the official Rustlings exercises
Init, Init,
/// Run a single exercise. Runs the next pending exercise if the exercise name is not specified /// Run a single exercise. Runs the next pending exercise if the exercise name is not specified
Run { Run {
@ -76,10 +81,6 @@ enum Subcommands {
Dev(DevCommands), Dev(DevCommands),
} }
fn in_official_repo() -> bool {
Path::new("dev/rustlings-repo.txt").exists()
}
fn main() -> Result<()> { fn main() -> Result<()> {
let args = Args::parse(); let args = Args::parse();
@ -123,6 +124,7 @@ fn main() -> Result<()> {
info_file.final_message.unwrap_or_default(), info_file.final_message.unwrap_or_default(),
)?; )?;
// Show the welcome message if the state file doesn't exist yet.
if let Some(welcome_message) = info_file.welcome_message { if let Some(welcome_message) = info_file.welcome_message {
match state_file_status { match state_file_status {
StateFileStatus::NotRead => { StateFileStatus::NotRead => {