use crate::{ example::{Example, ExampleBuffer, ExampleState}, headless::EpAppState, paths::{REPOS_DIR, WORKTREES_DIR}, progress::{InfoStyle, Progress, Step, StepProgress}, }; use anyhow::{Context as _, Result}; use collections::HashMap; use edit_prediction::EditPredictionStore; use edit_prediction::udiff::OpenedBuffers; use futures::{ AsyncWriteExt as _, lock::{Mutex, OwnedMutexGuard}, }; use gpui::{AsyncApp, Entity}; use language::{Anchor, Buffer, LanguageNotFound, ToOffset, ToPoint}; use project::buffer_store::BufferStoreEvent; use project::{Project, ProjectPath}; use std::{ cell::RefCell, fs, path::{Path, PathBuf}, sync::Arc, }; use util::{paths::PathStyle, rel_path::RelPath}; use zeta_prompt::CURSOR_MARKER; pub async fn run_load_project( example: &mut Example, app_state: Arc, mut cx: AsyncApp, ) -> Result<()> { if example.state.is_some() { return Ok(()); } let progress = Progress::global().start(Step::LoadProject, &example.spec.name); let project = setup_project(example, &app_state, &progress, &mut cx).await?; let _open_buffers = apply_edit_history(example, &project, &mut cx).await?; let (buffer, cursor_position) = cursor_position(example, &project, &mut cx).await?; let (example_buffer, language_name) = buffer.read_with(&cx, |buffer, _cx| { let cursor_point = cursor_position.to_point(&buffer); let language_name = buffer .language() .map(|l| l.name().to_string()) .unwrap_or_else(|| "Unknown".to_string()); ( ExampleBuffer { content: buffer.text(), cursor_row: cursor_point.row, cursor_column: cursor_point.column, cursor_offset: cursor_position.to_offset(&buffer), }, language_name, ) })?; progress.set_info(language_name, InfoStyle::Normal); example.buffer = Some(example_buffer); example.state = Some(ExampleState { buffer, project, cursor_position, _open_buffers, }); Ok(()) } async fn cursor_position( example: &Example, project: &Entity, cx: &mut AsyncApp, ) -> Result<(Entity, Anchor)> { let language_registry = project.read_with(cx, |project, _| project.languages().clone())?; let result = language_registry .load_language_for_file_path(&example.spec.cursor_path) .await; if let Err(error) = result && !error.is::() { return Err(error); } let worktree = project.read_with(cx, |project, cx| { project .visible_worktrees(cx) .next() .context("No visible worktrees") })??; let cursor_path = RelPath::new(&example.spec.cursor_path, PathStyle::Posix) .context("Failed to create RelPath")? .into_arc(); let cursor_buffer = project .update(cx, |project, cx| { project.open_buffer( ProjectPath { worktree_id: worktree.read(cx).id(), path: cursor_path, }, cx, ) })? .await?; let cursor_offset_within_excerpt = example .spec .cursor_position .find(CURSOR_MARKER) .context("missing cursor marker")?; let mut cursor_excerpt = example.spec.cursor_position.clone(); cursor_excerpt.replace_range( cursor_offset_within_excerpt..(cursor_offset_within_excerpt + CURSOR_MARKER.len()), "", ); let excerpt_offset = cursor_buffer.read_with(cx, |buffer, _cx| { let text = buffer.text(); let mut matches = text.match_indices(&cursor_excerpt); let (excerpt_offset, _) = matches.next().with_context(|| { format!( "\nExcerpt:\n\n{cursor_excerpt}\nBuffer text:\n{text}\n.Example: {}\nCursor excerpt did not exist in buffer.", example.spec.name ) })?; anyhow::ensure!( matches.next().is_none(), "More than one cursor position match found for {}", &example.spec.name ); Ok(excerpt_offset) })??; let cursor_offset = excerpt_offset + cursor_offset_within_excerpt; let cursor_anchor = cursor_buffer.read_with(cx, |buffer, _| buffer.anchor_after(cursor_offset))?; Ok((cursor_buffer, cursor_anchor)) } async fn setup_project( example: &mut Example, app_state: &Arc, step_progress: &StepProgress, cx: &mut AsyncApp, ) -> Result> { let ep_store = cx .update(|cx| EditPredictionStore::try_global(cx))? .context("Store should be initialized at init")?; let worktree_path = setup_worktree(example, step_progress).await?; if let Some(project) = app_state.project_cache.get(&example.spec.repository_url) { ep_store.update(cx, |ep_store, _| { ep_store.clear_history_for_project(&project); })?; let buffer_store = project.read_with(cx, |project, _| project.buffer_store().clone())?; let buffers = buffer_store.read_with(cx, |buffer_store, _| { buffer_store.buffers().collect::>() })?; for buffer in buffers { buffer .update(cx, |buffer, cx| buffer.reload(cx))? .await .ok(); } return Ok(project); } let project = cx.update(|cx| { Project::local( app_state.client.clone(), app_state.node_runtime.clone(), app_state.user_store.clone(), app_state.languages.clone(), app_state.fs.clone(), None, cx, ) })?; project .update(cx, |project, cx| { project.disable_worktree_scanner(cx); project.create_worktree(&worktree_path, true, cx) })? .await?; app_state .project_cache .insert(example.spec.repository_url.clone(), project.clone()); let buffer_store = project.read_with(cx, |project, _| project.buffer_store().clone())?; cx.subscribe(&buffer_store, { let project = project.clone(); move |_, event, cx| match event { BufferStoreEvent::BufferAdded(buffer) => { ep_store.update(cx, |store, cx| store.register_buffer(&buffer, &project, cx)); } _ => {} } })? .detach(); Ok(project) } async fn setup_worktree(example: &Example, step_progress: &StepProgress) -> Result { let (repo_owner, repo_name) = example.repo_name().context("failed to get repo name")?; let repo_dir = REPOS_DIR.join(repo_owner.as_ref()).join(repo_name.as_ref()); let worktree_path = WORKTREES_DIR .join(repo_owner.as_ref()) .join(repo_name.as_ref()); let repo_lock = lock_repo(&repo_dir).await; if !repo_dir.is_dir() { step_progress.set_substatus(format!("cloning {}", repo_name)); fs::create_dir_all(&repo_dir)?; run_git(&repo_dir, &["init"]).await?; run_git( &repo_dir, &["remote", "add", "origin", &example.spec.repository_url], ) .await?; } // Resolve the example to a revision, fetching it if needed. let revision = run_git( &repo_dir, &[ "rev-parse", &format!("{}^{{commit}}", example.spec.revision), ], ) .await; let revision = if let Ok(revision) = revision { revision } else { step_progress.set_substatus("fetching"); if run_git( &repo_dir, &["fetch", "--depth", "1", "origin", &example.spec.revision], ) .await .is_err() { run_git(&repo_dir, &["fetch", "origin"]).await?; } let revision = run_git(&repo_dir, &["rev-parse", "FETCH_HEAD"]).await?; revision }; // Create the worktree for this example if needed. step_progress.set_substatus("preparing worktree"); if worktree_path.is_dir() { run_git(&worktree_path, &["clean", "--force", "-d"]).await?; run_git(&worktree_path, &["reset", "--hard", "HEAD"]).await?; run_git(&worktree_path, &["checkout", revision.as_str()]).await?; } else { let worktree_path_string = worktree_path.to_string_lossy(); run_git( &repo_dir, &["branch", "-f", &example.spec.name, revision.as_str()], ) .await?; run_git( &repo_dir, &[ "worktree", "add", "-f", &worktree_path_string, &example.spec.name, ], ) .await?; } drop(repo_lock); // Apply the uncommitted diff for this example. if !example.spec.uncommitted_diff.is_empty() { step_progress.set_substatus("applying diff"); let mut apply_process = smol::process::Command::new("git") .current_dir(&worktree_path) .args(&["apply", "-"]) .stdin(std::process::Stdio::piped()) .spawn()?; let mut stdin = apply_process.stdin.take().context("Failed to get stdin")?; stdin .write_all(example.spec.uncommitted_diff.as_bytes()) .await?; stdin.close().await?; drop(stdin); let apply_result = apply_process.output().await?; anyhow::ensure!( apply_result.status.success(), "Failed to apply uncommitted diff patch with status: {}\nstderr:\n{}\nstdout:\n{}", apply_result.status, String::from_utf8_lossy(&apply_result.stderr), String::from_utf8_lossy(&apply_result.stdout), ); } step_progress.clear_substatus(); Ok(worktree_path) } async fn apply_edit_history( example: &Example, project: &Entity, cx: &mut AsyncApp, ) -> Result { edit_prediction::udiff::apply_diff(&example.spec.edit_history, project, cx).await } thread_local! { static REPO_LOCKS: RefCell>>> = RefCell::new(HashMap::default()); } #[must_use] pub async fn lock_repo(path: impl AsRef) -> OwnedMutexGuard<()> { REPO_LOCKS .with(|cell| { cell.borrow_mut() .entry(path.as_ref().to_path_buf()) .or_default() .clone() }) .lock_owned() .await } async fn run_git(repo_path: &Path, args: &[&str]) -> Result { let output = smol::process::Command::new("git") .current_dir(repo_path) .args(args) .output() .await?; anyhow::ensure!( output.status.success(), "`git {}` within `{}` failed with status: {}\nstderr:\n{}\nstdout:\n{}", args.join(" "), repo_path.display(), output.status, String::from_utf8_lossy(&output.stderr), String::from_utf8_lossy(&output.stdout), ); Ok(String::from_utf8(output.stdout)?.trim().to_string()) }