Make sure that all of the cross platform REST API replication options…

… are available
couchbase · Sep 27, 2016 · 5cfe25b · 5cfe25b
1 parent ba886b8
commit 5cfe25b
Show file tree

Hide file tree

Showing 2 changed files with 35 additions and 0 deletions.
diff --git a/src/Couchbase.Lite.Shared/Manager.cs b/src/Couchbase.Lite.Shared/Manager.cs
@@ -852,6 +852,7 @@ internal Replication ReplicationWithProperties(IDictionary<string, object> prope
             rep.FilterParams = properties.Get("query_params").AsDictionary<string, object>();
             rep.DocIds = properties.Get("doc_ids").AsList<string>();
             rep.Headers = new Dictionary<string, string>();
+            rep.ReplicationOptions = new ReplicationOptions(properties);
             foreach(var header in results.Get("headers").AsDictionary<string, string>()) {
                 if(header.Key.ToLowerInvariant() == "cookie") {
                     var cookie = default(Cookie);
@@ -987,6 +988,8 @@ private Status ParseReplicationProperties(IDictionary<string, object> properties
                 }
             }
 
+
+
             // Can't specify both a filter and doc IDs
             if (properties.ContainsKey("filter") && properties.ContainsKey("doc_ids")) {
                 return new Status(StatusCode.BadRequest);

diff --git a/src/Couchbase.Lite.Shared/Replication/ReplicationOptions.cs b/src/Couchbase.Lite.Shared/Replication/ReplicationOptions.cs
@@ -19,6 +19,7 @@
 // limitations under the License.
 //
 using System;
+using System.Collections.Generic;
 using Couchbase.Lite.Util;
 
 namespace Couchbase.Lite
@@ -31,6 +32,8 @@ public sealed class ReplicationOptions
 
         #region Constants
 
+        private const string Tag = nameof(ReplicationOptions);
+
         /// <summary>
         /// The default value for Heartbeat (5 minutes)
         /// </summary>
@@ -194,6 +197,35 @@ public ReplicationOptions()
             ReplicationRetryDelay = DefaultReplicationRetryDelay;
         }
 
+        internal ReplicationOptions(IDictionary<string, object> dictionary)
+            : this()
+        {
+            long heartbeatMs;
+            if(dictionary.TryGetValue<long>("heartbeat", out heartbeatMs)) {
+                Heartbeat = TimeSpan.FromMilliseconds(heartbeatMs);
+            }
+
+            long requestTimeoutMs;
+            if(dictionary.TryGetValue<long>("connection_timeout", out requestTimeoutMs)) {
+                RequestTimeout = TimeSpan.FromMilliseconds(requestTimeoutMs);
+            }
+
+            long pollIntervalMs;
+            if(dictionary.TryGetValue<long>("poll", out pollIntervalMs)) {
+                if(pollIntervalMs >= 30000) {
+                    PollInterval = TimeSpan.FromMilliseconds(pollIntervalMs);
+                } else {
+                    Log.To.Sync.W(Tag, $"poll interval of {pollIntervalMs} seconds is too short!");
+                }
+            }
+
+            UseWebSocket = dictionary.GetCast<bool>("websocket");
+            RemoteUUID = dictionary.GetCast<string>("remoteUUID");
+            PurgePushed = dictionary.GetCast<bool>("purgePushed");
+            AllNew = dictionary.GetCast<bool>("allNew");
+            Reset = dictionary.GetCast<bool>("reset");
+        }
+
         #endregion
 
         #region Overrides