Add Support for specifying Http Headers to be added to the connection in the config file (serilog-contrib#90)

Author: AmirSasson

README.md

@@ -45,7 +45,8 @@ This example shows the options that are currently available when using the appSe
     <add key="serilog:write-to:Elasticsearch.minimumLogEventLevel" value="Warning"/>
     <add key="serilog:write-to:Elasticsearch.bufferBaseFilename" value="C:\Temp\SerilogElasticBuffer"/>
     <add key="serilog:write-to:Elasticsearch.bufferFileSizeLimitBytes" value="5242880"/>
-    <add key="serilog:write-to:Elasticsearch.bufferLogShippingInterval" value="5000"/>
+    <add key="serilog:write-to:Elasticsearch.bufferLogShippingInterval" value="5000"/>	
+	<add key="serilog:write-to:Elasticsearch.connectionGlobalHeaders" value="Authorization=Bearer SOME-TOKEN;OtherHeader=OTHER-HEADER-VALUE" />
   </appSettings>
 ```
 
@@ -118,7 +119,8 @@ In your `appsettings.json` file, under the `Serilog` node, :
           "minimumLogEventLevel": "Warning",
           "bufferBaseFilename":  "C:/Temp/LogDigipolis/docker-elk-serilog-web-buffer",
           "bufferFileSizeLimitBytes": 5242880,
-          "bufferLogShippingInterval": 5000
+          "bufferLogShippingInterval": 5000,
+		  "connectionGlobalHeaders" :"Authorization=Bearer SOME-TOKEN;OtherHeader=OTHER-HEADER-VALUE"
         }       
     }]
   }

src/Serilog.Sinks.Elasticsearch/LoggerConfigurationElasticSearchExtensions.cs

@@ -20,6 +20,7 @@
 using Serilog.Core;
 using Serilog.Events;
 using Serilog.Sinks.Elasticsearch;
+using System.Collections.Specialized;
 
 namespace Serilog
 {
@@ -76,6 +77,7 @@ public static LoggerConfiguration Elasticsearch(
         /// <param name="bufferBaseFilename"><see cref="ElasticsearchSinkOptions.BufferBaseFilename"/></param>
         /// <param name="bufferFileSizeLimitBytes"><see cref="ElasticsearchSinkOptions.BufferFileSizeLimitBytes"/></param>
         /// <param name="bufferLogShippingInterval"><see cref="ElasticsearchSinkOptions.BufferLogShippingInterval"/></param>
+        /// <param name="connectionGlobalHeaders">A comma or semi column separated list of key value pairs of headers to be added to each elastic http request</param>        
         /// <returns>LoggerConfiguration object</returns>
         /// <exception cref="ArgumentNullException"><paramref name="nodeUris"/> is <see langword="null" />.</exception>
         public static LoggerConfiguration Elasticsearch(
@@ -90,7 +92,8 @@ public static LoggerConfiguration Elasticsearch(
             LogEventLevel minimumLogEventLevel = LogEventLevel.Information,
             string bufferBaseFilename = null,
             long? bufferFileSizeLimitBytes = null,
-            long bufferLogShippingInterval = 5000)
+            long bufferLogShippingInterval = 5000,
+            string connectionGlobalHeaders = null)
         {
             if (string.IsNullOrEmpty(nodeUris))
                 throw new ArgumentNullException("nodeUris", "No Elasticsearch node(s) specified.");
@@ -135,6 +138,22 @@ public static LoggerConfiguration Elasticsearch(
 
             options.BufferLogShippingInterval = TimeSpan.FromMilliseconds(bufferLogShippingInterval);
 
+            if (!string.IsNullOrWhiteSpace(connectionGlobalHeaders))
+            {
+                NameValueCollection headers = new NameValueCollection();
+                connectionGlobalHeaders
+                    .Split(new[] { ',', ';' }, StringSplitOptions.RemoveEmptyEntries)
+                    .ToList()
+                    .ForEach(headerValueStr =>
+                    {
+                        var headerValue = headerValueStr.Split(new[] { '=' }, StringSplitOptions.RemoveEmptyEntries);
+                        headers.Add(headerValue[0], headerValue[1]);
+                    });
+
+                options.ModifyConnectionSettings = (c) => c.GlobalHeaders(headers);
+            }
+
+
             return Elasticsearch(loggerSinkConfiguration, options);
         }
     }