Support custom HTTP Headers in SyncClient constructor

Author: aldycool

NETCoreSync/NETCoreSync.csproj

@@ -9,17 +9,17 @@
     <PackageProjectUrl>https://github.com/aldycool/NETCoreSync</PackageProjectUrl>
     <RepositoryUrl>https://github.com/aldycool/NETCoreSync</RepositoryUrl>
     <PackageTags>database sync synchronization framework NETCoreApp NETStandard Xamarin Forms</PackageTags>
-    <PackageReleaseNotes>## v1.2.0 Release Notes
+    <PackageReleaseNotes>## v1.2.1 Release Notes
 
 ### Added Features
-* Support conflict handling during `DeserializeJsonToExistingData` method
-* Support suppressing Exception during hook calls if updated with older time stamp (GlobalTimeStamp only)
+* Support custom HTTP Headers in `SyncClient` constructor
 
 ### Breaking Changes
-* `DeserializeJsonToExistingData` method signature change: adds `conflictType` parameter
+None
 </PackageReleaseNotes>
     <PackageRequireLicenseAcceptance>true</PackageRequireLicenseAcceptance>
-    <Version>1.2.0</Version>
+    <Version>1.2.1</Version>
+    <GeneratePackageOnBuild>false</GeneratePackageOnBuild>
   </PropertyGroup>
 
   <ItemGroup>

NETCoreSync/SyncClient.cs

@@ -15,6 +15,7 @@ public class SyncClient
         private readonly string synchronizationId;
         private readonly SyncEngine syncEngine;
         private readonly string serverUrl;
+        private readonly Dictionary<string, string> httpHeaders;
 
         public enum SynchronizationMethodEnum
         {
@@ -23,10 +24,16 @@ public enum SynchronizationMethodEnum
         }
 
         public SyncClient(string synchronizationId, SyncEngine syncEngine, string serverUrl)
+            : this(synchronizationId, syncEngine, serverUrl, null)
+        {
+        }
+
+        public SyncClient(string synchronizationId, SyncEngine syncEngine, string serverUrl, Dictionary<string, string> httpHeaders)
         {
             this.synchronizationId = synchronizationId ?? throw new NullReferenceException(nameof(synchronizationId));
             this.syncEngine = syncEngine ?? throw new NullReferenceException(nameof(syncEngine));
             this.serverUrl = serverUrl ?? throw new NullReferenceException(nameof(serverUrl));
+            this.httpHeaders = httpHeaders;
         }
 
         public async Task<SyncResult> SynchronizeAsync(SynchronizationMethodEnum synchronizationMethod = SynchronizationMethodEnum.PushThenPull, Dictionary<string, object> customInfo = null)
@@ -345,6 +352,15 @@ private async Task SynchronizeGlobalTimeStamp(SynchronizationMethodEnum synchron
 
             using (var httpClient = new HttpClient())
             {
+                if (httpHeaders != null)
+                {
+                    httpHeaders.ToList().ForEach(kvp => 
+                    {
+                        if (httpClient.DefaultRequestHeaders.Contains(kvp.Key)) httpClient.DefaultRequestHeaders.Remove(kvp.Key);
+                        httpClient.DefaultRequestHeaders.Add(kvp.Key, kvp.Value);
+                    });
+                }
+
                 using (var multipartFormDataContent = new MultipartFormDataContent())
                 {
                     ByteArrayContent byteArrayContent = new ByteArrayContent(compressed);