From 2c2f8f41a1795df7b4401f211d815519a0762011 Mon Sep 17 00:00:00 2001 From: narawat Date: Mon, 9 Mar 2026 02:35:22 +0700 Subject: [PATCH] remove redundant encode --- src/NATSBridge.jl | 14 +------------- 1 file changed, 1 insertion(+), 13 deletions(-) diff --git a/src/NATSBridge.jl b/src/NATSBridge.jl index 95f9db5..b0f781e 100644 --- a/src/NATSBridge.jl +++ b/src/NATSBridge.jl @@ -300,19 +300,7 @@ function envelope_to_json(env::msg_envelope_v1) "encoding" => payload.encoding, "size" => payload.size, ) - # Include data based on transport type - if payload.transport == "direct" && payload.data !== nothing - if payload.encoding == "base64" || payload.encoding == "json" || payload.encoding == "arrow-ipc" - payload_obj["data"] = payload.data - else - # For other encodings, use base64 - payload_bytes = _get_payload_bytes(payload.data) - payload_obj["data"] = Base64.base64encode(payload_bytes) - end - elseif payload.transport == "link" && payload.data !== nothing - # For link transport, data is a URL string - include directly - payload_obj["data"] = payload.data - end + payload_obj["data"] = payload.data if !isempty(payload.metadata) payload_obj["metadata"] = Dict(String(k) => v for (k, v) in payload.metadata) end