Update pom.xml to have testcontainers 1.21.3 (dapr#1436)

Signed-off-by: salaboy <[email protected]>
Signed-off-by: love12yadav <[email protected]>

Author: salaboy

pom.xml

@@ -47,7 +47,7 @@
     <surefire.version>3.2.2</surefire.version>
     <junit-bom.version>5.11.4</junit-bom.version>
     <snakeyaml.version>2.0</snakeyaml.version>
-    <testcontainers.version>1.20.5</testcontainers.version>
+    <testcontainers.version>1.21.3</testcontainers.version>
     <!-- Do NOT UPGRADE spring.version without checking springboot.version alignment -->
     <springboot.version>3.4.6</springboot.version>
     <springframework.version>6.2.7</springframework.version>

sdk/src/test/java/io/dapr/client/DaprClientGrpcTest.java

@@ -1384,44 +1384,64 @@ public void getStateThenDelete() throws Exception {
     String expectedValue1 = "Expected state 1";
     String key2 = "key2";
     String expectedValue2 = "Expected state 2";
+
     State<String> expectedState1 = buildStateKey(expectedValue1, key1, etag, new HashMap<>(), null);
     State<String> expectedState2 = buildStateKey(expectedValue2, key2, etag, new HashMap<>(), null);
+
     Map<String, DaprProtos.GetStateResponse> futuresMap = new HashMap<>();
     futuresMap.put(key1, buildFutureGetStateEnvelop(expectedValue1, etag));
-    futuresMap.put(key2, buildFutureGetStateEnvelop(expectedValue2, etag));
+    futuresMap.put(key2, buildFutureGetStateEnvelop(expectedValue2, etag)); // Will be removed on delete
 
+    // Mock getState for key1 (unchanged)
     doAnswer((Answer<Void>) invocation -> {
-      StreamObserver<DaprProtos.GetStateResponse> observer = (StreamObserver<DaprProtos.GetStateResponse>) invocation.getArguments()[1];
+      StreamObserver<DaprProtos.GetStateResponse> observer =
+              (StreamObserver<DaprProtos.GetStateResponse>) invocation.getArguments()[1];
       observer.onNext(futuresMap.get(key1));
       observer.onCompleted();
       return null;
     }).when(daprStub).getState(argThat(new GetStateRequestKeyMatcher(key1)), any());
+
+    // Mock getState for key2 — updated after delete
     doAnswer((Answer<Void>) invocation -> {
-      StreamObserver<DaprProtos.GetStateResponse> observer = (StreamObserver<DaprProtos.GetStateResponse>) invocation.getArguments()[1];
-      observer.onNext(futuresMap.get(key2));
+      StreamObserver<DaprProtos.GetStateResponse> observer =
+              (StreamObserver<DaprProtos.GetStateResponse>) invocation.getArguments()[1];
+      DaprProtos.GetStateResponse response = futuresMap.get(key2);
+      if (response != null) {
+        observer.onNext(response);
+      }
       observer.onCompleted();
       return null;
     }).when(daprStub).getState(argThat(new GetStateRequestKeyMatcher(key2)), any());
 
+    // getState for key1 and assert
     State<String> keyRequest1 = buildStateKey(null, key1, etag, null);
     Mono<State<String>> resultGet1 = client.getState(STATE_STORE_NAME, keyRequest1, String.class);
     assertEquals(expectedState1, resultGet1.block());
+
+    // Prepare getState for key2 (lazy)
     State<String> keyRequest2 = buildStateKey(null, key2, etag, null);
     Mono<State<String>> resultGet2 = client.getState(STATE_STORE_NAME, keyRequest2, String.class);
-    assertEquals(expectedState2, resultGet2.block());
 
+    // Mock deleteState for key2 (simulate deletion)
     doAnswer((Answer<Void>) invocation -> {
+      futuresMap.remove(key2);
       StreamObserver<Empty> observer = (StreamObserver<Empty>) invocation.getArguments()[1];
       observer.onNext(Empty.getDefaultInstance());
       observer.onCompleted();
       return null;
-    }).when(daprStub).deleteState(any(io.dapr.v1.DaprProtos.DeleteStateRequest.class), any());
+    }).when(daprStub).deleteState(any(DaprProtos.DeleteStateRequest.class), any());
 
-    Mono<Void> resultDelete = client.deleteState(STATE_STORE_NAME, keyRequest2.getKey(), keyRequest2.getEtag(),
-        keyRequest2.getOptions());
+    // Perform delete
+    Mono<Void> resultDelete = client.deleteState(
+            STATE_STORE_NAME, keyRequest2.getKey(), keyRequest2.getEtag(), keyRequest2.getOptions());
     resultDelete.block();
+
+    // Now block the original getState call (should be null)
+    State<String> stateAfterDelete = resultGet2.block();
+    assertNull(stateAfterDelete.getValue());
   }
 
+
   @Test
   public void deleteStateNullEtag() {
     String key = "key1";