pkgcruft-git 0.0.5

QA support for verifying git commits via pkgcruft
Documentation 
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

use pkgcraft::repo::ebuild::EbuildRepoBuilder;
use pkgcruft_git::service::PkgcruftServiceBuilder;
use tempfile::NamedTempFile;
use tokio::process::Command;

use crate::git::GitRepo;

#[tokio::test]
async fn uds() {
    let repo = EbuildRepoBuilder::new().name("repo").build().unwrap();
    GitRepo::init(&repo).unwrap();
    let tmp = NamedTempFile::new().unwrap();
    let socket = tmp.path().to_str().unwrap();

    // try connecting specific and default socket path
    for socket in [Some(socket), None] {
        let mut service = PkgcruftServiceBuilder::new(repo.path());
        if let Some(value) = socket {
            service = service.socket(value);
        }

        service.spawn().await.unwrap();
        let ver = env!("CARGO_PKG_VERSION");
        let expected = format!("client: {ver}, server: {ver}\n");

        let mut cmd = Command::new(env!("CARGO_BIN_EXE_pkgcruft-git"));
        if let Some(value) = socket {
            cmd.args(["-c", value]);
        }
        cmd.arg("version");
        let output = cmd.output().await.unwrap();
        let data = String::from_utf8(output.stdout).unwrap();
        assert_eq!(data, expected);
    }
}

#[tokio::test]
async fn tcp() {
    let repo = EbuildRepoBuilder::new().name("repo").build().unwrap();
    GitRepo::init(&repo).unwrap();

    for addr in ["127.0.0.1:0", "[::]:0"] {
        let service = PkgcruftServiceBuilder::new(repo.path())
            .socket(addr)
            .spawn()
            .await
            .unwrap();
        let url = format!("http://{}", &service.socket);

        let ver = env!("CARGO_PKG_VERSION");
        let expected = format!("client: {ver}, server: {ver}\n");

        // verify both raw socket and url args work
        for serve_addr in [&service.socket, &url] {
            let mut cmd = Command::new(env!("CARGO_BIN_EXE_pkgcruft-git"));
            cmd.arg("-c");
            cmd.arg(serve_addr);
            cmd.arg("version");
            let output = cmd.output().await.unwrap();
            let data = String::from_utf8(output.stdout).unwrap();
            assert_eq!(data, expected);
        }
    }
}

#[tokio::test]
async fn scan() {
    let mut repo = EbuildRepoBuilder::new().name("repo").build().unwrap();
    git2::Repository::init(repo.path()).unwrap();

    let tmp = NamedTempFile::new().unwrap();
    let socket = tmp.path().to_str().unwrap();
    let _service = PkgcruftServiceBuilder::new(repo.path())
        .socket(socket)
        .spawn()
        .await
        .unwrap();

    // empty repo
    let mut cmd = Command::new(env!("CARGO_BIN_EXE_pkgcruft-git"));
    cmd.args(["-c", socket]);
    cmd.arg("scan");
    let output = cmd.output().await.unwrap();
    let data = String::from_utf8(output.stdout).unwrap();
    assert_eq!(data, "");

    // invalid pkg
    repo.create_ebuild("cat/pkg-1", &["EAPI=invalid"]).unwrap();
    let mut cmd = Command::new(env!("CARGO_BIN_EXE_pkgcruft-git"));
    cmd.args(["-c", socket]);
    cmd.arg("scan");
    let output = cmd.output().await.unwrap();
    let data = String::from_utf8(output.stdout).unwrap();
    let expected = indoc::indoc! {"
        cat/pkg
          MetadataError: version 1: unsupported EAPI: invalid
    "};
    assert_eq!(data, expected);
}