Added a list command

src/commands/list.rs

@@ -0,0 +1,50 @@
+use std::path::PathBuf;
+use clap::Args;
+use crate::utils::config;
+use crate::utils::config::{Config, ConfigFile};
+
+#[derive(Args, Debug)]
+pub struct Arguments {
+    #[arg(long, default_value = ".", help = "Which directory to use as entry, defaults to the current directory")]
+    entry: String,
+}
+
+pub fn execute (arguments: &Arguments) -> Result<(), String> {
+    let Arguments { entry } = arguments;
+
+    // Resolve the entry path
+    let entry_config_path: PathBuf = config::resolve_config_path(entry)?;
+
+    // Discover all config paths
+    let config_paths: Vec<PathBuf> = config::discover_config_paths(&entry_config_path)?;
+
+    // Parse config file content
+    let config_files: Vec<ConfigFile> = config::read_config_files(config_paths)?;
+
+    // Parse config files
+    let configs: Vec<Config> = config::parse_config_files(config_files)?;
+
+    // get all available tasks
+    let tasks: Vec<String> = get_config_tasks(&configs)?;
+
+    println!("The following tasks are available:");
+    for task in tasks {
+        println!("  -  {}", task)
+    }
+
+    Ok(())
+}
+
+fn get_config_tasks(configs: &Vec<Config>) -> Result<Vec<String>, String> {
+    let mut tasks: Vec<String> = vec![];
+
+    for config in configs {
+        for task in config.tasks.keys() {
+            if !tasks.contains(&task) {
+                tasks.push(task.clone());
+            }
+        }
+    }
+
+    Ok(tasks)
+}

src/commands/mod.rs

@@ -1 +1,2 @@
 pub mod run;
+pub mod list;

src/commands/run.rs

@@ -1,15 +1,12 @@
-use std::collections::HashMap;
 use std::fmt::Debug;
-use std::fs::{canonicalize, read_to_string};
-use std::path::{Path, PathBuf};
+use std::path::PathBuf;
 use std::process::Command;
 use std::thread;
 use std::thread::JoinHandle;
 use std::time::Instant;
 use clap::Args;
