We now ignore certain headers without trying to forward them to the d…

…estination.
nickntg · Dec 9, 2024 · 114d8a7 · 114d8a7
1 parent 515f107
commit 114d8a7
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 5 deletions.
diff --git a/Projects/AWSRedrive.LinuxService/AWSRedrive.LinuxService.csproj b/Projects/AWSRedrive.LinuxService/AWSRedrive.LinuxService.csproj
@@ -3,7 +3,7 @@
   <PropertyGroup>
     <TargetFramework>net8.0</TargetFramework>
 	<ProjectGuid>{E2CEBBAF-6DF7-41E9-815D-9AD4CF90C845}</ProjectGuid>
-	<Version>1.0.13</Version>
+	<Version>1.0.14</Version>
   </PropertyGroup>
 
   <ItemGroup>

diff --git a/Projects/AWSRedrive.console/AWSRedrive.console.csproj b/Projects/AWSRedrive.console/AWSRedrive.console.csproj
@@ -3,7 +3,7 @@
   <PropertyGroup>
     <OutputType>Exe</OutputType>
     <TargetFramework>net8.0</TargetFramework>
-    <Version>1.0.13</Version>
+    <Version>1.0.14</Version>
   </PropertyGroup>
 
   <ItemGroup>

diff --git a/Projects/AWSRedrive/AWSRedrive.csproj b/Projects/AWSRedrive/AWSRedrive.csproj
@@ -3,7 +3,7 @@
   <PropertyGroup>
     <TargetFramework>net8.0</TargetFramework>
 	<ProjectGuid>{E2CEBBAF-6DF7-41E9-815D-9AD4CF90C844}</ProjectGuid>
-	<Version>1.0.13</Version>
+	<Version>1.0.14</Version>
   </PropertyGroup>
 
   <ItemGroup>

diff --git a/Projects/AWSRedrive/HttpMessageProcessor.cs b/Projects/AWSRedrive/HttpMessageProcessor.cs
@@ -14,6 +14,7 @@ namespace AWSRedrive
     public class HttpMessageProcessor : IMessageProcessor
     {
         private static readonly Logger Logger = LogManager.GetCurrentClassLogger();
+        private readonly string[] _ignoredHeaders = ["content-length", "host", "accept-encoding", "content-type", "accept"];
 
         public void ProcessMessage(string message, Dictionary<string, string> attributes, ConfigurationEntry configurationEntry)
         {
@@ -55,7 +56,10 @@ public void UnpackAttributesAsHeaders(string message, RestRequest request, Confi
                     var value = attribute.Value.Value.ToString();
                     if (!string.IsNullOrEmpty(value))
                     {
-                        request.AddHeader(attribute.Key, value);
+                        if (!_ignoredHeaders.Contains(attribute.Key.ToLower()))
+                        {
+                            request.AddHeader(attribute.Key, value);
+                        }
                     }
                 }
             }
@@ -144,7 +148,10 @@ public void AddAttributes(RestRequest request, Dictionary<string, string> attrib
             {
                 foreach (var key in attributes.Keys.Where(key => !string.IsNullOrEmpty(key) && !string.IsNullOrEmpty(attributes[key])))
                 {
-                    request.AddHeader(key, attributes[key]);
+                    if (!_ignoredHeaders.Contains(key.ToLower()))
+                    {
+                        request.AddHeader(key, attributes[key]);
+                    }
                 }
             }
         }