feat: Add cron-mon CLI command for creating new monitors (#85)

* feat: Add `cron-mon` CLI command for creating new monitors

* chore: Ignore binaries in code coverage

api/Makefile

@@ -25,7 +25,7 @@ test-coverage:
 	cargo llvm-cov \
         --no-clean \
         --show-missing-lines \
-        --ignore-filename-regex="src/infrastructure/db_schema.rs" \
+        --ignore-filename-regex="src/bin|src/infrastructure/db_schema.rs" \
         --fail-under-lines=95 \
         --jobs=3 \
         --lcov \

api/src/bin/cron_mon.rs

@@ -7,7 +7,9 @@ use std::sync::Arc;
 
 use clap::{Args, Parser, Subcommand};
 
-use cron_mon_api::application::services::get_process_late_jobs_service;
+use cron_mon_api::application::services::{
+    get_create_monitor_service, get_process_late_jobs_service,
+};
 use cron_mon_api::infrastructure::database::create_connection_pool;
 use cron_mon_api::infrastructure::logging::init_logging;
 
@@ -26,6 +28,9 @@ enum Command {
 
     /// Run the monitor.
     Monitor(MonitorArgs),
+
+    /// Create a new monitor.
+    CreateMonitor(CreateMonitorArgs),
 }
 
 #[derive(Args)]
@@ -35,6 +40,25 @@ struct MonitorArgs {
     interval: u64,
 }
 
+#[derive(Args)]
+struct CreateMonitorArgs {
+    /// The name of the monitor.
+    #[arg(short, long)]
+    name: String,
+
+    /// The expected duration of jobs monitored by this monitor, in seconds.
+    #[arg(short, long)]
+    expected: i32,
+
+    /// The grace duration for jobs monitored by this monitor, in seconds.
+    #[arg(short, long)]
+    grace: i32,
+
+    /// The tenant that the monitor is to belong to.
+    #[arg(short, long)]
+    tenant: String,
+}
+
 #[tokio::main]
 async fn main() {
     init_logging();
@@ -59,6 +83,14 @@ async fn main() {
             })
             .await;
         }
+        Command::CreateMonitor(args) => {
+            let pool = create_connection_pool().expect("Failed to create DB connection pool.");
+            let mut service = get_create_monitor_service(&pool);
+            service
+                .create_by_attributes(&args.tenant, &args.name, args.expected, args.grace)
+                .await
+                .expect("Failed to create monitor.");
+        }
     }
 }