rls: fix RlcProto parsing issues (#6822)

rls/src/main/java/io/grpc/rls/internal/RlsProtoConverters.java

@@ -17,6 +17,7 @@
 package io.grpc.rls.internal;
 
 import static com.google.common.base.Preconditions.checkArgument;
+import static com.google.common.base.Preconditions.checkNotNull;
 
 import com.google.common.base.Converter;
 import io.grpc.internal.JsonUtil;
@@ -31,6 +32,7 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 import java.util.concurrent.TimeUnit;
+import javax.annotation.Nullable;
 
 /**
  * RlsProtoConverters is a collection of {@link Converter} between RouteLookupService proto / json
@@ -104,14 +106,17 @@ public final class RlsProtoConverters {
               .covertAll(JsonUtil.checkObjectList(JsonUtil.getList(json, "grpcKeyBuilders")));
       String lookupService = JsonUtil.getString(json, "lookupService");
       long timeout =
-          TimeUnit.SECONDS.toMillis(JsonUtil.getNumberAsLong(json, "lookupServiceTimeout"));
+          TimeUnit.SECONDS.toMillis(
+              orDefault(
+                  JsonUtil.getNumberAsLong(json, "lookupServiceTimeout"),
+                  0L));
       Long maxAge =
           convertTimeIfNotNull(
               TimeUnit.SECONDS, TimeUnit.MILLISECONDS, JsonUtil.getNumberAsLong(json, "maxAge"));
       Long staleAge =
           convertTimeIfNotNull(
               TimeUnit.SECONDS, TimeUnit.MILLISECONDS, JsonUtil.getNumberAsLong(json, "staleAge"));
-      long cacheSize = JsonUtil.getNumberAsLong(json, "cacheSizeBytes");
+      long cacheSize = orDefault(JsonUtil.getNumberAsLong(json, "cacheSizeBytes"), Long.MAX_VALUE);
       List<String> validTargets = JsonUtil.checkStringList(JsonUtil.getList(json, "validTargets"));
       String defaultTarget = JsonUtil.getString(json, "defaultTarget");
       RequestProcessingStrategy strategy =
@@ -129,6 +134,13 @@ public final class RlsProtoConverters {
           strategy);
     }
 
+    private static <T> T orDefault(@Nullable T value, T defaultValue) {
+      if (value == null) {
+        return checkNotNull(defaultValue, "defaultValue");
+      }
+      return value;
+    }
+
     private static Long convertTimeIfNotNull(TimeUnit from, TimeUnit to, Long value) {
       if (value == null) {
         return null;

rls/src/main/java/io/grpc/rls/internal/RlsProtoData.java

@@ -238,10 +238,10 @@ public final class RlsProtoData {
       this.requestProcessingStrategy = requestProcessingStrategy;
       checkNotNull(requestProcessingStrategy, "requestProcessingStrategy");
       checkState(
-          (requestProcessingStrategy == RequestProcessingStrategy.SYNC_LOOKUP_CLIENT_SEES_ERROR
+          !((requestProcessingStrategy == RequestProcessingStrategy.SYNC_LOOKUP_CLIENT_SEES_ERROR
               || requestProcessingStrategy
               == RequestProcessingStrategy.ASYNC_LOOKUP_DEFAULT_TARGET_ON_MISS)
-              && !defaultTarget.isEmpty(),
+              && defaultTarget.isEmpty()),
           "defaultTarget cannot be empty if strategy is %s",
           requestProcessingStrategy);
     }
@@ -417,10 +417,10 @@ public final class RlsProtoData {
 
     private final boolean optional;
 
-    NameMatcher(String key, List<String> names, boolean optional) {
+    NameMatcher(String key, List<String> names, @Nullable Boolean optional) {
       this.key = checkNotNull(key, "key");
       this.names = ImmutableList.copyOf(checkNotNull(names, "names"));
-      this.optional = optional;
+      this.optional = optional != null ? optional : true;
     }
 
     /** The name that will be used in the RLS key_map to refer to this value. */

rls/src/test/java/io/grpc/rls/internal/RlsProtoConvertersTest.java

@@ -173,7 +173,7 @@ public class RlsProtoConvertersTest {
         + "  \"validTargets\": [\"a valid target\"],"
         + "  \"cacheSizeBytes\": 1000,\n"
         + "  \"defaultTarget\": \"us_east_1.cloudbigtable.googleapis.com\",\n"
-        + "  \"requestProcessingStrategy\": \"ASYNC_LOOKUP_DEFAULT_TARGET_ON_MISS\"\n"
+        + "  \"requestProcessingStrategy\": \"SYNC_LOOKUP_CLIENT_SEES_ERROR\"\n"
         + "}";
 
     RouteLookupConfig expectedConfig =
@@ -200,7 +200,7 @@ public class RlsProtoConvertersTest {
             /* cacheSize= */ 1000,
             /* validTargets= */ ImmutableList.of("a valid target"),
             /* defaultTarget= */ "us_east_1.cloudbigtable.googleapis.com",
-            RequestProcessingStrategy.ASYNC_LOOKUP_DEFAULT_TARGET_ON_MISS);
+            RequestProcessingStrategy.SYNC_LOOKUP_CLIENT_SEES_ERROR);
 
     RouteLookupConfigConverter converter = new RouteLookupConfigConverter();
     @SuppressWarnings("unchecked")