mycelium-api 8.3.1-rc.1

use myc_core::domain::dtos::callback::{
    CallbackContext, CallbackError, CallbackExecutor,
};
use shaku::Component;
use std::path::PathBuf;
use tokio::process::Command;

#[derive(Component)]
#[shaku(interface = CallbackExecutor)]
pub struct JavaScriptCallback {
    script_path: PathBuf,
    node_path: String,
    timeout_ms: u64,
    name: String,
}

impl JavaScriptCallback {
    pub fn new(
        script_path: impl Into<PathBuf>,
        node_path: Option<String>,
        timeout_ms: Option<u64>,
    ) -> Result<Self, CallbackError> {
        let script_path = script_path.into();

        if !script_path.exists() {
            return Err(CallbackError::ConfigError(format!(
                "Script not found: {}",
                script_path.display()
            )));
        }

        let name = script_path
            .file_name()
            .and_then(|n| n.to_str())
            .unwrap_or("unknown")
            .to_string();

        Ok(Self {
            script_path,
            node_path: node_path.unwrap_or_else(|| "node".to_string()),
            timeout_ms: timeout_ms.unwrap_or(5000),
            name,
        })
    }
}

#[async_trait::async_trait]
impl CallbackExecutor for JavaScriptCallback {
    async fn execute(
        &self,
        context: &CallbackContext,
    ) -> Result<(), CallbackError> {
        // Serialize context to JSON
        let context_json = serde_json::to_string(context).map_err(|e| {
            CallbackError::ScriptError(format!(
                "Failed to serialize context: {}",
                e
            ))
        })?;

        // Execute Node.js with timeout
        let output = tokio::time::timeout(
            std::time::Duration::from_millis(self.timeout_ms),
            Command::new(&self.node_path)
                .arg(&self.script_path)
                .arg("--context")
                .arg(&context_json)
                .output(),
        )
        .await
        .map_err(|_| {
            CallbackError::ScriptError("Script execution timeout".into())
        })?
        .map_err(|e| {
            CallbackError::ScriptError(format!("Failed to execute node: {}", e))
        })?;

        if !output.status.success() {
            let stderr = String::from_utf8_lossy(&output.stderr);
            return Err(CallbackError::ScriptError(format!(
                "Script failed with exit code {:?}: {}",
                output.status.code(),
                stderr
            )));
        }

        // Log stdout if present
        if !output.stdout.is_empty() {
            let stdout = String::from_utf8_lossy(&output.stdout);
            tracing::debug!("Script output: {}", stdout);
        }

        Ok(())
    }

    fn name(&self) -> &str {
        &self.name
    }
}