Expose gRPC service in OSGi service registry

And fix few things

Change-Id: If1829df08af92b37ab90790c4d6c306e06a0f04e
Issue-ID: CCSDK-947
Signed-off-by: Alexis de Talhouët <adetalhouet89@gmail.com>

5 files changed, 1491 insertions, 4 deletions

diff --git a/grpc-resource/provider/pom.xml b/grpc-resource/provider/pom.xml
index c567bba1..4eee611f 100644
--- a/grpc-resource/provider/pom.xml
+++ b/grpc-resource/provider/pom.xml
@@ -142,6 +142,7 @@
                             io.grpc.util
                         </Export-Package>
                         <Import-Package>!com.google.errorprone.annotations,*</Import-Package>
+                        <Embed-Dependency>*;inline=META-INF/services/**</Embed-Dependency>
                     </instructions>
                 </configuration>
             </plugin>
diff --git a/grpc-resource/provider/src/main/java/org/onap/ccsdk/sli/adaptors/grpc/JsonFormat.java b/grpc-resource/provider/src/main/java/org/onap/ccsdk/sli/adaptors/grpc/JsonFormat.java
new file mode 100644
index 00000000..a656d662
--- /dev/null
+++ b/grpc-resource/provider/src/main/java/org/onap/ccsdk/sli/adaptors/grpc/JsonFormat.java
@@ -0,0 +1,1479 @@
+/*
+ * Copyright (C) 2019 Google
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.onap.ccsdk.sli.adaptors.grpc;
+
+import com.google.common.base.Preconditions;
+import com.google.common.io.BaseEncoding;
+import com.google.gson.Gson;
+import com.google.gson.GsonBuilder;
+import com.google.gson.JsonArray;
+import com.google.gson.JsonElement;
+import com.google.gson.JsonIOException;
+import com.google.gson.JsonNull;
+import com.google.gson.JsonObject;
+import com.google.gson.JsonParser;
+import com.google.gson.JsonPrimitive;
+import com.google.gson.stream.JsonReader;
+import com.google.protobuf.Any;
+import com.google.protobuf.BoolValue;
+import com.google.protobuf.ByteString;
+import com.google.protobuf.BytesValue;
+import com.google.protobuf.Descriptors.Descriptor;
+import com.google.protobuf.Descriptors.EnumDescriptor;
+import com.google.protobuf.Descriptors.EnumValueDescriptor;
+import com.google.protobuf.Descriptors.FieldDescriptor;
+import com.google.protobuf.Descriptors.FieldDescriptor.JavaType;
+import com.google.protobuf.Descriptors.FieldDescriptor.Type;
+import com.google.protobuf.Descriptors.FileDescriptor;
+import com.google.protobuf.Descriptors.FileDescriptor.Syntax;
+import com.google.protobuf.Descriptors.OneofDescriptor;
+import com.google.protobuf.DoubleValue;
+import com.google.protobuf.DynamicMessage;
+import com.google.protobuf.FloatValue;
+import com.google.protobuf.Int32Value;
+import com.google.protobuf.Int64Value;
+import com.google.protobuf.InvalidProtocolBufferException;
+import com.google.protobuf.ListValue;
+import com.google.protobuf.Message;
+import com.google.protobuf.MessageOrBuilder;
+import com.google.protobuf.NullValue;
+import com.google.protobuf.StringValue;
+import com.google.protobuf.Struct;
+import com.google.protobuf.UInt32Value;
+import com.google.protobuf.UInt64Value;
+import com.google.protobuf.Value;
+import java.io.IOException;
+import java.io.Reader;
+import java.io.StringReader;
+import java.math.BigDecimal;
+import java.math.BigInteger;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import java.util.Map.Entry;
+import java.util.Set;
+import java.util.TreeMap;
+import java.util.logging.Logger;
+
+//Fork from :
+//
+//<dependency>
+//<groupId>com.google.protobuf</groupId>
+//<artifactId>protobuf-java-util</artifactId>
+//<version>3.6.1</version>
+//</dependency>
+
+public class JsonFormat {
+
+    private static final Logger logger = Logger.getLogger(JsonFormat.class.getName());
+
+    private JsonFormat() {
+    }
+
+    public static JsonFormat.Printer printer() {
+        return new JsonFormat.Printer(JsonFormat.TypeRegistry.getEmptyTypeRegistry(), false, Collections.emptySet(),
+            false, false, false);
+    }
+
+    public static JsonFormat.Parser parser() {
+        return new JsonFormat.Parser(JsonFormat.TypeRegistry.getEmptyTypeRegistry(), false, 100);
+    }
+
+    private static String unsignedToString(int value) {
+        return value >= 0 ? Integer.toString(value) : Long.toString((long) value & 4294967295L);
+    }
+
+    private static String unsignedToString(long value) {
+        return value >= 0L ? Long.toString(value)
+            : BigInteger.valueOf(value & 9223372036854775807L).setBit(63).toString();
+    }
+
+    private static String getTypeName(String typeUrl) throws InvalidProtocolBufferException {
+        String[] parts = typeUrl.split("/");
+        if (parts.length == 1) {
+            throw new InvalidProtocolBufferException("Invalid type url found: " + typeUrl);
+        } else {
+            return parts[parts.length - 1];
+        }
+    }
+
+    private static class ParserImpl {
+
+        private final JsonFormat.TypeRegistry registry;
+        private final JsonParser jsonParser;
+        private final boolean ignoringUnknownFields;
+        private final int recursionLimit;
+        private int currentDepth;
+        private static final Map<String, JsonFormat.ParserImpl.WellKnownTypeParser> wellKnownTypeParsers = buildWellKnownTypeParsers();
+        private final Map<Descriptor, Map<String, FieldDescriptor>> fieldNameMaps = new HashMap();
+        private static final BigInteger MAX_UINT64 = new BigInteger("FFFFFFFFFFFFFFFF", 16);
+        private static final double EPSILON = 1.0E-6D;
+        private static final BigDecimal MORE_THAN_ONE = new BigDecimal(String.valueOf(1.000001D));
+        private static final BigDecimal MAX_DOUBLE;
+        private static final BigDecimal MIN_DOUBLE;
+
+        ParserImpl(JsonFormat.TypeRegistry registry, boolean ignoreUnknownFields, int recursionLimit) {
+            this.registry = registry;
+            this.ignoringUnknownFields = ignoreUnknownFields;
+            this.jsonParser = new JsonParser();
+            this.recursionLimit = recursionLimit;
+            this.currentDepth = 0;
+        }
+
+        void merge(Reader json, com.google.protobuf.Message.Builder builder) throws IOException {
+            try {
+                JsonReader reader = new JsonReader(json);
+                reader.setLenient(false);
+                this.merge(this.jsonParser.parse(reader), builder);
+            } catch (InvalidProtocolBufferException var4) {
+                throw var4;
+            } catch (JsonIOException var5) {
+                if (var5.getCause() instanceof IOException) {
+                    throw (IOException) var5.getCause();
+                } else {
+                    throw new InvalidProtocolBufferException(var5.getMessage());
+                }
+            } catch (Exception var6) {
+                throw new InvalidProtocolBufferException(var6.getMessage());
+            }
+        }
+
+        void merge(String json, com.google.protobuf.Message.Builder builder) throws InvalidProtocolBufferException {
+            try {
+                JsonReader reader = new JsonReader(new StringReader(json));
+                reader.setLenient(false);
+                this.merge(this.jsonParser.parse(reader), builder);
+            } catch (InvalidProtocolBufferException var4) {
+                throw var4;
+            } catch (Exception var5) {
+                throw new InvalidProtocolBufferException(var5.getMessage());
+            }
+        }
+
+        private static Map<String, JsonFormat.ParserImpl.WellKnownTypeParser> buildWellKnownTypeParsers() {
+            Map<String, JsonFormat.ParserImpl.WellKnownTypeParser> parsers = new HashMap();
+            parsers.put(Any.getDescriptor().getFullName(), new JsonFormat.ParserImpl.WellKnownTypeParser() {
+                public void merge(JsonFormat.ParserImpl parser, JsonElement json,
+                    com.google.protobuf.Message.Builder builder) throws InvalidProtocolBufferException {
+                    parser.mergeAny(json, builder);
+                }
+            });
+            JsonFormat.ParserImpl.WellKnownTypeParser wrappersPrinter = new JsonFormat.ParserImpl.WellKnownTypeParser() {
+                public void merge(JsonFormat.ParserImpl parser, JsonElement json,
+                    com.google.protobuf.Message.Builder builder) throws InvalidProtocolBufferException {
+                    parser.mergeWrapper(json, builder);
+                }
+            };
+            parsers.put(BoolValue.getDescriptor().getFullName(), wrappersPrinter);
+            parsers.put(Int32Value.getDescriptor().getFullName(), wrappersPrinter);
+            parsers.put(UInt32Value.getDescriptor().getFullName(), wrappersPrinter);
+            parsers.put(Int64Value.getDescriptor().getFullName(), wrappersPrinter);
+            parsers.put(UInt64Value.getDescriptor().getFullName(), wrappersPrinter);
+            parsers.put(StringValue.getDescriptor().getFullName(), wrappersPrinter);
+            parsers.put(BytesValue.getDescriptor().getFullName(), wrappersPrinter);
+            parsers.put(FloatValue.getDescriptor().getFullName(), wrappersPrinter);
+            parsers.put(DoubleValue.getDescriptor().getFullName(), wrappersPrinter);
+            parsers.put(Struct.getDescriptor().getFullName(), new JsonFormat.ParserImpl.WellKnownTypeParser() {
+                public void merge(JsonFormat.ParserImpl parser, JsonElement json,
+                    com.google.protobuf.Message.Builder builder) throws InvalidProtocolBufferException {
+                    parser.mergeStruct(json, builder);
+                }
+            });
+            parsers.put(ListValue.getDescriptor().getFullName(), new JsonFormat.ParserImpl.WellKnownTypeParser() {
+                public void merge(JsonFormat.ParserImpl parser, JsonElement json,
+                    com.google.protobuf.Message.Builder builder) throws InvalidProtocolBufferException {
+                    parser.mergeListValue(json, builder);
+                }
+            });
+            parsers.put(Value.getDescriptor().getFullName(), new JsonFormat.ParserImpl.WellKnownTypeParser() {
+                public void merge(JsonFormat.ParserImpl parser, JsonElement json,
+                    com.google.protobuf.Message.Builder builder) throws InvalidProtocolBufferException {
+                    parser.mergeValue(json, builder);
+                }
+            });
+            return parsers;
+        }
+
+        private void merge(JsonElement json, com.google.protobuf.Message.Builder builder)
+            throws InvalidProtocolBufferException {
+            JsonFormat.ParserImpl.WellKnownTypeParser specialParser = (JsonFormat.ParserImpl.WellKnownTypeParser) wellKnownTypeParsers
+                .get(builder.getDescriptorForType().getFullName());
+            if (specialParser != null) {
+                specialParser.merge(this, json, builder);
+            } else {
+                this.mergeMessage(json, builder, false);
+            }
+        }
+
+        private Map<String, FieldDescriptor> getFieldNameMap(Descriptor descriptor) {
+            if (this.fieldNameMaps.containsKey(descriptor)) {
+                return (Map) this.fieldNameMaps.get(descriptor);
+            } else {
+                Map<String, FieldDescriptor> fieldNameMap = new HashMap();
+                Iterator var3 = descriptor.getFields().iterator();
+
+                while (var3.hasNext()) {
+                    FieldDescriptor field = (FieldDescriptor) var3.next();
+                    fieldNameMap.put(field.getName(), field);
+                    fieldNameMap.put(field.getJsonName(), field);
+                }
+
+                this.fieldNameMaps.put(descriptor, fieldNameMap);
+                return fieldNameMap;
+            }
+        }
+
+        private void mergeMessage(JsonElement json, com.google.protobuf.Message.Builder builder, boolean skipTypeUrl)
+            throws InvalidProtocolBufferException {
+            if (!(json instanceof JsonObject)) {
+                throw new InvalidProtocolBufferException("Expect message object but got: " + json);
+            } else {
+                JsonObject object = (JsonObject) json;
+                Map<String, FieldDescriptor> fieldNameMap = this.getFieldNameMap(builder.getDescriptorForType());
+                Iterator var6 = object.entrySet().iterator();
+
+                while (true) {
+                    Entry entry;
+                    do {
+                        if (!var6.hasNext()) {
+                            return;
+                        }
+
+                        entry = (Entry) var6.next();
+                    } while (skipTypeUrl && ((String) entry.getKey()).equals("@type"));
+
+                    FieldDescriptor field = (FieldDescriptor) fieldNameMap.get(entry.getKey());
+                    if (field == null) {
+                        if (!this.ignoringUnknownFields) {
+                            throw new InvalidProtocolBufferException(
+                                "Cannot find field: " + (String) entry.getKey() + " in message " + builder
+                                    .getDescriptorForType().getFullName());
+                        }
+                    } else {
+                        this.mergeField(field, (JsonElement) entry.getValue(), builder);
+                    }
+                }
+            }
+        }
+
+        private void mergeAny(JsonElement json, com.google.protobuf.Message.Builder builder)
+            throws InvalidProtocolBufferException {
+            Descriptor descriptor = builder.getDescriptorForType();
+            FieldDescriptor typeUrlField = descriptor.findFieldByName("type_url");
+            FieldDescriptor valueField = descriptor.findFieldByName("value");
+            if (typeUrlField != null && valueField != null && typeUrlField.getType() == Type.STRING
+                && valueField.getType() == Type.BYTES) {
+                if (!(json instanceof JsonObject)) {
+                    throw new InvalidProtocolBufferException("Expect message object but got: " + json);
+                } else {
+                    JsonObject object = (JsonObject) json;
+                    if (!object.entrySet().isEmpty()) {
+                        JsonElement typeUrlElement = object.get("@type");
+                        if (typeUrlElement == null) {
+                            throw new InvalidProtocolBufferException("Missing type url when parsing: " + json);
+                        } else {
+                            String typeUrl = typeUrlElement.getAsString();
+                            Descriptor contentType = this.registry.find(JsonFormat.getTypeName(typeUrl));
+                            if (contentType == null) {
+                                throw new InvalidProtocolBufferException("Cannot resolve type: " + typeUrl);
+                            } else {
+                                builder.setField(typeUrlField, typeUrl);
+                                com.google.protobuf.Message.Builder contentBuilder = DynamicMessage
+                                    .getDefaultInstance(contentType).newBuilderForType();
+                                JsonFormat.ParserImpl.WellKnownTypeParser specialParser = (JsonFormat.ParserImpl.WellKnownTypeParser) wellKnownTypeParsers
+                                    .get(contentType.getFullName());
+                                if (specialParser != null) {
+                                    JsonElement value = object.get("value");
+                                    if (value != null) {
+                                        specialParser.merge(this, value, contentBuilder);
+                                    }
+                                } else {
+                                    this.mergeMessage(json, contentBuilder, true);
+                                }
+
+                                builder.setField(valueField, contentBuilder.build().toByteString());
+                            }
+                        }
+                    }
+                }
+            } else {
+                throw new InvalidProtocolBufferException("Invalid Any type.");
+            }
+        }
+
+
+        private void mergeStruct(JsonElement json, com.google.protobuf.Message.Builder builder)
+            throws InvalidProtocolBufferException {
+            Descriptor descriptor = builder.getDescriptorForType();
+            FieldDescriptor field = descriptor.findFieldByName("fields");
+            if (field == null) {
+                throw new InvalidProtocolBufferException("Invalid Struct type.");
+            } else {
+                this.mergeMapField(field, json, builder);
+            }
+        }
+
+        private void mergeListValue(JsonElement json, com.google.protobuf.Message.Builder builder)
+            throws InvalidProtocolBufferException {
+            Descriptor descriptor = builder.getDescriptorForType();
+            FieldDescriptor field = descriptor.findFieldByName("values");
+            if (field == null) {
+                throw new InvalidProtocolBufferException("Invalid ListValue type.");
+            } else {
+                this.mergeRepeatedField(field, json, builder);
+            }
+        }
+
+        private void mergeValue(JsonElement json, com.google.protobuf.Message.Builder builder)
+            throws InvalidProtocolBufferException {
+            Descriptor type = builder.getDescriptorForType();
+            if (json instanceof JsonPrimitive) {
+                JsonPrimitive primitive = (JsonPrimitive) json;
+                if (primitive.isBoolean()) {
+                    builder.setField(type.findFieldByName("bool_value"), primitive.getAsBoolean());
+                } else if (primitive.isNumber()) {
+                    builder.setField(type.findFieldByName("number_value"), primitive.getAsDouble());
+                } else {
+                    builder.setField(type.findFieldByName("string_value"), primitive.getAsString());
+                }
+            } else {
+                com.google.protobuf.Message.Builder listBuilder;
+                FieldDescriptor field;
+                if (json instanceof JsonObject) {
+                    field = type.findFieldByName("struct_value");
+                    listBuilder = builder.newBuilderForField(field);
+                    this.merge(json, listBuilder);
+                    builder.setField(field, listBuilder.build());
+                } else if (json instanceof JsonArray) {
+                    field = type.findFieldByName("list_value");
+                    listBuilder = builder.newBuilderForField(field);
+                    this.merge(json, listBuilder);
+                    builder.setField(field, listBuilder.build());
+                } else {
+                    if (!(json instanceof JsonNull)) {
+                        throw new IllegalStateException("Unexpected json data: " + json);
+                    }
+
+                    builder.setField(type.findFieldByName("null_value"), NullValue.NULL_VALUE.getValueDescriptor());
+                }
+            }
+
+        }
+
+        private void mergeWrapper(JsonElement json, com.google.protobuf.Message.Builder builder)
+            throws InvalidProtocolBufferException {
+            Descriptor type = builder.getDescriptorForType();
+            FieldDescriptor field = type.findFieldByName("value");
+            if (field == null) {
+                throw new InvalidProtocolBufferException("Invalid wrapper type: " + type.getFullName());
+            } else {
+                builder.setField(field, this.parseFieldValue(field, json, builder));
+            }
+        }
+
+        private void mergeField(FieldDescriptor field, JsonElement json, com.google.protobuf.Message.Builder builder)
+            throws InvalidProtocolBufferException {
+            if (field.isRepeated()) {
+                if (builder.getRepeatedFieldCount(field) > 0) {
+                    throw new InvalidProtocolBufferException("Field " + field.getFullName() + " has already been set.");
+                }
+            } else {
+                if (builder.hasField(field)) {
+                    throw new InvalidProtocolBufferException("Field " + field.getFullName() + " has already been set.");
+                }
+
+                if (field.getContainingOneof() != null
+                    && builder.getOneofFieldDescriptor(field.getContainingOneof()) != null) {
+                    FieldDescriptor other = builder.getOneofFieldDescriptor(field.getContainingOneof());
+                    throw new InvalidProtocolBufferException(
+                        "Cannot set field " + field.getFullName() + " because another field " + other.getFullName()
+                            + " belonging to the same oneof has already been set ");
+                }
+            }
+
+            if (!field.isRepeated() || !(json instanceof JsonNull)) {
+                if (field.isMapField()) {
+                    this.mergeMapField(field, json, builder);
+                } else if (field.isRepeated()) {
+                    this.mergeRepeatedField(field, json, builder);
+                } else {
+                    Object value = this.parseFieldValue(field, json, builder);
+                    if (value != null) {
+                        builder.setField(field, value);
+                    }
+                }
+
+            }
+        }
+
+        private void mergeMapField(FieldDescriptor field, JsonElement json, com.google.protobuf.Message.Builder builder)
+            throws InvalidProtocolBufferException {
+            if (!(json instanceof JsonObject)) {
+                throw new InvalidProtocolBufferException("Expect a map object but found: " + json);
+            } else {
+                Descriptor type = field.getMessageType();
+                FieldDescriptor keyField = type.findFieldByName("key");
+                FieldDescriptor valueField = type.findFieldByName("value");
+                if (keyField != null && valueField != null) {
+                    JsonObject object = (JsonObject) json;
+                    Iterator var8 = object.entrySet().iterator();
+
+                    while (var8.hasNext()) {
+                        Entry<String, JsonElement> entry = (Entry) var8.next();
+                        com.google.protobuf.Message.Builder entryBuilder = builder.newBuilderForField(field);
+                        Object key = this
+                            .parseFieldValue(keyField, new JsonPrimitive((String) entry.getKey()), entryBuilder);
+                        Object value = this.parseFieldValue(valueField, (JsonElement) entry.getValue(), entryBuilder);
+                        if (value == null) {
+                            throw new InvalidProtocolBufferException("Map value cannot be null.");
+                        }
+
+                        entryBuilder.setField(keyField, key);
+                        entryBuilder.setField(valueField, value);
+                        builder.addRepeatedField(field, entryBuilder.build());
+                    }
+
+                } else {
+                    throw new InvalidProtocolBufferException("Invalid map field: " + field.getFullName());
+                }
+            }
+        }
+
+        private void mergeRepeatedField(FieldDescriptor field, JsonElement json,
+            com.google.protobuf.Message.Builder builder) throws InvalidProtocolBufferException {
+            if (!(json instanceof JsonArray)) {
+                throw new InvalidProtocolBufferException("Expect an array but found: " + json);
+            } else {
+                JsonArray array = (JsonArray) json;
+
+                for (int i = 0; i < array.size(); ++i) {
+                    Object value = this.parseFieldValue(field, array.get(i), builder);
+                    if (value == null) {
+                        throw new InvalidProtocolBufferException(
+                            "Repeated field elements cannot be null in field: " + field.getFullName());
+                    }
+
+                    builder.addRepeatedField(field, value);
+                }
+
+            }
+        }
+
+        private int parseInt32(JsonElement json) throws InvalidProtocolBufferException {
+            try {
+                return Integer.parseInt(json.getAsString());
+            } catch (Exception var4) {
+                try {
+                    BigDecimal value = new BigDecimal(json.getAsString());
+                    return value.intValueExact();
+                } catch (Exception var3) {
+                    throw new InvalidProtocolBufferException("Not an int32 value: " + json);
+                }
+            }
+        }
+
+        private long parseInt64(JsonElement json) throws InvalidProtocolBufferException {
+            try {
+                return Long.parseLong(json.getAsString());
+            } catch (Exception var4) {
+                try {
+                    BigDecimal value = new BigDecimal(json.getAsString());
+                    return value.longValueExact();
+                } catch (Exception var3) {
+                    throw new InvalidProtocolBufferException("Not an int64 value: " + json);
+                }
+            }
+        }
+
+        private int parseUint32(JsonElement json) throws InvalidProtocolBufferException {
+            try {
+                long result = Long.parseLong(json.getAsString());
+                if (result >= 0L && result <= 4294967295L) {
+                    return (int) result;
+                } else {
+                    throw new InvalidProtocolBufferException("Out of range uint32 value: " + json);
+                }
+            } catch (InvalidProtocolBufferException var6) {
+                throw var6;
+            } catch (Exception var7) {
+                try {
+                    BigDecimal decimalValue = new BigDecimal(json.getAsString());
+                    BigInteger value = decimalValue.toBigIntegerExact();
+                    if (value.signum() >= 0 && value.compareTo(new BigInteger("FFFFFFFF", 16)) <= 0) {
+                        return value.intValue();
+                    } else {
+                        throw new InvalidProtocolBufferException("Out of range uint32 value: " + json);
+                    }
+                } catch (InvalidProtocolBufferException var4) {
+                    throw var4;
+                } catch (Exception var5) {
+                    throw new InvalidProtocolBufferException("Not an uint32 value: " + json);
+                }
+            }
+        }
+
+        private long parseUint64(JsonElement json) throws InvalidProtocolBufferException {
+            try {
+                BigDecimal decimalValue = new BigDecimal(json.getAsString());
+                BigInteger value = decimalValue.toBigIntegerExact();
+                if (value.compareTo(BigInteger.ZERO) >= 0 && value.compareTo(MAX_UINT64) <= 0) {
+                    return value.longValue();
+                } else {
+                    throw new InvalidProtocolBufferException("Out of range uint64 value: " + json);
+                }
+            } catch (InvalidProtocolBufferException var4) {
+                throw var4;
+            } catch (Exception var5) {
+                throw new InvalidProtocolBufferException("Not an uint64 value: " + json);
+            }
+        }
+
+        private boolean parseBool(JsonElement json) throws InvalidProtocolBufferException {
+            if (json.getAsString().equals("true")) {
+                return true;
+            } else if (json.getAsString().equals("false")) {
+                return false;
+            } else {
+                throw new InvalidProtocolBufferException("Invalid bool value: " + json);
+            }
+        }
+
+        private float parseFloat(JsonElement json) throws InvalidProtocolBufferException {
+            if (json.getAsString().equals("NaN")) {
+                return (float) (0.0F / 0.0);
+            } else if (json.getAsString().equals("Infinity")) {
+                return (float) (1.0F / 0.0);
+            } else if (json.getAsString().equals("-Infinity")) {
+                return (float) (-1.0F / 0.0);
+            } else {
+                try {
+                    double value = Double.parseDouble(json.getAsString());
+                    if (value <= 3.402826869208755E38D && value >= -3.402826869208755E38D) {
+                        return (float) value;
+                    } else {
+                        throw new InvalidProtocolBufferException("Out of range float value: " + json);
+                    }
+                } catch (InvalidProtocolBufferException var4) {
+                    throw var4;
+                } catch (Exception var5) {
+                    throw new InvalidProtocolBufferException("Not a float value: " + json);
+                }
+            }
+        }
+
+        private double parseDouble(JsonElement json) throws InvalidProtocolBufferException {
+            if (json.getAsString().equals("NaN")) {
+                return 0.0D / 0.0;
+            } else if (json.getAsString().equals("Infinity")) {
+                return 1.0D / 0.0;
+            } else if (json.getAsString().equals("-Infinity")) {
+                return -1.0D / 0.0;
+            } else {
+                try {
+                    BigDecimal value = new BigDecimal(json.getAsString());
+                    if (value.compareTo(MAX_DOUBLE) <= 0 && value.compareTo(MIN_DOUBLE) >= 0) {
+                        return value.doubleValue();
+                    } else {
+                        throw new InvalidProtocolBufferException("Out of range double value: " + json);
+                    }
+                } catch (InvalidProtocolBufferException var3) {
+                    throw var3;
+                } catch (Exception var4) {
+                    throw new InvalidProtocolBufferException("Not an double value: " + json);
+                }
+            }
+        }
+
+        private String parseString(JsonElement json) {
+            return json.getAsString();
+        }
+
+        private ByteString parseBytes(JsonElement json) throws InvalidProtocolBufferException {
+            try {
+                return ByteString.copyFrom(BaseEncoding.base64().decode(json.getAsString()));
+            } catch (IllegalArgumentException var3) {
+                return ByteString.copyFrom(BaseEncoding.base64Url().decode(json.getAsString()));
+            }
+        }
+
+        private EnumValueDescriptor parseEnum(EnumDescriptor enumDescriptor, JsonElement json)
+            throws InvalidProtocolBufferException {
+            String value = json.getAsString();
+            EnumValueDescriptor result = enumDescriptor.findValueByName(value);
+            if (result == null) {
+                try {
+                    int numericValue = this.parseInt32(json);
+                    if (enumDescriptor.getFile().getSyntax() == Syntax.PROTO3) {
+                        result = enumDescriptor.findValueByNumberCreatingIfUnknown(numericValue);
+                    } else {
+                        result = enumDescriptor.findValueByNumber(numericValue);
+                    }
+                } catch (InvalidProtocolBufferException var6) {
+                    ;
+                }
+
+                if (result == null) {
+                    throw new InvalidProtocolBufferException(
+                        "Invalid enum value: " + value + " for enum type: " + enumDescriptor.getFullName());
+                }
+            }
+
+            return result;
+        }
+
+        private Object parseFieldValue(FieldDescriptor field, JsonElement json,
+            com.google.protobuf.Message.Builder builder) throws InvalidProtocolBufferException {
+            if (json instanceof JsonNull) {
+                if (field.getJavaType() == JavaType.MESSAGE && field.getMessageType().getFullName()
+                    .equals(Value.getDescriptor().getFullName())) {
+                    Value value = Value.newBuilder().setNullValueValue(0).build();
+                    return builder.newBuilderForField(field).mergeFrom(value.toByteString()).build();
+                } else {
+                    return field.getJavaType() == JavaType.ENUM && field.getEnumType().getFullName()
+                        .equals(NullValue.getDescriptor().getFullName()) ? field.getEnumType().findValueByNumber(0)
+                        : null;
+                }
+            } else {
+                switch (field.getType()) {
+                    case INT32:
+                    case SINT32:
+                    case SFIXED32:
+                        return this.parseInt32(json);
+                    case INT64:
+                    case SINT64:
+                    case SFIXED64:
+                        return this.parseInt64(json);
+                    case BOOL:
+                        return this.parseBool(json);
+                    case FLOAT:
+                        return this.parseFloat(json);
+                    case DOUBLE:
+                        return this.parseDouble(json);
+                    case UINT32:
+                    case FIXED32:
+                        return this.parseUint32(json);
+                    case UINT64:
+                    case FIXED64:
+                        return this.parseUint64(json);
+                    case STRING:
+                        return this.parseString(json);
+                    case BYTES:
+                        return this.parseBytes(json);
+                    case ENUM:
+                        return this.parseEnum(field.getEnumType(), json);
+                    case MESSAGE:
+                    case GROUP:
+                        if (this.currentDepth >= this.recursionLimit) {
+                            throw new InvalidProtocolBufferException("Hit recursion limit.");
+                        }
+
+                        ++this.currentDepth;
+                        com.google.protobuf.Message.Builder subBuilder = builder.newBuilderForField(field);
+                        this.merge(json, subBuilder);
+                        --this.currentDepth;
+                        return subBuilder.build();
+                    default:
+                        throw new InvalidProtocolBufferException("Invalid field type: " + field.getType());
+                }
+            }
+        }
+
+        static {
+            MAX_DOUBLE = (new BigDecimal(String.valueOf(1.7976931348623157E308D))).multiply(MORE_THAN_ONE);
+            MIN_DOUBLE = (new BigDecimal(String.valueOf(-1.7976931348623157E308D))).multiply(MORE_THAN_ONE);
+        }
+
+        private interface WellKnownTypeParser {
+
+            void merge(JsonFormat.ParserImpl var1, JsonElement var2, com.google.protobuf.Message.Builder var3)
+                throws InvalidProtocolBufferException;
+        }
+    }
+
+    private static final class PrinterImpl {
+
+        private final JsonFormat.TypeRegistry registry;
+        private final boolean alwaysOutputDefaultValueFields;
+        private final Set<FieldDescriptor> includingDefaultValueFields;
+        private final boolean preservingProtoFieldNames;
+        private final boolean printingEnumsAsInts;
+        private final JsonFormat.TextGenerator generator;
+        private final Gson gson;
+        private final CharSequence blankOrSpace;
+        private final CharSequence blankOrNewLine;
+        private static final Map<String, JsonFormat.PrinterImpl.WellKnownTypePrinter> wellKnownTypePrinters = buildWellKnownTypePrinters();
+
+        PrinterImpl(JsonFormat.TypeRegistry registry, boolean alwaysOutputDefaultValueFields,
+            Set<FieldDescriptor> includingDefaultValueFields, boolean preservingProtoFieldNames, Appendable jsonOutput,
+            boolean omittingInsignificantWhitespace, boolean printingEnumsAsInts) {
+            this.registry = registry;
+            this.alwaysOutputDefaultValueFields = alwaysOutputDefaultValueFields;
+            this.includingDefaultValueFields = includingDefaultValueFields;
+            this.preservingProtoFieldNames = preservingProtoFieldNames;
+            this.printingEnumsAsInts = printingEnumsAsInts;
+            this.gson = JsonFormat.PrinterImpl.GsonHolder.DEFAULT_GSON;
+            if (omittingInsignificantWhitespace) {
+                this.generator = new JsonFormat.CompactTextGenerator(jsonOutput);
+                this.blankOrSpace = "";
+                this.blankOrNewLine = "";
+            } else {
+                this.generator = new JsonFormat.PrettyTextGenerator(jsonOutput);
+                this.blankOrSpace = " ";
+                this.blankOrNewLine = "\n";
+            }
+
+        }
+
+        void print(MessageOrBuilder message) throws IOException {
+            JsonFormat.PrinterImpl.WellKnownTypePrinter specialPrinter = (JsonFormat.PrinterImpl.WellKnownTypePrinter) wellKnownTypePrinters
+                .get(message.getDescriptorForType().getFullName());
+            if (specialPrinter != null) {
+                specialPrinter.print(this, message);
+            } else {
+                this.print(message, (String) null);
+            }
+        }
+
+        private static Map<String, JsonFormat.PrinterImpl.WellKnownTypePrinter> buildWellKnownTypePrinters() {
+            Map<String, JsonFormat.PrinterImpl.WellKnownTypePrinter> printers = new HashMap();
+            printers.put(Any.getDescriptor().getFullName(), new JsonFormat.PrinterImpl.WellKnownTypePrinter() {
+                public void print(JsonFormat.PrinterImpl printer, MessageOrBuilder message) throws IOException {
+                    printer.printAny(message);
+                }
+            });
+            JsonFormat.PrinterImpl.WellKnownTypePrinter wrappersPrinter = new JsonFormat.PrinterImpl.WellKnownTypePrinter() {
+                public void print(JsonFormat.PrinterImpl printer, MessageOrBuilder message) throws IOException {
+                    printer.printWrapper(message);
+                }
+            };
+            printers.put(BoolValue.getDescriptor().getFullName(), wrappersPrinter);
+            printers.put(Int32Value.getDescriptor().getFullName(), wrappersPrinter);
+            printers.put(UInt32Value.getDescriptor().getFullName(), wrappersPrinter);
+            printers.put(Int64Value.getDescriptor().getFullName(), wrappersPrinter);
+            printers.put(UInt64Value.getDescriptor().getFullName(), wrappersPrinter);
+            printers.put(StringValue.getDescriptor().getFullName(), wrappersPrinter);
+            printers.put(BytesValue.getDescriptor().getFullName(), wrappersPrinter);
+            printers.put(FloatValue.getDescriptor().getFullName(), wrappersPrinter);
+            printers.put(DoubleValue.getDescriptor().getFullName(), wrappersPrinter);
+            printers.put(Struct.getDescriptor().getFullName(), new JsonFormat.PrinterImpl.WellKnownTypePrinter() {
+                public void print(JsonFormat.PrinterImpl printer, MessageOrBuilder message) throws IOException {
+                    printer.printStruct(message);
+                }
+            });
+            printers.put(Value.getDescriptor().getFullName(), new JsonFormat.PrinterImpl.WellKnownTypePrinter() {
+                public void print(JsonFormat.PrinterImpl printer, MessageOrBuilder message) throws IOException {
+                    printer.printValue(message);
+                }
+            });
+            printers.put(ListValue.getDescriptor().getFullName(), new JsonFormat.PrinterImpl.WellKnownTypePrinter() {
+                public void print(JsonFormat.PrinterImpl printer, MessageOrBuilder message) throws IOException {
+                    printer.printListValue(message);
+                }
+            });
+            return printers;
+        }
+
+        private void printAny(MessageOrBuilder message) throws IOException {
+            if (Any.getDefaultInstance().equals(message)) {
+                this.generator.print("{}");
+            } else {
+                Descriptor descriptor = message.getDescriptorForType();
+                FieldDescriptor typeUrlField = descriptor.findFieldByName("type_url");
+                FieldDescriptor valueField = descriptor.findFieldByName("value");
+                if (typeUrlField != null && valueField != null && typeUrlField.getType() == Type.STRING
+                    && valueField.getType() == Type.BYTES) {
+                    String typeUrl = (String) message.getField(typeUrlField);
+                    String typeName = JsonFormat.getTypeName(typeUrl);
+                    Descriptor type = this.registry.find(typeName);
+                    if (type == null) {
+                        throw new InvalidProtocolBufferException("Cannot find type for url: " + typeUrl);
+                    } else {
+                        ByteString content = (ByteString) message.getField(valueField);
+                        Message contentMessage = (Message) DynamicMessage.getDefaultInstance(type).getParserForType()
+                            .parseFrom(content);
+                        JsonFormat.PrinterImpl.WellKnownTypePrinter printer = (JsonFormat.PrinterImpl.WellKnownTypePrinter) wellKnownTypePrinters
+                            .get(typeName);
+                        if (printer != null) {
+                            this.generator.print("{" + this.blankOrNewLine);
+                            this.generator.indent();
+                            this.generator.print("\"@type\":" + this.blankOrSpace + this.gson.toJson(typeUrl) + ","
+                                + this.blankOrNewLine);
+                            this.generator.print("\"value\":" + this.blankOrSpace);
+                            printer.print(this, contentMessage);
+                            this.generator.print(this.blankOrNewLine);
+                            this.generator.outdent();
+                            this.generator.print("}");
+                        } else {
+                            this.print(contentMessage, typeUrl);
+                        }
+
+                    }
+                } else {
+                    throw new InvalidProtocolBufferException("Invalid Any type.");
+                }
+            }
+        }
+
+        private void printWrapper(MessageOrBuilder message) throws IOException {
+            Descriptor descriptor = message.getDescriptorForType();
+            FieldDescriptor valueField = descriptor.findFieldByName("value");
+            if (valueField == null) {
+                throw new InvalidProtocolBufferException("Invalid Wrapper type.");
+            } else {
+                this.printSingleFieldValue(valueField, message.getField(valueField));
+            }
+        }
+
+        private ByteString toByteString(MessageOrBuilder message) {
+            return message instanceof Message ? ((Message) message).toByteString()
+                : ((com.google.protobuf.Message.Builder) message).build().toByteString();
+        }
+
+        private void printStruct(MessageOrBuilder message) throws IOException {
+            Descriptor descriptor = message.getDescriptorForType();
+            FieldDescriptor field = descriptor.findFieldByName("fields");
+            if (field == null) {
+                throw new InvalidProtocolBufferException("Invalid Struct type.");
+            } else {
+                this.printMapFieldValue(field, message.getField(field));
+            }
+        }
+
+        private void printValue(MessageOrBuilder message) throws IOException {
+            Map<FieldDescriptor, Object> fields = message.getAllFields();
+            if (fields.isEmpty()) {
+                this.generator.print("null");
+            } else if (fields.size() != 1) {
+                throw new InvalidProtocolBufferException("Invalid Value type.");
+            } else {
+                Iterator var3 = fields.entrySet().iterator();
+
+                while (var3.hasNext()) {
+                    Entry<FieldDescriptor, Object> entry = (Entry) var3.next();
+                    this.printSingleFieldValue((FieldDescriptor) entry.getKey(), entry.getValue());
+                }
+
+            }
+        }
+
+        private void printListValue(MessageOrBuilder message) throws IOException {
+            Descriptor descriptor = message.getDescriptorForType();
+            FieldDescriptor field = descriptor.findFieldByName("values");
+            if (field == null) {
+                throw new InvalidProtocolBufferException("Invalid ListValue type.");
+            } else {
+                this.printRepeatedFieldValue(field, message.getField(field));
+            }
+        }
+
+        private void print(MessageOrBuilder message, String typeUrl) throws IOException {
+            this.generator.print("{" + this.blankOrNewLine);
+            this.generator.indent();
+            boolean printedField = false;
+            if (typeUrl != null) {
+                this.generator.print("\"@type\":" + this.blankOrSpace + this.gson.toJson(typeUrl));
+                printedField = true;
+            }
+
+            Map<FieldDescriptor, Object> fieldsToPrint = null;
+            Iterator var5;
+            if (!this.alwaysOutputDefaultValueFields && this.includingDefaultValueFields.isEmpty()) {
+                fieldsToPrint = message.getAllFields();
+            } else {
+                fieldsToPrint = new TreeMap(message.getAllFields());
+                var5 = message.getDescriptorForType().getFields().iterator();
+
+                label66:
+                while (true) {
+                    FieldDescriptor field;
+                    do {
+                        do {
+                            while (true) {
+                                if (!var5.hasNext()) {
+                                    break label66;
+                                }
+
+                                field = (FieldDescriptor) var5.next();
+                                if (!field.isOptional()) {
+                                    break;
+                                }
+
+                                if (field.getJavaType() != JavaType.MESSAGE || message.hasField(field)) {
+                                    OneofDescriptor oneof = field.getContainingOneof();
+                                    if (oneof == null || message.hasField(field)) {
+                                        break;
+                                    }
+                                }
+                            }
+                        } while (((Map) fieldsToPrint).containsKey(field));
+                    } while (!this.alwaysOutputDefaultValueFields && !this.includingDefaultValueFields.contains(field));
+
+                    ((Map) fieldsToPrint).put(field, message.getField(field));
+                }
+            }
+
+            Entry field;
+            for (var5 = ((Map) fieldsToPrint).entrySet().iterator(); var5.hasNext();
+                this.printField((FieldDescriptor) field.getKey(), field.getValue())) {
+                field = (Entry) var5.next();
+                if (printedField) {
+                    this.generator.print("," + this.blankOrNewLine);
+                } else {
+                    printedField = true;
+                }
+            }
+
+            if (printedField) {
+                this.generator.print(this.blankOrNewLine);
+            }
+
+            this.generator.outdent();
+            this.generator.print("}");
+        }
+
+        private void printField(FieldDescriptor field, Object value) throws IOException {
+            if (this.preservingProtoFieldNames) {
+                this.generator.print("\"" + field.getName() + "\":" + this.blankOrSpace);
+            } else {
+                this.generator.print("\"" + field.getJsonName() + "\":" + this.blankOrSpace);
+            }
+
+            if (field.isMapField()) {
+                this.printMapFieldValue(field, value);
+            } else if (field.isRepeated()) {
+                this.printRepeatedFieldValue(field, value);
+            } else {
+                this.printSingleFieldValue(field, value);
+            }
+
+        }
+
+        private void printRepeatedFieldValue(FieldDescriptor field, Object value) throws IOException {
+            this.generator.print("[");
+            boolean printedElement = false;
+
+            Object element;
+            for (Iterator var4 = ((List) value).iterator(); var4.hasNext();
+                this.printSingleFieldValue(field, element)) {
+                element = var4.next();
+                if (printedElement) {
+                    this.generator.print("," + this.blankOrSpace);
+                } else {
+                    printedElement = true;
+                }
+            }
+
+            this.generator.print("]");
+        }
+
+        private void printMapFieldValue(FieldDescriptor field, Object value) throws IOException {
+            Descriptor type = field.getMessageType();
+            FieldDescriptor keyField = type.findFieldByName("key");
+            FieldDescriptor valueField = type.findFieldByName("value");
+            if (keyField != null && valueField != null) {
+                this.generator.print("{" + this.blankOrNewLine);
+                this.generator.indent();
+                boolean printedElement = false;
+                Iterator var7 = ((List) value).iterator();
+
+                while (var7.hasNext()) {
+                    Object element = var7.next();
+                    Message entry = (Message) element;
+                    Object entryKey = entry.getField(keyField);
+                    Object entryValue = entry.getField(valueField);
+                    if (printedElement) {
+                        this.generator.print("," + this.blankOrNewLine);
+                    } else {
+                        printedElement = true;
+                    }
+
+                    this.printSingleFieldValue(keyField, entryKey, true);
+                    this.generator.print(":" + this.blankOrSpace);
+                    this.printSingleFieldValue(valueField, entryValue);
+                }
+
+                if (printedElement) {
+                    this.generator.print(this.blankOrNewLine);
+                }
+
+                this.generator.outdent();
+                this.generator.print("}");
+            } else {
+                throw new InvalidProtocolBufferException("Invalid map field.");
+            }
+        }
+
+        private void printSingleFieldValue(FieldDescriptor field, Object value) throws IOException {
+            this.printSingleFieldValue(field, value, false);
+        }
+
+        private void printSingleFieldValue(FieldDescriptor field, Object value, boolean alwaysWithQuotes)
+            throws IOException {
+            switch (field.getType()) {
+                case INT32:
+                case SINT32:
+                case SFIXED32:
+                    if (alwaysWithQuotes) {
+                        this.generator.print("\"");
+                    }
+
+                    this.generator.print(((Integer) value).toString());
+                    if (alwaysWithQuotes) {
+                        this.generator.print("\"");
+                    }
+                    break;
+                case INT64:
+                case SINT64:
+                case SFIXED64:
+                    this.generator.print("\"" + ((Long) value).toString() + "\"");
+                    break;
+                case BOOL:
+                    if (alwaysWithQuotes) {
+                        this.generator.print("\"");
+                    }
+
+                    if ((Boolean) value) {
+                        this.generator.print("true");
+                    } else {
+                        this.generator.print("false");
+                    }
+
+                    if (alwaysWithQuotes) {
+                        this.generator.print("\"");
+                    }
+                    break;
+                case FLOAT:
+                    Float floatValue = (Float) value;
+                    if (floatValue.isNaN()) {
+                        this.generator.print("\"NaN\"");
+                    } else if (floatValue.isInfinite()) {
+                        if (floatValue < 0.0F) {
+                            this.generator.print("\"-Infinity\"");
+                        } else {
+                            this.generator.print("\"Infinity\"");
+                        }
+                    } else {
+                        if (alwaysWithQuotes) {
+                            this.generator.print("\"");
+                        }
+
+                        this.generator.print(floatValue.toString());
+                        if (alwaysWithQuotes) {
+                            this.generator.print("\"");
+                        }
+                    }
+                    break;
+                case DOUBLE:
+                    Double doubleValue = (Double) value;
+                    if (doubleValue.isNaN()) {
+                        this.generator.print("\"NaN\"");
+                    } else if (doubleValue.isInfinite()) {
+                        if (doubleValue < 0.0D) {
+                            this.generator.print("\"-Infinity\"");
+                        } else {
+                            this.generator.print("\"Infinity\"");
+                        }
+                    } else {
+                        if (alwaysWithQuotes) {
+                            this.generator.print("\"");
+                        }
+
+                        this.generator.print(doubleValue.toString());
+                        if (alwaysWithQuotes) {
+                            this.generator.print("\"");
+                        }
+                    }
+                    break;
+                case UINT32:
+                case FIXED32:
+                    if (alwaysWithQuotes) {
+                        this.generator.print("\"");
+                    }
+
+                    this.generator.print(JsonFormat.unsignedToString((Integer) value));
+                    if (alwaysWithQuotes) {
+                        this.generator.print("\"");
+                    }
+                    break;
+                case UINT64:
+                case FIXED64:
+                    this.generator.print("\"" + JsonFormat.unsignedToString((Long) value) + "\"");
+                    break;
+                case STRING:
+                    this.generator.print(this.gson.toJson(value));
+                    break;
+                case BYTES:
+                    this.generator.print("\"");
+                    this.generator.print(BaseEncoding.base64().encode(((ByteString) value).toByteArray()));
+                    this.generator.print("\"");
+                    break;
+                case ENUM:
+                    if (field.getEnumType().getFullName().equals("google.protobuf.NullValue")) {
+                        if (alwaysWithQuotes) {
+                            this.generator.print("\"");
+                        }
+
+                        this.generator.print("null");
+                        if (alwaysWithQuotes) {
+                            this.generator.print("\"");
+                        }
+                    } else if (!this.printingEnumsAsInts && ((EnumValueDescriptor) value).getIndex() != -1) {
+                        this.generator.print("\"" + ((EnumValueDescriptor) value).getName() + "\"");
+                    } else {
+                        this.generator.print(String.valueOf(((EnumValueDescriptor) value).getNumber()));
+                    }
+                    break;
+                case MESSAGE:
+                case GROUP:
+                    this.print((Message) value);
+            }
+
+        }
+
+        private interface WellKnownTypePrinter {
+
+            void print(JsonFormat.PrinterImpl var1, MessageOrBuilder var2) throws IOException;
+        }
+
+        private static class GsonHolder {
+
+            private static final Gson DEFAULT_GSON = (new GsonBuilder()).disableHtmlEscaping().create();
+
+            private GsonHolder() {
+            }
+        }
+    }
+
+    private static final class PrettyTextGenerator implements JsonFormat.TextGenerator {
+
+        private final Appendable output;
+        private final StringBuilder indent;
+        private boolean atStartOfLine;
+
+        private PrettyTextGenerator(Appendable output) {
+            this.indent = new StringBuilder();
+            this.atStartOfLine = true;
+            this.output = output;
+        }
+
+        public void indent() {
+            this.indent.append("  ");
+        }
+
+        public void outdent() {
+            int length = this.indent.length();
+            if (length < 2) {
+                throw new IllegalArgumentException(" Outdent() without matching Indent().");
+            } else {
+                this.indent.delete(length - 2, length);
+            }
+        }
+
+        public void print(CharSequence text) throws IOException {
+            int size = text.length();
+            int pos = 0;
+
+            for (int i = 0; i < size; ++i) {
+                if (text.charAt(i) == '\n') {
+                    this.write(text.subSequence(pos, i + 1));
+                    pos = i + 1;
+                    this.atStartOfLine = true;
+                }
+            }
+
+            this.write(text.subSequence(pos, size));
+        }
+
+        private void write(CharSequence data) throws IOException {
+            if (data.length() != 0) {
+                if (this.atStartOfLine) {
+                    this.atStartOfLine = false;
+                    this.output.append(this.indent);
+                }
+
+                this.output.append(data);
+            }
+        }
+    }
+
+    private static final class CompactTextGenerator implements JsonFormat.TextGenerator {
+
+        private final Appendable output;
+
+        private CompactTextGenerator(Appendable output) {
+            this.output = output;
+        }
+
+        public void indent() {
+        }
+
+        public void outdent() {
+        }
+
+        public void print(CharSequence text) throws IOException {
+            this.output.append(text);
+        }
+    }
+
+    interface TextGenerator {
+
+        void indent();
+
+        void outdent();
+
+        void print(CharSequence var1) throws IOException;
+    }
+
+    public static class TypeRegistry {
+
+        private final Map<String, Descriptor> types;
+
+        public static JsonFormat.TypeRegistry getEmptyTypeRegistry() {
+            return JsonFormat.TypeRegistry.EmptyTypeRegistryHolder.EMPTY;
+        }
+
+        public static JsonFormat.TypeRegistry.Builder newBuilder() {
+            return new JsonFormat.TypeRegistry.Builder();
+        }
+
+        public Descriptor find(String name) {
+            return (Descriptor) this.types.get(name);
+        }
+
+        private TypeRegistry(Map<String, Descriptor> types) {
+            this.types = types;
+        }
+
+        public static class Builder {
+
+            private final Set<String> files;
+            private Map<String, Descriptor> types;
+
+            private Builder() {
+                this.files = new HashSet();
+                this.types = new HashMap();
+            }
+
+            public JsonFormat.TypeRegistry.Builder add(Descriptor messageType) {
+                if (this.types == null) {
+                    throw new IllegalStateException("A TypeRegistry.Builer can only be used once.");
+                } else {
+                    this.addFile(messageType.getFile());
+                    return this;
+                }
+            }
+
+            public JsonFormat.TypeRegistry.Builder add(Iterable<Descriptor> messageTypes) {
+                if (this.types == null) {
+                    throw new IllegalStateException("A TypeRegistry.Builder can only be used once.");
+                } else {
+                    Iterator var2 = messageTypes.iterator();
+
+                    while (var2.hasNext()) {
+                        Descriptor type = (Descriptor) var2.next();
+                        this.addFile(type.getFile());
+                    }
+
+                    return this;
+                }
+            }
+
+            public JsonFormat.TypeRegistry build() {
+                JsonFormat.TypeRegistry result = new JsonFormat.TypeRegistry(this.types);
+                this.types = null;
+                return result;
+            }
+
+            private void addFile(FileDescriptor file) {
+                if (this.files.add(file.getFullName())) {
+                    Iterator var2 = file.getDependencies().iterator();
+
+                    while (var2.hasNext()) {
+                        FileDescriptor dependency = (FileDescriptor) var2.next();
+                        this.addFile(dependency);
+                    }
+
+                    var2 = file.getMessageTypes().iterator();
+
+                    while (var2.hasNext()) {
+                        Descriptor message = (Descriptor) var2.next();
+                        this.addMessage(message);
+                    }
+
+                }
+            }
+
+            private void addMessage(Descriptor message) {
+                Iterator var2 = message.getNestedTypes().iterator();
+
+                while (var2.hasNext()) {
+                    Descriptor nestedType = (Descriptor) var2.next();
+                    this.addMessage(nestedType);
+                }
+
+                if (this.types.containsKey(message.getFullName())) {
+                    JsonFormat.logger.warning("Type " + message.getFullName() + " is added multiple times.");
+                } else {
+                    this.types.put(message.getFullName(), message);
+                }
+            }
+        }
+
+        private static class EmptyTypeRegistryHolder {
+
+            private static final JsonFormat.TypeRegistry EMPTY = new JsonFormat.TypeRegistry(Collections.emptyMap());
+
+            private EmptyTypeRegistryHolder() {
+            }
+        }
+    }
+
+    public static class Parser {
+
+        private final JsonFormat.TypeRegistry registry;
+        private final boolean ignoringUnknownFields;
+        private final int recursionLimit;
+        private static final int DEFAULT_RECURSION_LIMIT = 100;
+
+        private Parser(JsonFormat.TypeRegistry registry, boolean ignoreUnknownFields, int recursionLimit) {
+            this.registry = registry;
+            this.ignoringUnknownFields = ignoreUnknownFields;
+            this.recursionLimit = recursionLimit;
+        }
+
+        public JsonFormat.Parser usingTypeRegistry(JsonFormat.TypeRegistry registry) {
+            if (this.registry != JsonFormat.TypeRegistry.getEmptyTypeRegistry()) {
+                throw new IllegalArgumentException("Only one registry is allowed.");
+            } else {
+                return new JsonFormat.Parser(registry, this.ignoringUnknownFields, this.recursionLimit);
+            }
+        }
+
+        public JsonFormat.Parser ignoringUnknownFields() {
+            return new JsonFormat.Parser(this.registry, true, this.recursionLimit);
+        }
+
+        public void merge(String json, com.google.protobuf.Message.Builder builder)
+            throws InvalidProtocolBufferException {
+            (new JsonFormat.ParserImpl(this.registry, this.ignoringUnknownFields, this.recursionLimit))
+                .merge(json, builder);
+        }
+
+        public void merge(Reader json, com.google.protobuf.Message.Builder builder) throws IOException {
+            (new JsonFormat.ParserImpl(this.registry, this.ignoringUnknownFields, this.recursionLimit))
+                .merge(json, builder);
+        }
+
+        JsonFormat.Parser usingRecursionLimit(int recursionLimit) {
+            return new JsonFormat.Parser(this.registry, this.ignoringUnknownFields, recursionLimit);
+        }
+    }
+
+    public static class Printer {
+
+        private final JsonFormat.TypeRegistry registry;
+        private boolean alwaysOutputDefaultValueFields;
+        private Set<FieldDescriptor> includingDefaultValueFields;
+        private final boolean preservingProtoFieldNames;
+        private final boolean omittingInsignificantWhitespace;
+        private final boolean printingEnumsAsInts;
+
+        private Printer(JsonFormat.TypeRegistry registry, boolean alwaysOutputDefaultValueFields,
+            Set<FieldDescriptor> includingDefaultValueFields, boolean preservingProtoFieldNames,
+            boolean omittingInsignificantWhitespace, boolean printingEnumsAsInts) {
+            this.registry = registry;
+            this.alwaysOutputDefaultValueFields = alwaysOutputDefaultValueFields;
+            this.includingDefaultValueFields = includingDefaultValueFields;
+            this.preservingProtoFieldNames = preservingProtoFieldNames;
+            this.omittingInsignificantWhitespace = omittingInsignificantWhitespace;
+            this.printingEnumsAsInts = printingEnumsAsInts;
+        }
+
+        public JsonFormat.Printer usingTypeRegistry(JsonFormat.TypeRegistry registry) {
+            if (this.registry != JsonFormat.TypeRegistry.getEmptyTypeRegistry()) {
+                throw new IllegalArgumentException("Only one registry is allowed.");
+            } else {
+                return new JsonFormat.Printer(registry, this.alwaysOutputDefaultValueFields,
+                    this.includingDefaultValueFields, this.preservingProtoFieldNames,
+                    this.omittingInsignificantWhitespace, this.printingEnumsAsInts);
+            }
+        }
+
+        public JsonFormat.Printer includingDefaultValueFields() {
+            this.checkUnsetIncludingDefaultValueFields();
+            return new JsonFormat.Printer(this.registry, true, Collections.emptySet(), this.preservingProtoFieldNames,
+                this.omittingInsignificantWhitespace, this.printingEnumsAsInts);
+        }
+
+        public JsonFormat.Printer printingEnumsAsInts() {
+            this.checkUnsetPrintingEnumsAsInts();
+            return new JsonFormat.Printer(this.registry, this.alwaysOutputDefaultValueFields, Collections.emptySet(),
+                this.preservingProtoFieldNames, this.omittingInsignificantWhitespace, true);
+        }
+
+        private void checkUnsetPrintingEnumsAsInts() {
+            if (this.printingEnumsAsInts) {
+                throw new IllegalStateException("JsonFormat printingEnumsAsInts has already been set.");
+            }
+        }
+
+        public JsonFormat.Printer includingDefaultValueFields(Set<FieldDescriptor> fieldsToAlwaysOutput) {
+            Preconditions.checkArgument(null != fieldsToAlwaysOutput && !fieldsToAlwaysOutput.isEmpty(),
+                "Non-empty Set must be supplied for includingDefaultValueFields.");
+            this.checkUnsetIncludingDefaultValueFields();
+            return new JsonFormat.Printer(this.registry, false, fieldsToAlwaysOutput, this.preservingProtoFieldNames,
+                this.omittingInsignificantWhitespace, this.printingEnumsAsInts);
+        }
+
+        private void checkUnsetIncludingDefaultValueFields() {
+            if (this.alwaysOutputDefaultValueFields || !this.includingDefaultValueFields.isEmpty()) {
+                throw new IllegalStateException("JsonFormat includingDefaultValueFields has already been set.");
+            }
+        }
+
+        public JsonFormat.Printer preservingProtoFieldNames() {
+            return new JsonFormat.Printer(this.registry, this.alwaysOutputDefaultValueFields,
+                this.includingDefaultValueFields, true, this.omittingInsignificantWhitespace, this.printingEnumsAsInts);
+        }
+
+        public JsonFormat.Printer omittingInsignificantWhitespace() {
+            return new JsonFormat.Printer(this.registry, this.alwaysOutputDefaultValueFields,
+                this.includingDefaultValueFields, this.preservingProtoFieldNames, true, this.printingEnumsAsInts);
+        }
+
+        public void appendTo(MessageOrBuilder message, Appendable output) throws IOException {
+            (new JsonFormat.PrinterImpl(this.registry, this.alwaysOutputDefaultValueFields,
+                this.includingDefaultValueFields, this.preservingProtoFieldNames, output,
+                this.omittingInsignificantWhitespace, this.printingEnumsAsInts)).print(message);
+        }
+
+        public String print(MessageOrBuilder message) throws InvalidProtocolBufferException {
+            try {
+                StringBuilder builder = new StringBuilder();
+                this.appendTo(message, builder);
+                return builder.toString();
+            } catch (InvalidProtocolBufferException var3) {
+                throw var3;
+            } catch (IOException var4) {
+                throw new IllegalStateException(var4);
+            }
+        }
+    }
+}
diff --git a/grpc-resource/provider/src/main/java/org/onap/ccsdk/sli/adaptors/grpc/cds/BlueprintProcessingClient.java b/grpc-resource/provider/src/main/java/org/onap/ccsdk/sli/adaptors/grpc/cds/BlueprintProcessingClient.java
index 33fb8fa2..fdbe6f4e 100644
--- a/grpc-resource/provider/src/main/java/org/onap/ccsdk/sli/adaptors/grpc/cds/BlueprintProcessingClient.java
+++ b/grpc-resource/provider/src/main/java/org/onap/ccsdk/sli/adaptors/grpc/cds/BlueprintProcessingClient.java
@@ -17,6 +17,7 @@ package org.onap.ccsdk.sli.adaptors.grpc.cds;
 
 import io.grpc.ManagedChannel;
 import io.grpc.internal.DnsNameResolverProvider;
+import io.grpc.internal.PickFirstLoadBalancerProvider;
 import io.grpc.netty.NettyChannelBuilder;
 import java.util.Map;
 import org.onap.ccsdk.sli.adaptors.grpc.GrpcClient;
@@ -36,8 +37,9 @@ public class BlueprintProcessingClient implements GrpcClient {
     public BlueprintProcessingClient(BlueprintProcessingHandler handler, GrpcProperties props) {
         this.channel = NettyChannelBuilder
             .forAddress(props.getUrl(), props.getPort())
-            .usePlaintext()
             .nameResolverFactory(new DnsNameResolverProvider())
+            .loadBalancerFactory(new PickFirstLoadBalancerProvider())
+            .usePlaintext()
             .build();
         this.handler = handler;
     }
@@ -66,6 +68,7 @@ public class BlueprintProcessingClient implements GrpcClient {
      * <tr><td>blueprint_version</td><td>Mandatory</td><td>Version of the blueprint to process.</td></tr>
      * <tr><td>action</td><td>Mandatory</td><td>Action of the blueprint to process.</td></tr>
      * <tr><td>mode</td><td>Mandatory</td><td>Mode to operate the transaction.</td></tr>
+     * <tr><td>payload</td><td>Mandatory</td><td>Payload.</td></tr>
      * </tbody>
      * </table>
      */
