Search nodes

Author: mibewh

cloudcms-csharp-driver.csproj

@@ -6,7 +6,7 @@
     <RootNamespace>CloudCMS</RootNamespace>
 
     <PackageId>cloudcms</PackageId>
-    <PackageVersion>1.1.0</PackageVersion>
+    <PackageVersion>1.1.1</PackageVersion>
     <Title>CloudCMS Driver</Title>
     <Description>C# .NET driver for CloudCMS</Description>
     <Summary>C# .NET driver for CloudCMS</Summary>

src/branches/Branch.cs

@@ -80,6 +80,50 @@ public async Task<List<IBaseNode>> QueryNodesAsync(JObject query, JObject pagina
             return nodes;
         }
 
+        public async Task<List<IBaseNode>> SearchNodesAsync(string text, JObject pagination = null)
+        {
+            string uri = URI + "/nodes/search";
+            
+            IDictionary<string, string> queryParams = new Dictionary<string, string>();
+            if (pagination != null)
+            {
+                queryParams = pagination.ToObject<Dictionary<string, string>>();
+            }
+            
+            queryParams.Add("text", text);
+
+            JObject response = await Driver.GetAsync(uri, queryParams);
+
+            return NodeUtil.NodeList(response, this);
+        }
+
+        public async Task<List<IBaseNode>> SearchNodesAsync(JObject search, JObject pagination = null)
+        {
+            string uri = URI + "/nodes/search";
+            
+            IDictionary<string, string> queryParams = new Dictionary<string, string>();
+            if (pagination != null)
+            {
+                queryParams = pagination.ToObject<Dictionary<string, string>>();
+            }
+
+            JObject payload = null;
+            if (search.ContainsKey("search"))
+            {
+                payload = search;
+            }
+            else
+            {
+                payload = new JObject();
+                payload.Add("search", search);
+            }
+            
+            HttpContent content = new StringContent(payload.ToString());
+            JObject response = await Driver.PostAsync(uri, queryParams, content);
+
+            return NodeUtil.NodeList(response, this);
+        }
+
         public async Task<List<IBaseNode>> FindNodesAsync(JObject config, JObject pagination = null)
         {
             string uri = this.URI + "/nodes/find";

src/branches/IBranch.cs

@@ -12,6 +12,9 @@ public interface IBranch : IRepositoryDocument
         Task<IBaseNode> ReadNodeAsync(string nodeId);
 
         Task<List<IBaseNode>> QueryNodesAsync(JObject query, JObject pagination = null);
+        
+        Task<List<IBaseNode>> SearchNodesAsync(string text, JObject pagination = null);
+        Task<List<IBaseNode>> SearchNodesAsync(JObject search, JObject pagination = null);
 
         Task<List<IBaseNode>> FindNodesAsync(JObject config, JObject pagination = null);
 

tests/AbstractWithRepositoryTest.cs

@@ -19,7 +19,7 @@ private async Task SetupAsync()
         {
             JObject obj = new JObject();
             obj["title"] = "C# Driver Test Repository";
-            Repository = await Platform.CreateRepositoryAsync();
+            Repository = await Platform.CreateRepositoryAsync(obj);
         }
 
 

tests/NodeTest.cs

@@ -2,6 +2,7 @@
 using System.Threading;
 using System.Linq;
 using System.Collections.Generic;
+using System.Reflection;
 using System.Threading.Tasks;
 using Newtonsoft.Json.Linq;
 using CloudCMS;
@@ -66,7 +67,7 @@ public async void TestNodeCrud()
         }
 
         [Fact]
-        public async void TestNodeQueryFind()
+        public async void TestNodeQuerySearchFind()
         {
             IBranch branch = await Fixture.Repository.ReadBranchAsync("master");
 
@@ -114,6 +115,13 @@ public async void TestNodeQueryFind()
             Assert.Contains(node1.Id, findNodesIds);
             Assert.Contains(node2.Id, findNodesIds);
 
+            // search
+            List<IBaseNode> searchNodes = await branch.SearchNodesAsync("burger");
+            var searchNodesIds = searchNodes.Select(node => node.Id);
+            Assert.Equal(2, searchNodes.Count);
+            Assert.Contains(node1.Id, searchNodesIds);
+            Assert.Contains(node2.Id, searchNodesIds);
+
             await node1.DeleteAsync();
             await node2.DeleteAsync();
             await node3.DeleteAsync();