|
|
@@ -703,9 +703,16 @@ process_request(
|
|
|
}.
|
|
|
|
|
|
render_request_body(undefined, _, Msg) ->
|
|
|
+ encode_payload_with_base64(Msg),
|
|
|
emqx_utils_json:encode(Msg);
|
|
|
render_request_body(BodyTks, RenderTmplFunc, Msg) ->
|
|
|
- RenderTmplFunc(BodyTks, Msg).
|
|
|
+ MsgWithBase64 = encode_payload_with_base64(Msg),
|
|
|
+ RenderTmplFunc(BodyTks, MsgWithBase64).
|
|
|
+
|
|
|
+encode_payload_with_base64(Msg) ->
|
|
|
+ Payload = maps:get(<<"payload">>, Msg, <<>>),
|
|
|
+ Base64Payload = base64:encode(Payload),
|
|
|
+ maps:put(<<"base64_payload">>, Base64Payload, Msg).
|
|
|
|
|
|
render_headers(HeaderTks, RenderTmplFunc, Msg) ->
|
|
|
lists:map(
|