1#![doc(
61 html_logo_url = "https://raw.githubusercontent.com/kjanat/runner/d876a0b9716806d92e07f5d5560b022b6158ecd5/branding/icon.svg",
62 html_favicon_url = "https://raw.githubusercontent.com/kjanat/runner/d876a0b9716806d92e07f5d5560b022b6158ecd5/branding/icon.svg"
63)]
64
65pub(crate) mod chain;
66mod cli;
67mod cmd;
68mod complete;
69mod config;
70mod detect;
71mod resolver;
72mod schema;
73mod tool;
74mod types;
75
76use std::ffi::OsString;
77use std::io::IsTerminal;
78use std::path::{Path, PathBuf};
79
80use anyhow::{Result, bail};
81use clap::{CommandFactory, FromArgMatches};
82use colored::Colorize;
83
84use resolver::ResolveError;
85
86#[cfg(feature = "schema")]
89#[must_use]
90pub fn config_schema() -> schemars::Schema {
91 schemars::schema_for!(config::RunnerConfig)
92}
93
94#[must_use]
105pub fn exit_code_for_error(err: &anyhow::Error) -> i32 {
106 if err.downcast_ref::<ResolveError>().is_some() {
107 2
108 } else {
109 1
110 }
111}
112
113const REPOSITORY_URL: &str = env!("CARGO_PKG_REPOSITORY");
114const VERSION: &str = clap::crate_version!();
115
116pub fn run_from_env() -> Result<i32> {
130 let bin = bin_name_from_arg0(&std::env::args_os().next().unwrap_or_default())
131 .unwrap_or_else(|| "runner".to_string());
132 clap_complete::CompleteEnv::with_factory(move || {
133 configure_cli_command(cli::Cli::command(), true)
134 .name(bin.clone())
135 .bin_name(bin.clone())
136 })
137 .shells(complete::SHELLS)
138 .complete();
139 run_from_args(std::env::args_os())
140}
141
142pub fn run_from_args<I, T>(args: I) -> Result<i32>
154where
155 I: IntoIterator<Item = T>,
156 T: Into<OsString> + Clone,
157{
158 let cwd = std::env::current_dir()?;
159 run_in_dir(args, &cwd)
160}
161
162pub fn run_in_dir<I, T>(args: I, dir: &Path) -> Result<i32>
174where
175 I: IntoIterator<Item = T>,
176 T: Into<OsString> + Clone,
177{
178 let args: Vec<OsString> = args.into_iter().map(Into::into).collect();
179
180 if requests_version(&args) {
181 println!("{}", version_line(&args, std::io::stdout().is_terminal()));
182 return Ok(0);
183 }
184
185 let cli = match parse_cli(args) {
186 Ok(cli) => cli,
187 Err(err) => return render_clap_error(&err),
188 };
189 #[cfg(feature = "lsp")]
192 if matches!(cli.command.as_ref(), Some(cli::Command::Lsp)) {
193 return cmd::lsp::run();
194 }
195 let project_dir = resolve_project_dir(
196 configured_project_dir(
197 cli.global.project_dir.as_deref(),
198 std::env::var_os("RUNNER_DIR").as_deref(),
199 )
200 .as_deref(),
201 dir,
202 )?;
203 dispatch(cli, &project_dir)
204}
205
206fn parse_cli<I, T>(args: I) -> Result<cli::Cli, clap::Error>
207where
208 I: IntoIterator<Item = T>,
209 T: Into<OsString> + Clone,
210{
211 let args: Vec<OsString> = args.into_iter().map(Into::into).collect();
212
213 let mut command = configure_cli_command(cli::Cli::command(), std::io::stdout().is_terminal());
214 if let Some(bin_name) = args.first().and_then(bin_name_from_arg0) {
215 command = command.name(bin_name.clone()).bin_name(bin_name);
216 }
217 command = shorten_help_subcommand(command);
218
219 let matches = command.try_get_matches_from(args)?;
220 cli::Cli::from_arg_matches(&matches)
221}
222
223fn shorten_help_subcommand(mut command: clap::Command) -> clap::Command {
232 command.build();
233 if command.find_subcommand("help").is_some() {
234 command.mut_subcommand("help", |help| help.about("Print help for a subcommand"))
235 } else {
236 command
237 }
238}
239
240pub fn run_alias_from_env() -> Result<i32> {
261 let bin = bin_name_from_arg0(&std::env::args_os().next().unwrap_or_default())
262 .unwrap_or_else(|| "run".to_string());
263 clap_complete::CompleteEnv::with_factory(move || {
264 configure_cli_command(cli::RunAliasCli::command(), true)
265 .name(bin.clone())
266 .bin_name(bin.clone())
267 })
268 .shells(complete::SHELLS)
269 .complete();
270 run_alias_from_args(std::env::args_os())
271}
272
273pub fn run_alias_from_args<I, T>(args: I) -> Result<i32>
283where
284 I: IntoIterator<Item = T>,
285 T: Into<OsString> + Clone,
286{
287 let cwd = std::env::current_dir()?;
288 run_alias_in_dir(args, &cwd)
289}
290
291pub fn run_alias_in_dir<I, T>(args: I, dir: &Path) -> Result<i32>
301where
302 I: IntoIterator<Item = T>,
303 T: Into<OsString> + Clone,
304{
305 let args: Vec<OsString> = args.into_iter().map(Into::into).collect();
306
307 if requests_version(&args) {
308 println!("{}", version_line(&args, std::io::stdout().is_terminal()));
309 return Ok(0);
310 }
311
312 let cli = match parse_run_alias_cli(args.clone()) {
313 Ok(cli) => cli,
314 Err(err) => {
321 return match alias_builtin_request(&err) {
322 Some(AliasBuiltin::Help) => print_run_alias_help(&args),
323 Some(AliasBuiltin::Version) => {
324 println!("{}", version_line(&args, std::io::stdout().is_terminal()));
325 Ok(0)
326 }
327 None => render_clap_error(&err),
328 };
329 }
330 };
331
332 let project_dir = resolve_project_dir(
333 configured_project_dir(
334 cli.global.project_dir.as_deref(),
335 std::env::var_os("RUNNER_DIR").as_deref(),
336 )
337 .as_deref(),
338 dir,
339 )?;
340 dispatch_run_alias(cli, &project_dir)
341}
342
343enum AliasBuiltin {
345 Help,
346 Version,
347}
348
349fn alias_builtin_request(err: &clap::Error) -> Option<AliasBuiltin> {
359 use clap::error::{ContextKind, ContextValue, ErrorKind};
360
361 if err.kind() != ErrorKind::UnknownArgument {
362 return None;
363 }
364 match err.get(ContextKind::InvalidArg) {
365 Some(ContextValue::String(arg)) => match arg.as_str() {
366 "--help" | "-h" => Some(AliasBuiltin::Help),
367 "--version" | "-V" => Some(AliasBuiltin::Version),
368 _ => None,
369 },
370 _ => None,
371 }
372}
373
374fn print_run_alias_help(args: &[OsString]) -> Result<i32> {
382 let mut command =
383 configure_cli_command(cli::RunAliasCli::command(), std::io::stdout().is_terminal());
384 if let Some(bin_name) = args.first().and_then(bin_name_from_arg0) {
385 command = command.name(bin_name.clone()).bin_name(bin_name);
386 }
387 command.print_help()?;
388 Ok(0)
389}
390
391fn parse_run_alias_cli<I, T>(args: I) -> Result<cli::RunAliasCli, clap::Error>
392where
393 I: IntoIterator<Item = T>,
394 T: Into<OsString> + Clone,
395{
396 let args: Vec<OsString> = args.into_iter().map(Into::into).collect();
397
398 let mut command =
399 configure_cli_command(cli::RunAliasCli::command(), std::io::stdout().is_terminal());
400 if let Some(bin_name) = args.first().and_then(bin_name_from_arg0) {
401 command = command.name(bin_name.clone()).bin_name(bin_name);
402 }
403
404 let matches = command.try_get_matches_from(args)?;
405 cli::RunAliasCli::from_arg_matches(&matches)
406}
407
408fn dispatch_run_alias(cli: cli::RunAliasCli, dir: &Path) -> Result<i32> {
434 let bare = cli.task.is_none() && !cli.mode.sequential && !cli.mode.parallel;
435 let command = if bare {
436 None
437 } else {
438 Some(cli::Command::Run {
439 task: cli.task,
440 args: cli.args,
441 mode: cli.mode,
442 failure: cli.failure,
443 })
444 };
445 dispatch(
446 cli::Cli {
447 global: cli.global,
448 command,
449 },
450 dir,
451 )
452}
453
454#[must_use]
474pub fn bin_name_from_arg0(arg0: &OsString) -> Option<String> {
475 let name = Path::new(arg0)
476 .file_name()
477 .map(|segment| segment.to_string_lossy().into_owned())?;
478
479 let trimmed = strip_exe_suffix(&name);
480 (!trimmed.is_empty()).then(|| trimmed.to_string())
481}
482
483fn strip_exe_suffix(name: &str) -> &str {
490 const SUFFIX: &str = ".exe";
491 if name.len() > SUFFIX.len()
492 && name.is_char_boundary(name.len() - SUFFIX.len())
493 && name[name.len() - SUFFIX.len()..].eq_ignore_ascii_case(SUFFIX)
494 {
495 &name[..name.len() - SUFFIX.len()]
496 } else {
497 name
498 }
499}
500
501#[must_use]
514pub fn configure_cli_command(command: clap::Command, stdout_is_terminal: bool) -> clap::Command {
515 command.before_help(help_byline(stdout_is_terminal))
516}
517
518#[must_use]
537pub fn help_byline(stdout_is_terminal: bool) -> String {
538 let name = env!("RUNNER_AUTHOR_NAME");
539 let rendered = if stdout_is_terminal {
540 option_env!("RUNNER_AUTHOR_EMAIL").map_or_else(
541 || name.to_string(),
542 |mail| osc8_link(name, &format!("mailto:{mail}")),
543 )
544 } else {
545 name.to_string()
546 };
547 format!("by {rendered}")
548}
549
550#[must_use]
574pub fn requests_version(args: &[OsString]) -> bool {
575 if args.len() != 2 {
576 return false;
577 }
578
579 let flag = args[1].to_string_lossy();
580 flag == "--version" || flag == "-V"
581}
582
583fn version_line(args: &[OsString], stdout_is_terminal: bool) -> String {
584 let bin = args
585 .first()
586 .and_then(bin_name_from_arg0)
587 .unwrap_or_else(|| "runner".to_string());
588
589 if !stdout_is_terminal {
590 return format!("{bin} {VERSION}");
591 }
592
593 format!(
594 "{} {}",
595 osc8_link(&bin, REPOSITORY_URL),
596 osc8_link(VERSION, &release_url(VERSION))
597 )
598}
599
600fn release_url(version: &str) -> String {
601 format!("{REPOSITORY_URL}/releases/tag/v{version}")
602}
603
604fn osc8_link(label: &str, url: &str) -> String {
605 format!("\u{1b}]8;;{url}\u{1b}\\{label}\u{1b}]8;;\u{1b}\\")
606}
607
608fn configured_project_dir(
609 project_dir: Option<&Path>,
610 env_dir: Option<&std::ffi::OsStr>,
611) -> Option<PathBuf> {
612 project_dir
613 .map(Path::to_path_buf)
614 .or_else(|| env_dir.map(PathBuf::from))
615}
616
617pub(crate) fn expand_tilde(path: &Path) -> PathBuf {
624 expand_tilde_with(path, home_dir().as_deref())
625}
626
627fn expand_tilde_with(path: &Path, home: Option<&Path>) -> PathBuf {
628 let Some(home) = home else {
629 return path.to_path_buf();
630 };
631
632 match path.strip_prefix("~") {
633 Ok(rest) if rest.as_os_str().is_empty() => home.to_path_buf(),
635 Ok(rest) => home.join(rest),
637 Err(_) => path.to_path_buf(),
639 }
640}
641
642fn home_dir() -> Option<PathBuf> {
643 let var = if cfg!(windows) { "USERPROFILE" } else { "HOME" };
644 std::env::var_os(var)
645 .filter(|v| !v.is_empty())
646 .map(PathBuf::from)
647}
648
649fn resolve_project_dir(project_dir: Option<&Path>, cwd: &Path) -> Result<PathBuf> {
650 let project_dir = project_dir.map(expand_tilde);
651 let dir = match project_dir.as_deref() {
652 Some(path) if path.is_absolute() => path.to_path_buf(),
653 Some(path) => cwd.join(path),
654 None => cwd.to_path_buf(),
655 };
656
657 if !dir.exists() {
658 bail!("project dir does not exist: {}", dir.display());
659 }
660 if !dir.is_dir() {
661 bail!("project dir is not a directory: {}", dir.display());
662 }
663
664 Ok(dir)
665}
666
667fn render_clap_error(err: &clap::Error) -> Result<i32> {
668 let exit_code = err.exit_code();
669 err.print()?;
670 Ok(exit_code)
671}
672
673fn dispatch_install_chain(
674 ctx: &types::ProjectContext,
675 overrides: &resolver::ResolutionOverrides,
676 frozen: bool,
677 mode: cli::ChainModeFlags,
678 tasks: &[String],
679) -> Result<i32> {
680 let items = chain::parse::parse_task_list(tasks)?;
681
682 if !mode.parallel {
683 let mut all = vec![chain::ChainItem::install(frozen)];
687 all.extend(items);
688 return chain::exec::run_chain(
689 ctx,
690 overrides,
691 &chain::Chain {
692 mode: chain::ChainMode::Sequential,
693 items: all,
694 failure: overrides.failure_policy,
695 },
696 );
697 }
698
699 for task in tasks {
708 cmd::run::precheck_task(ctx, overrides, task)?;
709 }
710 let started = std::time::Instant::now();
717 let install_code = cmd::install(ctx, overrides, frozen)?;
718 cmd::emit_task_timing(overrides, "install", started.elapsed(), install_code);
719 let keep_going = matches!(overrides.failure_policy, chain::FailurePolicy::KeepGoing);
720 if install_code != 0 && !keep_going {
721 return Ok(install_code);
722 }
723 let task_code = chain::exec::run_chain(
724 ctx,
725 overrides,
726 &chain::Chain {
727 mode: chain::ChainMode::Parallel,
728 items,
729 failure: overrides.failure_policy,
730 },
731 )?;
732 Ok(if install_code != 0 {
735 install_code
736 } else {
737 task_code
738 })
739}
740
741fn dispatch_run(
742 ctx: &types::ProjectContext,
743 overrides: &resolver::ResolutionOverrides,
744 task: Option<String>,
745 args: Vec<String>,
746 mode: cli::ChainModeFlags,
747) -> Result<i32> {
748 if mode.sequential || mode.parallel {
749 let chain_mode = if mode.parallel {
750 chain::ChainMode::Parallel
751 } else {
752 chain::ChainMode::Sequential
753 };
754 let mut positionals: Vec<String> = Vec::new();
755 if let Some(t) = task {
756 positionals.push(t);
757 }
758 positionals.extend(args);
759 let items = chain::parse::parse_task_list(&positionals)?;
760 let c = chain::Chain {
761 mode: chain_mode,
762 items,
763 failure: overrides.failure_policy,
764 };
765 return chain::exec::run_chain(ctx, overrides, &c);
766 }
767 let Some(task) = task.as_deref() else {
768 bail!(
769 "task name required (drop -s/-p for single-task mode or supply at least one task name)"
770 );
771 };
772 if args.is_empty()
773 && let Some(code) = run_path_builtin_fallback(ctx, overrides, task)?
774 {
775 return Ok(code);
776 }
777 cmd::run(ctx, overrides, task, &args, None)
778}
779
780fn run_path_builtin_fallback(
798 ctx: &types::ProjectContext,
799 overrides: &resolver::ResolutionOverrides,
800 name: &str,
801) -> Result<Option<i32>> {
802 if has_task(ctx, name) {
803 return Ok(None);
804 }
805 let code = match name {
806 "install" => cmd::install(ctx, overrides, false)?,
807 "clean" => {
808 cmd::clean(ctx, false, false)?;
809 0
810 }
811 "list" | "info" => {
814 cmd::list(ctx, overrides, false, false, None)?;
815 0
816 }
817 "completions" => {
818 cmd::completions(None, None)?;
819 0
820 }
821 _ => return Ok(None),
822 };
823 Ok(Some(code))
824}
825
826fn schema_version_for_json(json: bool, requested: Option<u32>) -> Result<u32> {
831 if json {
832 schema::validate_schema_version(requested.unwrap_or(schema::SCHEMA_VERSION))
833 } else {
834 Ok(schema::SCHEMA_VERSION)
835 }
836}
837
838fn build_overrides(
844 cli: &cli::Cli,
845 loaded_config: Option<&config::LoadedConfig>,
846) -> Result<resolver::ResolutionOverrides> {
847 let (cli_keep_going, cli_kill_on_fail) = match cli.command.as_ref() {
848 Some(cli::Command::Run { failure, .. } | cli::Command::Install { failure, .. }) => {
849 (failure.keep_going, failure.kill_on_fail)
850 }
851 _ => (false, false),
852 };
853 let mut overrides = resolver::ResolutionOverrides::from_cli_and_env(
854 cli.global.pm_override.as_deref(),
855 cli.global.runner_override.as_deref(),
856 cli.global.fallback.as_deref(),
857 cli.global.on_mismatch.as_deref(),
858 resolver::DiagnosticFlags {
859 no_warnings: cli.global.no_warnings,
860 quiet: cli.global.quiet,
861 explain: cli.global.explain,
862 },
863 cli::ChainFailureFlags {
864 keep_going: cli_keep_going,
865 kill_on_fail: cli_kill_on_fail,
866 },
867 loaded_config,
868 )?;
869 apply_script_policy_flags(cli, &mut overrides);
870 Ok(overrides)
871}
872
873const fn apply_script_policy_flags(cli: &cli::Cli, overrides: &mut resolver::ResolutionOverrides) {
882 if let Some(cli::Command::Install {
883 no_scripts,
884 scripts,
885 ..
886 }) = cli.command.as_ref()
887 {
888 if *no_scripts {
889 overrides.script_policy = resolver::ScriptPolicy::Deny;
890 } else if *scripts {
891 overrides.script_policy = resolver::ScriptPolicy::Allow;
892 }
893 }
894}
895
896fn build_overrides_lenient(
901 cli: &cli::Cli,
902 loaded_config: Option<&config::LoadedConfig>,
903) -> Result<(resolver::ResolutionOverrides, Vec<types::DetectionWarning>)> {
904 let (cli_keep_going, cli_kill_on_fail) = match cli.command.as_ref() {
905 Some(cli::Command::Run { failure, .. } | cli::Command::Install { failure, .. }) => {
906 (failure.keep_going, failure.kill_on_fail)
907 }
908 _ => (false, false),
909 };
910 resolver::ResolutionOverrides::from_cli_and_env_lenient(
911 cli.global.pm_override.as_deref(),
912 cli.global.runner_override.as_deref(),
913 cli.global.fallback.as_deref(),
914 cli.global.on_mismatch.as_deref(),
915 resolver::DiagnosticFlags {
916 no_warnings: cli.global.no_warnings,
917 quiet: cli.global.quiet,
918 explain: cli.global.explain,
919 },
920 cli::ChainFailureFlags {
921 keep_going: cli_keep_going,
922 kill_on_fail: cli_kill_on_fail,
923 },
924 loaded_config,
925 )
926}
927
928fn dispatch_overrides(
934 cli: &cli::Cli,
935 loaded_config: Option<&config::LoadedConfig>,
936 ctx: &mut types::ProjectContext,
937) -> Result<resolver::ResolutionOverrides> {
938 match build_overrides(cli, loaded_config) {
939 Ok(overrides) => Ok(overrides),
940 Err(_) if matches!(cli.command, Some(cli::Command::Doctor { .. })) => {
941 let (overrides, env_warnings) = build_overrides_lenient(cli, loaded_config)?;
942 ctx.warnings.extend(env_warnings);
943 Ok(overrides)
944 }
945 Err(e) => Err(e),
946 }
947}
948
949fn dispatch(cli: cli::Cli, dir: &Path) -> Result<i32> {
950 let mut ctx = detect::detect(dir);
951 let loaded_config = match config::load(dir) {
958 Ok(loaded) => loaded,
959 Err(_) if matches!(cli.command, Some(cli::Command::Config { .. })) => None,
960 Err(e) => return Err(e),
961 };
962 if let Some(loaded) = &loaded_config {
963 ctx.warnings.extend(loaded.warnings.iter().cloned());
964 }
965 let overrides = dispatch_overrides(&cli, loaded_config.as_ref(), &mut ctx)?;
966
967 match cli.command {
968 None => cmd::info(&ctx, &overrides, false).map(|()| 0),
969 Some(cli::Command::Info { json }) => {
973 eprintln!(
974 "{} `runner info` is deprecated; use `runner list`",
975 "warn:".yellow().bold(),
976 );
977 if actions_rs::env::is_github_actions() {
983 eprintln!(
984 "::warning title=Deprecation::`runner info` is deprecated; use `runner list`"
985 );
986 }
987 schema_version_for_json(json, cli.global.schema_version)?;
988 cmd::list(&ctx, &overrides, false, json, None)?;
989 Ok(0)
990 }
991 Some(cli::Command::Run {
992 task, args, mode, ..
993 }) => dispatch_run(&ctx, &overrides, task, args, mode),
994 Some(cli::Command::External(args)) => {
995 if args.is_empty() {
996 cmd::info(&ctx, &overrides, false)?;
997 Ok(0)
998 } else {
999 cmd::run(&ctx, &overrides, &args[0], &args[1..], None)
1000 }
1001 }
1002 Some(cli::Command::Install {
1003 frozen,
1004 tasks,
1005 mode,
1006 ..
1007 }) if !tasks.is_empty() => dispatch_install_chain(&ctx, &overrides, frozen, mode, &tasks),
1008 Some(cli::Command::Install {
1009 frozen,
1010 mode,
1011 failure,
1012 ..
1013 }) => {
1014 if mode.sequential || mode.parallel || failure.keep_going || failure.kill_on_fail {
1018 eprintln!(
1019 "{} chain flags (-s/-p/-k/-K) have no effect without post-install task names",
1020 "note:".dimmed(),
1021 );
1022 }
1023 cmd::install(&ctx, &overrides, frozen)
1024 }
1025 Some(cli::Command::Clean {
1026 yes,
1027 include_framework,
1028 }) => {
1029 cmd::clean(&ctx, yes, include_framework)?;
1030 Ok(0)
1031 }
1032 Some(cli::Command::List { raw, json, source }) => {
1033 schema_version_for_json(json, cli.global.schema_version)?;
1034 cmd::list(&ctx, &overrides, raw, json, source.as_deref())?;
1035 Ok(0)
1036 }
1037 Some(cli::Command::Completions { shell, output }) => {
1038 cmd::completions(shell, output.as_deref())?;
1039 Ok(0)
1040 }
1041 #[cfg(feature = "man")]
1042 Some(cli::Command::Man { output }) => dispatch_man(output.as_deref()),
1043 #[cfg(feature = "schema")]
1044 Some(cli::Command::Schema { all, output }) => dispatch_schema(all, output.as_deref()),
1045 #[cfg(feature = "lsp")]
1046 Some(cli::Command::Lsp) => cmd::lsp::run(), Some(cli::Command::Doctor { json }) => {
1048 schema_version_for_json(json, cli.global.schema_version)?;
1049 cmd::doctor(&ctx, &overrides, json)?;
1050 Ok(0)
1051 }
1052 Some(cli::Command::Config { action }) => cmd::config(dir, action),
1053 Some(cli::Command::Why { task, json }) => {
1054 schema_version_for_json(json, cli.global.schema_version)?;
1055 cmd::why(&ctx, &overrides, &task, json)?;
1056 Ok(0)
1057 }
1058 }
1059}
1060
1061#[cfg(feature = "man")]
1062fn dispatch_man(output: Option<&Path>) -> Result<i32> {
1063 match output {
1064 Some(dir) => cmd::write_man_pages(dir)?,
1065 None => cmd::write_runner_page_to_stdout()?,
1066 }
1067 Ok(0)
1068}
1069
1070#[cfg(feature = "schema")]
1071fn dispatch_schema(all: bool, output: Option<&Path>) -> Result<i32> {
1072 cmd::write_schema(all, output)?;
1073 Ok(0)
1074}
1075
1076fn has_task(ctx: &types::ProjectContext, name: &str) -> bool {
1078 ctx.tasks.iter().any(|task| task.name == name)
1079}
1080
1081#[cfg(test)]
1082mod tests {
1083 use std::ffi::OsString;
1084 use std::fs;
1085 use std::path::{Path, PathBuf};
1086
1087 use super::{
1088 AliasBuiltin, VERSION, alias_builtin_request, bin_name_from_arg0, configured_project_dir,
1089 exit_code_for_error, expand_tilde_with, has_task, parse_cli, parse_run_alias_cli,
1090 release_url, requests_version, resolve_project_dir, run_alias_in_dir, run_in_dir,
1091 version_line,
1092 };
1093 use crate::cli;
1094 use crate::resolver::ResolveError;
1095 use crate::tool::test_support::TempDir;
1096 use crate::types::{Ecosystem, ProjectContext, Task, TaskSource};
1097
1098 #[test]
1099 fn exit_code_for_resolve_error_is_two() {
1100 let err: anyhow::Error = ResolveError::NoSignalsFound {
1101 ecosystem: Ecosystem::Node,
1102 soft: false,
1103 }
1104 .into();
1105
1106 assert_eq!(exit_code_for_error(&err), 2);
1107 }
1108
1109 #[test]
1110 fn exit_code_for_generic_error_is_one() {
1111 let err = anyhow::anyhow!("generic boom");
1112
1113 assert_eq!(exit_code_for_error(&err), 1);
1114 }
1115
1116 #[test]
1117 fn help_returns_zero_instead_of_exiting() {
1118 let code = run_in_dir(["runner", "--help"], Path::new("."))
1119 .expect("help should return an exit code");
1120
1121 assert_eq!(code, 0);
1122 }
1123
1124 #[test]
1125 fn invalid_args_return_non_zero_instead_of_exiting() {
1126 let code = run_in_dir(["runner", "--definitely-invalid"], Path::new("."))
1127 .expect("parse errors should return an exit code");
1128
1129 assert_ne!(code, 0);
1130 }
1131
1132 #[test]
1133 fn version_returns_zero_instead_of_exiting() {
1134 let code = run_in_dir(["runner", "--version"], Path::new("."))
1135 .expect("version should return an exit code");
1136
1137 assert_eq!(code, 0);
1138 }
1139
1140 #[test]
1141 fn requests_version_detects_top_level_version_flags() {
1142 assert!(requests_version(&[
1143 OsString::from("runner"),
1144 OsString::from("--version")
1145 ]));
1146 assert!(requests_version(&[
1147 OsString::from("runner"),
1148 OsString::from("-V")
1149 ]));
1150 assert!(!requests_version(&[
1151 OsString::from("runner"),
1152 OsString::from("info"),
1153 OsString::from("--version"),
1154 ]));
1155 }
1156
1157 #[test]
1158 fn release_url_points_to_version_tag() {
1159 assert_eq!(
1160 release_url(VERSION),
1161 format!("https://github.com/kjanat/runner/releases/tag/v{VERSION}")
1162 );
1163 }
1164
1165 #[test]
1166 fn version_line_wraps_bin_and_version_with_separate_links() {
1167 let line = version_line(&[OsString::from("runner")], true);
1168
1169 assert!(line.contains(
1170 "\u{1b}]8;;https://github.com/kjanat/runner\u{1b}\\runner\u{1b}]8;;\u{1b}\\"
1171 ));
1172 assert!(line.contains(&format!(
1173 "\u{1b}]8;;https://github.com/kjanat/runner/releases/tag/v{VERSION}\u{1b}\\{VERSION}\u{1b}]8;;\u{1b}\\"
1174 )));
1175 }
1176
1177 #[test]
1178 fn resolve_project_dir_uses_cwd_when_not_overridden() {
1179 let cwd = TempDir::new("runner-project-dir-default");
1180
1181 assert_eq!(
1182 resolve_project_dir(None, cwd.path()).expect("cwd should be accepted"),
1183 cwd.path()
1184 );
1185 }
1186
1187 #[test]
1188 fn resolve_project_dir_resolves_relative_paths_from_cwd() {
1189 let cwd = TempDir::new("runner-project-dir-cwd");
1190 fs::create_dir(cwd.path().join("child")).expect("child dir should be created");
1191
1192 let resolved = resolve_project_dir(Some(Path::new("child")), cwd.path())
1193 .expect("relative dir should resolve");
1194
1195 assert_eq!(resolved, cwd.path().join("child"));
1196 }
1197
1198 #[test]
1199 fn resolve_project_dir_rejects_missing_directories() {
1200 let cwd = TempDir::new("runner-project-dir-missing");
1201 let err = resolve_project_dir(Some(Path::new("missing")), cwd.path())
1202 .expect_err("missing dir should error");
1203
1204 assert!(err.to_string().contains("project dir does not exist"));
1205 }
1206
1207 #[test]
1208 fn expand_tilde_expands_leading_tilde_slash() {
1209 let home = Path::new("/home/example");
1210 assert_eq!(
1211 expand_tilde_with(Path::new("~/projects/recipe"), Some(home)),
1212 home.join("projects/recipe"),
1213 );
1214 }
1215
1216 #[test]
1217 fn expand_tilde_expands_bare_tilde() {
1218 let home = Path::new("/home/example");
1219 assert_eq!(expand_tilde_with(Path::new("~"), Some(home)), home);
1220 }
1221
1222 #[test]
1223 fn expand_tilde_leaves_other_paths_untouched() {
1224 let home = Path::new("/home/example");
1225 for raw in ["/abs/path", "relative/path", "~user/projects", "./~/foo"] {
1226 assert_eq!(
1227 expand_tilde_with(Path::new(raw), Some(home)),
1228 PathBuf::from(raw),
1229 "path {raw} should be unchanged",
1230 );
1231 }
1232 }
1233
1234 #[test]
1235 fn expand_tilde_without_home_is_noop() {
1236 assert_eq!(
1237 expand_tilde_with(Path::new("~/projects"), None),
1238 PathBuf::from("~/projects"),
1239 );
1240 }
1241
1242 #[test]
1243 fn resolve_project_dir_does_not_join_tilde_onto_cwd() {
1244 let home_var = if cfg!(windows) { "USERPROFILE" } else { "HOME" };
1250 if std::env::var_os(home_var).is_none_or(|v| v.is_empty()) {
1251 return;
1254 }
1255
1256 let cwd = TempDir::new("runner-project-dir-tilde");
1257 let err = resolve_project_dir(Some(Path::new("~/definitely-missing")), cwd.path())
1258 .expect_err("tilde dir should not resolve against cwd");
1259
1260 let message = err.to_string();
1261 assert!(message.contains("project dir does not exist"));
1262 let joined_tilde = cwd.path().join("~");
1265 assert!(
1266 !message.contains(&joined_tilde.display().to_string()),
1267 "tilde must not be joined onto cwd: {message}",
1268 );
1269 }
1270
1271 #[test]
1272 fn configured_project_dir_prefers_flag_over_env() {
1273 let dir = configured_project_dir(
1274 Some(Path::new("flag-dir")),
1275 Some(std::ffi::OsStr::new("env-dir")),
1276 )
1277 .expect("dir should be selected");
1278
1279 assert_eq!(dir, PathBuf::from("flag-dir"));
1280 }
1281
1282 #[test]
1283 fn configured_project_dir_falls_back_to_env() {
1284 let dir = configured_project_dir(None, Some(std::ffi::OsStr::new("env-dir")))
1285 .expect("env dir should be selected");
1286
1287 assert_eq!(dir, PathBuf::from("env-dir"));
1288 }
1289
1290 #[test]
1291 fn bin_name_from_arg0_uses_path_file_name() {
1292 let name = bin_name_from_arg0(&OsString::from("/tmp/run"));
1293
1294 assert_eq!(name.as_deref(), Some("run"));
1295 }
1296
1297 #[test]
1298 fn bin_name_from_arg0_strips_windows_exe_suffix() {
1299 let runner = bin_name_from_arg0(&OsString::from("runner.exe"));
1305 assert_eq!(runner.as_deref(), Some("runner"));
1306
1307 let run = bin_name_from_arg0(&OsString::from("run.exe"));
1308 assert_eq!(run.as_deref(), Some("run"));
1309 }
1310
1311 #[test]
1312 fn bin_name_from_arg0_strips_exe_case_insensitive() {
1313 let upper = bin_name_from_arg0(&OsString::from("RUNNER.EXE"));
1314 assert_eq!(upper.as_deref(), Some("RUNNER"));
1315
1316 let mixed = bin_name_from_arg0(&OsString::from("Run.Exe"));
1317 assert_eq!(mixed.as_deref(), Some("Run"));
1318 }
1319
1320 #[test]
1321 fn bin_name_from_arg0_preserves_unrelated_extensions() {
1322 let dotted = bin_name_from_arg0(&OsString::from("/tmp/runner.exe.bak"));
1325 assert_eq!(dotted.as_deref(), Some("runner.exe.bak"));
1326
1327 let other = bin_name_from_arg0(&OsString::from("/tmp/runner.sh"));
1328 assert_eq!(other.as_deref(), Some("runner.sh"));
1329 }
1330
1331 #[test]
1332 fn bin_name_from_arg0_handles_bare_dot_exe() {
1333 let bare = bin_name_from_arg0(&OsString::from(".exe"));
1336 assert_eq!(bare.as_deref(), Some(".exe"));
1337 }
1338
1339 fn stub_context(tasks: &[&str]) -> ProjectContext {
1340 ProjectContext {
1341 root: PathBuf::from("."),
1342 package_managers: Vec::new(),
1343 task_runners: Vec::new(),
1344 tasks: tasks
1345 .iter()
1346 .map(|name| Task {
1347 name: (*name).to_string(),
1348 source: TaskSource::PackageJson,
1349 run_target: None,
1350 description: None,
1351 alias_of: None,
1352 passthrough_to: None,
1353 })
1354 .collect(),
1355 node_version: None,
1356 current_node: None,
1357 is_monorepo: false,
1358 warnings: Vec::new(),
1359 }
1360 }
1361
1362 #[test]
1363 fn has_task_returns_true_for_existing_task() {
1364 let ctx = stub_context(&["clean", "install"]);
1365
1366 assert!(has_task(&ctx, "clean"));
1367 assert!(has_task(&ctx, "install"));
1368 assert!(!has_task(&ctx, "build"));
1369 }
1370
1371 #[test]
1372 fn run_alias_parses_builtin_names_as_tasks() {
1373 for name in [
1374 "clean",
1375 "install",
1376 "list",
1377 "exec",
1378 "info",
1379 "completions",
1380 "run",
1381 ] {
1382 let cli = parse_run_alias_cli(["run", name])
1383 .unwrap_or_else(|e| panic!("run {name} should parse: {e}"));
1384
1385 assert_eq!(cli.task.as_deref(), Some(name));
1386 assert!(cli.args.is_empty());
1387 }
1388 }
1389
1390 #[test]
1391 fn run_alias_forwards_trailing_args() {
1392 let cli = parse_run_alias_cli(["run", "test", "--watch", "--reporter=verbose"])
1393 .expect("run test --watch --reporter=verbose should parse");
1394
1395 assert_eq!(cli.task.as_deref(), Some("test"));
1396 assert_eq!(cli.args, vec!["--watch", "--reporter=verbose"]);
1397 }
1398
1399 #[test]
1400 fn run_alias_bare_has_no_task() {
1401 let cli = parse_run_alias_cli(["run"]).expect("bare run should parse");
1402
1403 assert!(cli.task.is_none());
1404 assert!(cli.args.is_empty());
1405 }
1406
1407 #[test]
1408 fn run_alias_honours_dir_flag() {
1409 let cli = parse_run_alias_cli(["run", "--dir=other", "build"])
1410 .expect("run --dir=other build should parse");
1411
1412 assert_eq!(cli.global.project_dir, Some(PathBuf::from("other")));
1413 assert_eq!(cli.task.as_deref(), Some("build"));
1414 }
1415
1416 #[test]
1417 fn run_alias_bare_shows_info() {
1418 let dir = TempDir::new("runner-run-bare");
1419
1420 let code =
1421 run_alias_in_dir(["run"], dir.path()).expect("bare run should succeed on empty dir");
1422
1423 assert_eq!(code, 0);
1424 }
1425
1426 #[test]
1427 fn run_alias_dispatch_shares_override_building_with_runner() {
1428 let dir = TempDir::new("runner-run-alias-bad-pm");
1433 let err = run_alias_in_dir(["run", "--pm", "zoot", "build"], dir.path())
1434 .expect_err("unknown --pm should error through the shared dispatch path");
1435 assert!(
1436 format!("{err}").contains("unknown package manager"),
1437 "alias must reuse the runner override builder: {err}",
1438 );
1439 }
1440
1441 #[test]
1442 fn run_alias_bare_matches_bare_runner_dashboard() {
1443 let dir = TempDir::new("runner-run-alias-bare-eq");
1447 let alias = run_alias_in_dir(["run"], dir.path()).expect("bare run should succeed");
1448 let runner = run_in_dir(["runner"], dir.path()).expect("bare runner should succeed");
1449 assert_eq!(alias, runner, "alias bare dispatch must match bare runner");
1450 assert_eq!(alias, 0);
1451 }
1452
1453 #[test]
1454 fn run_alias_bare_drops_chain_failure_flag() {
1455 let dir = TempDir::new("runner-run-alias-bare-drop-flag");
1464 fs::write(
1465 dir.path().join(crate::config::CONFIG_FILENAME),
1466 "[chain]\nkill_on_fail = true\n",
1467 )
1468 .expect("write runner.toml");
1469
1470 let code = run_alias_in_dir(["run", "-k"], dir.path())
1471 .expect("bare `run -k` must not error on an opposite-polarity [chain] config");
1472 assert_eq!(code, 0, "bare dashboard ignores the dropped failure flag");
1473 }
1474
1475 #[test]
1476 fn run_alias_forwards_help_and_version_after_task() {
1477 for flag in ["--help", "-h", "--version", "-V"] {
1481 let cli = parse_run_alias_cli(["run", "build", flag])
1482 .unwrap_or_else(|e| panic!("run build {flag} should parse: {e}"));
1483 assert_eq!(cli.task.as_deref(), Some("build"));
1484 assert_eq!(cli.args, vec![flag.to_string()]);
1485 }
1486 }
1487
1488 #[test]
1489 fn run_alias_forwards_interleaved_help_flag() {
1490 let cli = parse_run_alias_cli(["run", "build", "--foo", "--help", "--bar"])
1492 .expect("interleaved --help should parse and forward");
1493 assert_eq!(cli.task.as_deref(), Some("build"));
1494 assert_eq!(cli.args, vec!["--foo", "--help", "--bar"]);
1495 }
1496
1497 #[test]
1498 fn run_alias_double_dash_forwards_help_literally() {
1499 let cli = parse_run_alias_cli(["run", "build", "--", "--help"])
1502 .expect("run build -- --help should parse");
1503 assert_eq!(cli.task.as_deref(), Some("build"));
1504 assert_eq!(cli.args, vec!["--help"]);
1505 }
1506
1507 #[test]
1508 fn run_alias_leading_builtins_classified_as_own_request() {
1509 for flag in ["--help", "-h"] {
1513 let err = parse_run_alias_cli(["run", flag])
1514 .expect_err("leading help flag should not parse as a task");
1515 assert!(
1516 matches!(alias_builtin_request(&err), Some(AliasBuiltin::Help)),
1517 "{flag} before a task should be classified as a help request",
1518 );
1519 }
1520 for flag in ["--version", "-V"] {
1521 let err = parse_run_alias_cli(["run", flag])
1522 .expect_err("leading version flag should not parse as a task");
1523 assert!(
1524 matches!(alias_builtin_request(&err), Some(AliasBuiltin::Version)),
1525 "{flag} before a task should be classified as a version request",
1526 );
1527 }
1528 }
1529
1530 #[test]
1531 fn run_alias_global_flag_before_help_still_classified_as_help() {
1532 let err = parse_run_alias_cli(["run", "--pm", "npm", "--help"])
1535 .expect_err("--pm npm --help should not parse as a task");
1536 assert!(matches!(
1537 alias_builtin_request(&err),
1538 Some(AliasBuiltin::Help)
1539 ));
1540 }
1541
1542 #[test]
1543 fn run_alias_unknown_flag_is_not_a_builtin_request() {
1544 let err = parse_run_alias_cli(["run", "--bogus"])
1547 .expect_err("unknown leading flag should not parse");
1548 assert!(alias_builtin_request(&err).is_none());
1549 }
1550
1551 #[test]
1552 fn run_alias_own_help_and_version_return_zero() {
1553 let dir = TempDir::new("runner-run-builtin");
1558 assert_eq!(
1559 run_alias_in_dir(["run", "--help"], dir.path()).expect("run --help should succeed"),
1560 0,
1561 );
1562 assert_eq!(
1563 run_alias_in_dir(["run", "--pm", "npm", "--version"], dir.path())
1564 .expect("run --pm npm --version should succeed"),
1565 0,
1566 );
1567 }
1568
1569 #[test]
1570 fn runner_cli_still_parses_install_as_builtin_when_flag_set() {
1571 let cli = parse_cli(["runner", "install", "--frozen"]).expect("should parse");
1572
1573 match cli.command {
1574 Some(cli::Command::Install { frozen: true, .. }) => {}
1575 other => panic!("expected Install {{ frozen: true }}, got {other:?}"),
1576 }
1577 }
1578
1579 #[test]
1580 fn runner_cli_parses_install_frozen_short_flag() {
1581 let cli = parse_cli(["runner", "install", "-f"]).expect("should parse");
1582
1583 match cli.command {
1584 Some(cli::Command::Install { frozen: true, .. }) => {}
1585 other => panic!("expected Install {{ frozen: true }}, got {other:?}"),
1586 }
1587 }
1588
1589 #[test]
1590 fn runner_cli_parses_install_chain_flags_after_task_names() {
1591 let cli = parse_cli(["runner", "install", "build", "test", "-K"]).expect("parses");
1595 match cli.command {
1596 Some(cli::Command::Install {
1597 tasks,
1598 failure:
1599 cli::ChainFailureFlags {
1600 kill_on_fail: true, ..
1601 },
1602 ..
1603 }) => assert_eq!(tasks, vec!["build".to_string(), "test".to_string()]),
1604 other => {
1605 panic!("expected Install with kill_on_fail=true and clean task list, got {other:?}")
1606 }
1607 }
1608 }
1609
1610 #[test]
1611 fn runner_cli_parses_clean_as_builtin_when_flag_set() {
1612 let cli = parse_cli(["runner", "clean", "-y"]).expect("should parse");
1613
1614 match cli.command {
1615 Some(cli::Command::Clean { yes: true, .. }) => {}
1616 other => panic!("expected Clean {{ yes: true, .. }}, got {other:?}"),
1617 }
1618 }
1619
1620 #[test]
1621 fn runner_cli_routes_unknown_name_to_external() {
1622 let cli = parse_cli(["runner", "no-such-builtin"]).expect("should parse");
1623
1624 match cli.command {
1625 Some(cli::Command::External(args)) => {
1626 assert_eq!(args, vec!["no-such-builtin"]);
1627 }
1628 other => panic!("expected External, got {other:?}"),
1629 }
1630 }
1631
1632 #[test]
1633 fn runner_cli_parses_pm_and_runner_overrides_globally() {
1634 let cli = parse_cli(["runner", "--pm", "pnpm", "--runner", "just", "run", "build"])
1635 .expect("global --pm/--runner should parse on the run subcommand");
1636
1637 assert_eq!(cli.global.pm_override.as_deref(), Some("pnpm"));
1638 assert_eq!(cli.global.runner_override.as_deref(), Some("just"));
1639 match cli.command {
1640 Some(cli::Command::Run { task, args, .. }) => {
1641 assert_eq!(task.as_deref(), Some("build"));
1642 assert!(args.is_empty());
1643 }
1644 other => panic!("expected Run, got {other:?}"),
1645 }
1646 }
1647
1648 #[test]
1649 fn run_alias_parses_pm_override() {
1650 let cli =
1651 parse_run_alias_cli(["run", "--pm=bun", "test"]).expect("--pm=bun test should parse");
1652
1653 assert_eq!(cli.global.pm_override.as_deref(), Some("bun"));
1654 assert_eq!(cli.task.as_deref(), Some("test"));
1655 }
1656
1657 #[test]
1658 fn invalid_pm_override_value_returns_error() {
1659 let dir = TempDir::new("runner-bad-pm");
1662 let result = run_in_dir(["runner", "--pm", "zoot", "info"], dir.path());
1663
1664 let err = result.expect_err("unknown --pm should error");
1665 assert!(format!("{err}").contains("unknown package manager"));
1666 }
1667
1668 #[test]
1669 fn install_with_undetected_pm_override_exits_2() {
1670 let dir = TempDir::new("runner-install-undetected-pm");
1674 fs::write(
1675 dir.path().join("Cargo.toml"),
1676 "[package]\nname = \"fixture\"\nversion = \"0.0.0\"\n",
1677 )
1678 .expect("write Cargo.toml");
1679
1680 let err = run_in_dir(["runner", "--pm", "npm", "install"], dir.path())
1681 .expect_err("undetected --pm should refuse the install");
1682
1683 assert_eq!(
1684 exit_code_for_error(&err),
1685 2,
1686 "ResolveError must map to exit 2"
1687 );
1688 let msg = format!("{err}");
1689 assert!(msg.contains("--pm"), "should name the source: {msg}");
1690 assert!(msg.contains("cargo"), "should list detected PMs: {msg}");
1691 }
1692
1693 #[test]
1694 fn install_chain_with_undetected_pm_override_exits_2() {
1695 let dir = TempDir::new("runner-install-chain-undetected-pm");
1697 fs::write(
1698 dir.path().join("Cargo.toml"),
1699 "[package]\nname = \"fixture\"\nversion = \"0.0.0\"\n",
1700 )
1701 .expect("write Cargo.toml");
1702
1703 let err = run_in_dir(["runner", "--pm", "npm", "install", "build"], dir.path())
1704 .expect_err("undetected --pm should refuse the install chain");
1705
1706 assert_eq!(
1707 exit_code_for_error(&err),
1708 2,
1709 "ResolveError must map to exit 2"
1710 );
1711 }
1712
1713 #[test]
1714 fn schema_version_rejects_invalid_for_non_json_commands() {
1715 let dir = TempDir::new("runner-schema-invalid-completions");
1716
1717 let code = run_in_dir(
1718 ["runner", "--schema-version", "99", "completions", "bash"],
1719 dir.path(),
1720 )
1721 .expect("parse errors should return an exit code");
1722
1723 assert_ne!(code, 0);
1724 }
1725
1726 #[test]
1727 fn schema_version_rejects_invalid_for_run_alias_bare_info() {
1728 let dir = TempDir::new("runner-schema-invalid-run-alias");
1729
1730 let code = run_alias_in_dir(["run", "--schema-version", "99"], dir.path())
1731 .expect("parse errors should return an exit code");
1732
1733 assert_ne!(code, 0);
1734 }
1735
1736 #[test]
1737 fn schema_version_rejects_invalid_for_json_output() {
1738 let dir = TempDir::new("runner-schema-json-invalid");
1739
1740 let code = run_in_dir(
1741 ["runner", "--schema-version", "99", "info", "--json"],
1742 dir.path(),
1743 )
1744 .expect("parse errors should return an exit code");
1745
1746 assert_ne!(code, 0);
1747 }
1748
1749 #[test]
1750 fn runner_cli_parses_completions_output_long() {
1751 let cli = parse_cli(["runner", "completions", "--output", "/tmp/runner.zsh"])
1752 .expect("should parse");
1753
1754 match cli.command {
1755 Some(cli::Command::Completions {
1756 shell: None,
1757 output: Some(path),
1758 }) => assert_eq!(path, PathBuf::from("/tmp/runner.zsh")),
1759 other => panic!("expected Completions with --output long form, got {other:?}"),
1760 }
1761 }
1762
1763 #[test]
1764 fn runner_cli_parses_completions_output_short() {
1765 let cli =
1766 parse_cli(["runner", "completions", "-o", "/tmp/runner.zsh"]).expect("should parse");
1767
1768 match cli.command {
1769 Some(cli::Command::Completions {
1770 shell: None,
1771 output: Some(path),
1772 }) => assert_eq!(path, PathBuf::from("/tmp/runner.zsh")),
1773 other => panic!("expected Completions with -o short form, got {other:?}"),
1774 }
1775 }
1776
1777 #[test]
1778 fn runner_cli_parses_completions_shell_and_output() {
1779 let cli = parse_cli([
1780 "runner",
1781 "completions",
1782 "zsh",
1783 "--output",
1784 "/tmp/runner.zsh",
1785 ])
1786 .expect("should parse");
1787
1788 match cli.command {
1789 Some(cli::Command::Completions {
1790 shell: Some(_),
1791 output: Some(path),
1792 }) => assert_eq!(path, PathBuf::from("/tmp/runner.zsh")),
1793 other => panic!("expected Completions with both shell and output set, got {other:?}"),
1794 }
1795 }
1796}