make it so that payloads are symbolized by default and headers are also normalized by default as well

Author: GrantBirki

lib/hooks/app/api.rb

@@ -89,13 +89,15 @@ def validate_request(payload, headers, endpoint_config)
             end
 
             # Parse request payload
-            def parse_payload(raw_body, headers)
-              content_type = headers["Content-Type"] || headers["CONTENT_TYPE"]
+            def parse_payload(raw_body, headers, symbolize: true)
+              content_type = headers["Content-Type"] || headers["CONTENT_TYPE"] || headers["content-type"] || headers["HTTP_CONTENT_TYPE"]
 
               # Try to parse as JSON if content type suggests it or if it looks like JSON
               if content_type&.include?("application/json") || (raw_body.strip.start_with?("{", "[") rescue false)
                 begin
-                  return JSON.parse(raw_body)
+                  parsed_payload = JSON.parse(raw_body)
+                  parsed_payload = parsed_payload.transform_keys(&:to_sym) if symbolize && parsed_payload.is_a?(Hash)
+                  return parsed_payload
                 rescue JSON::ParserError
                   # If JSON parsing fails, return raw body
                 end
@@ -197,12 +199,15 @@ def determine_error_code(exception)
                   log.info "validating request (id: #{request_id}, handler: #{handler_class_name})"
                   validate_request(raw_body, headers, endpoint_config) if endpoint_config[:request_validator]
 
-                  # Parse payload
-                  payload = parse_payload(raw_body, headers)
+                  # Parse payload (symbolize_payload is true by default)
+                  payload = parse_payload(raw_body, headers, symbolize: config[:symbolize_payload])
 
                   # Load and instantiate handler
                   handler = load_handler(handler_class_name, config[:handler_dir])
 
+                  # Normalize the headers based on the endpoint configuration (normalization is the default)
+                  headers = Hooks::Plugins::Utils::Normalize.headers(headers) if config[:normalize_headers]
+
                   # Call handler
                   response = handler.call(
                     payload:,

lib/hooks/core/config_loader.rb

@@ -18,7 +18,9 @@ class ConfigLoader
         environment: "production",
         production: true,
         endpoints_dir: "./config/endpoints",
-        use_catchall_route: false
+        use_catchall_route: false,
+        symbolize_payload: true,
+        normalize_headers: true
       }.freeze
 
       # Load and merge configuration from various sources

lib/hooks/core/config_validator.rb

@@ -21,6 +21,8 @@ class ValidationError < StandardError; end
         optional(:environment).filled(:string, included_in?: %w[development production])
         optional(:endpoints_dir).filled(:string)
         optional(:use_catchall_route).filled(:bool)
+        optional(:symbolize_payload).filled(:bool)
+        optional(:normalize_headers).filled(:bool)
       end
 
       # Endpoint configuration schema

spec/acceptance/handlers/team1_handler.rb

@@ -14,7 +14,7 @@ def call(payload:, headers:, config:)
 
     # Process the payload based on type
     if payload.is_a?(Hash)
-      event_type = payload["event_type"] || "unknown"
+      event_type = payload[:event_type] || "unknown"
 
       case event_type
       when "deployment"