http-client-java, bug fix, array encoding support closed enum

packages/http-client-java/generator/http-client-generator-clientcore-test/src/main/java/encode/array/CommaDelimitedArrayProperty.java

@@ -75,12 +75,12 @@ public static CommaDelimitedArrayProperty fromJson(JsonReader jsonReader) throws
                 reader.nextToken();
 
                 if ("value".equals(fieldName)) {
-                    String valueEncodedAsString = reader.getString();
-                    value = valueEncodedAsString == null
-                        ? null
-                        : valueEncodedAsString.isEmpty()
+                    value = reader.getNullable(nonNullReader -> {
+                        String valueEncodedAsString = nonNullReader.getString();
+                        return valueEncodedAsString.isEmpty()
                             ? new LinkedList<>()
                             : new LinkedList<>(Arrays.asList(valueEncodedAsString.split(",", -1)));
+                    });
                 } else {
                     reader.skipChildren();
                 }

packages/http-client-java/generator/http-client-generator-clientcore-test/src/main/java/encode/array/NewlineDelimitedArrayProperty.java

@@ -75,12 +75,12 @@ public static NewlineDelimitedArrayProperty fromJson(JsonReader jsonReader) thro
                 reader.nextToken();
 
                 if ("value".equals(fieldName)) {
-                    String valueEncodedAsString = reader.getString();
-                    value = valueEncodedAsString == null
-                        ? null
-                        : valueEncodedAsString.isEmpty()
+                    value = reader.getNullable(nonNullReader -> {
+                        String valueEncodedAsString = nonNullReader.getString();
+                        return valueEncodedAsString.isEmpty()
                             ? new LinkedList<>()
                             : new LinkedList<>(Arrays.asList(valueEncodedAsString.split("\n", -1)));
+                    });
                 } else {
                     reader.skipChildren();
                 }

packages/http-client-java/generator/http-client-generator-clientcore-test/src/main/java/encode/array/PipeDelimitedArrayProperty.java

@@ -75,12 +75,12 @@ public static PipeDelimitedArrayProperty fromJson(JsonReader jsonReader) throws
                 reader.nextToken();
 
                 if ("value".equals(fieldName)) {
-                    String valueEncodedAsString = reader.getString();
-                    value = valueEncodedAsString == null
-                        ? null
-                        : valueEncodedAsString.isEmpty()
+                    value = reader.getNullable(nonNullReader -> {
+                        String valueEncodedAsString = nonNullReader.getString();
+                        return valueEncodedAsString.isEmpty()
                             ? new LinkedList<>()
                             : new LinkedList<>(Arrays.asList(valueEncodedAsString.split("\\|", -1)));
+                    });
                 } else {
                     reader.skipChildren();
                 }

packages/http-client-java/generator/http-client-generator-clientcore-test/src/main/java/encode/array/SpaceDelimitedArrayProperty.java

@@ -75,12 +75,12 @@ public static SpaceDelimitedArrayProperty fromJson(JsonReader jsonReader) throws
                 reader.nextToken();
 
                 if ("value".equals(fieldName)) {
-                    String valueEncodedAsString = reader.getString();
-                    value = valueEncodedAsString == null
-                        ? null
-                        : valueEncodedAsString.isEmpty()
+                    value = reader.getNullable(nonNullReader -> {
+                        String valueEncodedAsString = nonNullReader.getString();
+                        return valueEncodedAsString.isEmpty()
                             ? new LinkedList<>()
                             : new LinkedList<>(Arrays.asList(valueEncodedAsString.split(" ", -1)));
+                    });
                 } else {
                     reader.skipChildren();
                 }

packages/http-client-java/generator/http-client-generator-core/src/main/java/com/microsoft/typespec/http/client/generator/core/model/clientmodel/ClassType.java

@@ -26,7 +26,7 @@
 /**
  * The details of a class type that is used by a client.
  */