diff --git a/grpc-resource/provider/src/main/java/org/onap/ccsdk/sli/adaptors/grpc/cds/BlueprintProcessingHandler.java b/grpc-resource/provider/src/main/java/org/onap/ccsdk/sli/adaptors/grpc/cds/BlueprintProcessingHandler.java
index 6a618fb3..c142da91 100644
--- a/grpc-resource/provider/src/main/java/org/onap/ccsdk/sli/adaptors/grpc/cds/BlueprintProcessingHandler.java
+++ b/grpc-resource/provider/src/main/java/org/onap/ccsdk/sli/adaptors/grpc/cds/BlueprintProcessingHandler.java
@@ -17,6 +17,7 @@ package org.onap.ccsdk.sli.adaptors.grpc.cds;
 
 import com.google.protobuf.InvalidProtocolBufferException;
 import com.google.protobuf.Struct;
+import com.google.protobuf.Struct.Builder;
 import io.grpc.ManagedChannel;
 import io.grpc.Status;
 import io.grpc.stub.StreamObserver;
@@ -32,6 +33,7 @@ import org.onap.ccsdk.apps.controllerblueprints.processing.api.BluePrintProcessi
 import org.onap.ccsdk.apps.controllerblueprints.processing.api.BluePrintProcessingServiceGrpc.BluePrintProcessingServiceStub;
 import org.onap.ccsdk.apps.controllerblueprints.processing.api.ExecutionServiceInput;
 import org.onap.ccsdk.apps.controllerblueprints.processing.api.ExecutionServiceOutput;
