feat: add monitors CLI command (API parity)

src/agent_discovery.rs

@@ -578,4 +578,48 @@ const RESOURCE_SPECS: &[ResourceSpec] = &[
             "PUBLIC reports also mark their runs public.",
         ],
     },
+    ResourceSpec {
+        name: "monitors",
+        commands: &[
+            "context",
+            "list",
+            "get",
+            "create",
+            "update",
+            "delete",
+            "test-evaluate",
+            "events.list",
+        ],
+        description: "Monitors evaluate runs and dispatch alerts when configured conditions match.",
+        id_name: "monitor_id",
+        id_format: "Coval monitor ID",
+        requires: &["runs"],
+        optional: &["agents", "tags", "scheduled-runs"],
+        produces: &["monitor events", "alerts"],
+        related: &["runs", "metrics", "agents", "scheduled-runs"],
+        workflows: &[WorkflowSpec {
+            name: "Inspect monitors",
+            argv: &["monitors", "list"],
+        }],
+        pitfalls: &[
+            "Create requests require at least one condition.",
+            "Channel auth tokens are redacted in CLI output.",
+        ],
+    },
+    ResourceSpec {
+        name: "tags",
+        commands: &["context", "list", "get", "create", "update", "delete"],
+        description: "Tags label Coval resources for filtering, organization, and monitor targeting.",
+        id_name: "tag_id",
+        id_format: "Coval tag ID",
+        requires: &[],
+        optional: &["agents", "monitors"],
+        produces: &["resource labels"],
+        related: &["agents", "monitors"],
+        workflows: &[WorkflowSpec {
+            name: "Inspect tags",
+            argv: &["tags", "list"],
+        }],
+        pitfalls: &["Tag colors should be valid CSS-style color values when provided."],
+    },
 ];

src/cli.rs

@@ -114,6 +114,10 @@ pub enum Commands {
         #[command(subcommand)]
         command: commands::reports::ReportCommands,
     },
+    Monitors {
+        #[command(subcommand)]
+        command: commands::monitors::MonitorCommands,
+    },
     Tags {
         #[command(subcommand)]
         command: commands::tags::TagCommands,
@@ -149,6 +153,7 @@ impl Commands {
             Self::ReviewAnnotations { .. } => "review-annotations",
             Self::ReviewProjects { .. } => "review-projects",
             Self::Reports { .. } => "reports",
+            Self::Monitors { .. } => "monitors",
             Self::Tags { .. } => "tags",
         }
     }
@@ -176,6 +181,7 @@ impl Commands {
             Self::ReviewAnnotations { command } => command.operation(),
             Self::ReviewProjects { command } => command.operation(),
             Self::Reports { command } => command.operation(),
+            Self::Monitors { command } => command.operation(),
             Self::Tags { command } => command.operation(),
         }
     }
@@ -266,6 +272,9 @@ pub async fn run(cli: Cli, ctx: &OutputContext) -> anyhow::Result<()> {
         Commands::Reports {
             command: commands::reports::ReportCommands::Context,
         } => commands::agent::resource_context("reports", ctx),
+        Commands::Monitors {
+            command: commands::monitors::MonitorCommands::Context,
+        } => commands::agent::resource_context("monitors", ctx),
         Commands::Tags {
             command: commands::tags::TagCommands::Context,
         } => commands::agent::resource_context("tags", ctx),
@@ -327,6 +336,9 @@ pub async fn run(cli: Cli, ctx: &OutputContext) -> anyhow::Result<()> {
                 Commands::Reports { command } => {
                     commands::reports::execute(command, &client, ctx).await
                 }
+                Commands::Monitors { command } => {
+                    commands::monitors::execute(command, &client, ctx).await
+                }
                 Commands::Tags { command } => commands::tags::execute(command, &client, ctx).await,
                 _ => unreachable!(),
             }

src/client/mod.rs

@@ -216,6 +216,10 @@ impl CovalClient {
         }
     }
 
+    pub fn monitors(&self) -> MonitorsClient<'_> {
+        MonitorsClient(self)
+    }
+
     pub fn tags(&self) -> TagsClient<'_> {
         TagsClient(self)
     }
@@ -247,6 +251,8 @@ pub struct WidgetsClient<'a> {
 }
 pub struct TagsClient<'a>(&'a CovalClient);
 
+pub struct MonitorsClient<'a>(&'a CovalClient);
+
 impl AgentsClient<'_> {
     pub async fn list(
         &self,
@@ -1232,6 +1238,69 @@ impl WidgetsClient<'_> {
     }
 }
 
+impl MonitorsClient<'_> {
+    pub async fn list(
+        &self,
+        params: models::ListParams,
+    ) -> Result<models::ListMonitorsResponse, ApiError> {
+        let mut url = self.0.url("/v1/monitors");
+        params.apply_to(&mut url);
+        self.0.get(url).await
+    }
+
+    pub async fn get(&self, id: &str) -> Result<models::Monitor, ApiError> {
+        let url = self.0.url(&format!("/v1/monitors/{id}"));
+        let resp: models::GetMonitorResponse = self.0.get(url).await?;
+        Ok(resp.monitor)
+    }
+
+    pub async fn create(
+        &self,
+        req: models::CreateMonitorRequest,
+    ) -> Result<models::Monitor, ApiError> {
+        let url = self.0.url("/v1/monitors");
+        self.0.post(url, &req).await
+    }
+
+    pub async fn update(
+        &self,
+        id: &str,
+        req: models::UpdateMonitorRequest,
+    ) -> Result<models::Monitor, ApiError> {
+        let url = self.0.url(&format!("/v1/monitors/{id}"));
+        self.0.patch(url, &req).await
+    }
+
+    pub async fn delete(&self, id: &str) -> Result<(), ApiError> {
+        let url = self.0.url(&format!("/v1/monitors/{id}"));
+        self.0.delete(url).await
+    }
+
+    pub async fn test_evaluate(
+        &self,
+        monitor_id: &str,
+        run_id: &str,
+    ) -> Result<models::TestEvaluateResponse, ApiError> {
+        let url = self
+            .0
+            .url(&format!("/v1/monitors/{monitor_id}/test-evaluate"));
+        let req = models::TestEvaluateRequest {
+            run_id: run_id.to_string(),
+        };
+        self.0.post(url, &req).await
+    }
+
+    pub async fn list_events(
+        &self,
+        monitor_id: &str,
+        params: models::ListParams,
+    ) -> Result<models::ListMonitorEventsResponse, ApiError> {
+        let mut url = self.0.url(&format!("/v1/monitors/{monitor_id}/events"));
+        params.apply_to(&mut url);
+        self.0.get(url).await
+    }
+}
+
 impl TagsClient<'_> {
     pub async fn list(&self) -> Result<models::ListTagsResponse, ApiError> {
         let url = self.0.url("/v1/tags");

src/client/models/mod.rs

@@ -7,6 +7,7 @@ mod conversation;
 mod dashboard;
 mod metric;
 mod metric_model;
+mod monitor;
 mod mutation;
 mod persona;
 mod report;
@@ -28,6 +29,7 @@ pub use conversation::*;
 pub use dashboard::*;
 pub use metric::*;
 pub use metric_model::*;
+pub use monitor::*;
 pub use mutation::*;
 pub use persona::*;
 pub use report::*;