checking empty metadata

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

Author: salaboy

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

@@ -1262,6 +1262,43 @@ public void saveStateWithMetaTest() {
     assertEquals("customValue", argument.getValue().getStates(0).getMetadata().get("custom"));
   }
 
+  @Test
+  public void saveStateWithMetaContentTypeTest() {
+    String key = "key1";
+    String etag = "ETag1";
+    String value = "State value";
+    Map<String, String> metadata = new HashMap<>();
+    ArgumentCaptor<DaprProtos.SaveStateRequest> argument = ArgumentCaptor.forClass(DaprProtos.SaveStateRequest.class);
+    doAnswer((Answer<Void>) invocation -> {
+      StreamObserver<Empty> observer = (StreamObserver<Empty>) invocation.getArguments()[1];
+      observer.onNext(Empty.getDefaultInstance());
+      observer.onCompleted();
+      return null;
+    }).when(daprStub).saveState(argument.capture(), any());
+
+
+    Mono<Void> result = client.saveState(STATE_STORE_NAME, key, etag, value, metadata,null);
+    result.block();
+    assertEquals("application/json", argument.getValue().getStates(0).getMetadata().get("contentType"));
+  }
+
+  @Test
+  public void saveStateWithMetaEmptyTest() {
+    String key = "key1";
+    String etag = "ETag1";
+    ArgumentCaptor<DaprProtos.SaveStateRequest> argument = ArgumentCaptor.forClass(DaprProtos.SaveStateRequest.class);
+    doAnswer((Answer<Void>) invocation -> {
+      StreamObserver<Empty> observer = (StreamObserver<Empty>) invocation.getArguments()[1];
+      observer.onNext(Empty.getDefaultInstance());
+      observer.onCompleted();
+      return null;
+    }).when(daprStub).saveState(argument.capture(), any());
+
+    Mono<Void> result = client.saveState(STATE_STORE_NAME, key, etag, null, null,null);
+    result.block();
+    assertTrue(argument.getValue().getStates(0).getMetadata().keySet().isEmpty());
+  }
+
   @Test
   public void saveStateTest() {
     String key = "key1";