/*-
* ============LICENSE_START=======================================================
* Copyright (C) 2018 Ericsson. All rights reserved.
+ * Modifications Copyright (C) 2021 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* 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.
- *
+ *
* SPDX-License-Identifier: Apache-2.0
* ============LICENSE_END=========================================================
*/
import com.google.gson.JsonDeserializer;
import com.google.gson.JsonSerializer;
+import com.google.gson.TypeAdapter;
import org.onap.policy.common.parameters.GroupValidationResult;
import org.onap.policy.common.parameters.ParameterGroup;
import org.onap.policy.common.parameters.ValidationStatus;
* <li>adaptedClass: The name of the class being adapted.
* <li>adapterClass: the JSON adapter class to use for the adapted class.
* </ol>
- *
+ *
* @author Liam Fallon (liam.fallon@ericsson.com)
*/
//@formatter:on
if (adaptedClass == null) {
return null;
}
-
+
try {
return Class.forName(adaptedClass);
} catch (final ClassNotFoundException e) {
if (adaptorClass == null) {
return null;
}
-
+
try {
return Class.forName(adaptorClass);
} catch (final ClassNotFoundException e) {
final GroupValidationResult result = new GroupValidationResult(this);
getClass(ADAPTED_CLASS, adaptedClass, result);
-
+
Class<?> adaptorClazz = getClass(ADAPTOR_CLASS, adaptorClass, result);
+
if (adaptorClazz != null) {
String errorMessage = null;
-
+
+ if (TypeAdapter.class.isAssignableFrom(adaptorClazz)) {
+ return result;
+ }
+
if (!JsonSerializer.class.isAssignableFrom(adaptorClazz)) {
errorMessage = "class is not a JsonSerializer";
}
-
+
if (!JsonDeserializer.class.isAssignableFrom(adaptorClazz)) {
if (errorMessage == null) {
errorMessage = "class is not a JsonDeserializer";
/**
* Check a class exists.
- *
- * @param parameterName the parameter name of the class to check for existence
- * @param classToCheck the class to check for existence
+ *
+ * @param parameterName the parameter name of the class to check for existence
+ * @param classToCheck the class to check for existence
* @param result the result of the check
*/
private Class<?> getClass(String parameterName, String classToCheck, final GroupValidationResult result) {
result.setResult(parameterName, ValidationStatus.INVALID, "parameter is null or blank");
return null;
}
-
+
// Get the class for the event protocol
try {
return Class.forName(classToCheck);
/*-
* ============LICENSE_START=======================================================
* Copyright (C) 2018 Ericsson. All rights reserved.
+ * Modifications Copyright (C) 2021 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* 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.
- *
+ *
* SPDX-License-Identifier: Apache-2.0
* ============LICENSE_END=========================================================
*/
jsonPars.setAdaptorClass("org.onap.policy.apex.context.impl.schema.java.SupportJsonAdapter");
assertTrue(pars.validate().isValid());
+ jsonPars.setAdaptedClass("java.lang.String");
+ jsonPars.setAdaptorClass("org.onap.policy.apex.context.impl.schema.java.SupportJsonAdapter2");
+ assertTrue(pars.validate().isValid());
+
Map<String, JavaSchemaHelperJsonAdapterParameters> adapterMap = new LinkedHashMap<>();
pars.setJsonAdapters(adapterMap);
--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * Copyright (C) 2021 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * 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.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.apex.context.impl.schema.java;
+
+import com.google.gson.TypeAdapter;
+import com.google.gson.stream.JsonReader;
+import com.google.gson.stream.JsonToken;
+import com.google.gson.stream.JsonWriter;
+import java.io.IOException;
+
+public class SupportJsonAdapter2 extends TypeAdapter<String> {
+
+ @Override
+ public void write(JsonWriter out, String value) throws IOException {
+ if (value == null) {
+ out.nullValue();
+
+ } else {
+ out.value(value);
+ }
+ }
+
+ @Override
+ public String read(JsonReader in) throws IOException {
+ if (in.peek() == JsonToken.NULL) {
+ in.nextNull();
+ return null;
+ } else {
+ return in.nextString();
+ }
+ }
+}
"jsonAdapters": {
"Instant": {
"adaptedClass": "java.time.Instant",
- "adaptorClass": "org.onap.policy.controlloop.util.Serialization$GsonInstantAdapter"
+ "adaptorClass": "org.onap.policy.common.gson.InstantAsMillisTypeAdapter"
}
}
}
"jsonAdapters": {
"Instant": {
"adaptedClass": "java.time.Instant",
- "adaptorClass": "org.onap.policy.controlloop.util.Serialization$GsonInstantAdapter"
+ "adaptorClass": "org.onap.policy.common.gson.InstantAsMillisTypeAdapter"
},
"APPC_LCM_REQUEST": {
"adaptedClass": "org.onap.policy.appclcm.LcmRequest",
"jsonAdapters": {
"Instant": {
"adaptedClass": "java.time.Instant",
- "adaptorClass": "org.onap.policy.controlloop.util.Serialization$GsonInstantAdapter"
+ "adaptorClass": "org.onap.policy.common.gson.InstantAsMillisTypeAdapter"
}
}
}
"jsonAdapters": {
"Instant": {
"adaptedClass": "java.time.Instant",
- "adaptorClass": "org.onap.policy.controlloop.util.Serialization$GsonInstantAdapter"
+ "adaptorClass": "org.onap.policy.common.gson.InstantAsMillisTypeAdapter"
}
}
}
"jsonAdapters": {
"Instant": {
"adaptedClass": "java.time.Instant",
- "adaptorClass": "org.onap.policy.controlloop.util.Serialization$GsonInstantAdapter"
+ "adaptorClass": "org.onap.policy.common.gson.InstantAsMillisTypeAdapter"
}
}
}
"jsonAdapters": {
"Instant": {
"adaptedClass": "java.time.Instant",
- "adaptorClass": "org.onap.policy.controlloop.util.Serialization$GsonInstantAdapter"
+ "adaptorClass": "org.onap.policy.common.gson.InstantAsMillisTypeAdapter"
}
}
}
"jsonAdapters": {
"Instant": {
"adaptedClass": "java.time.Instant",
- "adaptorClass": "org.onap.policy.controlloop.util.Serialization$GsonInstantAdapter"
+ "adaptorClass": "org.onap.policy.common.gson.InstantAsMillisTypeAdapter"
}
}
}
"jsonAdapters": {
"Instant": {
"adaptedClass": "java.time.Instant",
- "adaptorClass": "org.onap.policy.controlloop.util.Serialization$GsonInstantAdapter"
+ "adaptorClass": "org.onap.policy.common.gson.InstantAsMillisTypeAdapter"
}
}
}
"jsonAdapters": {
"Instant": {
"adaptedClass": "java.time.Instant",
- "adaptorClass": "org.onap.policy.controlloop.util.Serialization$GsonInstantAdapter"
+ "adaptorClass": "org.onap.policy.common.gson.InstantAsMillisTypeAdapter"
}
}
}
* ============LICENSE_START=======================================================
* Copyright (C) 2018 Ericsson. All rights reserved.
* Modifications Copyright (C) 2019-2020 Nordix Foundation.
+ * Modifications Copyright (C) 2021 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import org.onap.policy.appclcm.AppcLcmDmaapWrapper;
import org.onap.policy.appclcm.AppcLcmInput;
import org.onap.policy.appclcm.AppcLcmOutput;
-import org.onap.policy.controlloop.util.Serialization;
+import org.onap.policy.common.gson.InstantAsMillisTypeAdapter;
/**
* Respond to an APPC request with a given delay.
private final Timer appcTimer;
private static final Gson gson = new GsonBuilder()
- .registerTypeAdapter(Instant.class, new Serialization.GsonInstantAdapter()).setPrettyPrinting().create();
+ .registerTypeAdapter(Instant.class, new InstantAsMillisTypeAdapter()).setPrettyPrinting().create();
private static Integer nextResponseCode = 400;
* ============LICENSE_START=======================================================
* Copyright (C) 2016-2018 Ericsson. All rights reserved.
* Modifications Copyright (C) 2019-2020 Nordix Foundation.
+ * Modifications Copyright (C) 2021 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import javax.ws.rs.QueryParam;
import javax.ws.rs.core.Response;
import org.onap.policy.apex.core.infrastructure.threading.ThreadUtilities;
+import org.onap.policy.common.gson.InstantAsMillisTypeAdapter;
import org.onap.policy.common.utils.resources.TextFileUtils;
-import org.onap.policy.controlloop.util.Serialization;
import org.slf4j.ext.XLogger;
import org.slf4j.ext.XLoggerFactory;
private static final Random randomDelayInc = new Random();
private static final Gson gson = new GsonBuilder()
- .registerTypeAdapter(Instant.class, new Serialization.GsonInstantAdapter()).setPrettyPrinting().create();
+ .registerTypeAdapter(Instant.class, new InstantAsMillisTypeAdapter()).setPrettyPrinting().create();
private static final AtomicInteger nextVnfId = new AtomicInteger(0);
private static Boolean nextControlLoopMessageIsOnset = true;
Code Review / policy / apex-pdp.git / commitdiff