Function log_stderr_line

lib/dsc-lib/src/dscresources/command_resource.rs:1181–1242

Log output from a process as traces. # Arguments `process_name` - The name of the process `process_id` - The ID of the process `trace_line` - The stderr line from the process

(process_id: &u32, trace_line: &'a str)

/// * `process_id` - The ID of the process
/// * `trace_line` - The stderr line from the process
pub fn log_stderr_line<'a>(process_id: &u32, trace_line: &'a str) -> &'a str
{
    if !trace_line.is_empty()
    {
        if let Ok(trace_object) = serde_json::from_str::<Trace>(trace_line) {
            let mut include_target = trace_object.level == TraceLevel::Debug || trace_object.level == TraceLevel::Trace;
            let target = if let Some(t) = trace_object.target.as_deref() { t } else {
                include_target = false;
                ""
            };
            let line_number = if let Some(l) = trace_object.line_number { l } else {
                include_target = false;
                0
            };
            let trace_message = if include_target {
                format!("PID {process_id}: {target}: {line_number}: {}", trace_object.fields.message)
            } else {
                format!("PID {process_id}: {}", trace_object.fields.message)
            };
            match trace_object.level {
                TraceLevel::Error => {
                    error!(trace_message);
                },
                TraceLevel::Warn => {
                    warn!(trace_message);
                },
                TraceLevel::Info => {
                    info!(trace_message);
                },
                TraceLevel::Debug => {
                    debug!(trace_message);
                },
                TraceLevel::Trace => {
                    trace!(trace_message);
                },
            }
        }
        else if let Ok(json_obj) = serde_json::from_str::<Value>(trace_line) {
            if let Some(msg) = json_obj.get("error") {
                error!("PID {process_id}: {}", msg.as_str().unwrap_or_default());
            } else if let Some(msg) = json_obj.get("warn") {
                warn!("PID {process_id}: {}", msg.as_str().unwrap_or_default());
            } else if let Some(msg) = json_obj.get("info") {
                info!("PID {process_id}: {}", msg.as_str().unwrap_or_default());
            } else if let Some(msg) = json_obj.get("debug") {
                debug!("PID {process_id}: {}", msg.as_str().unwrap_or_default());
            } else if let Some(msg) = json_obj.get("trace") {
                trace!("PID {process_id}: {}", msg.as_str().unwrap_or_default());
            } else {
                // the line is a valid json, but not one of standard trace lines - return it as filtered stderr_line
                trace!("PID {process_id}: {trace_line}");
                return trace_line;
            }
        } else {
            // the line is not a valid json - return it as filtered stderr_line
            trace!("PID {process_id}: {}", trace_line);
            return trace_line;
        }