From ff36c3b15958cd1df6bd40106877732b8ab64da7 Mon Sep 17 00:00:00 2001
From: Christian Dalager <christian.dalager@eksponent.com>
Date: Fri, 16 Feb 2024 14:29:51 +0100
Subject: [PATCH] Adding /searchcommits?q=my search term

---
 src/Function/SearchCommits.cs | 57 +++++++++++++++++++++++++++++++++++
 1 file changed, 57 insertions(+)
 create mode 100644 src/Function/SearchCommits.cs

diff --git a/src/Function/SearchCommits.cs b/src/Function/SearchCommits.cs
new file mode 100644
index 0000000..7dce9bd
--- /dev/null
+++ b/src/Function/SearchCommits.cs
@@ -0,0 +1,57 @@
+using System.Net;
+using System.Text.Json;
+using CommitStore.Functions;
+using Microsoft.Azure.Cosmos;
+using Microsoft.Azure.Functions.Worker;
+using Microsoft.Azure.Functions.Worker.Http;
+using Microsoft.Extensions.Logging;
+
+namespace Function
+{
+    public class SearchCommits
+    {
+        private readonly ILogger _logger;
+
+        public SearchCommits(ILoggerFactory loggerFactory)
+        {
+            _logger = loggerFactory.CreateLogger<SearchCommits>();
+        }
+
+        [Function("SearchCommits")]
+        public async Task<HttpResponseData> Run(
+            [HttpTrigger(AuthorizationLevel.Function, "get", "post")] HttpRequestData req
+        )
+        {
+            _logger.LogInformation("C# HTTP trigger function processed a request.");
+
+            var response = req.CreateResponse(HttpStatusCode.OK);
+
+            // get search param querystring 'q'
+            var queryString = req.Url.Query;
+            var searchParam = System.Web.HttpUtility.ParseQueryString(queryString).Get("q") ?? "";
+            _logger.LogInformation($"Search param: {searchParam}");
+
+            // get cosmosdbconnectionstring
+            var cosmosDbConnectionString = Environment.GetEnvironmentVariable("CosmosDBConnection");
+            var client = new CosmosClient(cosmosDbConnectionString);
+            var database = client.GetDatabase("commitstore-db");
+            var container = database.GetContainer("commits");
+
+            QueryDefinition qdef = new QueryDefinition(
+                $"SELECT * FROM c where CONTAINS(c.message, @searchParam,true) or CONTAINS(c.branch, @searchParam,true) order by c.timestamp desc"
+            ).WithParameter("@searchParam", searchParam);
+
+            var feedIterator = container.GetItemQueryIterator<CommitData>(qdef);
+            // var feedIterator = queryable.ToFeedIterator();
+            var commits = new List<CommitData>();
+            while (feedIterator.HasMoreResults)
+            {
+                var commitResponses = await feedIterator.ReadNextAsync();
+                commits.AddRange(commitResponses);
+            }
+            response.WriteString(JsonSerializer.Serialize(commits));
+
+            return response;
+        }
+    }
+}