-use glob::glob;
-use globset::{Glob, GlobSetBuilder};
-use serde::Deserialize;
+use crate::utils::config;
+use crate::utils::config::{Config, ConfigFile, ConfigStructure, OrderedTask, OrderedTasks, Task, TaskExit};
 
 #[derive(Args, Debug)]
 pub struct Arguments {
@@ -19,30 +16,30 @@ pub struct Arguments {
     entry: String,
 }
 
-pub fn run (arguments: &Arguments) -> Result<(), String> {
+pub fn execute (arguments: &Arguments) -> Result<(), String> {
     let Arguments { entry, task_name } = arguments;
 
     // Start the timer
     let start_time = Instant::now();
 
     // Resolve the entry path
-    let entry_config_path: PathBuf = resolve_config_path(entry)?;
+    let entry_config_path: PathBuf = config::resolve_config_path(entry)?;
 
     // Discover all config paths
-    let config_paths: Vec<PathBuf> = discover_config_paths(&entry_config_path)?;
+    let config_paths: Vec<PathBuf> = config::discover_config_paths(&entry_config_path)?;
 
     // Parse config file content
-    let config_files: Vec<ConfigFile> = read_config_files(config_paths)?;
+    let config_files: Vec<ConfigFile> = config::read_config_files(config_paths)?;
 
     // Parse config files
-    let configs: Vec<Config> = parse_config_files(config_files)?;
+    let configs: Vec<Config> = config::parse_config_files(config_files)?;
 
     // Resolve dependencies based on the directory structure
     // (In the future this will be configurable based on a dependency config field)
-    let config_structure: ConfigStructure = resolve_config_structure(&entry_config_path, configs)?;
+    let config_structure: ConfigStructure = config::resolve_config_structure(&entry_config_path, configs)?;
 
     // Gather the tasks from the config
-    let ordered_tasks: OrderedTasks = resolve_task_order(config_structure, task_name)?;
+    let ordered_tasks: OrderedTasks = config::resolve_task_order(config_structure, task_name)?;
 
     // Run the commands, one by one
     // > In the future this is configurable on the rask level and maybe on the config file level
@@ -133,365 +130,3 @@ fn find_highest_order(ordered_tasks: &OrderedTasks) -> Result<u64, String> {
 
     Ok(highest_order)
 }
-
-#[derive(Debug, Clone)]
-enum TaskExit {
-    SUCCESS,
-    FAILURE
-}
-
-#[derive(Debug, Clone)]
-struct Task {
-    command: String,
-    directory: PathBuf,
-}
-
-#[derive(Debug, Clone)]
-struct OrderedTask {
-    task: Task,
-    order: u64
-}
-
-type OrderedTasks = Vec<OrderedTask>;
-
-fn resolve_task_order(config_structure: ConfigStructure, task_name: &String) -> Result<OrderedTasks, String> {
-    let mut ordered_tasks: OrderedTasks = vec![];
-
-    order_tasks(&mut ordered_tasks, config_structure, task_name, 0);
-
-    Ok(ordered_tasks)
-}
-
-fn order_tasks(ordered_tasks: &mut OrderedTasks, config_structure: ConfigStructure, task_name: &String, index: u64) {
-    let ConfigStructure { config, children } = config_structure;
-    let Config { tasks, dir_path, .. } = config;
-    match tasks.get(task_name) {
-        None => {}
-        Some(&ref config_task) => ordered_tasks.push(OrderedTask{
-            task: Task {
-                command: config_task.content.clone(),
-                directory: dir_path,
-            },
-            order: index
-        })
-    }
-
-    for child in children {
-        order_tasks(ordered_tasks, child, task_name, index+1);
-    }
-}
-
-#[derive(Debug, Clone)]
-struct ConfigStructure {
-    config: Config,
-    children: Vec<ConfigStructure>
-}
-
-fn resolve_config_structure(entry_config_path: &PathBuf, configs: Vec<Config>) -> Result<ConfigStructure, String> {
-    let mut path_map: HashMap<PathBuf, Config> = HashMap::new();
-
-    for config in configs {
-        path_map.insert(config.clone().file_path, config);
-    }
-
-    let config_structure: ConfigStructure = construct_config_structure(entry_config_path, &path_map)?;
-
-    Ok(config_structure)
-}
-
-fn construct_config_structure(config_path: &PathBuf, config_path_map: &HashMap<PathBuf, Config>) -> Result<ConfigStructure, String> {
-    let config = config_path_map.get(config_path).ok_or("Unknown config path")?;
-
-    let paths: Vec<PathBuf> = config_path_map.keys().cloned().collect();
-    let Config { directories, .. } = config;
-    let config_directory: &Path = config_path.parent().unwrap();
-    let mut child_paths: Vec<PathBuf> = vec![];
-
-    for directory in directories {
-        let path_pattern: PathBuf = get_config_glob_pattern(config_directory, &directory);
-
-        // TODO: Maybe abstract?
-        let pattern = match Glob::new(path_pattern.to_str().unwrap()) {
-            Ok(pattern) => pattern,
-            Err(err) => return Err(format!("Failed to create glob pattern: {:?}", err)),
-        };
-        let mut builder = GlobSetBuilder::new();
-        builder.add(pattern);
-        let glob_set = builder.build().unwrap();
-
-        for path in &paths {
-            if glob_set.is_match(path) {
-                child_paths.push(path.to_path_buf());
-            }
-        }
-    }
-
-    let config_structure = ConfigStructure {
-        config: config.clone(),
-        children: child_paths
-            .iter()
-            .map(|path| construct_config_structure(path, config_path_map).unwrap())
-            .collect()
-    };
-
-    Ok(config_structure)
-}
-
-#[derive(Debug, Clone)]
-enum TaskType {
-    SHELL
-}
-
-#[derive(Debug, Clone)]
-#[allow(dead_code)]
-struct ConfigTask {
-    task_type: TaskType,
-    content: String
-}
-
-type ConfigTasks = HashMap<String, ConfigTask>;
-type ConfigDirectories = Vec<String>;
-
-#[derive(Debug, Clone, Default, Deserialize)]
-enum TaskEngine {
-    #[serde(rename = "composer")]
-    COMPOSER,
-    #[serde(rename = "npm")]
-    NPM,
-    #[serde(rename = "yarn")]
-    YARN,
-    #[serde(rename = "pnpm")]
-    PNPM,
-    #[serde(rename = "none")]
-    #[default]
-    NONE
-}
-
-#[derive(Debug, Clone)]
-#[allow(dead_code)]
-struct Config {
-    name: String,
-    task_engine: TaskEngine,
-    tasks: HashMap<String, ConfigTask>,
-    file_path: PathBuf,
-    dir_path: PathBuf,
-    directories: ConfigDirectories,
-}
-
-fn parse_config_files(config_files: Vec<ConfigFile>) -> Result<Vec<Config>, String> {
-    let mut configs: Vec<Config> = vec![];
-
-    for config_file in config_files {
-        let config = parse_config_file(config_file)?;
-        configs.push(config);
-    }
-
-    Ok(configs)
-}
-
-fn parse_config_file(config_file: ConfigFile) -> Result<Config, String> {
-    let ConfigFile { name, tasks: config_file_tasks, __file_path: file_path, __dir_path: dir_path, directories, task_engine } = config_file;
-
-    let tasks: ConfigTasks = match task_engine {
-        TaskEngine::COMPOSER => parse_composer_tasks(&dir_path)?,
-        TaskEngine::NPM => parse_node_tasks(&dir_path, "npm")?,
-        TaskEngine::YARN => parse_node_tasks(&dir_path, "yarn")?,
-        TaskEngine::PNPM => parse_node_tasks(&dir_path, "pnpm")?,
-        TaskEngine::NONE => parse_config_tasks(config_file_tasks)?,
-    };
-
-    let config: Config = Config { name, tasks, file_path, dir_path, directories, task_engine };
-
-    Ok(config)
-}
-
-#[derive(Debug, Clone, Deserialize, Default)]
-struct PackageJsonFile {
-    #[serde(default)]
-    scripts: HashMap<String, String>,
-}
-
-fn parse_node_tasks(dir_path: &PathBuf, prefix: &str) -> Result<ConfigTasks, String> {
-    let mut file_path = dir_path.clone();
-    file_path.push("package.json");
-    let content = read_file_content(file_path)?;
-
-    let package_json: PackageJsonFile = serde_json::from_str(&content).expect(format!("Failed to package.json from \"{:?}\"", dir_path).as_str());
-
-    let mut config_tasks: ConfigTasks = HashMap::new();
-    for key in package_json.scripts.keys() {
-        config_tasks.insert(key.clone(), ConfigTask {
-            task_type: TaskType::SHELL,
-            content: format!("{:?} run {:?}", prefix, key)
-        });
-    }
-
-    Ok(config_tasks)
-}
-
-#[derive(Debug, Clone, Deserialize)]
-#[serde(untagged)]
-enum ComposerJsonScriptValue {
-    Single(String),
-    Multiple(Vec<String>),
-}
-
-#[derive(Debug, Clone, Deserialize, Default)]
-struct ComposerJsonFile {
-    #[serde(default)]
-    scripts: HashMap<String, ComposerJsonScriptValue>,
-}
-
-fn parse_composer_tasks(dir_path: &PathBuf) -> Result<ConfigTasks, String> {
-    let mut file_path = dir_path.clone();
-    file_path.push("composer.json");
-    let content = read_file_content(file_path)?;
-
-    let package_json: ComposerJsonFile = serde_json::from_str(&content).expect(format!("Failed to composer.json from \"{:?}\"", dir_path).as_str());
-
-    let mut config_tasks: ConfigTasks = HashMap::new();
-    for key in package_json.scripts.keys() {
-        config_tasks.insert(key.clone(), ConfigTask {
-            task_type: TaskType::SHELL,
-            content: format!("composer run {:?}", key)
-        });
-    }
-
-    Ok(config_tasks)
-}
-
-fn parse_config_tasks(tasks: ConfigFileTasks) -> Result<ConfigTasks, String> {
-    let mut config_tasks: ConfigTasks = HashMap::new();
-
-    for (key, value) in tasks {
-        let config_task: ConfigTask = ConfigTask {
-            task_type: TaskType::SHELL,
-            content: value
-        };
-
-        config_tasks.insert(key, config_task);
-    }
-
-    Ok(config_tasks)
-}
-
-fn read_config_files(paths: Vec<PathBuf>) -> Result<Vec<ConfigFile>, String> {
-    let mut configs_files: Vec<ConfigFile> = vec![];
-
-    for path in paths {
-        let config_file = read_config_file(path)?;
-        configs_files.push(config_file);
-    }
-
-    Ok(configs_files)
-}
-
-fn discover_config_paths(path: &PathBuf) -> Result<Vec<PathBuf>, String> {
-    let mut found_config_paths: Vec<PathBuf> = vec![path.clone()];
-
-    // Read config
-    let mut path_stack: Vec<PathBuf> = vec![path.clone()];
-    while !path_stack.is_empty() {
-        let ConfigFile { directories, __file_path: _file_path, .. } = read_config_file(path_stack.pop().unwrap())?;
-
-        // Extract directories
-        let config_directory = _file_path.parent().ok_or("Failed to get parent directory")?;
-        for directory in directories {
-            let pattern = get_config_glob_pattern(config_directory, &directory);
-
-            // Find config files based on the pattern in the directories value
-            let pattern_string: &str = pattern.to_str().unwrap();
-            for pattern_results in glob(pattern_string).map_err(|e| format!("Failed to read glob pattern: {}", e))? {
-                if let Ok(found_config_path) = pattern_results {
-                    // Only add if the path was not already processed, preventing loops.
-                    if !found_config_paths.contains(&found_config_path) {
-                        found_config_paths.push(found_config_path.clone());
-                        path_stack.push(found_config_path.clone());
-                    }
-                }
-            }
-        }
-    }
-
-    Ok(found_config_paths)
-}
-
-fn get_config_glob_pattern(root_path: &Path, glob_pattern: &String) -> PathBuf {
-    let mut pattern: PathBuf = root_path.to_path_buf();
-
-    pattern.push(glob_pattern);
-    if !pattern.ends_with(".yaml") {
-        pattern.push("rask.yaml");
-    }
-
-    pattern
-}
-
-fn read_file_content (path: PathBuf) -> Result<String, String> {
-    match read_to_string(path) {
-        Ok(content) => Ok(content),
-        Err(err) => Err(format!("Failed to read file: {}", err)),
-    }
-}
-
-type ConfigFileTasks = HashMap<String, String>;
-
-#[derive(Debug, Deserialize, Default)]
-struct ConfigFile {
-    name: String,
-    #[serde(default)]
-    task_engine: TaskEngine,
-    #[serde(default)]
-    directories: ConfigDirectories,
-    #[serde(default)]
-    tasks: ConfigFileTasks,
-    // The following fields are not part of the yaml file.
-    #[serde(default)]
-    __file_path: PathBuf,
-    #[serde(default)]
-    __dir_path: PathBuf,
-}
-
-fn read_config_file(path: PathBuf) -> Result<ConfigFile, String> {
-    let content = read_file_content(path.clone())?;
-
-    let mut config_file: ConfigFile = serde_yaml::from_str(&content).expect(format!("Failed to parse YAML from \"{:?}\"", path).as_str());
-
-    config_file.__file_path = path.clone();
-    config_file.__dir_path = path.parent().unwrap().to_path_buf();
-
-    Ok(config_file)
-}
-
-fn resolve_config_path<P: AsRef<Path> + Debug + Clone + Copy>(path: P) -> Result<PathBuf, String> {
-    let full_path = match canonicalize(path) {
-        Ok(full_path) => full_path,
-        Err(_) => return Err(format!("Target does not exists: {:?}", path.clone()))
-    };
-
-    if full_path.is_dir() {
-        let config_file = find_config_file(full_path)?;
-        return Ok(config_file)
-    }
-
-    Ok(full_path)
-}
-
-const CONFIG_FILENAMES: [&str; 1] = ["rask.yaml"];
-
-fn find_config_file(directory_path: PathBuf) -> Result<PathBuf, String> {
-    if !directory_path.is_dir() {
-        return Err(format!("\"{:?}\" is not a directory", directory_path))
-    }
-
-    for filename in CONFIG_FILENAMES {
-        let mut possible_config_file = directory_path.clone();
-        possible_config_file.push(filename);
-        match possible_config_file.exists() {
-            true => return Ok(possible_config_file),
-            false => {}
-        }
-    }
-
-    Err(format!("Unable to find a config file (\"{:?}\") in {:?}", CONFIG_FILENAMES, directory_path))
-}

src/main.rs

@@ -1,13 +1,15 @@
 use std::process::exit;
 use clap::{Parser, Subcommand};
 use commands::run;
+use commands::list;
 
 mod commands;
 mod utils;
 
 #[derive(Subcommand, Debug)]
 enum Command {
-    Run(run::Arguments)
+    Run(run::Arguments),
+    List(list::Arguments),
 }
 
 #[derive(Parser, Debug)]
@@ -21,7 +23,8 @@ fn main() {
     let arguments = Arguments::parse();
 
     let result = match &arguments.command {
-        Command::Run(arguments) => { run::run(arguments) }
+        Command::Run(arguments) => { run::execute(arguments) },
+        Command::List(arguments) => { list::execute(arguments) },
     };
 
     match result {

src/utils/config.rs

@@ -0,0 +1,367 @@
+use std::path::{Path, PathBuf};
+use std::fmt::Debug;
+use std::fs::{canonicalize, read_to_string};
+use std::collections::HashMap;
+use globset::{Glob, GlobSetBuilder};
+use serde::Deserialize;
+
+#[derive(Debug, Clone)]
+pub enum TaskExit {
+    SUCCESS,
+    FAILURE
+}
+
+#[derive(Debug, Clone)]
+pub struct Task {
+    pub command: String,
+    pub directory: PathBuf,
+}
+
+#[derive(Debug, Clone)]
+pub struct OrderedTask {
+    pub task: Task,
+    pub order: u64
+}
+
+pub type OrderedTasks = Vec<OrderedTask>;
+
+pub fn resolve_task_order(config_structure: ConfigStructure, task_name: &String) -> Result<OrderedTasks, String> {
+    let mut ordered_tasks: OrderedTasks = vec![];
+
+    order_tasks(&mut ordered_tasks, config_structure, task_name, 0);
+
+    Ok(ordered_tasks)
+}
+
+fn order_tasks(ordered_tasks: &mut OrderedTasks, config_structure: ConfigStructure, task_name: &String, index: u64) {
+    let ConfigStructure { config, children } = config_structure;
+    let Config { tasks, dir_path, .. } = config;
+    match tasks.get(task_name) {
+        None => {}
+        Some(&ref config_task) => ordered_tasks.push(OrderedTask{
+            task: Task {
+                command: config_task.content.clone(),
+                directory: dir_path,
+            },
+            order: index
+        })
+    }
+
+    for child in children {
+        order_tasks(ordered_tasks, child, task_name, index+1);
+    }
+}
+
+#[derive(Debug, Clone)]
+pub struct ConfigStructure {
+    pub config: Config,
+    pub children: Vec<ConfigStructure>
+}
+
+pub fn resolve_config_structure(entry_config_path: &PathBuf, configs: Vec<Config>) -> Result<ConfigStructure, String> {
+    let mut path_map: HashMap<PathBuf, Config> = HashMap::new();
+
+    for config in configs {
+        path_map.insert(config.clone().file_path, config);
+    }
+
+    let config_structure: ConfigStructure = construct_config_structure(entry_config_path, &path_map)?;
+
+    Ok(config_structure)
+}
+
+fn construct_config_structure(config_path: &PathBuf, config_path_map: &HashMap<PathBuf, Config>) -> Result<ConfigStructure, String> {
+    let config = config_path_map.get(config_path).ok_or("Unknown config path")?;
+
+    let paths: Vec<PathBuf> = config_path_map.keys().cloned().collect();
+    let Config { directories, .. } = config;
+    let config_directory: &Path = config_path.parent().unwrap();
+    let mut child_paths: Vec<PathBuf> = vec![];
+
+    for directory in directories {
+        let path_pattern: PathBuf = get_config_glob_pattern(config_directory, &directory);
+
+        let pattern = match Glob::new(path_pattern.to_str().unwrap()) {
+            Ok(pattern) => pattern,
+            Err(err) => return Err(format!("Failed to create glob pattern: {:?}", err)),
+        };
+        let mut builder = GlobSetBuilder::new();
+        builder.add(pattern);
+        let glob_set = builder.build().unwrap();
+
+        for path in &paths {
+            if glob_set.is_match(path) {
+                child_paths.push(path.to_path_buf());
+            }
+        }
+    }
+
+    let config_structure = ConfigStructure {
+        config: config.clone(),
+        children: child_paths
+            .iter()
+            .map(|path| construct_config_structure(path, config_path_map).unwrap())
+            .collect()
+    };
+
+    Ok(config_structure)
+}
+
+#[derive(Debug, Clone)]
+pub enum TaskType {
+    SHELL
+}
+
+#[derive(Debug, Clone)]
+#[allow(dead_code)]
+pub struct ConfigTask {
+    pub(crate) task_type: TaskType,
+    pub(crate) content: String
+}
+
+type ConfigTasks = HashMap<String, ConfigTask>;
+type ConfigDirectories = Vec<String>;
+
+#[derive(Debug, Clone, Default, Deserialize)]
+pub enum TaskEngine {
+    #[serde(rename = "composer")]
+    COMPOSER,
+    #[serde(rename = "npm")]
+    NPM,
+    #[serde(rename = "yarn")]
+    YARN,
+    #[serde(rename = "pnpm")]
+    PNPM,
+    #[serde(rename = "none")]
+    #[default]
+    NONE
+}
+
+#[derive(Debug, Clone)]
+#[allow(dead_code)]
+pub struct Config {
+    pub(crate)name: String,
+    pub(crate)task_engine: TaskEngine,
+    pub(crate)tasks: HashMap<String, ConfigTask>,
+    pub(crate)file_path: PathBuf,
+    pub(crate)dir_path: PathBuf,
+    pub(crate)directories: ConfigDirectories,
+}
+
+pub fn parse_config_files(config_files: Vec<ConfigFile>) -> Result<Vec<Config>, String> {
+    let mut configs: Vec<Config> = vec![];
+
+    for config_file in config_files {
+        let config = parse_config_file(config_file)?;
+        configs.push(config);
+    }
+
+    Ok(configs)
+}
+
+fn parse_config_file(config_file: ConfigFile) -> Result<Config, String> {
+    let ConfigFile { name, tasks: config_file_tasks, __file_path: file_path, __dir_path: dir_path, directories, task_engine } = config_file;
+
+    let tasks: ConfigTasks = match task_engine {
+        TaskEngine::COMPOSER => parse_composer_tasks(&dir_path)?,
+        TaskEngine::NPM => parse_node_tasks(&dir_path, "npm")?,
+        TaskEngine::YARN => parse_node_tasks(&dir_path, "yarn")?,
+        TaskEngine::PNPM => parse_node_tasks(&dir_path, "pnpm")?,
+        TaskEngine::NONE => parse_config_tasks(config_file_tasks)?,
+    };
+
+    let config: Config = Config { name, tasks, file_path, dir_path, directories, task_engine };
+
+    Ok(config)
+}
+
+#[derive(Debug, Clone, Deserialize, Default)]
+struct PackageJsonFile {
+    #[serde(default)]
+    scripts: HashMap<String, String>,
+}
+
+fn parse_node_tasks(dir_path: &PathBuf, prefix: &str) -> Result<ConfigTasks, String> {
+    let mut file_path = dir_path.clone();
+    file_path.push("package.json");
+    let content = read_file_content(file_path)?;
+
+    let package_json: PackageJsonFile = serde_json::from_str(&content).expect(format!("Failed to package.json from \"{:?}\"", dir_path).as_str());
+
+    let mut config_tasks: ConfigTasks = HashMap::new();
+    for key in package_json.scripts.keys() {
+        config_tasks.insert(key.clone(), ConfigTask {
+            task_type: TaskType::SHELL,
+            content: format!("{:?} run {:?}", prefix, key)
+        });
+    }
+
+    Ok(config_tasks)
+}
+
+#[derive(Debug, Clone, Deserialize)]
+#[serde(untagged)]
+enum ComposerJsonScriptValue {
+    Single(String),
+    Multiple(Vec<String>),
+}
+
+#[derive(Debug, Clone, Deserialize, Default)]
+struct ComposerJsonFile {
+    #[serde(default)]
+    scripts: HashMap<String, ComposerJsonScriptValue>,
+}
+
+fn parse_composer_tasks(dir_path: &PathBuf) -> Result<ConfigTasks, String> {
+    let mut file_path = dir_path.clone();
+    file_path.push("composer.json");
+    let content = read_file_content(file_path)?;
+
+    let package_json: ComposerJsonFile = serde_json::from_str(&content).expect(format!("Failed to composer.json from \"{:?}\"", dir_path).as_str());
+
+    let mut config_tasks: ConfigTasks = HashMap::new();
+    for key in package_json.scripts.keys() {
+        config_tasks.insert(key.clone(), ConfigTask {
+            task_type: TaskType::SHELL,
+            content: format!("composer run {:?}", key)
+        });
+    }
+
+    Ok(config_tasks)
+}
+
+fn parse_config_tasks(tasks: ConfigFileTasks) -> Result<ConfigTasks, String> {
+    let mut config_tasks: ConfigTasks = HashMap::new();
+
+    for (key, value) in tasks {
+        let config_task: ConfigTask = ConfigTask {
+            task_type: TaskType::SHELL,
+            content: value
+        };
+
+        config_tasks.insert(key, config_task);
+    }
+
+    Ok(config_tasks)
+}
+
+pub fn read_config_files(paths: Vec<PathBuf>) -> Result<Vec<ConfigFile>, String> {
+    let mut configs_files: Vec<ConfigFile> = vec![];
+
+    for path in paths {
+        let config_file = read_config_file(path)?;
+        configs_files.push(config_file);
+    }
+
+    Ok(configs_files)
+}
+
+pub fn discover_config_paths(path: &PathBuf) -> Result<Vec<PathBuf>, String> {
+    let mut found_config_paths: Vec<PathBuf> = vec![path.clone()];
+
+    // Read config
+    let mut path_stack: Vec<PathBuf> = vec![path.clone()];
+    while !path_stack.is_empty() {
+        let ConfigFile { directories, __file_path: _file_path, .. } = read_config_file(path_stack.pop().unwrap())?;
+
+        // Extract directories
+        let config_directory = _file_path.parent().ok_or("Failed to get parent directory")?;
+        for directory in directories {
+            let pattern = get_config_glob_pattern(config_directory, &directory);
+
+            // Find config files based on the pattern in the directories value
+            let pattern_string: &str = pattern.to_str().unwrap();
+            for pattern_results in glob::glob(pattern_string).map_err(|e| format!("Failed to read glob pattern: {}", e))? {
+                if let Ok(found_config_path) = pattern_results {
+                    // Only add if the path was not already processed, preventing loops.
+                    if !found_config_paths.contains(&found_config_path) {
+                        found_config_paths.push(found_config_path.clone());
+                        path_stack.push(found_config_path.clone());
+                    }
+                }
+            }
+        }
+    }
+
+    Ok(found_config_paths)
+}
+
+fn get_config_glob_pattern(root_path: &Path, glob_pattern: &String) -> PathBuf {
+    let mut pattern: PathBuf = root_path.to_path_buf();
+
+    pattern.push(glob_pattern);
+    if !pattern.ends_with(".yaml") {
+        pattern.push("rask.yaml");
+    }
+
+    pattern
+}
+
+fn read_file_content (path: PathBuf) -> Result<String, String> {
+    match read_to_string(path) {
+        Ok(content) => Ok(content),
+        Err(err) => Err(format!("Failed to read file: {}", err)),
+    }
+}
+
+type ConfigFileTasks = HashMap<String, String>;
+
+#[derive(Debug, Deserialize, Default)]
+pub struct ConfigFile {
+    pub(crate) name: String,
+    #[serde(default)]
+    pub(crate) task_engine: TaskEngine,
+    #[serde(default)]
+    pub(crate) directories: ConfigDirectories,
+    #[serde(default)]
+    pub(crate) tasks: ConfigFileTasks,
+    // The following fields are not part of the yaml file.
+    #[serde(default)]
+    __file_path: PathBuf,
+    #[serde(default)]
+    __dir_path: PathBuf,
+}
+
+fn read_config_file(path: PathBuf) -> Result<ConfigFile, String> {
+    let content = read_file_content(path.clone())?;
+
+    let mut config_file: ConfigFile = serde_yaml::from_str(&content).expect(format!("Failed to parse YAML from \"{:?}\"", path).as_str());
+
+    config_file.__file_path = path.clone();
+    config_file.__dir_path = path.parent().unwrap().to_path_buf();
+
+    Ok(config_file)
+}
+
+pub fn resolve_config_path<P: AsRef<Path> + Debug + Clone + Copy>(path: P) -> Result<PathBuf, String> {
+    let full_path = match canonicalize(path) {
+        Ok(full_path) => full_path,
+        Err(_) => return Err(format!("Target does not exists: {:?}", path.clone()))
+    };
+
+    if full_path.is_dir() {
+        let config_file = find_config_file(full_path)?;
+        return Ok(config_file)
+    }
+
+    Ok(full_path)
+}
+
+const CONFIG_FILENAMES: [&str; 1] = ["rask.yaml"];
+
+fn find_config_file(directory_path: PathBuf) -> Result<PathBuf, String> {
+    if !directory_path.is_dir() {
+        return Err(format!("\"{:?}\" is not a directory", directory_path))
+    }
+
+    for filename in CONFIG_FILENAMES {
+        let mut possible_config_file = directory_path.clone();
+        possible_config_file.push(filename);
+        match possible_config_file.exists() {
+            true => return Ok(possible_config_file),
+            false => {}
+        }
+    }
+
+    Err(format!("Unable to find a config file (\"{:?}\") in {:?}", CONFIG_FILENAMES, directory_path))
+}

src/utils/mod.rs

@@ -0,0 +1 @@
+pub mod config;