PartitionKey test cases

Author: kirankumarkolli

Microsoft.Azure.Cosmos/src/Microsoft.Azure.Cosmos.csproj

@@ -183,10 +183,6 @@
 		<Service Include="{508349b6-6b84-4df5-91f0-309beebad82d}" />
 	</ItemGroup>
 
-	<ItemGroup>
-	  <Folder Include="Resource\FullFidelity\Converters\" />
-	</ItemGroup>
-
 	<PropertyGroup Condition=" '$(ProjectRef)' != 'True' ">
 		<SignAssembly>true</SignAssembly>
 		<DelaySign>true</DelaySign>

Microsoft.Azure.Cosmos/src/Resource/FullFidelity/ChangeFeedMetadata.cs

@@ -5,7 +5,9 @@
 namespace Microsoft.Azure.Cosmos
 {
     using System;
+    using System.Collections.Generic;
     using System.Text.Json;
+    using System.Text.Json.Serialization;
     using Microsoft.Azure.Cosmos.Resource.FullFidelity;
     using Newtonsoft.Json;
     using Newtonsoft.Json.Converters;
@@ -25,12 +27,12 @@ class ChangeFeedMetadata
         /// <summary>
         /// The change's conflict resolution timestamp.
         /// </summary>
-        public DateTime ConflictResolutionTimestamp => UnixEpoch.AddSeconds(this.ConflictResolutionTimestampInSecones.Value);
+        public DateTime ConflictResolutionTimestamp => UnixEpoch.AddSeconds(this.ConflictResolutionTimestampInSeconds.Value);
 
         [System.Text.Json.Serialization.JsonInclude]
         [System.Text.Json.Serialization.JsonPropertyName(ChangeFeedMetadataFields.ConflictResolutionTimestamp)]
         [JsonProperty(PropertyName = ChangeFeedMetadataFields.ConflictResolutionTimestamp, NullValueHandling = NullValueHandling.Ignore)]
-        internal double? ConflictResolutionTimestampInSecones { get; set; }
+        internal double? ConflictResolutionTimestampInSeconds { get; set; }
 
         /// <summary>
         /// The current change's logical sequence number.
@@ -44,7 +46,7 @@ class ChangeFeedMetadata
         /// The change's feed operation type <see cref="ChangeFeedOperationType"/>.
         /// </summary>
         [JsonProperty(PropertyName = ChangeFeedMetadataFields.OperationType, NullValueHandling = NullValueHandling.Ignore)]
-        [JsonConverter(typeof(StringEnumConverter))]
+        [Newtonsoft.Json.JsonConverter(typeof(StringEnumConverter))]
         [System.Text.Json.Serialization.JsonInclude]
         [System.Text.Json.Serialization.JsonPropertyName(ChangeFeedMetadataFields.OperationType)]
         [System.Text.Json.Serialization.JsonConverter(typeof(System.Text.Json.Serialization.JsonStringEnumConverter))]
@@ -65,5 +67,10 @@ class ChangeFeedMetadata
         [System.Text.Json.Serialization.JsonInclude]
         [System.Text.Json.Serialization.JsonPropertyName(ChangeFeedMetadataFields.TimeToLiveExpired)]
         public bool IsTimeToLiveExpired { get; internal set; }
+
+        [System.Text.Json.Serialization.JsonInclude]
+        [JsonProperty(PropertyName = ChangeFeedMetadataFields.PartitionKey, NullValueHandling = NullValueHandling.Ignore)]
+        [JsonPropertyName(ChangeFeedMetadataFields.PartitionKey)]
+        public Dictionary<string, object> PartitionKey { get; internal set; }
     }
 }

Microsoft.Azure.Cosmos/src/Resource/FullFidelity/ChangeFeedMetadataFields.cs

@@ -11,5 +11,6 @@ internal class ChangeFeedMetadataFields
         public const string OperationType = "operationType";
         public const string PreviousImageLSN = "previousImageLSN";
         public const string TimeToLiveExpired = "timeToLiveExpired";
+        public const string PartitionKey = "partitionKey";
     }
 }

Microsoft.Azure.Cosmos/tests/Microsoft.Azure.Cosmos.EmulatorTests/CFP/AllVersionsAndDeletes/BuilderWithCustomSerializerTests.cs

@@ -39,7 +39,12 @@ public void ValidateNSJAndSTJSerializationOfChangeFeedItemDeleteTimeToLiveExpire
                ""crts"": 1722511591,
                ""operationType"": ""delete"",
                ""timeToLiveExpired"": true,
-               ""previousImageLSN"": 16
+               ""previousImageLSN"": 16,
+               ""id"": ""1"",
+               ""partitionKey"": {
+                ""pk1"": ""1"",
+                ""pk2"": ""2""
+               }
               },
               ""previous"": {
                ""id"": ""1"",
@@ -92,6 +97,10 @@ static void ValidateDeserialization(List<ChangeFeedItem<ToDoActivity>> activitie
                 Assert.IsTrue(deletedChange.Metadata.IsTimeToLiveExpired);
                 Assert.IsNotNull(deletedChange.Previous);
                 Assert.AreEqual(expected: "Testing TTL on CFP.", actual: deletedChange.Previous.description);
+                Assert.AreEqual(expected: "pk1", actual: deletedChange.Metadata.PartitionKey.First().Key);
+                Assert.AreEqual(expected: "1", actual: deletedChange.Metadata.PartitionKey.First().Value.ToString());
+                Assert.AreEqual(expected: "pk2", actual: deletedChange.Metadata.PartitionKey.Last().Key);
+                Assert.AreEqual(expected: "2", actual: deletedChange.Metadata.PartitionKey.Last().Value.ToString());
                 Assert.AreEqual(expected: "1", actual: deletedChange.Previous.id);
                 Assert.AreEqual(expected: 5, actual: deletedChange.Previous.ttl);
             }
@@ -313,7 +322,7 @@ public void ValidateChangeFeedMetadataSerializationReplaceAnDeleteWriteTest(bool
                 Lsn = 374,
                 OperationType = ChangeFeedOperationType.Create,
                 IsTimeToLiveExpired = true,
-                ConflictResolutionTimestampInSecones = 1722455970
+                ConflictResolutionTimestampInSeconds = 1722455970
             };
 
             string json = System.Text.Json.JsonSerializer.Serialize<ChangeFeedMetadata>(
@@ -339,7 +348,7 @@ public void ValidateChangeFeedMetadataSerializationCreateWriteTest(bool property
             {
                 Lsn = 374,
                 OperationType = ChangeFeedOperationType.Create,
-                ConflictResolutionTimestampInSecones = 1722455970
+                ConflictResolutionTimestampInSeconds = 1722455970
             };
 
             string json = System.Text.Json.JsonSerializer.Serialize<ChangeFeedMetadata>(