ccd-cli 1.0.0-beta.4

Bootstrap and validate Continuous Context Development repositories
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
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107

use std::process::ExitCode;

use anyhow::Result;

use crate::commands;
use crate::host_adapter;
use crate::mcp;
use crate::output::{self, OutputFormat};
use crate::paths;

pub(crate) fn host(command: crate::HostCommand, format: OutputFormat) -> Result<ExitCode> {
    match command {
        crate::HostCommand::Apply(args) => {
            let repo_path = paths::cli::resolve(&args.path)?;
            let report = commands::host::apply(
                &repo_path,
                args.profile.as_deref(),
                args.host.map(crate::RepoHostArg::into_host),
                args.force,
                args.with_launcher,
            )?;
            output::render_report(format, &report)
        }
    }
}

pub(crate) fn host_hook(args: crate::HostHookRunArgs, format: OutputFormat) -> Result<ExitCode> {
    let repo_path = paths::cli::resolve(&args.path)?;
    let profile_name = crate::profile::resolve(args.profile.as_deref())?;
    let host = crate::resolve_host_adapter_name(args.host.clone())?;
    let hook = args.hook.as_str();
    let hook_protocol_hook = if format == OutputFormat::HookProtocol {
        if host != "claude" {
            anyhow::bail!(
                "--output hook-protocol is only implemented for --host claude; host `{host}` is not supported in v1"
            );
        }
        let cli_hook = hook.replace('_', "-");
        commands::host::claude_event_for_hook(&cli_hook)?;
        Some(cli_hook)
    } else {
        None
    };
    let runtime_hints = crate::host_hook_runtime_hints(&args);
    let session_start = crate::host_hook_session_start_options(&args);
    let capture = crate::build_host_hook_capture(&args, &host, &runtime_hints)?;
    let report = host_adapter::run_hook(
        &repo_path,
        profile_name.as_str(),
        &host,
        hook,
        session_start,
        args.diagnostics,
        args.host_total_context_chars,
        args.attempt_outcome
            .map(crate::AttemptOutcomeArg::into_state_outcome),
        capture,
        args.protected_write.into_state_options(),
        runtime_hints,
    )?;

    if let Some(cli_hook) = hook_protocol_hook {
        let payload = commands::host::build_hook_protocol_payload(
            &cli_hook,
            commands::host::HookProtocolInputs {
                context: report.context(),
                session_boundary_action: report.session_boundary_action(),
            },
        )?;
        println!("{}", serde_json::to_string_pretty(&payload)?);
        return Ok(ExitCode::SUCCESS);
    }

    output::render_report(format, &report)
}

pub(crate) fn telemetry(
    command: crate::TelemetryCommand,
    format: OutputFormat,
) -> Result<ExitCode> {
    match command {
        crate::TelemetryCommand::Report(args) => {
            let repo_path = paths::cli::resolve(&args.path)?;
            let report =
                commands::telemetry::run_report(&repo_path, args.profile.as_deref(), args.limit)?;
            output::render_report(format, &report)
        }
    }
}

pub(crate) fn mcp_serve() -> Result<ExitCode> {
    mcp::serve()?;
    Ok(ExitCode::SUCCESS)
}

#[cfg(feature = "daemon")]
pub(crate) fn daemon(args: crate::DaemonArgs) -> Result<ExitCode> {
    let rt = tokio::runtime::Runtime::new()
        .map_err(|e| anyhow::anyhow!("failed to create tokio runtime: {e}"))?;
    rt.block_on(mcp::daemon::serve(
        &args.host,
        args.port,
        args.profile,
        args.cors,
    ))?;
    Ok(ExitCode::SUCCESS)
}