forked from kemitix/git-next
tests: add more tests to config crate
This commit is contained in:
parent
9462957c5e
commit
1010eaec64
5 changed files with 269 additions and 74 deletions
|
@ -93,3 +93,4 @@ tokio = { version = "1.37" }
|
||||||
|
|
||||||
# Testing
|
# Testing
|
||||||
assert2 = "0.3"
|
assert2 = "0.3"
|
||||||
|
pretty_assertions = "1.4"
|
||||||
|
|
|
@ -56,6 +56,7 @@ actix = { workspace = true }
|
||||||
[dev-dependencies]
|
[dev-dependencies]
|
||||||
# # Testing
|
# # Testing
|
||||||
assert2 = { workspace = true }
|
assert2 = { workspace = true }
|
||||||
|
pretty_assertions = { workspace = true }
|
||||||
|
|
||||||
[lints.clippy]
|
[lints.clippy]
|
||||||
nursery = { level = "warn", priority = -1 }
|
nursery = { level = "warn", priority = -1 }
|
||||||
|
|
|
@ -459,19 +459,103 @@ mod server {
|
||||||
mod load {
|
mod load {
|
||||||
//
|
//
|
||||||
|
|
||||||
use std::collections::{BTreeMap, HashMap};
|
use std::{
|
||||||
|
collections::{BTreeMap, HashMap},
|
||||||
|
net::SocketAddr,
|
||||||
|
str::FromStr as _,
|
||||||
|
};
|
||||||
|
|
||||||
use assert2::let_assert;
|
use assert2::let_assert;
|
||||||
|
use pretty_assertions::assert_eq;
|
||||||
|
|
||||||
use crate::{
|
use crate::{
|
||||||
server::{Http, ServerConfig, ServerStorage, Webhook},
|
server::{Http, ServerConfig, ServerStorage, Webhook},
|
||||||
tests::TestResult,
|
tests::TestResult,
|
||||||
ForgeConfig, ForgeType, RepoBranches, RepoConfig, RepoConfigSource, ServerRepoConfig,
|
ForgeAlias, ForgeConfig, ForgeType, RepoAlias, RepoBranches, RepoConfig,
|
||||||
|
RepoConfigSource, ServerRepoConfig,
|
||||||
};
|
};
|
||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
fn load_should_parse_server_config() -> TestResult {
|
fn load_should_parse_server_config() -> TestResult {
|
||||||
let fs = kxio::fs::temp()?;
|
let fs = kxio::fs::temp()?;
|
||||||
|
given_server_config(&fs)?;
|
||||||
|
let_assert!(Ok(config) = ServerConfig::load(&fs));
|
||||||
|
let expected = ServerConfig::new(
|
||||||
|
Http::new("0.0.0.0".to_string(), 8080),
|
||||||
|
expected_webhook(),
|
||||||
|
expected_storage(),
|
||||||
|
HashMap::from([("default".to_string(), expected_forge_config())]),
|
||||||
|
);
|
||||||
|
assert_eq!(config, expected, "ServerConfig");
|
||||||
|
|
||||||
|
if let Some(forge) = config.forge.get("world") {
|
||||||
|
if let Some(repo) = forge.get_repo("sam") {
|
||||||
|
let repo_config = repo.repo_config();
|
||||||
|
let expected = Some(RepoConfig::new(
|
||||||
|
RepoBranches::new(
|
||||||
|
"master".to_string(),
|
||||||
|
"upcoming".to_string(),
|
||||||
|
"sam-dev".to_string(),
|
||||||
|
),
|
||||||
|
RepoConfigSource::Server,
|
||||||
|
));
|
||||||
|
assert_eq!(repo_config, expected, "RepoConfig");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
#[test]
|
||||||
|
fn should_return_forges() -> TestResult {
|
||||||
|
let fs = kxio::fs::temp()?;
|
||||||
|
given_server_config(&fs)?;
|
||||||
|
let config = ServerConfig::load(&fs)?;
|
||||||
|
let forges = config.forges().collect::<Vec<_>>();
|
||||||
|
let forge_config = expected_forge_config();
|
||||||
|
let expected = vec![(ForgeAlias::new("default".to_string()), &forge_config)];
|
||||||
|
assert_eq!(forges, expected);
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
#[test]
|
||||||
|
fn should_return_storage() -> TestResult {
|
||||||
|
let fs = kxio::fs::temp()?;
|
||||||
|
given_server_config(&fs)?;
|
||||||
|
let config = ServerConfig::load(&fs)?;
|
||||||
|
let storage = config.storage();
|
||||||
|
assert_eq!(storage, &expected_storage());
|
||||||
|
assert_eq!(storage.path(), std::path::Path::new("/opt/git-next/data"));
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
#[test]
|
||||||
|
fn should_return_webhook() -> TestResult {
|
||||||
|
let fs = kxio::fs::temp()?;
|
||||||
|
given_server_config(&fs)?;
|
||||||
|
let config = ServerConfig::load(&fs)?;
|
||||||
|
let webhook = config.webhook();
|
||||||
|
assert_eq!(webhook, &expected_webhook());
|
||||||
|
assert_eq!(
|
||||||
|
webhook
|
||||||
|
.url(&ForgeAlias::new("a".to_string()), &RepoAlias::new("b"))
|
||||||
|
.as_ref(),
|
||||||
|
"http://localhost:9909/a/b"
|
||||||
|
);
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
#[test]
|
||||||
|
fn should_return_http() -> TestResult {
|
||||||
|
let fs = kxio::fs::temp()?;
|
||||||
|
given_server_config(&fs)?;
|
||||||
|
let config = ServerConfig::load(&fs)?;
|
||||||
|
let_assert!(Ok(http) = config.http());
|
||||||
|
assert_eq!(http, expected_http());
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
fn given_server_config(fs: &kxio::fs::FileSystem) -> Result<(), kxio::fs::Error> {
|
||||||
fs.file_write(
|
fs.file_write(
|
||||||
&fs.base().join("git-next-server.toml"),
|
&fs.base().join("git-next-server.toml"),
|
||||||
r#"
|
r#"
|
||||||
|
@ -480,7 +564,7 @@ mod server {
|
||||||
port = 8080
|
port = 8080
|
||||||
|
|
||||||
[webhook]
|
[webhook]
|
||||||
url = "http://localhost:9909/webhook"
|
url = "http://localhost:9909"
|
||||||
|
|
||||||
[storage]
|
[storage]
|
||||||
path = "/opt/git-next/data"
|
path = "/opt/git-next/data"
|
||||||
|
@ -503,14 +587,21 @@ mod server {
|
||||||
dev = "sam-dev"
|
dev = "sam-dev"
|
||||||
"#,
|
"#,
|
||||||
)
|
)
|
||||||
?;
|
}
|
||||||
let_assert!(Ok(config) = ServerConfig::load(&fs));
|
|
||||||
let expected = ServerConfig::new(
|
fn expected_storage() -> ServerStorage {
|
||||||
Http::new("0.0.0.0".to_string(), 8080),
|
ServerStorage::new("/opt/git-next/data".into())
|
||||||
Webhook::new("http://localhost:9909/webhook".to_string()),
|
}
|
||||||
ServerStorage::new("/opt/git-next/data".into()),
|
|
||||||
HashMap::from([(
|
fn expected_webhook() -> Webhook {
|
||||||
"default".to_string(),
|
Webhook::new("http://localhost:9909".to_string())
|
||||||
|
}
|
||||||
|
|
||||||
|
fn expected_http() -> SocketAddr {
|
||||||
|
SocketAddr::from_str("0.0.0.0:8080").unwrap_or_else(|_| panic!())
|
||||||
|
}
|
||||||
|
|
||||||
|
fn expected_forge_config() -> ForgeConfig {
|
||||||
ForgeConfig::new(
|
ForgeConfig::new(
|
||||||
ForgeType::MockForge,
|
ForgeType::MockForge,
|
||||||
"git.example.net".to_string(),
|
"git.example.net".to_string(),
|
||||||
|
@ -551,27 +642,130 @@ mod server {
|
||||||
),
|
),
|
||||||
),
|
),
|
||||||
]),
|
]),
|
||||||
),
|
)
|
||||||
)]),
|
}
|
||||||
);
|
}
|
||||||
assert_eq!(config, expected, "ServerConfig");
|
}
|
||||||
|
mod registered_webhook {
|
||||||
|
|
||||||
if let Some(forge) = config.forge.get("world") {
|
use crate::{RegisteredWebhook, WebhookAuth, WebhookId};
|
||||||
if let Some(repo) = forge.get_repo("sam") {
|
|
||||||
let repo_config = repo.repo_config();
|
#[test]
|
||||||
let expected = Some(RepoConfig::new(
|
fn should_return_id() {
|
||||||
|
let id = WebhookId::new("a".to_string());
|
||||||
|
let auth = WebhookAuth::generate();
|
||||||
|
let rw = RegisteredWebhook::new(id.clone(), auth);
|
||||||
|
|
||||||
|
assert_eq!(rw.id(), &id);
|
||||||
|
}
|
||||||
|
#[test]
|
||||||
|
fn should_return_auth() {
|
||||||
|
let id = WebhookId::new("a".to_string());
|
||||||
|
let auth = WebhookAuth::generate();
|
||||||
|
let rw = RegisteredWebhook::new(id, auth.clone());
|
||||||
|
|
||||||
|
assert_eq!(rw.auth(), &auth);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
mod webhook {
|
||||||
|
mod message {
|
||||||
|
use crate::{webhook::message::Body, ForgeAlias, RepoAlias, WebhookMessage};
|
||||||
|
|
||||||
|
#[test]
|
||||||
|
fn should_return_forge_alias() {
|
||||||
|
let message = given_message();
|
||||||
|
assert_eq!(message.forge_alias(), &expected_forge_alias());
|
||||||
|
}
|
||||||
|
#[test]
|
||||||
|
fn should_return_repo_alias() {
|
||||||
|
let message = given_message();
|
||||||
|
assert_eq!(message.repo_alias(), &expected_repo_alias());
|
||||||
|
}
|
||||||
|
#[test]
|
||||||
|
fn should_return_body() {
|
||||||
|
let message = given_message();
|
||||||
|
assert_eq!(message.body().as_bytes(), expected_body().as_bytes());
|
||||||
|
}
|
||||||
|
#[test]
|
||||||
|
fn should_return_header() {
|
||||||
|
let message = given_message();
|
||||||
|
assert_eq!(message.header("c"), Some("d".to_string()));
|
||||||
|
}
|
||||||
|
fn given_message() -> WebhookMessage {
|
||||||
|
WebhookMessage::new(
|
||||||
|
expected_forge_alias(),
|
||||||
|
expected_repo_alias(),
|
||||||
|
expected_headers(),
|
||||||
|
expected_body(),
|
||||||
|
)
|
||||||
|
}
|
||||||
|
fn expected_forge_alias() -> ForgeAlias {
|
||||||
|
ForgeAlias::new("a".to_string())
|
||||||
|
}
|
||||||
|
fn expected_repo_alias() -> RepoAlias {
|
||||||
|
RepoAlias::new("b")
|
||||||
|
}
|
||||||
|
fn expected_headers() -> std::collections::HashMap<String, String> {
|
||||||
|
[("c", "d"), ("e", "f")]
|
||||||
|
.into_iter()
|
||||||
|
.map(|(k, v)| (k.to_string(), v.to_string()))
|
||||||
|
.collect()
|
||||||
|
}
|
||||||
|
fn expected_body() -> Body {
|
||||||
|
Body::new("g".to_string())
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
mod push {
|
||||||
|
use crate::{
|
||||||
|
webhook::{push::Branch, Push},
|
||||||
|
BranchName, RepoBranches,
|
||||||
|
};
|
||||||
|
|
||||||
|
#[test]
|
||||||
|
fn should_return_main_branch() {
|
||||||
|
let repo_branches = given_repo_branches();
|
||||||
|
let push_event = given_push_event(repo_branches.main());
|
||||||
|
assert_eq!(push_event.branch(&repo_branches), Some(Branch::Main));
|
||||||
|
}
|
||||||
|
#[test]
|
||||||
|
fn should_return_next_branch() {
|
||||||
|
let repo_branches = given_repo_branches();
|
||||||
|
let push_event = given_push_event(repo_branches.next());
|
||||||
|
assert_eq!(push_event.branch(&repo_branches), Some(Branch::Next));
|
||||||
|
}
|
||||||
|
#[test]
|
||||||
|
fn should_return_dev_branch() {
|
||||||
|
let repo_branches = given_repo_branches();
|
||||||
|
let push_event = given_push_event(repo_branches.dev());
|
||||||
|
assert_eq!(push_event.branch(&repo_branches), Some(Branch::Dev));
|
||||||
|
}
|
||||||
|
#[test]
|
||||||
|
fn should_not_return_other_branches() {
|
||||||
|
let repo_branches = given_repo_branches();
|
||||||
|
let push_event = given_push_event(BranchName::new("foo"));
|
||||||
|
assert_eq!(push_event.branch(&repo_branches), None);
|
||||||
|
}
|
||||||
|
#[test]
|
||||||
|
fn should_return_sha() {
|
||||||
|
let repo_branches = given_repo_branches();
|
||||||
|
let push_event = given_push_event(repo_branches.main());
|
||||||
|
assert_eq!(push_event.sha(), "sha");
|
||||||
|
}
|
||||||
|
#[test]
|
||||||
|
fn should_return_message() {
|
||||||
|
let repo_branches = given_repo_branches();
|
||||||
|
let push_event = given_push_event(repo_branches.main());
|
||||||
|
assert_eq!(push_event.message(), "message");
|
||||||
|
}
|
||||||
|
fn given_push_event(branch_name: BranchName) -> Push {
|
||||||
|
Push::new(branch_name, "sha".to_string(), "message".to_string())
|
||||||
|
}
|
||||||
|
fn given_repo_branches() -> RepoBranches {
|
||||||
RepoBranches::new(
|
RepoBranches::new(
|
||||||
"master".to_string(),
|
"a-main".to_string(),
|
||||||
"upcoming".to_string(),
|
"b-next".to_string(),
|
||||||
"sam-dev".to_string(),
|
"c-dev".to_string(),
|
||||||
),
|
)
|
||||||
RepoConfigSource::Server,
|
|
||||||
));
|
|
||||||
assert_eq!(repo_config, expected, "RepoConfig");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
Ok(())
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -31,7 +31,7 @@ impl Push {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug)]
|
#[derive(Debug, PartialEq, Eq)]
|
||||||
pub enum Branch {
|
pub enum Branch {
|
||||||
Main,
|
Main,
|
||||||
Next,
|
Next,
|
||||||
|
|
|
@ -3,7 +3,7 @@ addr = "0.0.0.0"
|
||||||
port = 8080
|
port = 8080
|
||||||
|
|
||||||
[webhook]
|
[webhook]
|
||||||
url = "https://localhost:8080"
|
url = "https://localhost:8080" # don't include any query path or a trailing slash
|
||||||
|
|
||||||
[storage]
|
[storage]
|
||||||
path = "./data"
|
path = "./data"
|
||||||
|
@ -15,7 +15,6 @@ forge_type = "ForgeJo"
|
||||||
hostname = "git.example.net"
|
hostname = "git.example.net"
|
||||||
user = "git-next" # the user to perform actions as
|
user = "git-next" # the user to perform actions as
|
||||||
token = "API-Token"
|
token = "API-Token"
|
||||||
# path to private SSH key for user?
|
|
||||||
|
|
||||||
[forge.default.repos]
|
[forge.default.repos]
|
||||||
hello = { repo = "user/hello", branch = "main", gitdir = "/opt/git/projects/user/hello.git" } # maps to https://git.example.net/user/hello on the branch 'main'
|
hello = { repo = "user/hello", branch = "main", gitdir = "/opt/git/projects/user/hello.git" } # maps to https://git.example.net/user/hello on the branch 'main'
|
||||||
|
|
Loading…
Reference in a new issue