faucet-cli 1.9.0

Config-driven CLI runner for faucet-stream pipelines (YAML / JSON, Meltano-style)
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
68
69

//! Shared `ServerState` builders for the serve unit tests.
//!
//! `ServeConfig` has ~20 fields, so every handler test that needs a `ServerState`
//! used to hand-roll the same struct literal — three copies already, and each new
//! field meant editing all of them. One builder here keeps that cost at one edit.

use crate::serve::cluster::ClusterConfig;
use crate::serve::config::{AuthMode, HistoryBackendSpec, ServeConfig};
use crate::serve::history::RunHistory;
use crate::serve::history::memory::MemoryHistory;
use crate::serve::state::ServerState;
use std::sync::Arc;
use std::time::Duration;
use tokio_util::sync::CancellationToken;

/// A no-auth, in-memory, single-instance `ServeConfig`.
pub fn test_config() -> ServeConfig {
    ServeConfig {
        listen: "127.0.0.1:0".parse().expect("loopback addr"),
        auth: AuthMode::None,
        max_concurrent_runs: 4,
        max_queued_runs: 8,
        default_config_path: None,
        history: HistoryBackendSpec::Memory,
        cors_origins: vec![],
        body_limit_bytes: 1_048_576,
        shutdown_grace: Duration::from_secs(60),
        retain_terminal_runs: Duration::from_secs(60),
        idempotency_retention: Duration::from_secs(60),
        lease_ttl: Duration::from_secs(30),
        probe_timeout: Duration::from_secs(10),
        env_file: None,
        no_env_file: true,
        log_level: "warn".into(),
        ui_enabled: true,
        cluster: ClusterConfig::disabled(),
        triggers_path: None,
        callback_allow_hosts: Vec::new(),
    }
}

/// Build a `ServerState` over `config` with a fresh in-memory history backend.
pub fn state_from(config: &ServeConfig) -> ServerState {
    let history = Arc::new(MemoryHistory::new(config.idempotency_retention)) as Arc<dyn RunHistory>;
    ServerState::new(
        config,
        None,
        CancellationToken::new(),
        history,
        crate::serve::logs::LogHub::new(),
        None,
        #[cfg(feature = "triggers")]
        crate::serve::triggers::health::TriggersHandle::empty(),
    )
}

/// The common case: a single-instance server on an in-memory store.
pub fn test_state() -> ServerState {
    state_from(&test_config())
}

/// A server that believes it is part of a cluster — used to exercise the
/// cluster-only branches (pending runs, cross-instance cancel, the
/// secret-param persistence refusal).
pub fn test_state_clustered() -> ServerState {
    let mut config = test_config();
    config.cluster.enabled = true;
    state_from(&config)
}