Json Repository Helper supports PUT (update)

Author: Dries Verbeke

Fritz.InstantAPIs/Repositories/Json/JsonRepositoryHelper.cs

@@ -23,9 +23,9 @@ public Task<IEnumerable<JsonObject>> Get(HttpRequest request, JsonContext contex
 	public Task<JsonObject?> GetById(HttpRequest request, JsonContext context, string name, int id, CancellationToken cancellationToken)
 	{
 		var array = context.LoadTable(name);
-		var matchedItem = array.SingleOrDefault(row => row
+		var matchedItem = array.SingleOrDefault(row => row != null && row
 			.AsObject()
-			.Any(o => o.Key.ToLower() == "id" && o.Value.ToString() == id.ToString())
+			.Any(o => o.Key.ToLower() == "id" && o.Value?.GetValue<int>() == id)
 		)?.AsObject();
 		return Task.FromResult(matchedItem);
 	}
@@ -35,8 +35,13 @@ public Task<int> Insert(HttpRequest request, JsonContext context, string name, J
 	{
 
 		var array = context.LoadTable(name);
-		var key = array.Count + 1;
-		newObj.AsObject().Add("Id", key.ToString());
+		var lastKey = array
+			.Select(row => row?.AsObject().FirstOrDefault(o => o.Key.ToLower() == "id").Value?.GetValue<int>())
+			.Select(x => x.GetValueOrDefault())
+			.Max();
+
+		var key = lastKey + 1;
+		newObj.AsObject().Add("id", key);
 		array.Add(newObj);
 		context.SaveChanges();
 
@@ -45,17 +50,38 @@ public Task<int> Insert(HttpRequest request, JsonContext context, string name, J
 
 	public Task Update(HttpRequest request, JsonContext context, string name, int id, JsonObject newObj, CancellationToken cancellationToken)
 	{
-		throw new NotImplementedException();
+		var array = context.LoadTable(name);
+		var matchedItem = array.SingleOrDefault(row => row != null
+			&& row.AsObject().Any(o => o.Key.ToLower() == "id" && o.Value?.GetValue<int>() == id)
+		)?.AsObject();
+		if (matchedItem != null)
+		{
+			var updates = newObj
+				.GroupJoin(matchedItem, o => o.Key, i => i.Key, (o, i) => new { NewValue = o, OldValue = i.FirstOrDefault() })
+				.Where(x => x.NewValue.Key.ToLower() != "id")
+				.ToList();
+			foreach (var newField in updates)
+			{
+				if (newField.OldValue.Value != null)
+				{
+					matchedItem.Remove(newField.OldValue.Key);
+				}
+				matchedItem.Add(newField.NewValue.Key, JsonValue.Create(newField.NewValue.Value?.GetValue<string>()));
+			}
+			context.SaveChanges();
+		}
+
+		return Task.CompletedTask;
 	}
 
 	public Task<bool> Delete(HttpRequest request, JsonContext context, string name, int id, CancellationToken cancellationToken)
 	{
 		var array = context.LoadTable(name);
 		var matchedItem = array
 			.Select((value, index) => new { value, index })
-			.SingleOrDefault(row => row.value
-				.AsObject()
-				.Any(o => o.Key.ToLower() == "id" && o.Value.ToString() == id.ToString()));
+			.SingleOrDefault(row => row.value == null
+				? false 
+				: row.value.AsObject().Any(o => o.Key.ToLower() == "id" && o.Value?.GetValue<int>() == id));
 		if (matchedItem != null)
 		{
 			array.RemoveAt(matchedItem.index);