moadim 3.6.2

Loop engine for AI agents — routines over REST, MCP, and a built-in web UI
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
49
50
51
52
53
54
55


/// Parse `args` (argv with the binary name stripped) and run the selected data subcommand against
/// the running server, returning the process exit code to surface.
///
/// On a clap parse error (bad flags, `--help`, `--version`) the formatted message is printed and the
/// matching code returned (`0` for help/version, `2` for a usage error), mirroring clap conventions
/// without aborting the process so the path stays unit-testable.
pub fn run(args: Vec<String>) -> i32 {
    match DataCli::try_parse_from(args) {
        Ok(cli) => dispatch(cli.command),
        Err(err) => {
            let _ = err.print();
            match err.kind() {
                clap::error::ErrorKind::DisplayHelp | clap::error::ErrorKind::DisplayVersion => 0,
                _ => 2,
            }
        }
    }
}

/// Route a parsed [`DataCommand`] to the matching REST call.
pub(crate) fn dispatch(command: DataCommand) -> i32 {
    match command {
        DataCommand::Routines(cmd) => dispatch_routine(*cmd),
        DataCommand::Schedule(ScheduleCmd::Trigger { id }) => request(
            "POST",
            &format!("{}/scheduled-trigger", routine_path(&id)),
            None,
        ),
        DataCommand::Enable { routine, json } => set_routine_enabled(&routine, true, None, json),
        DataCommand::Disable {
            routine,
            reason,
            json,
        } => set_routine_enabled(&routine, false, reason, json),
        DataCommand::Agents => request("GET", "/api/v1/agents", None),
        DataCommand::Export { out } => crate::export_import::run_export(out),
        DataCommand::Import {
            file,
            dry_run,
            force,
        } => crate::export_import::run_import(&file, dry_run, force),
        DataCommand::Lock { scope } => request(
            "POST",
            "/api/v1/routines/lock",
            Some(&serde_json::json!({ "scope": scope }).to_string()),
        ),
        DataCommand::Unlock { scope } => request(
            "DELETE",
            &format!("/api/v1/routines/lock?scope={scope}"),
            None,
        ),
        DataCommand::LockStatus => request("GET", "/api/v1/routines/lock", None),
    }
}