intent_engine/dashboard/
models.rs

1use serde::{Deserialize, Serialize};
2use serde_json::Value;
3
4/// API response wrapper
5#[derive(Serialize)]
6pub struct ApiResponse<T> {
7    pub data: T,
8}
9
10/// API error response
11#[derive(Serialize)]
12pub struct ApiError {
13    pub code: String,
14    pub message: String,
15    #[serde(skip_serializing_if = "Option::is_none")]
16    pub details: Option<Value>,
17}
18
19/// Create task request
20#[derive(Deserialize)]
21pub struct CreateTaskRequest {
22    pub name: String,
23    #[serde(skip_serializing_if = "Option::is_none")]
24    pub spec: Option<String>,
25    #[serde(skip_serializing_if = "Option::is_none")]
26    pub priority: Option<i32>,
27    #[serde(skip_serializing_if = "Option::is_none")]
28    pub parent_id: Option<i64>,
29}
30
31/// Update task request
32#[derive(Deserialize)]
33pub struct UpdateTaskRequest {
34    #[serde(skip_serializing_if = "Option::is_none")]
35    pub name: Option<String>,
36    #[serde(skip_serializing_if = "Option::is_none")]
37    pub spec: Option<String>,
38    #[serde(skip_serializing_if = "Option::is_none")]
39    pub priority: Option<i32>,
40    #[serde(skip_serializing_if = "Option::is_none")]
41    pub status: Option<String>,
42}
43
44/// Create event request
45#[derive(Deserialize)]
46pub struct CreateEventRequest {
47    #[serde(rename = "type")]
48    pub event_type: String,
49    pub data: String,
50}
51
52/// Spawn subtask request
53#[derive(Deserialize)]
54pub struct SpawnSubtaskRequest {
55    pub name: String,
56    #[serde(skip_serializing_if = "Option::is_none")]
57    pub spec: Option<String>,
58}
59
60/// Query parameters for task list
61#[derive(Deserialize)]
62pub struct TaskListQuery {
63    #[serde(skip_serializing_if = "Option::is_none")]
64    pub status: Option<String>,
65    #[serde(skip_serializing_if = "Option::is_none")]
66    pub parent: Option<String>,
67}
68
69/// Query parameters for event list
70#[derive(Deserialize)]
71pub struct EventListQuery {
72    #[serde(skip_serializing_if = "Option::is_none")]
73    pub event_type: Option<String>,
74    #[serde(skip_serializing_if = "Option::is_none")]
75    pub since: Option<String>,
76    #[serde(skip_serializing_if = "Option::is_none")]
77    pub limit: Option<i32>,
78}
79
80/// Query parameters for search
81#[derive(Deserialize)]
82pub struct SearchQuery {
83    pub query: String,
84    #[serde(default = "default_true")]
85    pub include_tasks: bool,
86    #[serde(default = "default_true")]
87    pub include_events: bool,
88    #[serde(skip_serializing_if = "Option::is_none")]
89    pub limit: Option<i32>,
90}
91
92fn default_true() -> bool {
93    true
94}
95
96#[cfg(test)]
97mod tests {
98    use super::*;
99
100    #[test]
101    fn test_create_task_request_deserialization() {
102        let json = r#"{"name":"Test Task","spec":"Test spec","priority":1}"#;
103        let req: CreateTaskRequest = serde_json::from_str(json).unwrap();
104        assert_eq!(req.name, "Test Task");
105        assert_eq!(req.spec, Some("Test spec".to_string()));
106        assert_eq!(req.priority, Some(1));
107    }
108
109    #[test]
110    fn test_api_response_serialization() {
111        let response = ApiResponse { data: "test" };
112        let json = serde_json::to_string(&response).unwrap();
113        assert!(json.contains("\"data\""));
114    }
115
116    #[test]
117    fn test_api_error_serialization() {
118        let error = ApiError {
119            code: "TEST_ERROR".to_string(),
120            message: "Test message".to_string(),
121            details: None,
122        };
123        let json = serde_json::to_string(&error).unwrap();
124        assert!(json.contains("TEST_ERROR"));
125        assert!(!json.contains("details"));
126    }
127
128    #[test]
129    fn test_search_query_defaults() {
130        let json = r#"{"query":"test"}"#;
131        let query: SearchQuery = serde_json::from_str(json).unwrap();
132        assert_eq!(query.query, "test");
133        assert!(query.include_tasks);
134        assert!(query.include_events);
135    }
136}
intent_engine/dashboard/models.rs

intent_engine/dashboard/
models.rs
