tandem_server/
lib.rs

1#![recursion_limit = "512"]
2
3use std::path::PathBuf;
4
5use tandem_types::EngineEvent;
6
7use tandem_workflows::{WorkflowRunRecord, WorkflowRunStatus, WorkflowSourceRef};
8
9mod agent_teams;
10pub mod app;
11mod automation_v2;
12#[cfg(feature = "browser")]
13mod browser;
14mod bug_monitor;
15mod bug_monitor_github;
16mod capability_resolver;
17mod config;
18mod http;
19mod mcp_catalog;
20mod memory;
21mod optimization;
22mod pack_builder;
23mod pack_manager;
24mod preset_composer;
25mod preset_registry;
26mod preset_summary;
27mod routines;
28mod runtime;
29mod shared_resources;
30mod util;
31pub mod webui;
32mod workflows;
33
34pub use agent_teams::AgentTeamRuntime;
35pub use automation_v2::types::{
36    AutomationAgentMcpPolicy, AutomationAgentProfile, AutomationAgentToolPolicy,
37    AutomationApprovalGate, AutomationExecutionPolicy, AutomationFailureRecord,
38    AutomationFlowInputRef, AutomationFlowNode, AutomationFlowOutputContract, AutomationFlowSpec,
39    AutomationGateDecisionRecord, AutomationLifecycleRecord, AutomationNodeOutput,
40    AutomationNodeOutputFreshness, AutomationNodeOutputProvenance, AutomationNodeStageKind,
41    AutomationOutputEnforcement, AutomationOutputValidatorKind, AutomationPendingGate,
42    AutomationRunCheckpoint, AutomationRunStatus, AutomationStopKind, AutomationV2RunRecord,
43    AutomationV2Schedule, AutomationV2ScheduleType, AutomationV2Spec, AutomationV2Status,
44    AutomationValidatorSummary, WorkflowPlan, WorkflowPlanChatMessage, WorkflowPlanConversation,
45    WorkflowPlanDraftRecord, WorkflowPlanStep,
46};
47#[cfg(feature = "browser")]
48pub use browser::{
49    install_browser_sidecar, BrowserHealthSummary, BrowserSidecarInstallResult,
50    BrowserSmokeTestResult, BrowserSubsystem,
51};
52pub use bug_monitor::types::{
53    BugMonitorBindingCandidate, BugMonitorCapabilityMatch, BugMonitorCapabilityReadiness,
54    BugMonitorConfig, BugMonitorDraftRecord, BugMonitorIncidentRecord, BugMonitorLabelMode,
55    BugMonitorPostRecord, BugMonitorProviderPreference, BugMonitorReadiness,
56    BugMonitorRuntimeStatus, BugMonitorStatus, BugMonitorSubmission,
57};
58pub use capability_resolver::CapabilityResolver;
59pub use http::serve;
60pub use memory::types::{GovernedMemoryRecord, MemoryAuditEvent};
61pub use optimization::{
62    apply_optimization_execution_override, derive_phase1_metrics_from_run,
63    derive_phase1_validator_case_outcomes_from_run, establish_phase1_baseline,
64    evaluate_phase1_promotion, freeze_optimization_artifact, load_optimization_phase1_config,
65    optimization_snapshot_hash, parse_phase1_metrics, phase1_baseline_replay_due,
66    validate_phase1_candidate_mutation, validate_phase1_workflow_target, OptimizationArtifactRefs,
67    OptimizationBaselineReplayRecord, OptimizationBudgetPolicy, OptimizationCampaignRecord,
68    OptimizationCampaignStatus, OptimizationEvalSpec, OptimizationExecutionOverride,
69    OptimizationExperimentRecord, OptimizationExperimentStatus, OptimizationFrozenArtifact,
70    OptimizationFrozenArtifacts, OptimizationGuardrailKind, OptimizationMetricKind,
71    OptimizationMutableField, OptimizationMutationPolicy, OptimizationPhase1Config,
72    OptimizationPhase1Metrics, OptimizationPromotionDecision, OptimizationPromotionDecisionKind,
73    OptimizationSafetyScope, OptimizationTargetKind, OptimizationValidatedMutation,
74};
75pub use pack_manager::PackManager;
76pub use preset_composer::PromptComposeInput;
77pub use preset_registry::PresetRegistry;
78pub use routines::errors::RoutineStoreError;
79pub use routines::types::{
80    ExternalActionRecord, RoutineHistoryEvent, RoutineMisfirePolicy, RoutineRunArtifact,
81    RoutineRunRecord, RoutineRunStatus, RoutineSchedule, RoutineSessionPolicy, RoutineSpec,
82    RoutineStatus, RoutineTriggerPlan,
83};
84pub use runtime::lease::EngineLease;
85pub use runtime::runs::{ActiveRun, RunRegistry};
86pub use runtime::state::RuntimeState;
87pub use runtime::worktrees::ManagedWorktreeRecord;
88pub use shared_resources::types::{ResourceConflict, ResourceStoreError, SharedResourceRecord};
89pub use util::build::{
90    binary_modified_at_ms, binary_path_for_health, build_id, build_provenance, git_sha,
91};
92pub use util::host::detect_host_runtime_context;
93pub use util::time::now_ms;
94pub use workflows::{
95    canonical_workflow_event_names, dispatch_workflow_event, execute_hook_binding,
96    execute_workflow, parse_workflow_action, run_workflow_dispatcher, simulate_workflow_event,
97};
98
99pub(crate) fn normalize_absolute_workspace_root(raw: &str) -> Result<String, String> {
100    let trimmed = raw.trim();
101    if trimmed.is_empty() {
102        return Err("workspace_root is required".to_string());
103    }
104    let as_path = PathBuf::from(trimmed);
105    if !as_path.is_absolute() {
106        return Err("workspace_root must be an absolute path".to_string());
107    }
108    tandem_core::normalize_workspace_path(trimmed)
109        .ok_or_else(|| "workspace_root is invalid".to_string())
110}
111
112// Re-exports from app::state (impl AppState moved here)
113pub use crate::app::state::{
114    derive_status_index_update, evaluate_routine_execution_policy, sha256_hex, truncate_text,
115    AppState, ChannelRuntime, ChannelStatus, RoutineExecutionDecision, StatusIndexUpdate,
116};
117
118pub use crate::app::startup::{StartupSnapshot, StartupState, StartupStatus};
119
120pub use config::channels::{
121    ChannelsConfigFile, DiscordConfigFile, SlackConfigFile, TelegramConfigFile,
122};
123pub use config::webui::normalize_web_ui_prefix;
124pub use config::webui::WebUiConfig;
125
126// Also need normalize_allowed_users_or_wildcard?
127pub use crate::app::state::automation::lifecycle::{
128    automation_lifecycle_event_metadata_for_node, record_automation_lifecycle_event,
129    record_automation_lifecycle_event_with_metadata, record_automation_workflow_state_events,
130};
131pub use crate::app::state::default_model_spec_from_effective_config;
132pub use crate::app::state::extract_persistable_tool_part;
133pub use crate::app::state::run_automation_v2_executor;
134pub use crate::app::state::{
135    automation_node_required_output_path, clear_automation_subtree_outputs,
136    collect_automation_descendants, refresh_automation_runtime_state,
137};
138pub use crate::app::tasks::{
139    run_agent_team_supervisor, run_automation_v2_scheduler, run_bug_monitor,
140    run_optimization_scheduler, run_routine_executor, run_routine_scheduler,
141    run_session_context_run_journaler, run_session_part_persister, run_status_indexer,
142    run_usage_aggregator,
143};
144pub use config::channels::normalize_allowed_tools;
145pub use config::channels::normalize_allowed_users_or_wildcard;
tandem_server/lib.rs

tandem_server/
lib.rs