-public class ClassType implements IType, ConvertToJsonTypeTrait {
+public class ClassType implements IType, ConvertToJsonTypeTrait, ConvertFromJsonTypeTrait {
     private static ClassType withClientCoreReplacement(String azureClass, String clientCoreClass) {
         return withClientCoreAndVNextReplacement(azureClass, clientCoreClass, clientCoreClass);
     }
@@ -282,6 +282,7 @@ private static Builder withVNextReplacementBuilder(String azureClass, String azu
     public static final ClassType POLLER_FLUX = new ClassType("com.azure.core.util.polling", "PollerFlux");
 
     // Complex mapped types
+    // JSON type is STRING, wire type is Base64Url/Base64Uri, client type is byte[]
     public static final ClassType BASE_64_URL
         = withClientCoreReplacementBuilder("com.azure.core.util.Base64Url", "io.clientcore.core.utils.Base64Uri", false)
             .serializationValueGetterModifier(valueGetter -> "Objects.toString(" + valueGetter + ", null)")
@@ -310,6 +311,7 @@ private static Builder withVNextReplacementBuilder(String azureClass, String azu
             .xmlAttributeDeserializationTemplate("%s.getNullableAttribute(%s, %s, BinaryData::fromObject)")
             .build();
 
+    // JSON type is STRING, wire type is DateTimeRfc1123, client type is OffsetDateTime
     public static final ClassType DATE_TIME_RFC_1123
         = withClientCoreReplacementBuilder("com.azure.core.util.DateTimeRfc1123",
             "io.clientcore.core.utils.DateTimeRfc1123", false)
@@ -497,8 +499,11 @@ private static Builder withVNextReplacementBuilder(String azureClass, String azu
         .xmlAttributeDeserializationTemplate("%s.getNullableAttribute(%s, %s, OffsetDateTime::parse)")
         .build();
 
+    // JSON type is NUMERIC, client type is OffsetDateTime
     public static final ClassType UNIX_TIME_LONG = new ClassType.Builder(false).prototypeAsLong().build();
+    // JSON type is NUMERIC, client type is Duration
     public static final ClassType DURATION_LONG = new ClassType.Builder(false).prototypeAsLong().build();
+    // JSON type is NUMERIC, client type is Duration
     public static final ClassType DURATION_DOUBLE = new ClassType.Builder(false).prototypeAsDouble().build();
 
     public static final ClassType URL = new Builder(false)
@@ -786,9 +791,31 @@ public boolean isUsedInXml() {
 
     @Override
     public String convertToJsonType(String variableName) {
+        String expression = convertFromClientType(variableName);
         return serializationValueGetterModifier != null
-            ? serializationValueGetterModifier.apply(variableName)
-            : variableName;
+            ? serializationValueGetterModifier.apply(expression)
+            : expression;
+    }
+
+    @Override
+    public String convertFromJsonType(String variableName) {
+        // TODO (weidxu): it may be better to refactor it to type initialization, similar as
+        // defaultValueExpressionConverter
+        if (this == ClassType.INTEGER_AS_STRING) {
+            return variableName + " == null ? null : Integer.parseInt(" + variableName + ")";
+        } else if (this == ClassType.LONG_AS_STRING) {
+            return variableName + " == null ? null : Long.parseInt(" + variableName + ")";
+        } else if (this == ClassType.DATE_TIME) {
+            return variableName + " == null ? null : OffsetDateTime.parse(" + variableName + ")";
+        } else if (this == ClassType.DATE_TIME_RFC_1123) {
+            return variableName + " == null ? null : new DateTimeRfc1123(" + variableName + ")";
+        } else if (this == ClassType.DURATION) {
+            return variableName + " == null ? null : Duration.parse(" + variableName + ")";
+        } else if (this == ClassType.URL) {
+            return variableName + " == null ? null : new URL(" + variableName + ")";
+        } else {
+            return convertToClientType(variableName);
+        }
     }
 
     public static class Builder {

packages/http-client-java/generator/http-client-generator-core/src/main/java/com/microsoft/typespec/http/client/generator/core/model/clientmodel/ConvertFromJsonTypeTrait.java

@@ -0,0 +1,18 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+
+package com.microsoft.typespec.http.client.generator.core.model.clientmodel;
+
+/**
+ * Trait for types that can convert a JSON wire value back into the client type.
+ */
+public interface ConvertFromJsonTypeTrait {
+
+    /**
+     * Gets the expression that converts the JSON wire value into this type.
+     *
+     * @param variableName The variable to convert.
+     * @return The expression that converts the variable to this type.
+     */
+    String convertFromJsonType(String variableName);
+}

packages/http-client-java/generator/http-client-generator-core/src/main/java/com/microsoft/typespec/http/client/generator/core/model/clientmodel/ConvertToJsonTypeTrait.java

@@ -6,10 +6,10 @@
 public interface ConvertToJsonTypeTrait {
 
     /**
-     * Gets the expression that convert the variable of this type to the wire type.
+     * Gets the expression that convert the variable of this type to the JSON wire type.
      *
      * @param variableName The variable to convert.
-     * @return The expression that convert the variable to the wire type.
+     * @return The expression that convert the variable to the JSON wire type.
      */
     String convertToJsonType(String variableName);
 }

packages/http-client-java/generator/http-client-generator-core/src/main/java/com/microsoft/typespec/http/client/generator/core/model/clientmodel/EnumType.java

@@ -11,7 +11,7 @@
 /**
  * The details of an enumerated type that is used by a service.
  */
-public class EnumType implements IType, ConvertToJsonTypeTrait {
+public class EnumType implements IType, ConvertToJsonTypeTrait, ConvertFromJsonTypeTrait {
     /**
      * The name of the new Enum.
      */
@@ -233,6 +233,11 @@ public String convertToJsonType(String variableName) {
         return variableName + " == null ? null : " + variableName + "." + getToMethodName() + "()";
     }
 
+    @Override
+    public String convertFromJsonType(String variableName) {
+        return variableName + " == null ? null : " + getName() + "." + getFromMethodName() + "(" + variableName + ")";
+    }
+
     public static class Builder {
         private String name;
         private String description;

packages/http-client-java/generator/http-client-generator-core/src/main/java/com/microsoft/typespec/http/client/generator/core/model/clientmodel/PrimitiveType.java

@@ -12,7 +12,7 @@
 /**
  * A basic type used by a client.
  */
-public class PrimitiveType implements IType, ConvertToJsonTypeTrait {
+public class PrimitiveType implements IType, ConvertToJsonTypeTrait, ConvertFromJsonTypeTrait {
     public static final PrimitiveType VOID = new Builder().name("void").nullableType(ClassType.VOID).build();
 
     public static final PrimitiveType BOOLEAN = new Builder().name("boolean")
@@ -50,6 +50,7 @@ public class PrimitiveType implements IType, ConvertToJsonTypeTrait {
 
     public static final PrimitiveType LONG = new Builder().prototypeAsLong().build();
 
+    // JSON type is STRING
     public static final PrimitiveType INT_AS_STRING = new Builder().name("int")
         .nullableType(ClassType.INTEGER_AS_STRING)
         .defaultValueExpressionConverter(
@@ -63,6 +64,7 @@ public class PrimitiveType implements IType, ConvertToJsonTypeTrait {
         .xmlAttributeDeserializationTemplate("%s.getNullableAttribute(%s, %s, Integer::valueOf)")
         .build();
 
+    // JSON type is STRING
     public static final PrimitiveType LONG_AS_STRING = new Builder().prototypeAsLong()
         .nullableType(ClassType.LONG_AS_STRING)
         .defaultValueExpressionConverter(defaultValueExpression -> "Long.parseLong(\"" + defaultValueExpression + "\")")
@@ -99,12 +101,15 @@ public class PrimitiveType implements IType, ConvertToJsonTypeTrait {
         .xmlElementDeserializationMethod("getStringElement().charAt(0)")
         .build();
 
+    // JSON type is NUMERIC, client type is OffsetDateTime
     public static final PrimitiveType UNIX_TIME_LONG
         = new Builder().prototypeAsLong().nullableType(ClassType.UNIX_TIME_LONG).build();
 
+    // JSON type is NUMERIC, client type is Duration
     public static final PrimitiveType DURATION_LONG
         = new Builder().prototypeAsLong().nullableType(ClassType.DURATION_LONG).build();
 
+    // JSON type is NUMERIC, client type is Duration
     public static final PrimitiveType DURATION_DOUBLE
         = new Builder().prototypeAsDouble().nullableType(ClassType.DURATION_DOUBLE).build();
 
@@ -305,10 +310,22 @@ public String toString() {
 
     @Override
     public String convertToJsonType(String variableName) {
+        String expression = convertFromClientType(variableName);
         if (wrapSerializationWithObjectsToString) {
-            return "Objects.toString(" + variableName + ", null)";
+            return "Objects.toString(" + expression + ", null)";
         } else {
-            return variableName;
+            return expression;
+        }
+    }
+
+    @Override
+    public String convertFromJsonType(String variableName) {
+        if (this == PrimitiveType.INT_AS_STRING) {
+            return variableName + " == null ? null : Integer.parseInt(" + variableName + ")";
+        } else if (this == PrimitiveType.LONG_AS_STRING) {
+            return variableName + " == null ? null : Long.parseInt(" + variableName + ")";
+        } else {
+            return convertToClientType(variableName);
         }
     }
 

packages/http-client-java/generator/http-client-generator-core/src/main/java/com/microsoft/typespec/http/client/generator/core/template/StreamSerializationModelTemplate.java

@@ -15,6 +15,7 @@
 import com.microsoft.typespec.http.client.generator.core.model.clientmodel.ClientModelProperty;
 import com.microsoft.typespec.http.client.generator.core.model.clientmodel.ClientModelPropertyAccess;
 import com.microsoft.typespec.http.client.generator.core.model.clientmodel.ClientModelPropertyReference;
+import com.microsoft.typespec.http.client.generator.core.model.clientmodel.ConvertFromJsonTypeTrait;
 import com.microsoft.typespec.http.client.generator.core.model.clientmodel.ConvertToJsonTypeTrait;
 import com.microsoft.typespec.http.client.generator.core.model.clientmodel.IType;
 import com.microsoft.typespec.http.client.generator.core.model.clientmodel.IterableType;
@@ -1623,13 +1624,7 @@ private void generateJsonDeserializationLogic(JavaBlock deserializationBlock, Cl
                     deserializationBlock.line(property.getName() + " = reader.readUntyped();");
                 }
             } else if (wireType instanceof IterableType) {
-                final String propertyStringVariableName = property.getName() + "EncodedAsString";
                 IType wireElementType = ((IterableType) wireType).getElementType();
-                if (property.getArrayEncoding() != null) {
-                    // need to prepare the expression for propertyStringVariableName,
-                    // to be used in "if (property.getArrayEncoding() == null)" block
-                    deserializationBlock.line("String " + propertyStringVariableName + " = reader.getString();");
-                }
 
                 if (!propertiesManager.hasConstructorArguments()) {
                     deserializationBlock.text(property.getClientType() + " ");
@@ -1640,21 +1635,38 @@ private void generateJsonDeserializationLogic(JavaBlock deserializationBlock, Cl
                     deserializeJsonContainerProperty(deserializationBlock, "readArray", wireType, wireElementType,
                         ((IterableType) clientType).getElementType(), 0);
                 } else {
+                    final String propertyStringVariableName = property.getName() + "EncodedAsString";
                     // LinkedList is used to be consistent with internal code of core, e.g. "readArray" API
                     if (wireElementType == ClassType.STRING) {
                         // wireType is String
-                        deserializationBlock.line(
-                            "%1$s == null ? null : %1$s.isEmpty() ? new LinkedList<>() : new LinkedList<>(Arrays.asList(%1$s.split(\"%2$s\", -1)));",
-                            propertyStringVariableName, property.getArrayEncoding().getEscapedDelimiter());
+                        deserializationBlock.line("reader.getNullable(nonNullReader -> {");
+                        deserializationBlock.indent(() -> {
+                            deserializationBlock.line("String %1$s = nonNullReader.getString();",
+                                propertyStringVariableName);
+                            deserializationBlock.line(
+                                "return %1$s.isEmpty() ? new LinkedList<>() : new LinkedList<>(Arrays.asList(%1$s.split(\"%2$s\", -1)));",
+                                propertyStringVariableName, property.getArrayEncoding().getEscapedDelimiter());
+                        });
+                        deserializationBlock.line("});");
                     } else {
                         // wireType need to be converted from String
-                        String conversionExpress = wireElementType.defaultValueExpression("valueAsString")
-                            .replace("\"valueAsString\"", "valueAsString");
-                        deserializationBlock.line(
-                            "%1$s == null ? null : %1$s.isEmpty() ? new LinkedList<>() : new LinkedList<>(Arrays.stream(%1$s.split(\"%2$s\", -1)).map(valueAsString -> %3$s).collect(Collectors.toList()));",
-                            propertyStringVariableName, property.getArrayEncoding().getEscapedDelimiter(),
-                            conversionExpress);
-
+                        if (wireElementType instanceof ConvertFromJsonTypeTrait) {
+                            String conversionExpress
+                                = ((ConvertFromJsonTypeTrait) wireElementType).convertFromJsonType("valueAsString");
+                            deserializationBlock.line("reader.getNullable(nonNullReader -> {");
+                            deserializationBlock.indent(() -> {
+                                deserializationBlock.line("String %1$s = nonNullReader.getString();",
+                                    propertyStringVariableName);
+                                deserializationBlock.line(
+                                    "%1$s.isEmpty() ? new LinkedList<>() : new LinkedList<>(Arrays.stream(%1$s.split(\"%2$s\", -1)).map(valueAsString -> %3$s).collect(Collectors.toList()));",
+                                    propertyStringVariableName, property.getArrayEncoding().getEscapedDelimiter(),
+                                    conversionExpress);
+                            });
+                            deserializationBlock.line("});");
+                        } else {
+                            throw new RuntimeException("Unable to convert type " + wireElementType
+                                + " from String for ArrayEncoding serialization.");
+                        }
                     }
                 }