1use std::collections::HashMap;
5use std::fs;
6use std::path::{Path, PathBuf};
7
8use crate::model::{DiffLine, DiffModel, FileDiff, FileStatus, Hunk, HunkId, LineKind, hunk_id};
9use crate::vcs::{BranchInfo, HeadInfo, LogEntry, NetworkOp, StatusModel, Vcs, VcsError};
10
11pub const DEFAULT_CONTEXT_LINES: u32 = 3;
13
14pub struct GitVcs {
15 repo: git2::Repository,
16 context_lines: u32,
17}
18
19impl GitVcs {
20 pub fn open(root: &Path) -> Result<Self, VcsError> {
21 Self::open_with_context(root, DEFAULT_CONTEXT_LINES)
22 }
23
24 pub fn open_with_context(root: &Path, context_lines: u32) -> Result<Self, VcsError> {
26 let repo = git2::Repository::open(root)?;
27 if repo.workdir().is_none() {
28 return Err(VcsError::NoWorkdir);
29 }
30 Ok(Self {
31 repo,
32 context_lines,
33 })
34 }
35
36 fn head_tree(&self) -> Result<Option<git2::Tree<'_>>, VcsError> {
38 match self.repo.head() {
39 Ok(head) => Ok(Some(head.peel_to_tree()?)),
40 Err(err) if err.code() == git2::ErrorCode::UnbornBranch => Ok(None),
41 Err(err) => Err(err.into()),
42 }
43 }
44
45 fn workdir_path(&self) -> Result<&Path, VcsError> {
46 self.repo.workdir().ok_or(VcsError::NoWorkdir)
47 }
48
49 fn has_tracked_changes(&self) -> Result<bool, VcsError> {
53 let mut opts = git2::StatusOptions::new();
54 opts.include_untracked(false).include_ignored(false);
55 let statuses = self.repo.statuses(Some(&mut opts))?;
56 Ok(statuses.iter().next().is_some())
57 }
58}
59
60impl Vcs for GitVcs {
61 fn git_dir(&self) -> Result<PathBuf, VcsError> {
62 Ok(self.repo.path().to_path_buf())
65 }
66
67 fn head(&self) -> Result<HeadInfo, VcsError> {
68 match self.repo.head() {
69 Ok(head) => {
70 let branch = if head.is_branch() {
71 Some(head.shorthand()?.to_owned())
72 } else {
73 None
74 };
75 let commit = head.peel_to_commit()?;
76 let upstream = branch.as_deref().and_then(|name| {
77 let local = self.repo.find_branch(name, git2::BranchType::Local).ok()?;
78 let upstream = local.upstream().ok()?;
79 upstream.name().ok().flatten().map(str::to_owned)
80 });
81 Ok(HeadInfo {
82 branch,
83 oid7: short7(&commit.id().to_string()),
84 subject: commit.summary()?.unwrap_or_default().to_owned(),
85 upstream,
86 })
87 }
88 Err(err) if err.code() == git2::ErrorCode::UnbornBranch => {
89 let branch = self
90 .repo
91 .find_reference("HEAD")
92 .ok()
93 .and_then(|r| r.symbolic_target().ok().flatten().map(str::to_owned))
94 .and_then(|t| t.strip_prefix("refs/heads/").map(str::to_owned));
95 Ok(HeadInfo {
96 branch,
97 oid7: String::new(),
98 subject: String::new(),
99 upstream: None,
100 })
101 }
102 Err(err) => Err(err.into()),
103 }
104 }
105
106 fn status(&self) -> Result<StatusModel, VcsError> {
107 let mut workdir = self
110 .repo
111 .diff_index_to_workdir(None, Some(&mut workdir_diff_options(self.context_lines)))?;
112 let workdir_model = diff_to_model(&self.repo, &mut workdir)?;
113 let (untracked, unstaged): (Vec<_>, Vec<_>) = workdir_model
114 .files
115 .into_iter()
116 .partition(|f| f.status == FileStatus::Untracked);
117
118 let head_tree = self.head_tree()?;
119 let mut opts = git2::DiffOptions::new();
120 opts.context_lines(self.context_lines);
121 let mut staged = self
122 .repo
123 .diff_tree_to_index(head_tree.as_ref(), None, Some(&mut opts))?;
124 let staged = diff_to_model(&self.repo, &mut staged)?;
125
126 Ok(StatusModel {
127 untracked: DiffModel { files: untracked },
128 unstaged: DiffModel { files: unstaged },
129 staged,
130 })
131 }
132
133 fn working_tree_diff(&self) -> Result<DiffModel, VcsError> {
134 let head_tree = self.head_tree()?;
135 let mut diff = self.repo.diff_tree_to_workdir_with_index(
136 head_tree.as_ref(),
137 Some(&mut workdir_diff_options(self.context_lines)),
138 )?;
139 let mut find = git2::DiffFindOptions::new();
140 find.renames(true);
141 diff.find_similar(Some(&mut find))?;
142 diff_to_model(&self.repo, &mut diff)
143 }
144
145 fn commit_diff(&self, oid: &str) -> Result<DiffModel, VcsError> {
146 let oid = git2::Oid::from_str(oid)?;
147 let commit = self.repo.find_commit(oid)?;
148 let tree = commit.tree()?;
149 let parent_tree = commit.parent(0).ok().map(|p| p.tree()).transpose()?;
151 let mut opts = git2::DiffOptions::new();
152 opts.context_lines(self.context_lines);
153 let mut diff =
154 self.repo
155 .diff_tree_to_tree(parent_tree.as_ref(), Some(&tree), Some(&mut opts))?;
156 diff_to_model(&self.repo, &mut diff)
157 }
158
159 fn range_diff(&self, oldest_oid: &str, newest_oid: &str) -> Result<DiffModel, VcsError> {
160 let oldest = self.repo.find_commit(git2::Oid::from_str(oldest_oid)?)?;
161 let newest = self.repo.find_commit(git2::Oid::from_str(newest_oid)?)?;
162 let newest_tree = newest.tree()?;
163 let base_tree = oldest.parent(0).ok().map(|p| p.tree()).transpose()?;
167 let mut opts = git2::DiffOptions::new();
168 opts.context_lines(self.context_lines);
169 let mut diff =
170 self.repo
171 .diff_tree_to_tree(base_tree.as_ref(), Some(&newest_tree), Some(&mut opts))?;
172 diff_to_model(&self.repo, &mut diff)
173 }
174
175 fn log(&self, limit: usize) -> Result<Vec<LogEntry>, VcsError> {
176 if self.head_tree()?.is_none() {
177 return Ok(Vec::new());
178 }
179 let mut refs_by_oid: HashMap<git2::Oid, Vec<String>> = HashMap::new();
180 for reference in self.repo.references()?.flatten() {
181 let Ok(name) = reference.shorthand().map(str::to_owned) else {
182 continue;
183 };
184 let Some(target) = reference.peel_to_commit().ok().map(|c| c.id()) else {
186 continue;
187 };
188 refs_by_oid.entry(target).or_default().push(name);
189 }
190
191 let mut walk = self.repo.revwalk()?;
192 walk.set_sorting(git2::Sort::TOPOLOGICAL | git2::Sort::TIME)?;
193 walk.push_head()?;
194 let mut entries = Vec::new();
195 for oid in walk.take(limit) {
196 let oid = oid?;
197 let commit = self.repo.find_commit(oid)?;
198 let full = oid.to_string();
199 entries.push(LogEntry {
200 oid7: short7(&full),
201 oid: full,
202 refs: refs_by_oid.get(&oid).cloned().unwrap_or_default(),
203 subject: commit.summary()?.unwrap_or_default().to_owned(),
204 author: commit.author().name().unwrap_or_default().to_owned(),
205 time_unix: commit.time().seconds(),
206 });
207 }
208 Ok(entries)
209 }
210
211 fn branches(&self) -> Result<Vec<BranchInfo>, VcsError> {
212 let mut out = Vec::new();
213 for entry in self.repo.branches(Some(git2::BranchType::Local))? {
214 let (branch, _) = entry?;
215 let Some(name) = branch.name()?.map(str::to_owned) else {
216 continue;
217 };
218 out.push(BranchInfo {
219 name,
220 is_head: branch.is_head(),
221 });
222 }
223 Ok(out)
224 }
225
226 fn stage(&self, rel: &Path) -> Result<(), VcsError> {
227 let root = self.workdir_path()?;
228 let mut index = self.repo.index()?;
229 if root.join(rel).exists() {
230 index.add_path(rel)?;
231 } else {
232 index.remove_path(rel)?;
233 }
234 index.write()?;
235 Ok(())
236 }
237
238 fn stage_hunk(&self, rel: &Path, hunk: &HunkId) -> Result<(), VcsError> {
239 let diff = self
240 .repo
241 .diff_index_to_workdir(None, Some(&mut workdir_diff_options(self.context_lines)))?;
242 let patch = synthesize_patch(&diff, rel, hunk, false)?;
243 let diff = git2::Diff::from_buffer(&patch)?;
244 self.repo.apply(&diff, git2::ApplyLocation::Index, None)?;
245 Ok(())
246 }
247
248 fn unstage(&self, rel: &Path) -> Result<(), VcsError> {
249 match self.repo.head() {
250 Ok(head) => {
251 let target = head.peel(git2::ObjectType::Commit)?;
252 self.repo.reset_default(Some(&target), [rel])?;
253 }
254 Err(err) if err.code() == git2::ErrorCode::UnbornBranch => {
256 let mut index = self.repo.index()?;
257 index.remove_path(rel)?;
258 index.write()?;
259 }
260 Err(err) => return Err(err.into()),
261 }
262 Ok(())
263 }
264
265 fn unstage_hunk(&self, rel: &Path, hunk: &HunkId) -> Result<(), VcsError> {
266 let head_tree = self.head_tree()?;
267 let mut opts = git2::DiffOptions::new();
268 opts.context_lines(self.context_lines);
269 let diff = self
270 .repo
271 .diff_tree_to_index(head_tree.as_ref(), None, Some(&mut opts))?;
272 let patch = synthesize_patch(&diff, rel, hunk, true)?;
273 let diff = git2::Diff::from_buffer(&patch)?;
274 self.repo.apply(&diff, git2::ApplyLocation::Index, None)?;
275 Ok(())
276 }
277
278 fn discard(&self, rel: &Path) -> Result<(), VcsError> {
279 let head_tree = self.head_tree()?;
280 let mut opts = git2::DiffOptions::new();
281 opts.pathspec(rel).disable_pathspec_match(true);
282 let staged = self
283 .repo
284 .diff_tree_to_index(head_tree.as_ref(), None, Some(&mut opts))?;
285 if staged.deltas().len() > 0 {
286 return Err(VcsError::Rejected(
287 "file has staged changes; unstage first".into(),
288 ));
289 }
290 let status = self.repo.status_file(rel)?;
291 if status.contains(git2::Status::WT_NEW) {
292 fs::remove_file(self.workdir_path()?.join(rel))?;
293 return Ok(());
294 }
295 let mut checkout = git2::build::CheckoutBuilder::new();
302 checkout.path(rel).force().update_index(true);
303 self.repo.checkout_head(Some(&mut checkout))?;
304 Ok(())
305 }
306
307 fn commit(&self, message: &str) -> Result<String, VcsError> {
308 if message.trim().is_empty() {
309 return Err(VcsError::Rejected("empty commit message".into()));
310 }
311 let mut index = self.repo.index()?;
312 let tree_id = index.write_tree()?;
313 let tree = self.repo.find_tree(tree_id)?;
314 let signature = self.repo.signature()?;
315 let parent = match self.repo.head() {
316 Ok(head) => Some(head.peel_to_commit()?),
317 Err(err) if err.code() == git2::ErrorCode::UnbornBranch => None,
318 Err(err) => return Err(err.into()),
319 };
320 let parents: Vec<&git2::Commit<'_>> = parent.iter().collect();
321 let oid = self.repo.commit(
322 Some("HEAD"),
323 &signature,
324 &signature,
325 message,
326 &tree,
327 &parents,
328 )?;
329 Ok(oid.to_string())
330 }
331
332 fn head_message(&self) -> Result<String, VcsError> {
333 let commit = self.repo.head()?.peel_to_commit()?;
334 Ok(commit.message().unwrap_or_default().to_owned())
335 }
336
337 fn amend(&self, message: Option<&str>, use_index: bool) -> Result<String, VcsError> {
338 if let Some(message) = message
339 && message.trim().is_empty()
340 {
341 return Err(VcsError::Rejected("empty commit message".into()));
342 }
343 let head = self.repo.head()?.peel_to_commit()?;
344 let tree = if use_index {
347 let mut index = self.repo.index()?;
348 let tree_id = index.write_tree()?;
349 self.repo.find_tree(tree_id)?
350 } else {
351 head.tree()?
352 };
353 let oid = head.amend(Some("HEAD"), None, None, None, message, Some(&tree))?;
354 Ok(oid.to_string())
355 }
356
357 fn create_branch(&self, name: &str, checkout: bool) -> Result<(), VcsError> {
358 let head = self.repo.head()?.peel_to_commit()?;
359 self.repo.branch(name, &head, false)?;
360 if checkout {
361 self.checkout(name)?;
362 }
363 Ok(())
364 }
365
366 fn delete_branch(&self, name: &str) -> Result<(), VcsError> {
367 let mut branch = self.repo.find_branch(name, git2::BranchType::Local)?;
368 if branch.is_head() {
369 return Err(VcsError::Rejected(
370 "cannot delete the checked-out branch".into(),
371 ));
372 }
373 branch.delete()?;
374 Ok(())
375 }
376
377 fn checkout(&self, name: &str) -> Result<(), VcsError> {
378 let branch = self.repo.find_branch(name, git2::BranchType::Local)?;
379 let target = branch.get().peel(git2::ObjectType::Commit)?;
380 self.repo.checkout_tree(&target, None)?;
382 self.repo.set_head(&format!("refs/heads/{name}"))?;
383 Ok(())
384 }
385
386 fn stash_push(&self, message: Option<&str>) -> Result<(), VcsError> {
387 if !self.has_tracked_changes()? {
388 return Err(VcsError::Rejected("nothing to stash".into()));
389 }
390 let mut repo = git2::Repository::open(self.workdir_path()?)?;
393 let signature = repo.signature()?;
394 repo.stash_save2(&signature, message, None)?;
395 Ok(())
396 }
397
398 fn stash_pop(&self) -> Result<(), VcsError> {
399 let mut repo = git2::Repository::open(self.workdir_path()?)?;
400 match repo.stash_pop(0, None) {
401 Ok(()) => Ok(()),
402 Err(err) if err.code() == git2::ErrorCode::NotFound => {
403 Err(VcsError::Rejected("no stash to pop".into()))
404 }
405 Err(err) if err.code() == git2::ErrorCode::Conflict => Err(VcsError::Rejected(
408 "stash applied with conflicts; resolve them — the stash was kept".into(),
409 )),
410 Err(err) => Err(err.into()),
411 }
412 }
413
414 fn network_argv(&self, op: NetworkOp) -> Vec<String> {
415 let args: &[&str] = match op {
419 NetworkOp::Push => &["push"],
420 NetworkOp::PushSetUpstream => &["push", "-u", "origin", "HEAD"],
421 NetworkOp::Pull => &["pull"],
422 NetworkOp::Fetch => &["fetch"],
423 NetworkOp::FetchAll => &["fetch", "--all"],
424 };
425 std::iter::once("git")
426 .chain(args.iter().copied())
427 .map(str::to_owned)
428 .collect()
429 }
430
431 fn workdir(&self) -> Result<PathBuf, VcsError> {
432 Ok(self.workdir_path()?.to_path_buf())
433 }
434}
435
436fn synthesize_patch(
441 diff: &git2::Diff<'_>,
442 rel: &Path,
443 target: &HunkId,
444 reverse: bool,
445) -> Result<Vec<u8>, VcsError> {
446 let rel = rel.to_string_lossy();
447 for idx in 0..diff.deltas().len() {
448 let Some(patch) = git2::Patch::from_diff(diff, idx)? else {
449 continue;
450 };
451 let delta = patch.delta();
452 if delta.flags().is_binary() || delta_new_path(&delta) != rel {
453 continue;
454 }
455 for h in 0..patch.num_hunks() {
456 if hunk_id(&rel, &hunk_model_lines(&patch, h)?)? == *target {
457 return render_hunk_patch(&patch, h, &rel, delta.status(), reverse);
458 }
459 }
460 }
461 Err(VcsError::Rejected("hunk not found (diff changed?)".into()))
462}
463
464fn render_hunk_patch(
465 patch: &git2::Patch<'_>,
466 h: usize,
467 rel: &str,
468 status: git2::Delta,
469 reverse: bool,
470) -> Result<Vec<u8>, VcsError> {
471 let added = matches!(status, git2::Delta::Added | git2::Delta::Untracked);
472 let deleted = status == git2::Delta::Deleted;
473 let mut out = Vec::new();
474 out.extend_from_slice(format!("diff --git a/{rel} b/{rel}\n").as_bytes());
475 if (added && !reverse) || (deleted && reverse) {
479 out.extend_from_slice(
480 format!("new file mode 100644\n--- /dev/null\n+++ b/{rel}\n").as_bytes(),
481 );
482 } else if (deleted && !reverse) || (added && reverse) {
483 out.extend_from_slice(
484 format!("deleted file mode 100644\n--- a/{rel}\n+++ /dev/null\n").as_bytes(),
485 );
486 } else {
487 out.extend_from_slice(format!("--- a/{rel}\n+++ b/{rel}\n").as_bytes());
488 }
489 let (hunk, line_count) = patch.hunk(h)?;
490 let (old, new) = (
491 (hunk.old_start(), hunk.old_lines()),
492 (hunk.new_start(), hunk.new_lines()),
493 );
494 let ((minus_start, minus_lines), (plus_start, plus_lines)) =
495 if reverse { (new, old) } else { (old, new) };
496 out.extend_from_slice(
497 format!("@@ -{minus_start},{minus_lines} +{plus_start},{plus_lines} @@\n").as_bytes(),
498 );
499 for l in 0..line_count {
500 let line = patch.line_in_hunk(h, l)?;
501 let origin = match (line.origin(), reverse) {
502 (' ', _) => Some(b' '),
503 ('+', false) | ('-', true) => Some(b'+'),
504 ('-', false) | ('+', true) => Some(b'-'),
505 ('=' | '>' | '<', _) => None,
509 _ => continue,
510 };
511 if let Some(origin) = origin {
512 out.push(origin);
513 }
514 out.extend_from_slice(line.content());
515 }
516 Ok(out)
517}
518
519fn workdir_diff_options(context_lines: u32) -> git2::DiffOptions {
520 let mut opts = git2::DiffOptions::new();
521 opts.include_untracked(true)
522 .recurse_untracked_dirs(true)
523 .show_untracked_content(true)
524 .context_lines(context_lines);
525 opts
526}
527
528fn short7(oid: &str) -> String {
529 oid.get(..7).unwrap_or(oid).to_owned()
530}
531
532fn diff_to_model(
533 repo: &git2::Repository,
534 diff: &mut git2::Diff<'_>,
535) -> Result<DiffModel, VcsError> {
536 let mut files = Vec::new();
537 for idx in 0..diff.deltas().len() {
538 if let Some(file) = build_file(repo, diff, idx)? {
539 files.push(file);
540 }
541 }
542 Ok(DiffModel { files })
546}
547
548fn build_file(
549 repo: &git2::Repository,
550 diff: &mut git2::Diff<'_>,
551 idx: usize,
552) -> Result<Option<FileDiff>, VcsError> {
553 let Some(patch) = git2::Patch::from_diff(diff, idx)? else {
554 return Ok(build_binary_file(diff, idx));
556 };
557 let delta = patch.delta();
558 if delta.flags().is_binary() {
559 return Ok(build_binary_file(diff, idx));
560 }
561 let file_path = delta_new_path(&delta);
562 let status = map_status(delta.status());
563 let old_path = if status == FileStatus::Renamed {
564 delta
565 .old_file()
566 .path()
567 .map(|p| p.to_string_lossy().into_owned())
568 } else {
569 None
570 };
571
572 let old_text = blob_text(repo, delta.old_file().id());
573 let new_text = new_side_text(repo, &delta, &file_path);
574
575 let mut hunks = Vec::new();
576 for h in 0..patch.num_hunks() {
577 let (hunk, _) = patch.hunk(h)?;
578 let lines = hunk_model_lines(&patch, h)?;
579 let id = hunk_id(&file_path, &lines)?;
580 hunks.push(Hunk {
581 id,
582 old_start: hunk.old_start(),
583 old_lines: hunk.old_lines(),
584 new_start: hunk.new_start(),
585 new_lines: hunk.new_lines(),
586 context: hunk_context(&hunk),
587 lines,
588 });
589 }
590
591 Ok(Some(FileDiff {
592 path: file_path,
593 old_path,
594 status,
595 binary: false,
596 old_text,
597 new_text,
598 hunks,
599 }))
600}
601
602fn hunk_context(hunk: &git2::DiffHunk<'_>) -> String {
606 let header = String::from_utf8_lossy(hunk.header());
607 match header.split_once(" @@") {
608 Some((_, rest)) => rest.trim_matches(['\n', '\r', ' ']).to_owned(),
609 None => String::new(),
610 }
611}
612
613fn hunk_model_lines(patch: &git2::Patch<'_>, h: usize) -> Result<Vec<DiffLine>, VcsError> {
617 let (_, line_count) = patch.hunk(h)?;
618 let mut lines = Vec::with_capacity(line_count);
619 for l in 0..line_count {
620 let line = patch.line_in_hunk(h, l)?;
621 let kind = match line.origin() {
622 '-' => LineKind::Deleted,
623 '+' => LineKind::Added,
624 ' ' => LineKind::Context,
625 _ => continue,
627 };
628 let text = String::from_utf8_lossy(line.content())
629 .trim_end_matches(['\n', '\r'])
630 .to_owned();
631 lines.push(DiffLine::new(
632 kind,
633 line.old_lineno(),
634 line.new_lineno(),
635 text,
636 ));
637 }
638 Ok(lines)
639}
640
641fn build_binary_file(diff: &git2::Diff<'_>, idx: usize) -> Option<FileDiff> {
642 let delta = diff.get_delta(idx)?;
643 Some(FileDiff {
644 path: delta_new_path(&delta),
645 old_path: None,
646 status: map_status(delta.status()),
647 binary: true,
648 old_text: None,
649 new_text: None,
650 hunks: Vec::new(),
651 })
652}
653
654fn delta_new_path(delta: &git2::DiffDelta<'_>) -> String {
655 delta
656 .new_file()
657 .path()
658 .or_else(|| delta.old_file().path())
659 .map(|p| p.to_string_lossy().into_owned())
660 .unwrap_or_default()
661}
662
663fn map_status(status: git2::Delta) -> FileStatus {
664 match status {
665 git2::Delta::Added => FileStatus::Added,
666 git2::Delta::Deleted => FileStatus::Deleted,
667 git2::Delta::Renamed => FileStatus::Renamed,
668 git2::Delta::Untracked => FileStatus::Untracked,
669 _ => FileStatus::Modified,
670 }
671}
672
673fn blob_text(repo: &git2::Repository, oid: git2::Oid) -> Option<String> {
674 if oid.is_zero() {
675 return None;
676 }
677 let blob = repo.find_blob(oid).ok()?;
678 if blob.is_binary() {
679 return None;
680 }
681 String::from_utf8(blob.content().to_vec()).ok()
682}
683
684fn new_side_text(
687 repo: &git2::Repository,
688 delta: &git2::DiffDelta<'_>,
689 rel: &str,
690) -> Option<String> {
691 if delta.status() == git2::Delta::Deleted {
692 return None;
693 }
694 if let Some(text) = blob_text(repo, delta.new_file().id()) {
695 return Some(text);
696 }
697 let root = repo.workdir()?;
698 fs::read_to_string(root.join(rel)).ok()
699}