Method prepare_llm_request

crates/core/src/plugins/nemo_guardrails/python.rs:172–201

(
        &self,
        request: LlmRequest,
        enable_input: bool,
    )

    }

    async fn prepare_llm_request(
        &self,
        request: LlmRequest,
        enable_input: bool,
    ) -> FlowResult<(LlmRequest, Vec<Json>)> {
        let codec = self.codec()?;
        let mut current_request = request;
        let mut annotated = codec.decode(&current_request)?;
        let mut messages = messages_from_annotated(&annotated)?;

        if enable_input {
            match self
                .bridge
                .check(messages.clone(), LocalRailKind::Input)
                .await?
            {
                LocalCheckOutcome::Passed => {}
                LocalCheckOutcome::Blocked { rail, .. } => {
                    return Err(blocked_error("input", rail.as_deref()));
                }
                LocalCheckOutcome::Modified { content, .. } => {
                    replace_last_role_content(&mut annotated, "user", content)?;
                    current_request = codec.encode(&annotated, &current_request)?;
                    messages = messages_from_annotated(&annotated)?;
                }
            }
        }

        Ok((current_request, messages))
    }

    async fn check_output_rails(&self, messages: &[Json], response_text: &str) -> FlowResult<()> {
        let mut output_messages = messages.to_vec();