|
|
|
|
| use serde::{Deserialize, Serialize};
|
|
|
|
|
| #[derive(Debug, Clone, Serialize, Deserialize)]
|
| pub struct TelemetryEvent {
|
| pub event_type: String,
|
| pub declaration_hash: String,
|
| pub timestamp: String,
|
| pub data: serde_json::Value,
|
| }
|
|
|
|
|
| pub struct Observatory {
|
| events: Vec<TelemetryEvent>,
|
| }
|
|
|
| impl Observatory {
|
| pub fn new() -> Self {
|
| Self {
|
| events: Vec::new(),
|
| }
|
| }
|
|
|
|
|
| pub fn record(&mut self, event_type: &str, declaration_hash: &str, data: serde_json::Value) {
|
| let event = TelemetryEvent {
|
| event_type: event_type.to_string(),
|
| declaration_hash: declaration_hash.to_string(),
|
| timestamp: chrono::Utc::now().to_rfc3339(),
|
| data,
|
| };
|
| self.events.push(event);
|
| }
|
|
|
|
|
| pub fn get_events(&self, declaration_hash: &str) -> Vec<&TelemetryEvent> {
|
| self.events
|
| .iter()
|
| .filter(|e| e.declaration_hash == declaration_hash)
|
| .collect()
|
| }
|
|
|
|
|
| pub fn all_events(&self) -> &[TelemetryEvent] {
|
| &self.events
|
| }
|
| }
|
|
|
