-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Extracted structs into their own modules and refactored to be DRY.
- Loading branch information
Showing
7 changed files
with
230 additions
and
160 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,100 @@ | ||
| //! The `command` module contains functions that implement the command-line | ||
| //! interface for the application. | ||
| //! | ||
| //! Public functions: | ||
| //! - The public `add_task` function adds a new pending task to the task list. | ||
| //! - The public `list_all_tasks` function lists all the tasks in the task list. | ||
| //! | ||
| //! Private functions: | ||
| //! - The private `next_task_number` function gets the next task number to be used. | ||
| //! | ||
| use crate::{task::Task, Result}; | ||
| use surrealdb::{engine::local::Db, Surreal}; | ||
|
|
||
| /// Adds a new pending task to the task list. | ||
| /// | ||
| /// The `add_task` function takes a `name` parameter, which is the name of the task | ||
| /// to be added. It then initializes the SurrealDB database and prints a message | ||
| /// indicating that the task has been created. | ||
| /// | ||
| /// The function is asynchronous because it calls the `Database::new` method, which | ||
| /// is asynchronous. | ||
| /// | ||
| /// # Parameters | ||
| /// - `name`: The name of the task to be added. | ||
| /// | ||
| /// # Panics | ||
| /// The function will panic if the database connection fails. | ||
| /// | ||
| /// # Errors | ||
| /// The function will return an error if the database connection fails. | ||
| /// | ||
| pub async fn add_task(db: &Surreal<Db>, names: Vec<String>) -> Result<()> { | ||
| for name in names { | ||
| let number = next_task_number(db).await?; | ||
| let created: Vec<Task> = db.create("tasks").content(Task::new(number, name)).await?; | ||
| let task = created.first().ok_or("Failed to add task.")?; | ||
|
|
||
| println!("Created task {}: {}", task.number(), task.name()); | ||
| } | ||
|
|
||
| Ok(()) | ||
| } | ||
|
|
||
| /// Lists all the tasks in the task list. | ||
| /// | ||
| /// The `list_all_tasks` function initializes the SurrealDB database and queries | ||
| /// the database for all the tasks. It then prints the task number and name for | ||
| /// each task found in the database. | ||
| /// | ||
| /// # Parameters | ||
| /// | ||
| /// There are no parameters for this function. | ||
| /// | ||
| /// # Returns | ||
| /// | ||
| /// The function returns `Ok(())` if the operation is successful. | ||
| /// | ||
| /// # Errors | ||
| /// | ||
| /// The function will return an error if the database query fails. | ||
| /// | ||
| pub async fn list_all_tasks(db: &Surreal<Db>) -> Result<()> { | ||
| let mut response = db.query("SELECT * FROM tasks ORDER BY number ASC").await?; | ||
| let tasks: Vec<Task> = response.take(0)?; | ||
|
|
||
| if tasks.is_empty() { | ||
| println!("No tasks found."); | ||
| } else { | ||
| for task in tasks { | ||
| println!("{}: {}", task.number(), task.name()); | ||
| } | ||
| } | ||
|
|
||
| Ok(()) | ||
| } | ||
|
|
||
| /// Gets the next task number. | ||
| /// | ||
| /// The `next_task_number` function takes a reference to the SurrealDB database | ||
| /// and returns the next task number to be used. It queries the database for the | ||
| /// existing tasks, finds the maximum task number, and increments it by one to | ||
| /// get the next task number. | ||
| /// | ||
| /// # Parameters | ||
| /// | ||
| /// - `db`: A reference to the SurrealDB database. | ||
| /// | ||
| /// # Returns | ||
| /// | ||
| /// The function returns the next task number to be used. | ||
| /// | ||
| /// # Errors | ||
| /// | ||
| /// The function will return an error if the database query fails. | ||
| /// | ||
| async fn next_task_number(db: &Surreal<Db>) -> Result<i64> { | ||
| let tasks: Vec<Task> = db.select("tasks").await?; | ||
| let next_number = tasks.iter().map(|t| t.number()).max().unwrap_or(0) + 1; | ||
| Ok(next_number) | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.