webthing 0.15.2

use serde_json;
use serde_json::json;
use std::marker::{Send, Sync};

use super::utils::timestamp;

/// High-level Event trait.
pub trait Event: Send + Sync {
    /// Get the event description.
    ///
    /// Returns a JSON map describing the event.
    fn as_event_description(&self) -> serde_json::Map<String, serde_json::Value> {
        let mut description = serde_json::Map::new();
        let mut inner = serde_json::Map::new();
        inner.insert("timestamp".to_string(), json!(self.get_time()));

        let data = self.get_data();
        if data.is_some() {
            inner.insert("data".to_string(), json!(data));
        }

        description.insert(self.get_name(), json!(inner));
        description
    }

    /// Get the event's name.
    fn get_name(&self) -> String;

    /// Get the event's data.
    fn get_data(&self) -> Option<serde_json::Value>;

    /// Get the event's timestamp.
    fn get_time(&self) -> String;
}

/// Basic event implementation.
///
/// An Event represents an individual event from a thing.
///
/// This can easily be used by other events to handle most of the boring work.
pub struct BaseEvent {
    name: String,
    data: Option<serde_json::Value>,
    time: String,
}

impl BaseEvent {
    /// Create a new BaseEvent.
    pub fn new(name: String, data: Option<serde_json::Value>) -> Self {
        Self {
            name,
            data,
            time: timestamp(),
        }
    }
}

impl Event for BaseEvent {
    /// Get the event's name.
    fn get_name(&self) -> String {
        self.name.clone()
    }

    /// Get the event's data.
    fn get_data(&self) -> Option<serde_json::Value> {
        self.data.clone()
    }

    /// Get the event's timestamp.
    fn get_time(&self) -> String {
        self.time.clone()
    }
}