diff --git a/src/bin/repo.rs b/src/bin/repo.rs index 913e885d..9e1d1546 100644 --- a/src/bin/repo.rs +++ b/src/bin/repo.rs @@ -293,7 +293,7 @@ fn repo_inner( let is_cook = *command == CliCommand::Cook; let source_dir = handle_fetch(recipe, config, is_cook, logger)?; if is_cook { - handle_cook(recipe, config, source_dir, recipe.is_deps, logger)?; + handle_cook(recipe, config, source_dir, logger)?; } Ok(()) }; @@ -628,9 +628,9 @@ fn handle_fetch( allow_offline: bool, logger: &PtyOut, ) -> anyhow::Result { - let source_dir = match config.cook.offline && allow_offline { + let source_dir = match (config.cook.offline) && allow_offline { true => fetch_offline(&recipe, logger), - false => fetch(&recipe, logger), + false => fetch(&recipe, !recipe.is_deps, logger), } .map_err(|e| anyhow!("failed to fetch: {:?}", e))?; @@ -641,7 +641,6 @@ fn handle_cook( recipe: &CookRecipe, config: &CliConfig, source_dir: PathBuf, - is_deps: bool, logger: &PtyOut, ) -> anyhow::Result<()> { let recipe_dir = &recipe.dir; @@ -653,7 +652,7 @@ fn handle_cook( &recipe.name, &recipe.recipe, &config.cook, - !is_deps, + !recipe.is_deps, logger, ) .map_err(|err| anyhow!("failed to build: {:?}", err))?; @@ -1099,7 +1098,6 @@ fn run_tui_cook( let cooker_handle = thread::spawn(move || { 'done: for (mut recipe, source_dir) in work_rx { let name = recipe.name.clone(); - let is_deps = recipe.is_deps; let (mut stdout_writer, mut stderr_writer) = setup_logger(&cooker_status_tx, &name); let mut logger = Some((&mut stdout_writer, &mut stderr_writer)); 'again: loop { @@ -1107,13 +1105,7 @@ fn run_tui_cook( .send(StatusUpdate::StartCook(name.clone())) .unwrap(); let _ = recipe.reload_recipe(); // reread recipe.toml in case we're retrying - let handler = handle_cook( - &recipe, - &cooker_config, - source_dir.clone(), - is_deps, - &logger, - ); + let handler = handle_cook(&recipe, &cooker_config, source_dir.clone(), &logger); if let Some(log_path) = cooker_config.logs_dir.as_ref() { if let Err(err_ctx) = &handler { log_to_pty!(&logger, "\n{:?}", err_ctx) diff --git a/src/cook/fetch.rs b/src/cook/fetch.rs index f17dc100..ecfb77e4 100644 --- a/src/cook/fetch.rs +++ b/src/cook/fetch.rs @@ -52,7 +52,7 @@ pub fn fetch_offline(recipe: &CookRecipe, logger: &PtyOut) -> Result { - fetch(recipe, logger)?; + fetch(recipe, true, logger)?; "local_source".to_string() } Some(SourceRecipe::SameAs { same_as }) => { @@ -114,7 +114,7 @@ pub fn fetch_offline(recipe: &CookRecipe, logger: &PtyOut) -> Result Result { +pub fn fetch(recipe: &CookRecipe, check_source: bool, logger: &PtyOut) -> Result { let recipe_dir = &recipe.dir; let source_dir = recipe_dir.join("source"); match recipe.recipe.build.kind { @@ -134,7 +134,7 @@ pub fn fetch(recipe: &CookRecipe, logger: &PtyOut) -> Result { Some(SourceRecipe::SameAs { same_as }) => { let recipe = fetch_resolve_canon(recipe_dir, &same_as, recipe.name.is_host())?; // recursively fetch - fetch(&recipe, logger)?; + fetch(&recipe, check_source, logger)?; fetch_make_symlink(&source_dir, &same_as)?; fetch_get_source_info(&recipe)?.source_identifier } @@ -195,6 +195,8 @@ pub fn fetch(recipe: &CookRecipe, logger: &PtyOut) -> Result { rename(&source_dir_tmp, &source_dir)?; false + } else if !check_source { + true } else { if !source_dir.join(".git").is_dir() { return Err(format!( @@ -323,28 +325,30 @@ pub fn fetch(recipe: &CookRecipe, logger: &PtyOut) -> Result { }) => { let source_tar = recipe_dir.join("source.tar"); let mut tar_updated = false; - while { + loop { if !source_tar.is_file() { tar_updated = true; download_wget(&tar, &source_tar, logger)?; + continue; + } + if !check_source { + break; } let source_tar_blake3 = get_blake3(&source_tar, tar_updated && logger.is_none())?; if let Some(blake3) = blake3 { - if source_tar_blake3 != *blake3 { - if tar_updated { - return Err(format!( - "The downloaded tar blake3 '{source_tar_blake3}' is not equal to blake3 in recipe.toml" - )); - } else { - log_to_pty!( - logger, - "DEBUG: source tar blake3 is different and need redownload" - ); - remove_all(&source_tar)?; - } - true + if source_tar_blake3 == *blake3 { + break; + } + if tar_updated { + return Err(format!( + "The downloaded tar blake3 '{source_tar_blake3}' is not equal to blake3 in recipe.toml" + )); } else { - false + log_to_pty!( + logger, + "DEBUG: source tar blake3 is different and need redownload" + ); + remove_all(&source_tar)?; } } else { //TODO: set blake3 hash on the recipe with something like "cook fix" @@ -354,9 +358,9 @@ pub fn fetch(recipe: &CookRecipe, logger: &PtyOut) -> Result { source_tar.display(), source_tar_blake3 ); - false + break; } - } {} + } if source_dir.is_dir() { if tar_updated || fetch_is_patches_newer(recipe_dir, patches, &source_dir)? { log_to_pty!( @@ -396,6 +400,7 @@ pub fn fetch(recipe: &CookRecipe, logger: &PtyOut) -> Result { package_path, cargoflags: _, } = &recipe.recipe.build.kind + && check_source { fetch_cargo(&source_dir, package_path.as_ref(), logger)?; }