Struct BodyTransformerPlugin 

pub struct BodyTransformerPlugin {
    request: Option<String>,
    response: Option<String>,
}

Rewrites context.request.body and/or context.response.body by rendering a template against the parsed JSON body and context variables.

A node with a request transform must sit before the upstream node; a node with a response transform must sit after it (the response body is empty until the upstream runs). Configuring both on one node only makes sense in single-node positions where both sides are populated — normally use two nodes.

Failures (a non-empty body that is not valid JSON, or an undecodable response encoding) exit through the error port with code BODY_DECODE_FAILED — status 400 for request bodies, 502 for response bodies. An empty body renders the template with all {{body...}} placeholders empty.

Fields

request: Option<String>

response: Option<String>

Implementations

impl BodyTransformerPlugin

pub fn from_config(config: &HashMap<String, Value>) -> Result<Self, String>

Builds the plugin from node config.

Accepted keys (at least one of request / response is required):

• request (object): transform applied to the request body.
  • template (string, required): the output body; see the module docs for the {{body.path}} / {{$var}} placeholder subset.
  • input_format (string, default json): only json is accepted.
• response (object): same shape, applied to the response body.

Rejected at config load: missing/empty templates, unbalanced {{, any input_format other than json, and template_is_base64: true (both documented deviations from APISIX).

type: body-transformer
config:
  request:
    input_format: json
    template: '{"name":"{{body.user.name}}","trace":"{{$http_x_request_id}}"}'

fn fail( &self, ctx: Context, status: u16, detail: String, ) -> PluginExecutionError

Builds the error-port rejection for an undecodable body.

Trait Implementations

impl Plugin for BodyTransformerPlugin

fn plugin_type(&self) -> &str

Unique identifier for the plugin type (e.g., “proxy-rewrite”, “upstream”).

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, ctx: Context, _named_inputs: &'life1 HashMap<String, Value>, ) -> Pin<Box<dyn Future<Output = Result<PluginOutput, PluginExecutionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Executes the plugin logic against the request/response context.