Client Encryption: Fixes issue with clients using incorrect/stale Enc…

…ryption Policy or Encryption Keys from the cache. (Azure#2403) This PR fixes issue with clients using incorrect or stale policy when cache is not updated with the latest Encryption policy or Encryption Key, which could occur when a container or database is deleted and recreated with same Id but with different policy and Keys.
juraj-blazek · May 6, 2021 · 3a6981a · 3a6981a
1 parent ea8e7bf
commit 3a6981a
Show file tree

Hide file tree

Showing 13 changed files with 1,565 additions and 759 deletions.
diff --git a/Microsoft.Azure.Cosmos.Encryption/src/Constants.cs b/Microsoft.Azure.Cosmos.Encryption/src/Constants.cs
@@ -6,7 +6,8 @@ namespace Microsoft.Azure.Cosmos.Encryption
 {
     internal static class Constants
     {
-        public const int CachedEncryptionSettingsDefaultTTLInMinutes = 60;
         public const string DocumentsResourcePropertyName = "Documents";
+        public const string SubStatusHeader = "x-ms-substatus";
+        public const string IncorrectContainerRidSubStatus = "1024";
     }
 }
diff --git a/Microsoft.Azure.Cosmos.Encryption/src/Custom/EncryptionContainer.cs b/Microsoft.Azure.Cosmos.Encryption/src/Custom/EncryptionContainer.cs
@@ -927,22 +927,6 @@ public override Task<ResponseMessage> PatchItemStreamAsync(
             throw new NotImplementedException();
         }
 
-        public override Task<ResponseMessage> ReadManyItemsStreamAsync(
-            IReadOnlyList<(string id, PartitionKey partitionKey)> items,
-            ReadManyRequestOptions readManyRequestOptions = null,
-            CancellationToken cancellationToken = default)
-        {
-            throw new NotImplementedException();
-        }
-
-        public override Task<FeedResponse<T>> ReadManyItemsAsync<T>(
-            IReadOnlyList<(string id, PartitionKey partitionKey)> items,
-            ReadManyRequestOptions readManyRequestOptions = null,
-            CancellationToken cancellationToken = default)
-        {
-            throw new NotImplementedException();
-        }
-
         public override ChangeFeedProcessorBuilder GetChangeFeedProcessorBuilder<T>(
             string processorName,
             ChangeFeedHandler<T> onChangesDelegate)
@@ -970,5 +954,21 @@ public override ChangeFeedProcessorBuilder GetChangeFeedProcessorBuilderWithManu
         {
             throw new NotImplementedException();
         }
+
+        public override Task<ResponseMessage> ReadManyItemsStreamAsync(
+            IReadOnlyList<(string id, PartitionKey partitionKey)> items,
+            ReadManyRequestOptions readManyRequestOptions = null,
+            CancellationToken cancellationToken = default)
+        {
+            throw new NotImplementedException();
+        }
+
+        public override Task<FeedResponse<T>> ReadManyItemsAsync<T>(
+            IReadOnlyList<(string id, PartitionKey partitionKey)> items,
+            ReadManyRequestOptions readManyRequestOptions = null,
+            CancellationToken cancellationToken = default)
+        {
+            throw new NotImplementedException();
+        }
     }
 }