Skip to main content

max / goingson

5.2 KB · 151 lines History Blame Raw
1 //! Integration tests for dashboard stats.
2
3 use chrono::{Duration, Utc};
4 use goingson_core::{DashboardStats, HighUrgencyTask, NewEvent, NewTask, Priority};
5
6 use crate::commands::stats::DashboardStatsResponse;
7 use crate::test_utils::{create_test_project, setup_test_state};
8
9 /// Computes the same UTC day windows the `get_dashboard_stats` command derives.
10 fn windows() -> (
11 chrono::DateTime<Utc>,
12 chrono::DateTime<Utc>,
13 chrono::DateTime<Utc>,
14 chrono::DateTime<Utc>,
15 ) {
16 let now = Utc::now();
17 let today = now.date_naive();
18 let midnight = |d: chrono::NaiveDate| d.and_hms_opt(0, 0, 0).unwrap().and_utc();
19 let today_start = midnight(today);
20 let tomorrow_start = midnight(today + Duration::days(1));
21 let week_end = midnight(today + Duration::days(8));
22 (now, today_start, tomorrow_start, week_end)
23 }
24
25 #[tokio::test]
26 async fn dashboard_counts_tasks_by_due_window() {
27 let (state, user_id) = setup_test_state().await;
28 let (now, today_start, tomorrow_start, week_end) = windows();
29
30 // Overdue: due 3 days ago.
31 let overdue = NewTask::builder("Overdue task")
32 .priority(Priority::High)
33 .due(now - Duration::days(3))
34 .build();
35 state.tasks.create(user_id, overdue).await.unwrap();
36
37 // Due this week (but not today): 3 days out.
38 let this_week = NewTask::builder("This week task")
39 .priority(Priority::Medium)
40 .due(now + Duration::days(3))
41 .build();
42 state.tasks.create(user_id, this_week).await.unwrap();
43
44 let stats = state
45 .stats
46 .get_dashboard_stats(user_id, now, today_start, tomorrow_start, week_end)
47 .await
48 .unwrap();
49
50 assert_eq!(stats.overdue_count, 1);
51 assert_eq!(stats.tasks_due_today, 0);
52 assert_eq!(stats.tasks_due_this_week, 1);
53 // No emails seeded.
54 assert_eq!(stats.unread_emails, 0);
55 }
56
57 #[tokio::test]
58 async fn dashboard_counts_projects_and_events() {
59 let (state, user_id) = setup_test_state().await;
60 let (now, today_start, tomorrow_start, week_end) = windows();
61
62 // create_test_project makes one Active project.
63 create_test_project(&state, user_id).await;
64
65 // Event within the 7-day window and one beyond it.
66 let soon = NewEvent::builder("Soon", now + Duration::days(2)).build();
67 state.events.create(user_id, soon).await.unwrap();
68 let far = NewEvent::builder("Far", now + Duration::days(30)).build();
69 state.events.create(user_id, far).await.unwrap();
70
71 let stats = state
72 .stats
73 .get_dashboard_stats(user_id, now, today_start, tomorrow_start, week_end)
74 .await
75 .unwrap();
76
77 assert_eq!(stats.active_projects, 1);
78 assert_eq!(stats.upcoming_events, 1);
79 }
80
81 #[tokio::test]
82 async fn dashboard_high_urgency_sorted_and_excludes_completed() {
83 let (state, user_id) = setup_test_state().await;
84 let (now, today_start, tomorrow_start, week_end) = windows();
85
86 for (desc, urgency) in [("low", 1.0), ("high", 9.0), ("mid", 5.0)] {
87 let t = NewTask::builder(desc)
88 .priority(Priority::Medium)
89 .urgency(urgency)
90 .build();
91 state.tasks.create(user_id, t).await.unwrap();
92 }
93 // A very urgent but completed task must not appear.
94 let done = NewTask::builder("done")
95 .priority(Priority::High)
96 .urgency(100.0)
97 .build();
98 let done = state.tasks.create(user_id, done).await.unwrap();
99 state.tasks.complete(done.id, user_id).await.unwrap();
100
101 let stats = state
102 .stats
103 .get_dashboard_stats(user_id, now, today_start, tomorrow_start, week_end)
104 .await
105 .unwrap();
106
107 assert_eq!(stats.high_urgency_tasks.len(), 3);
108 assert_eq!(stats.high_urgency_tasks[0].description, "high");
109 assert_eq!(stats.high_urgency_tasks[0].urgency, 9.0);
110 assert_eq!(stats.high_urgency_tasks[2].description, "low");
111 assert!(stats
112 .high_urgency_tasks
113 .iter()
114 .all(|t| t.description != "done"));
115 }
116
117 /// The response type renames fields (tasks_due_today -> dueTodayCount, etc.), so the
118 /// `From` mapping is where a wiring regression would hide.
119 #[tokio::test]
120 async fn response_conversion_maps_fields() {
121 let stats = DashboardStats {
122 tasks_due_today: 2,
123 tasks_due_this_week: 5,
124 overdue_count: 3,
125 unread_emails: 7,
126 upcoming_events: 4,
127 active_projects: 6,
128 high_urgency_tasks: vec![HighUrgencyTask {
129 id: "abc".to_string(),
130 description: "Ship it".to_string(),
131 urgency: 8.5,
132 status: "Pending".to_string(),
133 due: Some("2026-07-04T00:00:00Z".to_string()),
134 }],
135 };
136
137 let resp = DashboardStatsResponse::from(stats);
138
139 assert_eq!(resp.due_today_count, 2);
140 assert_eq!(resp.due_this_week_count, 5);
141 assert_eq!(resp.overdue_count, 3);
142 assert_eq!(resp.unread_emails, 7);
143 assert_eq!(resp.upcoming_events, 4);
144 assert_eq!(resp.active_projects, 6);
145 assert_eq!(resp.high_urgency_tasks.len(), 1);
146 assert_eq!(resp.high_urgency_tasks[0].id, "abc");
147 assert_eq!(resp.high_urgency_tasks[0].description, "Ship it");
148 assert_eq!(resp.high_urgency_tasks[0].urgency, 8.5);
149 assert_eq!(resp.high_urgency_tasks[0].due.as_deref(), Some("2026-07-04T00:00:00Z"));
150 }
151