chore: collapse stack-up

1 files changed, 139 insertions, 0 deletions

diff --git a/lib/warden-stack/src/config.rs b/lib/warden-stack/src/config.rs
new file mode 100644
index 0000000..9f42f43
--- /dev/null
+++ b/lib/warden-stack/src/config.rs
@@ -0,0 +1,139 @@
+use serde::Deserialize;
+
+use std::{fmt::Display, sync::Arc};
+
+#[derive(Clone, Debug, Deserialize)]
+pub struct AppConfig {
+    #[serde(skip)]
+    pub name: Arc<str>,
+    #[serde(skip)]
+    pub version: Arc<str>,
+    #[serde(default)]
+    pub env: Environment,
+    #[cfg(feature = "api")]
+    #[serde(default = "default_port")]
+    pub port: u16,
+}
+
+#[cfg(feature = "api")]
+pub(crate) fn default_port() -> u16 {
+    2210
+}
+
+#[cfg(feature = "tracing")]
+pub(crate) fn default_log() -> String {
+    #[cfg(debug_assertions)]
+    return "debug".into();
+    #[cfg(not(debug_assertions))]
+    "info".into()
+}
+
+#[derive(Clone, Debug, Deserialize)]
+pub struct Configuration {
+    pub application: AppConfig,
+    #[cfg(feature = "postgres")]
+    pub database: crate::postgres::PostgresConfig,
+    #[cfg(feature = "cache")]
+    pub cache: crate::cache::CacheConfig,
+    #[serde(default)]
+    pub misc: serde_json::Value,
+    #[cfg(feature = "tracing")]
+    pub monitoring: Monitoring,
+    #[cfg(any(feature = "nats-core", feature = "nats-jetstream"))]
+    pub nats: crate::nats::NatsConfig,
+}
+
+#[derive(Clone, Debug, Deserialize)]
+pub struct Monitoring {
+    #[serde(rename = "log-level")]
+    #[cfg(feature = "tracing")]
+    #[serde(default = "default_log")]
+    pub log_level: String,
+    #[cfg(feature = "opentelemetry")]
+    #[serde(rename = "opentelemetry-endpoint")]
+    #[serde(default = "default_opentelemetry")]
+    pub opentelemetry_endpoint: Arc<str>,
+    #[cfg(feature = "tracing-loki")]
+    #[serde(rename = "loki-endpoint")]
+    #[serde(default = "default_loki")]
+    pub loki_endpoint: Arc<str>,
+}
+
+#[cfg(feature = "tracing-loki")]
+pub(crate) fn default_loki() -> Arc<str> {
+    "http://localhost:3100".into()
+}
+
+#[cfg(feature = "opentelemetry")]
+pub(crate) fn default_opentelemetry() -> Arc<str> {
+    "http://localhost:4317".into()
+}
+
+#[derive(Clone, Copy, Debug, Deserialize, PartialEq, Eq, Default)]
+#[cfg_attr(test, derive(serde::Serialize))]
+#[serde(rename_all = "lowercase")]
+pub enum Environment {
+    #[default]
+    Development,
+    Production,
+}
+
+impl Display for Environment {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        write!(
+            f,
+            "{}",
+            match self {
+                Environment::Development => "development",
+                Environment::Production => "production",
+            }
+        )
+    }
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    // Test that the enum is correctly serialized and deserialized
+    #[test]
+    fn test_environment_serialization() {
+        // Test serialization for Development
+        let dev = Environment::Development;
+        let dev_json = serde_json::to_string(&dev).unwrap();
+        assert_eq!(dev_json, "\"development\"");
+
+        // Test serialization for Production
+        let prod = Environment::Production;
+        let prod_json = serde_json::to_string(&prod).unwrap();
+        assert_eq!(prod_json, "\"production\"");
+
+        // Test deserialization for Development
+        let dev_str = "\"development\"";
+        let deserialized_dev: Environment = serde_json::from_str(dev_str).unwrap();
+        assert_eq!(deserialized_dev, Environment::Development);
+
+        // Test deserialization for Production
+        let prod_str = "\"production\"";
+        let deserialized_prod: Environment = serde_json::from_str(prod_str).unwrap();
+        assert_eq!(deserialized_prod, Environment::Production);
+    }
+
+    // Test Display implementation
+    #[test]
+    fn test_environment_display() {
+        let dev = Environment::Development;
+        assert_eq!(format!("{}", dev), "development");
+
+        let prod = Environment::Production;
+        assert_eq!(format!("{}", prod), "production");
+    }
+
+    #[test]
+    #[cfg(feature = "api")]
+    fn test_port() {
+        let listen_address =
+            std::net::SocketAddr::from((std::net::Ipv6Addr::UNSPECIFIED, default_port()));
+        assert_eq!(listen_address.port(), default_port());
+    }
+}