Added partition keys to Cosmos DB get single item and delete item methods

Author: joelhulen

dotnet/ServerlessMicroservices.Shared/Services/CosmosPersistenceService.cs

@@ -58,7 +58,7 @@ public async Task<DriverItem> RetrieveDriver(string code)
                 // NOTE: ReadDocumentAsync is really fast in Cosmos as it bypasses all indexing...but it requires the doc ID
                 var docId = $"{code.ToUpper()}-{ItemCollectionTypes.Driver}";
                 RequestOptions options = new RequestOptions() { PartitionKey = new Microsoft.Azure.Documents.PartitionKey(code.ToUpper()) };
-                var request = (await GetDocDBClient(_settingService)).ReadDocumentAsync<DriverItem>(UriFactory.CreateDocumentUri(_docDbDatabaseName, _docDbDigitalMainCollectionName, docId)/*, options*/);
+                var request = (await GetDocDBClient(_settingService)).ReadDocumentAsync<DriverItem>(UriFactory.CreateDocumentUri(_docDbDatabaseName, _docDbDigitalMainCollectionName, docId), options);
                 cost = request.Result.RequestCharge;
                 return request.Result;
             }
@@ -346,8 +346,8 @@ public async Task DeleteDriver(string code)
                     throw new Exception($"Unable to locate a driver with code {code}");
 
                 var link = (string)driver.Self;
-                //RequestOptions requestOptions = new RequestOptions { PartitionKey = new Microsoft.Azure.Documents.PartitionKey(driver.Code.ToUpper()) };
-                var response = await(await GetDocDBClient(_settingService)).DeleteDocumentAsync(link /*,requestOptions*/);
+                RequestOptions requestOptions = new RequestOptions { PartitionKey = new Microsoft.Azure.Documents.PartitionKey(code.ToUpper()) };
+                var response = await(await GetDocDBClient(_settingService)).DeleteDocumentAsync(link, requestOptions);
                 cost += response.RequestCharge;
 
                 //TODO: Also delete the associated driver location items
@@ -380,7 +380,7 @@ public async Task<TripItem> RetrieveTrip(string code)
                 // NOTE: ReadDocumentAsync is really fast in Cosmos as it bypasses all indexing...but it requires the doc ID
                 var docId = $"{code.ToUpper()}-{ItemCollectionTypes.Trip}";
                 RequestOptions options = new RequestOptions() { PartitionKey = new Microsoft.Azure.Documents.PartitionKey(code.ToUpper()) };
-                var request = (await GetDocDBClient(_settingService)).ReadDocumentAsync<TripItem>(UriFactory.CreateDocumentUri(_docDbDatabaseName, _docDbDigitalMainCollectionName, docId)/*, options*/);
+                var request = (await GetDocDBClient(_settingService)).ReadDocumentAsync<TripItem>(UriFactory.CreateDocumentUri(_docDbDatabaseName, _docDbDigitalMainCollectionName, docId), options);
                 cost = request.Result.RequestCharge;
                 return request.Result;
             }
@@ -612,8 +612,8 @@ public async Task DeleteTrip(string code)
                     throw new Exception($"Unable to locate a trip with code {code}");
 
                 var link = (string)trip.Self;
-                //RequestOptions requestOptions = new RequestOptions { PartitionKey = new Microsoft.Azure.Documents.PartitionKey(driver.Code.ToUpper()) };
-                var response = await (await GetDocDBClient(_settingService)).DeleteDocumentAsync(link /*,requestOptions*/);
+                RequestOptions requestOptions = new RequestOptions { PartitionKey = new Microsoft.Azure.Documents.PartitionKey(code.ToUpper()) };
+                var response = await (await GetDocDBClient(_settingService)).DeleteDocumentAsync(link, requestOptions);
                 cost += response.RequestCharge;
 
                 await _changeNotifierService.TripDeleted(trip);