fix(gcp_pubsub): redact request when errors occur

apps/emqx_bridge_gcp_pubsub/src/emqx_bridge_gcp_pubsub_connector.erl

@@ -355,7 +355,7 @@ do_send_requests_sync(State, {prepared_request, {Method, Path, Body}}, ResourceI
             ),
             ?SLOG(error, #{
                 msg => "gcp_pubsub_error_response",
-                request => Request,
+                request => emqx_connector_http:redact_request(Request),
                 connector => ResourceId,
                 status_code => StatusCode
             }),
@@ -371,9 +371,10 @@ do_send_requests_sync(State, {prepared_request, {Method, Path, Body}}, ResourceI
             ),
             ?SLOG(error, #{
                 msg => "gcp_pubsub_error_response",
-                request => Request,
+                request => emqx_connector_http:redact_request(Request),
                 connector => ResourceId,
-                status_code => StatusCode
+                status_code => StatusCode,
+                resp_body => RespBody
             }),
             {error, #{status_code => StatusCode, headers => RespHeaders, body => RespBody}}
     end.

apps/emqx_connector/src/emqx_connector_http.erl

@@ -42,6 +42,9 @@
     namespace/0
 ]).
 
+%% for other webhook-like connectors.
+-export([redact_request/1]).
+
 -export([validate_method/1, join_paths/2]).
 
 -type connect_timeout() :: emqx_schema:duration() | infinity.