Fixed indexing policy getting reset when not provided (Azure#22246)

Author: kushagraThapar

sdk/cosmos/azure-spring-data-cosmos-test/src/test/java/com/azure/spring/data/cosmos/repository/integration/IndexPolicyUpdateIT.java

@@ -9,6 +9,7 @@
 import com.azure.cosmos.models.IndexingPolicy;
 import com.azure.spring.data.cosmos.IntegrationTestCollectionManager;
 import com.azure.spring.data.cosmos.core.CosmosTemplate;
+import com.azure.spring.data.cosmos.domain.Address;
 import com.azure.spring.data.cosmos.domain.ComplexIndexPolicyEntity;
 import com.azure.spring.data.cosmos.domain.IndexPolicyEntity;
 import com.azure.spring.data.cosmos.repository.TestRepositoryConfig;
@@ -45,9 +46,11 @@ public class IndexPolicyUpdateIT {
 
     CosmosEntityInformation<ComplexIndexPolicyEntity, String> complexIndexPolicyEntityInformation = new CosmosEntityInformation<>(ComplexIndexPolicyEntity.class);
 
+    CosmosEntityInformation<Address, String> addressEntityInformation = new CosmosEntityInformation<>(Address.class);
+
     @Before
     public void setup() {
-        collectionManager.ensureContainersCreatedAndEmpty(template, IndexPolicyEntity.class, ComplexIndexPolicyEntity.class);
+        collectionManager.ensureContainersCreatedAndEmpty(template, IndexPolicyEntity.class, ComplexIndexPolicyEntity.class, Address.class);
     }
 
     @Test
@@ -104,4 +107,12 @@ public void testContainerReplaceShouldNotOccurIfComplexIndexIsUnchanged() {
         new SimpleCosmosRepository<>(complexIndexPolicyEntityInformation, spyTemplate);
         Mockito.verify(spyTemplate, Mockito.never()).replaceContainerProperties(Mockito.any(), Mockito.any());
     }
+
+    @Test
+    public void testContainerReplaceShouldNotOccurIfIndexingPolicyIsNotSpecified() {
+        new SimpleCosmosRepository<>(addressEntityInformation, template);
+        CosmosTemplate spyTemplate = Mockito.spy(template);
+        new SimpleCosmosRepository<>(addressEntityInformation, spyTemplate);
+        Mockito.verify(spyTemplate, Mockito.never()).replaceContainerProperties(Mockito.any(), Mockito.any());
+    }
 }

sdk/cosmos/azure-spring-data-cosmos-test/src/test/java/com/azure/spring/data/cosmos/repository/integration/ReactiveIndexPolicyUpdateIT.java

@@ -9,6 +9,7 @@
 import com.azure.cosmos.models.IndexingPolicy;
 import com.azure.spring.data.cosmos.ReactiveIntegrationTestCollectionManager;
 import com.azure.spring.data.cosmos.core.ReactiveCosmosTemplate;
+import com.azure.spring.data.cosmos.domain.Address;
 import com.azure.spring.data.cosmos.domain.ComplexIndexPolicyEntity;
 import com.azure.spring.data.cosmos.domain.IndexPolicyEntity;
 import com.azure.spring.data.cosmos.repository.TestRepositoryConfig;
@@ -45,6 +46,8 @@ public class ReactiveIndexPolicyUpdateIT {
 
     CosmosEntityInformation<ComplexIndexPolicyEntity, String> complexIndexPolicyEntityInformation = new CosmosEntityInformation<>(ComplexIndexPolicyEntity.class);
 
+    CosmosEntityInformation<Address, String> addressEntityInformation = new CosmosEntityInformation<>(Address.class);
+
     @Before
     public void setup() {
         collectionManager.ensureContainersCreatedAndEmpty(template, IndexPolicyEntity.class, ComplexIndexPolicyEntity.class);
@@ -105,4 +108,12 @@ public void testContainerReplaceShouldNotOccurIfComplexIndexIsUnchanged() {
         Mockito.verify(spyTemplate, Mockito.never()).replaceContainerProperties(Mockito.any(), Mockito.any());
     }
 
+    @Test
+    public void testContainerReplaceShouldNotOccurIfIndexingPolicyIsNotSpecified() {
+        new SimpleReactiveCosmosRepository<>(addressEntityInformation, template);
+        ReactiveCosmosTemplate spyTemplate = Mockito.spy(template);
+        new SimpleReactiveCosmosRepository<>(addressEntityInformation, spyTemplate);
+        Mockito.verify(spyTemplate, Mockito.never()).replaceContainerProperties(Mockito.any(), Mockito.any());
+    }
+
 }

sdk/cosmos/azure-spring-data-cosmos/src/main/java/com/azure/spring/data/cosmos/repository/support/CosmosEntityInformation.java

@@ -66,6 +66,7 @@ public class CosmosEntityInformation<T, ID> extends AbstractEntityInformation<T,
     private final boolean autoGenerateId;
     private final boolean persitable;
     private final boolean autoScale;
+    private final boolean isIndexingPolicySpecified;
 
 
     /**
@@ -100,6 +101,7 @@ public CosmosEntityInformation(Class<T> domainType) {
         this.autoCreateContainer = getIsAutoCreateContainer(domainType);
         this.persitable = Persistable.class.isAssignableFrom(domainType);
         this.autoScale = getIsAutoScale(domainType);
+        this.isIndexingPolicySpecified = isIndexingPolicySpecified(domainType);
     }
 
     @Override
@@ -268,6 +270,14 @@ public boolean isAutoScale() {
         return autoScale;
     }
 
+    public boolean isIndexingPolicySpecified() {
+        return this.isIndexingPolicySpecified;
+    }
+
+    private boolean isIndexingPolicySpecified(Class<?> domainType) {
+        return domainType.getAnnotation(CosmosIndexingPolicy.class) != null;
+    }
+
     private IndexingPolicy getIndexingPolicy(Class<?> domainType) {
         final IndexingPolicy policy = new IndexingPolicy();
 

sdk/cosmos/azure-spring-data-cosmos/src/main/java/com/azure/spring/data/cosmos/repository/support/SimpleCosmosRepository.java

@@ -51,6 +51,7 @@ public SimpleCosmosRepository(CosmosEntityInformation<T, ID> metadata,
 
         CosmosContainerProperties currentProperties = getContainerProperties();
         if (currentProperties != null
+            && information.isIndexingPolicySpecified()
             && policyNeedsUpdate(currentProperties.getIndexingPolicy(), information.getIndexingPolicy())) {
             currentProperties.setIndexingPolicy(information.getIndexingPolicy());
             replaceContainerProperties(currentProperties);

sdk/cosmos/azure-spring-data-cosmos/src/main/java/com/azure/spring/data/cosmos/repository/support/SimpleReactiveCosmosRepository.java

@@ -47,6 +47,7 @@ public SimpleReactiveCosmosRepository(CosmosEntityInformation<T, K> metadata,
 
         CosmosContainerProperties currentProperties = getContainerProperties();
         if (currentProperties != null
+            && entityInformation.isIndexingPolicySpecified()
             && policyNeedsUpdate(currentProperties.getIndexingPolicy(), entityInformation.getIndexingPolicy())) {
             currentProperties.setIndexingPolicy(entityInformation.getIndexingPolicy());
             replaceContainerProperties(currentProperties);