crosslink 0.8.0

A synced issue tracker CLI for multi-agent AI development
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
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67

pub mod collect;
pub mod config;
pub mod dispatch;
pub mod engine;
pub mod history;
pub mod metrics;
pub mod notify;
pub mod patterns;
pub mod seen_set;
pub mod sources;
pub mod tuning;
pub mod watch;
pub mod webhook;

use anyhow::Result;
use std::path::Path;

use crate::db::Database;
use crate::shared_writer::SharedWriter;
use crate::SentinelCommands;

use config::SentinelConfig;

pub fn dispatch_cmd(
    command: SentinelCommands,
    crosslink_dir: &Path,
    db: &Database,
    writer: Option<&SharedWriter>,
    quiet: bool,
    json: bool,
) -> Result<()> {
    match command {
        SentinelCommands::Run { dry_run, label } => {
            let config = SentinelConfig::load(crosslink_dir)?;
            engine::run_oneshot(
                crosslink_dir,
                db,
                writer,
                &config,
                dry_run,
                label.as_deref(),
                quiet,
            )?;
            Ok(())
        }
        SentinelCommands::Watch { interval } => watch::start(crosslink_dir, interval),
        SentinelCommands::Status => watch::status(crosslink_dir, db),
        SentinelCommands::History {
            limit,
            detail,
            json: json_flag,
        } => {
            let use_json = json || json_flag;
            history::show_history(db, limit, detail, use_json)
        }
        SentinelCommands::Stop => watch::stop(crosslink_dir),
        SentinelCommands::Metrics { json: json_flag } => {
            let use_json = json || json_flag;
            metrics::show_metrics(db, use_json)
        }
        SentinelCommands::Patterns { json: json_flag } => {
            let use_json = json || json_flag;
            patterns::detect_patterns(db, use_json)
        }
        SentinelCommands::RunDaemon { dir, interval } => watch::run_watch_loop(&dir, interval),
    }
}