intent-engine 0.11.1

A command-line database service for tracking strategic intent, tasks, and events
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
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156

/// Tests for CLI notifier functionality
/// Covers environment variable disabling and notification behavior
use intent_engine::dashboard::cli_notifier::{CliNotifier, NotificationMessage};

#[tokio::test]
async fn test_notifications_enabled_by_default() {
    // Ensure env var is not set
    std::env::remove_var("IE_DISABLE_DASHBOARD_NOTIFICATIONS");

    let notifier = CliNotifier::with_port(65001); // Use high port to avoid conflicts

    // Should not panic even if Dashboard is not running
    // (fire-and-forget behavior)
    notifier.notify_task_changed(Some(1), "created", None).await;

    // Test passes if no panic occurs
}

#[tokio::test]
async fn test_notifications_disabled_via_env_value_1() {
    // Set env var to "1"
    std::env::set_var("IE_DISABLE_DASHBOARD_NOTIFICATIONS", "1");

    let notifier = CliNotifier::with_port(65002);

    // Should return immediately without attempting connection
    notifier.notify_task_changed(Some(1), "created", None).await;

    // Cleanup
    std::env::remove_var("IE_DISABLE_DASHBOARD_NOTIFICATIONS");

    // Test passes if no panic occurs and returns quickly
}

#[tokio::test]
async fn test_notifications_disabled_via_env_value_true() {
    // Set env var to "true" (case-insensitive)
    std::env::set_var("IE_DISABLE_DASHBOARD_NOTIFICATIONS", "true");

    let notifier = CliNotifier::with_port(65003);

    // Should return immediately without attempting connection
    notifier.notify_task_changed(Some(1), "created", None).await;

    // Cleanup
    std::env::remove_var("IE_DISABLE_DASHBOARD_NOTIFICATIONS");
}

#[tokio::test]
async fn test_notifications_disabled_via_env_value_true_uppercase() {
    // Set env var to "TRUE" (case-insensitive check)
    std::env::set_var("IE_DISABLE_DASHBOARD_NOTIFICATIONS", "TRUE");

    let notifier = CliNotifier::with_port(65004);

    // Should return immediately without attempting connection
    notifier.notify_task_changed(Some(1), "created", None).await;

    // Cleanup
    std::env::remove_var("IE_DISABLE_DASHBOARD_NOTIFICATIONS");
}

#[tokio::test]
async fn test_notifications_not_disabled_with_other_values() {
    // Set env var to a value that should NOT disable notifications
    std::env::set_var("IE_DISABLE_DASHBOARD_NOTIFICATIONS", "0");

    let notifier = CliNotifier::with_port(65005);

    // Should attempt notification (but fail gracefully since Dashboard not running)
    notifier.notify_task_changed(Some(1), "created", None).await;

    // Cleanup
    std::env::remove_var("IE_DISABLE_DASHBOARD_NOTIFICATIONS");
}

#[tokio::test]
async fn test_notification_message_types() {
    std::env::remove_var("IE_DISABLE_DASHBOARD_NOTIFICATIONS");

    let notifier = CliNotifier::with_port(65006);

    // Test TaskChanged notification
    notifier
        .notify_task_changed(Some(42), "updated", Some("/test/path".to_string()))
        .await;

    // Test EventAdded notification
    notifier.notify_event_added(42, 1, None).await;

    // Test WorkspaceChanged notification
    notifier.notify_workspace_changed(Some(42), None).await;

    // Test direct notify with custom message
    let message = NotificationMessage::TaskChanged {
        task_id: Some(42),
        operation: "deleted".to_string(),
        project_path: Some("/test/path".to_string()),
    };
    notifier.notify(message).await;

    // All tests pass if no panic occurs
}

#[tokio::test]
async fn test_disabled_notifications_with_all_message_types() {
    std::env::set_var("IE_DISABLE_DASHBOARD_NOTIFICATIONS", "1");

    let notifier = CliNotifier::with_port(65007);

    // All of these should return immediately without attempting connection
    notifier
        .notify_task_changed(Some(42), "created", None)
        .await;
    notifier.notify_event_added(42, 1, None).await;
    notifier.notify_workspace_changed(Some(42), None).await;

    // Cleanup
    std::env::remove_var("IE_DISABLE_DASHBOARD_NOTIFICATIONS");
}

#[tokio::test]
async fn test_env_var_checked_per_notification() {
    std::env::remove_var("IE_DISABLE_DASHBOARD_NOTIFICATIONS");

    let notifier = CliNotifier::with_port(65008);

    // First notification should work (env var not set)
    notifier.notify_task_changed(Some(1), "created", None).await;

    // Set env var
    std::env::set_var("IE_DISABLE_DASHBOARD_NOTIFICATIONS", "1");

    // Second notification should be disabled
    notifier.notify_task_changed(Some(2), "created", None).await;

    // Unset env var
    std::env::remove_var("IE_DISABLE_DASHBOARD_NOTIFICATIONS");

    // Third notification should work again
    notifier.notify_task_changed(Some(3), "created", None).await;
}

#[test]
fn test_notifier_creation() {
    // Verify notifier can be created
    let _notifier = CliNotifier::new();
    // Test passes if no panic occurs
}

#[test]
fn test_notifier_with_custom_port() {
    // Verify notifier can be created with custom port
    let _notifier = CliNotifier::with_port(8080);
    // Test passes if no panic occurs
}