use crate::{Config, ContainerConfig, Server};
use derive_builder::Builder;
use dockertest::{PullPolicy, Source};
use std::collections::HashMap;
const IMAGE: &str = "ghcr.io/navikt/mock-oauth2-server";
const PORT: u32 = 8080;
const LOG_MSG: &str = "started server on address";
const SOURCE: Source = Source::DockerHub(PullPolicy::IfNotPresent);
#[derive(Clone, Default, Builder)]
#[builder(default)]
pub struct OIDCServerConfig {
#[builder(default = "Vec::new()")]
pub args: Vec<String>,
#[builder(default = "HashMap::new()")]
pub env: HashMap<String, String>,
#[builder(default = "crate::server::new_handle(IMAGE)")]
pub handle: String,
#[builder(default = "8200")]
pub port: u32,
#[builder(default = "15")]
pub timeout: u16,
#[builder(default = "String::from(\"0.3.5\")")]
pub version: String,
}
impl OIDCServerConfig {
pub fn builder() -> OIDCServerConfigBuilder {
OIDCServerConfigBuilder::default()
}
}
impl Config for OIDCServerConfig {
fn into_composition(self) -> dockertest::Composition {
let ports = vec![(PORT, self.port)];
ContainerConfig {
args: self.args,
env: self.env,
handle: self.handle,
name: IMAGE.into(),
source: SOURCE,
timeout: self.timeout,
version: self.version,
ports: Some(ports),
wait_msg: Some(LOG_MSG.into()),
}
.into()
}
fn handle(&self) -> &str {
self.handle.as_str()
}
}
pub struct OIDCServer {
pub address: String,
pub local_address: String,
pub port: u32,
}
impl Server for OIDCServer {
type Config = OIDCServerConfig;
fn new(config: &Self::Config, container: &dockertest::RunningContainer) -> Self {
OIDCServer {
address: format!("http://{}:{}", container.ip(), config.port),
local_address: format!("http://localhost:{}", config.port),
port: config.port,
}
}
}
#[cfg(test)]
mod tests {
use super::{OIDCServer, OIDCServerConfig};
use crate::Test;
use test_env_log::test;
#[test]
fn test_oidc() {
let config = OIDCServerConfig::builder().port(8090).build().unwrap();
let mut test = Test::new();
test.register(config);
test.run(|instance| async move {
let server: OIDCServer = instance.server();
let client = reqwest::Client::new();
let resp = client
.get(format!(
"{}/default/.well-known/openid-configuration",
server.local_address
))
.send()
.await;
assert!(resp.is_ok());
assert_eq!(resp.unwrap().status(), 200);
});
}
}