sjl 0.7.0

use serde::{Serialize, ser::SerializeMap};
use serde_json::{Map, Value};

use crate::timestamp::FormattedTimestamp;

pub(crate) struct LogEvent<'a, Data: Serialize> {
    pub(crate) timestamp: FormattedTimestamp,
    pub(crate) timestamp_key: &'a str,
    pub(crate) level: &'a str,
    pub(crate) message: &'a str,
    pub(crate) context: &'a Map<String, Value>,
    pub(crate) data: Option<&'a Data>,
}

impl<'a, Data: Serialize> Serialize for LogEvent<'a, Data> {
    fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
    where
        S: serde::Serializer,
    {
        // Determine the size first
        let len = 3 + self.context.len() + self.data.is_some() as usize;
        let mut map = serializer.serialize_map(Some(len))?;

        map.serialize_entry(self.timestamp_key, &self.timestamp)?;
        map.serialize_entry("level", self.level)?;
        map.serialize_entry("message", self.message)?;

        // Flatten context keys
        for (k, v) in self.context {
            map.serialize_entry(k, v)?;
        }

        // Don't show null data if nothing is there, just omit it
        if let Some(data) = self.data {
            map.serialize_entry("data", data)?;
        }

        map.end()
    }
}

#[cfg(test)]
mod tests {
    use serde::{Deserialize, Serialize};
    use serde_json::{Map, Value, json};
    #[derive(Serialize, Deserialize)]
    enum UserType {
        Basic,
        Admin { access: String },
    }

    #[derive(Serialize, Deserialize)]
    struct User {
        name: String,
        user_type: UserType,
    }

    use crate::{
        LogLevel,
        log_event::LogEvent,
        timestamp::{DEFAULT_TS_FORMAT, FormattedTimestamp},
    };

    #[test]
    fn test_serializes() {
        let user = User {
            name: "user1".to_string(),
            user_type: UserType::Admin {
                access: "full".to_string(),
            },
        };
        let mut test_map = Map::new();
        test_map.insert("test_map".to_string(), Value::String("test_value".into()));
        test_map.insert("user".to_string(), serde_json::to_value(user).unwrap());

        let ts = FormattedTimestamp::new(Some(DEFAULT_TS_FORMAT));
        let event = LogEvent {
            level: LogLevel::Info.as_str(),
            message: "Saul Goodman",
            timestamp: ts,
            timestamp_key: "poop",
            data: Some(&json!({"sample_key": "sample_data"})),
            context: &test_map,
        };

        let result = serde_json::to_string(&event).unwrap();
        let parsed_result: serde_json::Value = serde_json::from_str(&result).unwrap();

        assert!(result.contains("\"level\":\"info\""));
        assert!(result.contains("\"message\":\"Saul Goodman\""));
        assert!(result.contains("\"sample_key\":\"sample_data\""));
        assert!(result.contains("\"test_map\":\"test_value\""));
        assert!(parsed_result["data"].is_object());
        assert_eq!(parsed_result["data"]["sample_key"], "sample_data");
        assert!(parsed_result["poop"].as_str().unwrap().ends_with("Z"));

        println!("{}", parsed_result);
        assert_eq!(
            parsed_result["user"]["user_type"]["Admin"]["access"],
            "full"
        );
    }

    #[test]
    fn test_omits_custom_data_when_none() {
        let event: LogEvent<()> = LogEvent {
            level: LogLevel::Info.as_str(),
            message: "Saul Goodman",
            timestamp: FormattedTimestamp::new(None),
            data: None,
            context: &Map::new(),
            timestamp_key: "timestamp",
        };

        let result = serde_json::to_string(&event).unwrap();
        let parsed_result: serde_json::Value = serde_json::from_str(&result).unwrap();
        assert!(parsed_result.get("data").is_none())
    }
}