update local insert to use id not resource key

Author: Lanning, Mark

ItemStore/src/ThingsLibrary.ItemStore.Cosmos/ItemStoreCosmos.cs

@@ -184,7 +184,7 @@ public async Task<bool> ExistsAsync(string partitionKey, string resourceKey, Can
 
             return await this.GetAsync(partitionKey, resourceKey, cancellationToken) != null;
         }
-
+        
         /// <inheritdoc />
         public async Task<ItemEnvelope?> GetAsync(string partitionKey, string resourceKey, CancellationToken cancellationToken)
         {

ItemStore/src/ThingsLibrary.ItemStore.Local/ItemStoreLocal.cs

@@ -217,13 +217,21 @@ public Task<bool> ExistsAsync(string partitionKey, string resourceKey, Cancellat
             return Task.FromResult<bool>(this.Collection.Count(x => x.ResourceKey == resourceKey) > 0);
         }
 
+        /// <inheritdoc />       
+        public Task<ItemEnvelope?> GetAsync(string id, CancellationToken cancellationToken)
+        {
+            var result = this.Collection.FindOne(x => x.Id == id);
+
+            return Task.FromResult<ItemEnvelope?>(result);
+        }
+
         /// <inheritdoc />       
         public Task<ItemEnvelope?> GetAsync(string partitionKey, string resourceKey, CancellationToken cancellationToken)
         {
             ArgumentException.ThrowIfNullOrEmpty(partitionKey);
             ArgumentException.ThrowIfNullOrEmpty(resourceKey);
 
-            var result = this.Collection.FindOne(x => x.ResourceKey == resourceKey);
+            var result = this.Collection.FindOne(x => x.Partition == partitionKey && x.ResourceKey == resourceKey);
 
             return Task.FromResult<ItemEnvelope?>(result);            
         }
@@ -236,7 +244,7 @@ public Task<List<ItemEnvelope>> GetFamilyAsync(string partitionKey, string resou
 
             var resourceKeyPrefix = $"{resourceKey}/";
 
-            var items = this.Collection.Query().Where(x => x.ResourceKey == resourceKey || x.ResourceKey.StartsWith(resourceKeyPrefix)).ToList();
+            var items = this.Collection.Query().Where(x => x.Partition == partitionKey && (x.ResourceKey == resourceKey || x.ResourceKey.StartsWith(resourceKeyPrefix))).ToList();
 
             return Task.FromResult<List<ItemEnvelope>>(items);
         }
@@ -257,7 +265,7 @@ public Task InsertAsync(ItemEnvelope itemEnvelope, CancellationToken cancellatio
             lock (LockObject)
             {
                 // creates
-                this.Collection.Insert(itemEnvelope);
+                this.Collection.Insert(itemEnvelope.Id, itemEnvelope);
             }
 
             //save out entity?
@@ -279,7 +287,8 @@ public Task UpdateAsync(ItemEnvelope itemEnvelope, CancellationToken cancellatio
             lock (LockObject)
             {
                 // creates (if missing) or replaces entity
-                this.Collection.Upsert(itemEnvelope.ResourceKey, itemEnvelope);
+                bool updated = this.Collection.Update(itemEnvelope.Id, itemEnvelope);
+                if (!updated) { throw new InvalidOperationException($"Unable to update ItemEnvelope with ResourceKey '{itemEnvelope.ResourceKey}' because it does not exist."); }
             }
 
             //save out entity?

ItemStore/tests/ThingsLibrary.ItemStore.Tests/UnitTests.cs

@@ -126,7 +126,7 @@ public async Task Test_InsertUpdate()
             await ItemStore.UpdateAsync(envelope2, UnitTests.CancellationToken);
             Thread.Sleep(100);
 
-            // ======================================================================
+            // =================================>=====================================
             // FETCH
             var envelope3 = await ItemStore.GetAsync(partitionKey, resourceKey, UnitTests.CancellationToken);