nika 0.35.4

Semantic YAML workflow engine for AI tasks - DAG execution, MCP integration, multi-provider LLM support
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89

//! Notification System Types
//!
//! Types for the TUI notification system (TIER 3.4).

// ═══════════════════════════════════════════
// NOTIFICATION LEVEL
// ═══════════════════════════════════════════

/// Notification severity level
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum NotificationLevel {
    /// Informational (workflow complete, etc.)
    Info,
    /// Warning (task slow, high token usage)
    Warning,
    /// Alert (critical issues)
    Alert,
    /// Success (workflow completed successfully)
    Success,
    /// Error (workflow failed)
    Error,
}

impl NotificationLevel {
    /// Get icon for this level
    pub fn icon(&self) -> &'static str {
        match self {
            NotificationLevel::Info => "ℹ",
            NotificationLevel::Warning => "⚠",
            NotificationLevel::Alert => "🔔",
            NotificationLevel::Success => "✓",
            NotificationLevel::Error => "✗",
        }
    }
}

// ═══════════════════════════════════════════
// NOTIFICATION
// ═══════════════════════════════════════════

/// A system notification (TIER 3.4)
#[derive(Debug, Clone)]
pub struct Notification {
    /// Notification level/severity
    pub level: NotificationLevel,
    /// Notification message
    pub message: String,
    /// Timestamp (ms since workflow start)
    pub timestamp_ms: u64,
    /// Whether this notification has been dismissed
    pub dismissed: bool,
}

impl Notification {
    /// Create a new notification
    pub fn new(level: NotificationLevel, message: impl Into<String>, timestamp_ms: u64) -> Self {
        Self {
            level,
            message: message.into(),
            timestamp_ms,
            dismissed: false,
        }
    }

    /// Create an info notification
    pub fn info(message: impl Into<String>, timestamp_ms: u64) -> Self {
        Self::new(NotificationLevel::Info, message, timestamp_ms)
    }

    /// Create a warning notification
    pub fn warning(message: impl Into<String>, timestamp_ms: u64) -> Self {
        Self::new(NotificationLevel::Warning, message, timestamp_ms)
    }

    /// Create an alert notification
    pub fn alert(message: impl Into<String>, timestamp_ms: u64) -> Self {
        Self::new(NotificationLevel::Alert, message, timestamp_ms)
    }

    /// Create a success notification
    pub fn success(message: impl Into<String>, timestamp_ms: u64) -> Self {
        Self::new(NotificationLevel::Success, message, timestamp_ms)
    }

    /// Create an error notification
    pub fn error(message: impl Into<String>, timestamp_ms: u64) -> Self {
        Self::new(NotificationLevel::Error, message, timestamp_ms)
    }
}