✨ feat(envoy-proxy): Log HTTP request payloads

dynatrace-oss · Nov 22, 2023 · ea1306b · ea1306b
1 parent 79446f3
commit ea1306b
Show file tree

Hide file tree

Showing 2 changed files with 26 additions and 0 deletions.
diff --git a/src/envoy-proxy/config/envoy-config.yaml b/src/envoy-proxy/config/envoy-config.yaml
@@ -50,7 +50,17 @@ static_resources:
                           timestamp: "%START_TIME%"
                           upstream_remote_address: "%UPSTREAM_REMOTE_ADDRESS%"
                           user_agent: "%REQ(User-Agent)%"
+                          payload: "%DYNAMIC_METADATA(envoy.filters.http.lua.request-filter:payload)%"
                 http_filters:
+                  - name: envoy.filters.http.lua
+                    typed_config:
+                      "@type": type.googleapis.com/envoy.extensions.filters.http.lua.v3.Lua
+                      default_source_code:
+                        inline_string: |
+                          local request_logger = require("/etc/envoy/unguard/request-logger")
+                          function envoy_on_request(request_handle)
+                            request_logger.log_payload(request_handle)
+                          end
                   - name: envoy.filters.http.router
                     typed_config:
                       "@type": type.googleapis.com/envoy.extensions.filters.http.router.v3.Router

diff --git a/src/envoy-proxy/config/request-logger.lua b/src/envoy-proxy/config/request-logger.lua
@@ -0,0 +1,16 @@
+local request_logger = {}
+
+function request_logger.log_payload(handle)
+    local payload = ""
+    for chunk in handle:bodyChunks() do
+      local chunk_length = chunk:length()
+      if (chunk_length > 0) then
+        payload = payload .. chunk:getBytes(0, chunk_length)
+      end
+    end
+    payload = tostring(payload)
+    handle:streamInfo():dynamicMetadata():set("envoy.filters.http.lua.request-filter", "payload", payload)
+    return payload
+end
+
+return request_logger