use serde::Serialize;
use std::path::PathBuf;
use crate::component::{self, Component};
use crate::config::{is_json_input, parse_bulk_ids};
use crate::error::{Error, Result};
use crate::module;
use crate::output::{BulkResult, BulkSummary, ItemOutcome};
use crate::paths;
use crate::permissions;
use crate::shell;
use crate::ssh::execute_local_command_in_dir;
#[derive(Debug, Clone)]
pub enum ResolvedBuildCommand {
ComponentDefined(String),
ModuleProvided {
command: String,
source: String,
},
LocalScript {
command: String,
script_name: String,
},
}
impl ResolvedBuildCommand {
pub fn command(&self) -> &str {
match self {
ResolvedBuildCommand::ComponentDefined(cmd) => cmd,
ResolvedBuildCommand::ModuleProvided { command, .. } => command,
ResolvedBuildCommand::LocalScript { command, .. } => command,
}
}
}
pub fn resolve_build_command(component: &Component) -> Result<ResolvedBuildCommand> {
if let Some(cmd) = &component.build_command {
return Ok(ResolvedBuildCommand::ComponentDefined(cmd.clone()));
}
if let Some(modules) = &component.modules {
for module_id in modules.keys() {
if let Some(module) = module::load_module(module_id) {
if let Some(build) = &module.build {
if let Some(module_script) = &build.module_script {
if let Ok(module_dir) = paths::module(module_id) {
let script_path = module_dir.join(module_script);
if script_path.exists() {
let quoted_path = shell::quote_path(&script_path.to_string_lossy());
let command = build
.command_template
.as_ref()
.map(|t| t.replace("{{script}}", "ed_path))
.unwrap_or_else(|| format!("sh {}", quoted_path));
return Ok(ResolvedBuildCommand::ModuleProvided {
command,
source: format!("{}:{}", module_id, module_script),
});
}
}
}
let local_path = PathBuf::from(&component.local_path);
for script_name in &build.script_names {
let local_script = local_path.join(script_name);
if local_script.exists() {
let command = build
.command_template
.as_ref()
.map(|t| t.replace("{{script}}", script_name))
.unwrap_or_else(|| format!("sh {}", script_name));
return Ok(ResolvedBuildCommand::LocalScript {
command,
script_name: script_name.clone(),
});
}
}
}
}
}
}
Err(Error::other(format!(
"Component '{}' has no build configuration. Either:\n\
- Configure buildCommand: homeboy component set {} --json '{{\"buildCommand\": \"<command>\"}}'\n\
- Link a module with build support: homeboy component set {} --json '{{\"modules\": {{\"wordpress\": {{}}}}}}'",
component.id, component.id, component.id
)))
}
#[derive(Debug, Clone, Serialize)]
pub struct BuildOutput {
pub command: String,
pub component_id: String,
pub build_command: String,
pub stdout: String,
pub stderr: String,
pub success: bool,
}
#[derive(Debug, Serialize)]
#[serde(untagged)]
pub enum BuildResult {
Single(BuildOutput),
Bulk(BulkResult<BuildOutput>),
}
pub fn run(input: &str) -> Result<(BuildResult, i32)> {
if is_json_input(input) {
run_bulk(input)
} else {
run_single(input)
}
}
pub fn build_component(component: &component::Component) -> (Option<i32>, Option<String>) {
let resolved = match resolve_build_command(component) {
Ok(r) => r,
Err(e) => return (Some(1), Some(e.to_string())),
};
let build_cmd = resolved.command().to_string();
permissions::fix_local_permissions(&component.local_path);
let output = execute_local_command_in_dir(&build_cmd, Some(&component.local_path), None);
if output.success {
(Some(output.exit_code), None)
} else {
(
Some(output.exit_code),
Some(format!(
"Build failed for '{}'. Fix build errors before deploying.",
component.id
)),
)
}
}
fn run_single(component_id: &str) -> Result<(BuildResult, i32)> {
let (output, exit_code) = execute_build(component_id)?;
Ok((BuildResult::Single(output), exit_code))
}
fn run_bulk(json_spec: &str) -> Result<(BuildResult, i32)> {
let input = parse_bulk_ids(json_spec)?;
let mut results = Vec::with_capacity(input.component_ids.len());
let mut succeeded = 0usize;
let mut failed = 0usize;
for id in &input.component_ids {
match execute_build(id) {
Ok((output, _)) => {
if output.success {
succeeded += 1;
} else {
failed += 1;
}
results.push(ItemOutcome {
id: id.clone(),
result: Some(output),
error: None,
});
}
Err(e) => {
failed += 1;
results.push(ItemOutcome {
id: id.clone(),
result: None,
error: Some(e.to_string()),
});
}
}
}
let exit_code = if failed > 0 { 1 } else { 0 };
Ok((
BuildResult::Bulk(BulkResult {
action: "build".to_string(),
results,
summary: BulkSummary {
total: succeeded + failed,
succeeded,
failed,
},
}),
exit_code,
))
}
fn execute_build(component_id: &str) -> Result<(BuildOutput, i32)> {
let comp = component::load(component_id)?;
let resolved = resolve_build_command(&comp)?;
let build_cmd = resolved.command().to_string();
permissions::fix_local_permissions(&comp.local_path);
let output = execute_local_command_in_dir(&build_cmd, Some(&comp.local_path), None);
Ok((
BuildOutput {
command: "build.run".to_string(),
component_id: component_id.to_string(),
build_command: build_cmd,
stdout: output.stdout,
stderr: output.stderr,
success: output.success,
},
output.exit_code,
))
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn is_json_input_detects_json() {
assert!(is_json_input(r#"{"componentIds": ["a"]}"#));
assert!(is_json_input(r#" {"componentIds": ["a"]}"#));
assert!(!is_json_input("extrachill-api"));
assert!(!is_json_input("some-component-id"));
}
}