Method process_message

core/src/agents.rs:219–235

(
        &self,
        message: AgentMessage,
        context: &mut WorkflowContext,
    )

    }

    async fn process_message(
        &self,
        message: AgentMessage,
        context: &mut WorkflowContext,
    ) -> GraphBitResult<AgentMessage> {
        let request = self.build_llm_request(&message);

        let response = self.llm_provider.complete(request).await?;

        // Update context with usage information
        context.set_metadata(
            "last_token_usage".to_string(),
            serde_json::to_value(&response.usage)?,
        );

        Ok(self.llm_response_to_message(response, &message))
    }

    async fn execute(&self, message: AgentMessage) -> GraphBitResult<serde_json::Value> {
        let request = self.build_llm_request(&message);