+import org.onap.ccsdk.sli.adaptors.grpc.JsonFormat;
 import org.onap.ccsdk.sli.adaptors.grpc.Utils;
 import org.onap.ccsdk.sli.core.sli.SvcLogicException;
 import org.onap.ccsdk.sli.core.sli.SvcLogicResource.QueryStatus;
@@ -114,9 +116,9 @@ public class BlueprintProcessingHandler {
             .setMode(mode)
             .build();
 
-        Struct struct;
+        Builder struct = Struct.newBuilder();
         try {
-            struct = Struct.newBuilder().mergeFrom(payload.getBytes()).build();
+            JsonFormat.parser().merge(payload, struct);
         } catch (InvalidProtocolBufferException e) {
             log.error("Failed converting payload for blueprint({}:{}) for action({}). {}", blueprintVersion,
                 blueprintName, action, e);
@@ -125,7 +127,7 @@ public class BlueprintProcessingHandler {
 
         final ExecutionServiceInput request = ExecutionServiceInput.newBuilder()
             .setActionIdentifiers(actionIdentifiers)
-            .setPayload(struct)
+            .setPayload(struct.build())
             .setCommonHeader(commonHeader).build();
 
         final StreamObserver<ExecutionServiceInput> requestObserver = asyncStub.process(responseObserver);
diff --git a/grpc-resource/provider/src/main/resources/org/opendaylight/blueprint/grpc-client.xml b/grpc-resource/provider/src/main/resources/org/opendaylight/blueprint/grpc-client.xml
index e6e75159..2c428da3 100644
--- a/grpc-resource/provider/src/main/resources/org/opendaylight/blueprint/grpc-client.xml
+++ b/grpc-resource/provider/src/main/resources/org/opendaylight/blueprint/grpc-client.xml
@@ -29,5 +29,7 @@
         <argument ref="blueprintProcessingHandler"/>
         <argument ref="grpcProperty"/>
     </bean>
+    <service ref="grpcClient" interface="org.onap.ccsdk.sli.adaptors.grpc.cds.BlueprintProcessingClient"
+      odl:type="default"/>
 
 </blueprint>