//! Audit configuration and event tagging use nostr_sdk::prelude::*; use std::time::Duration; /// Audit configuration #[derive(Debug, Clone)] pub struct AuditConfig { /// Unique ID for this audit run pub run_id: String, /// Mode: CI (isolated) or Production (live) pub mode: AuditMode, /// Cleanup timestamp (events can be cleaned after this) pub cleanup_after: Timestamp, /// Whether to actually create events or just query pub read_only: bool, } /// Audit mode #[derive(Debug, Clone, Copy, PartialEq, Eq)] pub enum AuditMode { /// Isolated CI/CD tests - only see own events CI, /// Production audit - see all events, minimal writes Production, } impl AuditConfig { /// Create config for CI/CD testing pub fn ci() -> Self { let run_id = format!("ci-{}", uuid::Uuid::new_v4()); Self { run_id, mode: AuditMode::CI, cleanup_after: Timestamp::now() + 3600, // 1 hour from now read_only: false, } } /// Create config for production audit pub fn production() -> Self { let run_id = format!("prod-audit-{}", Timestamp::now().as_u64()); Self { run_id, mode: AuditMode::Production, cleanup_after: Timestamp::now() + 300, // 5 minutes from now read_only: true, // Default to read-only for production } } /// Create config with custom run ID pub fn with_run_id(run_id: String, mode: AuditMode) -> Self { Self { run_id, mode, cleanup_after: Timestamp::now() + 3600, read_only: mode == AuditMode::Production, } } /// Get audit tags for an event pub fn audit_tags(&self) -> Vec { vec![ Tag::custom( TagKind::Custom(std::borrow::Cow::Borrowed("grasp-audit")), vec!["true"] ), Tag::custom( TagKind::Custom(std::borrow::Cow::Borrowed("audit-run-id")), vec![self.run_id.clone()] ), Tag::custom( TagKind::Custom(std::borrow::Cow::Borrowed("audit-cleanup")), vec![self.cleanup_after.to_string()] ), ] } } /// Builder for audit events pub struct AuditEventBuilder { kind: Kind, content: String, tags: Vec, config: AuditConfig, } impl AuditEventBuilder { /// Create a new audit event builder pub fn new(kind: Kind, content: impl Into, config: AuditConfig) -> Self { Self { kind, content: content.into(), tags: Vec::new(), config, } } /// Add a tag pub fn tag(mut self, tag: Tag) -> Self { self.tags.push(tag); self } /// Add multiple tags pub fn tags(mut self, tags: Vec) -> Self { self.tags.extend(tags); self } /// Build the event with audit tags pub async fn build(self, keys: &Keys) -> anyhow::Result { let mut all_tags = self.tags; all_tags.extend(self.config.audit_tags()); let event = EventBuilder::new(self.kind, self.content, all_tags) .to_event(keys) .await?; Ok(event) } } #[cfg(test)] mod tests { use super::*; #[test] fn test_ci_config() { let config = AuditConfig::ci(); assert_eq!(config.mode, AuditMode::CI); assert!(!config.read_only); assert!(config.run_id.starts_with("ci-")); } #[test] fn test_production_config() { let config = AuditConfig::production(); assert_eq!(config.mode, AuditMode::Production); assert!(config.read_only); assert!(config.run_id.starts_with("prod-audit-")); } #[test] fn test_audit_tags() { let config = AuditConfig::ci(); let tags = config.audit_tags(); assert_eq!(tags.len(), 3); // Check grasp-audit tag assert!(tags.iter().any(|t| { matches!(t.kind(), TagKind::Custom(k) if k == "grasp-audit") })); // Check audit-run-id tag assert!(tags.iter().any(|t| { matches!(t.kind(), TagKind::Custom(k) if k == "audit-run-id") })); // Check audit-cleanup tag assert!(tags.iter().any(|t| { matches!(t.kind(), TagKind::Custom(k) if k == "audit-cleanup") })); } #[tokio::test] async fn test_audit_event_builder() { let config = AuditConfig::ci(); let keys = Keys::generate(); let event = AuditEventBuilder::new(Kind::TextNote, "test", config.clone()) .tag(Tag::custom(TagKind::Custom("test".into()), vec!["value"])) .build(&keys) .await .unwrap(); // Should have our custom tag + 3 audit tags assert!(event.tags.len() >= 4); // Verify event is valid assert!(event.verify().is_ok()); } }