circus-evaluator 0.12.0

Nix evaluation support for Circus
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106

//! Tests for the git clone/fetch module.
//! Uses git2 to create a temporary repository, then exercises `clone_or_fetch`.
#![expect(clippy::unwrap_used, clippy::expect_used, reason = "Fine in tests")]

use git2::{Repository, Signature};
use tempfile::TempDir;

#[test]
fn test_clone_or_fetch_clones_new_repo() {
  let upstream_dir = TempDir::new().unwrap();
  let work_dir = TempDir::new().unwrap();

  // Create a non-bare repo to clone from (bare repos have no HEAD by default)
  let upstream = Repository::init(upstream_dir.path()).unwrap();
  // Create initial commit
  {
    let sig = Signature::now("Test", "test@example.com").unwrap();
    let tree_id = upstream.index().unwrap().write_tree().unwrap();
    let tree = upstream.find_tree(tree_id).unwrap();
    upstream
      .commit(Some("HEAD"), &sig, &sig, "initial", &tree, &[])
      .unwrap();
  }

  let url = format!("file://{}", upstream_dir.path().display());
  let result = circus_evaluator::git::clone_or_fetch(
    &url,
    work_dir.path(),
    "test-project",
    None,
  );

  assert!(
    result.is_ok(),
    "clone_or_fetch should succeed: {:?}",
    result.err()
  );
  let (repo_path, hash): (std::path::PathBuf, String) = result.unwrap();
  assert!(repo_path.exists());
  assert!(!hash.is_empty());
  assert_eq!(hash.len(), 40); // full SHA-1
}

#[test]
fn test_clone_or_fetch_fetches_existing() {
  let upstream_dir = TempDir::new().unwrap();
  let work_dir = TempDir::new().unwrap();

  let upstream = Repository::init(upstream_dir.path()).unwrap();
  {
    let sig = Signature::now("Test", "test@example.com").unwrap();
    let tree_id = upstream.index().unwrap().write_tree().unwrap();
    let tree = upstream.find_tree(tree_id).unwrap();
    upstream
      .commit(Some("HEAD"), &sig, &sig, "initial", &tree, &[])
      .unwrap();
  }

  let url = format!("file://{}", upstream_dir.path().display());

  // First clone
  let (_, hash1): (std::path::PathBuf, String) =
    circus_evaluator::git::clone_or_fetch(
      &url,
      work_dir.path(),
      "test-project",
      None,
    )
    .expect("first clone failed");

  // Make another commit upstream
  {
    let sig = Signature::now("Test", "test@example.com").unwrap();
    let tree_id = upstream.index().unwrap().write_tree().unwrap();
    let tree = upstream.find_tree(tree_id).unwrap();
    let head = upstream.head().unwrap().peel_to_commit().unwrap();
    upstream
      .commit(Some("HEAD"), &sig, &sig, "second", &tree, &[&head])
      .unwrap();
  }

  // Second fetch
  let (_, hash2): (std::path::PathBuf, String) =
    circus_evaluator::git::clone_or_fetch(
      &url,
      work_dir.path(),
      "test-project",
      None,
    )
    .expect("second fetch failed");

  assert!(!hash1.is_empty());
  assert!(!hash2.is_empty());
}

#[test]
fn test_clone_invalid_url_returns_error() {
  let work_dir = TempDir::new().unwrap();
  let result = circus_evaluator::git::clone_or_fetch(
    "file:///nonexistent/repo",
    work_dir.path(),
    "bad-proj",
    None,
  );
  assert!(result.is_err());
}