ggen-domain 3.2.0

Domain logic layer for ggen - pure business logic without CLI dependencies
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48

//! Hook monitoring - domain logic
//!
//! Pure business logic for monitoring hooks.

use ggen_utils::error::Result;
use serde::{Deserialize, Serialize};

/// Arguments for monitoring hooks
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct MonitorInput {
    /// Graph to monitor
    pub graph: String,

    /// Monitoring interval in seconds
    pub interval: u64,

    /// Run once and exit (don't watch continuously)
    pub once: bool,
}

/// Execute monitor hooks with input (pure domain function)
pub async fn execute_monitor(input: MonitorInput) -> Result<MonitorResult> {
    use crate::hook::list::execute_list;
    use crate::hook::ListInput;

    // Load all hooks that match the graph
    let hooks = execute_list(ListInput {
        verbose: false,
        filter: Some(input.graph.clone()),
    })
    .await?;

    // For now, return basic monitoring status
    // Real implementation would watch file system and trigger hooks
    Ok(MonitorResult {
        active_hooks: hooks.len(),
        watching: 0, // Would be file count in real implementation
        hooks,
    })
}

/// Monitor result
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct MonitorResult {
    pub active_hooks: usize,
    pub watching: usize,
    pub hooks: Vec<crate::hook::list::HookInfo>,
}