uptrakit-openapi-client 0.0.4

use crate::Result;
use crate::UptrakitClient;
use crate::types_impl::scheduler::{
    ScheduledTaskResponse, TriggerScheduledTaskResponse, UpdateScheduledTaskRequest,
};
use uuid::Uuid;

impl UptrakitClient {
    /// List all scheduled tasks.
    pub async fn list_scheduled_tasks(&self) -> Result<Vec<ScheduledTaskResponse>> {
        self.get(crate::paths::scheduler::BASE).await
    }

    /// Get a single scheduled task by ID.
    pub async fn get_scheduled_task(&self, id: &Uuid) -> Result<ScheduledTaskResponse> {
        self.get(&crate::paths::scheduler::by_id(id)).await
    }

    /// Update a scheduled task (interval, jitter, enabled state, or config).
    pub async fn update_scheduled_task(
        &self,
        id: &Uuid,
        req: &UpdateScheduledTaskRequest,
    ) -> Result<ScheduledTaskResponse> {
        self.put_json(&crate::paths::scheduler::by_id(id), req)
            .await
    }

    /// Trigger immediate execution of a scheduled task.
    pub async fn trigger_scheduled_task(&self, id: &Uuid) -> Result<TriggerScheduledTaskResponse> {
        self.post_empty(&crate::paths::scheduler::trigger(id)).await
    }
}

#[cfg(test)]
mod tests {
    use crate::types_impl::scheduler::UpdateScheduledTaskRequest;

    #[test]
    fn update_scheduled_task_request_serialization() {
        let req = UpdateScheduledTaskRequest {
            interval_seconds: Some(21600),
            jitter_seconds: Some(300),
            enabled: Some(true),
            task_config: None,
        };
        let json = serde_json::to_value(&req).expect("serialize");
        assert_eq!(json["interval_seconds"], 21600);
        assert_eq!(json["jitter_seconds"], 300);
        assert_eq!(json["enabled"], true);
    }

    #[test]
    fn update_scheduled_task_request_with_config() {
        let req = UpdateScheduledTaskRequest {
            interval_seconds: None,
            jitter_seconds: None,
            enabled: None,
            task_config: Some(serde_json::json!({"key": "value"})),
        };
        let json = serde_json::to_value(&req).expect("serialize");
        assert_eq!(json["task_config"]["key"], "value");
    }
}