From 710992a925b44fa9594d8f70bbc9f22a6f91d8ad Mon Sep 17 00:00:00 2001 From: Jim Hahn Date: Wed, 13 Feb 2019 13:55:31 -0500 Subject: Remove jackson from policy coders Coders came in pairs, one for GSON and one for Jackson. Replaced the pairs with a single coder for GSON. Simplified list copy. Removed multipleToolsetRetries flag. Removed additional jackson code. It had been removed, but the changes were somehow lost. Simplified another list copy. Updated license dates. Note: the date in PolicyEngineTest will be updated via a different review (mgmt-gson). Change-Id: Id3c7688c2389d194f66afcefa14303cf403ada16 Issue-ID: POLICY-1431 Signed-off-by: Jim Hahn --- .../drools/controller/DroolsControllerFactory.java | 18 +- .../controller/internal/MavenDroolsController.java | 20 +- .../drools/protocol/coders/EventProtocolCoder.java | 201 +++++++-------------- .../protocol/coders/EventProtocolParams.java | 20 +- .../protocol/coders/ProtocolCoderToolset.java | 145 +-------------- .../coders/TopicCoderFilterConfiguration.java | 48 +---- 6 files changed, 74 insertions(+), 378 deletions(-) (limited to 'policy-management/src/main/java') diff --git a/policy-management/src/main/java/org/onap/policy/drools/controller/DroolsControllerFactory.java b/policy-management/src/main/java/org/onap/policy/drools/controller/DroolsControllerFactory.java index 6dcae635..24fc6de9 100644 --- a/policy-management/src/main/java/org/onap/policy/drools/controller/DroolsControllerFactory.java +++ b/policy-management/src/main/java/org/onap/policy/drools/controller/DroolsControllerFactory.java @@ -2,7 +2,7 @@ * ============LICENSE_START======================================================= * policy-management * ================================================================================ - * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved. + * Copyright (C) 2017-2019 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. @@ -37,7 +37,6 @@ import org.onap.policy.drools.properties.DroolsProperties; import org.onap.policy.drools.protocol.coders.JsonProtocolFilter; import org.onap.policy.drools.protocol.coders.TopicCoderFilterConfiguration; import org.onap.policy.drools.protocol.coders.TopicCoderFilterConfiguration.CustomGsonCoder; -import org.onap.policy.drools.protocol.coders.TopicCoderFilterConfiguration.CustomJacksonCoder; import org.onap.policy.drools.protocol.coders.TopicCoderFilterConfiguration.PotentialCoderFilter; import org.onap.policy.drools.utils.Pair; import org.slf4j.Logger; @@ -311,19 +310,6 @@ class IndexedDroolsControllerFactory implements DroolsControllerFactory { } } - String customJackson = properties.getProperty(propertyTopicEntityPrefix + firstTopic - + PolicyEndPointProperties.PROPERTY_TOPIC_EVENTS_CUSTOM_MODEL_CODER_JACKSON_SUFFIX); - - CustomJacksonCoder customJacksonCoder = null; - if (customJackson != null && !customJackson.isEmpty()) { - try { - customJacksonCoder = new CustomJacksonCoder(customJackson); - } catch (IllegalArgumentException e) { - logger.warn("{}: cannot create custom-jackson-coder {} because of {}", this, customJackson, - e.getMessage(), e); - } - } - // 3. second the list of classes associated with each topic String eventClasses = properties @@ -395,7 +381,7 @@ class IndexedDroolsControllerFactory implements DroolsControllerFactory { } TopicCoderFilterConfiguration topic2Classes2Filters = - new TopicCoderFilterConfiguration(firstTopic, classes2Filters, customGsonCoder, customJacksonCoder); + new TopicCoderFilterConfiguration(firstTopic, classes2Filters, customGsonCoder); topics2DecodedClasses2Filters.add(topic2Classes2Filters); } diff --git a/policy-management/src/main/java/org/onap/policy/drools/controller/internal/MavenDroolsController.java b/policy-management/src/main/java/org/onap/policy/drools/controller/internal/MavenDroolsController.java index 6e9f04ed..55352fe2 100644 --- a/policy-management/src/main/java/org/onap/policy/drools/controller/internal/MavenDroolsController.java +++ b/policy-management/src/main/java/org/onap/policy/drools/controller/internal/MavenDroolsController.java @@ -46,7 +46,6 @@ import org.onap.policy.drools.protocol.coders.EventProtocolParams; import org.onap.policy.drools.protocol.coders.JsonProtocolFilter; import org.onap.policy.drools.protocol.coders.TopicCoderFilterConfiguration; import org.onap.policy.drools.protocol.coders.TopicCoderFilterConfiguration.CustomGsonCoder; -import org.onap.policy.drools.protocol.coders.TopicCoderFilterConfiguration.CustomJacksonCoder; import org.onap.policy.drools.protocol.coders.TopicCoderFilterConfiguration.PotentialCoderFilter; import org.onap.policy.drools.utils.ReflectionUtil; import org.slf4j.Logger; @@ -270,22 +269,6 @@ public class MavenDroolsController implements DroolsController { } } - CustomJacksonCoder customJacksonCoder = coderConfig.getCustomJacksonCoder(); - if (coderConfig.getCustomJacksonCoder() != null - && coderConfig.getCustomJacksonCoder().getClassContainer() != null - && !coderConfig.getCustomJacksonCoder().getClassContainer().isEmpty()) { - - String customJacksonCoderClass = coderConfig.getCustomJacksonCoder().getClassContainer(); - if (!ReflectionUtil.isClass(this.policyContainer.getClassLoader(), - customJacksonCoderClass)) { - throw makeRetrieveEx(customJacksonCoderClass); - } else { - if (logger.isInfoEnabled()) { - logClassFetched(customJacksonCoderClass); - } - } - } - List coderFilters = coderConfig.getCoderFilters(); if (coderFilters == null || coderFilters.isEmpty()) { continue; @@ -312,14 +295,13 @@ public class MavenDroolsController implements DroolsController { .eventClass(potentialCodedClass) .protocolFilter(protocolFilter) .customGsonCoder(customGsonCoder) - .customJacksonCoder(customJacksonCoder) .modelClassLoaderHash(this.policyContainer.getClassLoader().hashCode())); } else { EventProtocolCoder.manager.addEncoder( EventProtocolParams.builder().groupId(this.getGroupId()) .artifactId(this.getArtifactId()).topic(topic) .eventClass(potentialCodedClass).protocolFilter(protocolFilter) - .customGsonCoder(customGsonCoder).customJacksonCoder(customJacksonCoder) + .customGsonCoder(customGsonCoder) .modelClassLoaderHash(this.policyContainer.getClassLoader().hashCode())); } } diff --git a/policy-management/src/main/java/org/onap/policy/drools/protocol/coders/EventProtocolCoder.java b/policy-management/src/main/java/org/onap/policy/drools/protocol/coders/EventProtocolCoder.java index 6d16c601..56eadad3 100644 --- a/policy-management/src/main/java/org/onap/policy/drools/protocol/coders/EventProtocolCoder.java +++ b/policy-management/src/main/java/org/onap/policy/drools/protocol/coders/EventProtocolCoder.java @@ -2,7 +2,7 @@ * ============LICENSE_START======================================================= * ONAP * ================================================================================ - * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved. + * Copyright (C) 2017-2019 AT&T Intellectual Property. All rights reserved. * Modifications Copyright(C) 2018 Samsung Electronics Co., Ltd. * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); @@ -26,10 +26,8 @@ import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.Map; - import org.onap.policy.drools.controller.DroolsController; import org.onap.policy.drools.protocol.coders.EventProtocolCoder.CoderFilters; -import org.onap.policy.drools.utils.Pair; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -379,7 +377,7 @@ class MultiplexorEventProtocolCoder implements EventProtocolCoder { @Override public void addDecoder(EventProtocolParams eventProtocolParams) { logger.info( - "{}: add-decoder {}:{}:{}:{}:{}:{}:{}:{}", + "{}: add-decoder {}:{}:{}:{}:{}:{}:{}", this, eventProtocolParams.getGroupId(), eventProtocolParams.getArtifactId(), @@ -387,7 +385,6 @@ class MultiplexorEventProtocolCoder implements EventProtocolCoder { eventProtocolParams.getEventClass(), eventProtocolParams.getProtocolFilter(), eventProtocolParams.getCustomGsonCoder(), - eventProtocolParams.getCustomJacksonCoder(), eventProtocolParams.getModelClassLoaderHash()); this.decoders.add(eventProtocolParams); } @@ -400,7 +397,7 @@ class MultiplexorEventProtocolCoder implements EventProtocolCoder { @Override public void addEncoder(EventProtocolParams eventProtocolParams) { logger.info( - "{}: add-decoder {}:{}:{}:{}:{}:{}:{}:{}", + "{}: add-decoder {}:{}:{}:{}:{}:{}:{}", this, eventProtocolParams.getGroupId(), eventProtocolParams.getArtifactId(), @@ -408,7 +405,6 @@ class MultiplexorEventProtocolCoder implements EventProtocolCoder { eventProtocolParams.getEventClass(), eventProtocolParams.getProtocolFilter(), eventProtocolParams.getCustomGsonCoder(), - eventProtocolParams.getCustomJacksonCoder(), eventProtocolParams.getModelClassLoaderHash()); this.encoders.add(eventProtocolParams); } @@ -513,14 +509,14 @@ class MultiplexorEventProtocolCoder implements EventProtocolCoder { */ @Override public ProtocolCoderToolset getDecoders(String groupId, String artifactId, String topic) { - Pair decoderToolsets = + ProtocolCoderToolset decoderToolsets = this.decoders.getCoders(groupId, artifactId, topic); if (decoderToolsets == null) { throw new IllegalArgumentException( "Decoders not found for " + groupId + ":" + artifactId + ":" + topic); } - return decoderToolsets.first(); + return decoderToolsets; } /** @@ -534,18 +530,13 @@ class MultiplexorEventProtocolCoder implements EventProtocolCoder { @Override public List getDecoders(String groupId, String artifactId) { - List> decoderToolsets = + List decoderToolsets = this.decoders.getCoders(groupId, artifactId); if (decoderToolsets == null) { throw new IllegalArgumentException("Decoders not found for " + groupId + ":" + artifactId); } - List parser1CoderToolset = new ArrayList<>(); - for (Pair coderToolsetPair : decoderToolsets) { - parser1CoderToolset.add(coderToolsetPair.first()); - } - - return parser1CoderToolset; + return new ArrayList<>(decoderToolsets); } /** @@ -629,24 +620,20 @@ abstract class GenericEventProtocolCoder { private static Logger logger = LoggerFactory.getLogger(GenericEventProtocolCoder.class); /** - * Mapping topic:controller-id -> / where protocol-coder-toolset-pair contains both - * a jackson-protocol-coder-toolset and a gson-protocol-coder-toolset. The first value of the pair will the protocol - * coder toolset most likely to be successful with the encoding or decoding, and consequently the second value will - * be the less likely. + * Mapping topic:controller-id -> / where protocol-coder-toolset contains + * a gson-protocol-coder-toolset. */ - protected final HashMap> coders = + protected final HashMap coders = new HashMap<>(); /** * Mapping topic + classname -> Protocol Set. */ - protected final HashMap>> + protected final HashMap> reverseCoders = new HashMap<>(); - protected boolean multipleToolsetRetries = false; - - GenericEventProtocolCoder(boolean multipleToolsetRetries) { - this.multipleToolsetRetries = multipleToolsetRetries; + GenericEventProtocolCoder() { + super(); } /** @@ -678,18 +665,11 @@ abstract class GenericEventProtocolCoder { synchronized (this) { if (coders.containsKey(key)) { - Pair toolsets = coders.get(key); + ProtocolCoderToolset toolset = coders.get(key); - logger.info("{}: adding coders for existing {}: {}", this, key, toolsets.first()); + logger.info("{}: adding coders for existing {}: {}", this, key, toolset); - toolsets - .first() - .addCoder( - eventProtocolParams.getEventClass(), - eventProtocolParams.getProtocolFilter(), - eventProtocolParams.getModelClassLoaderHash()); - toolsets - .second() + toolset .addCoder( eventProtocolParams.getEventClass(), eventProtocolParams.getProtocolFilter(), @@ -701,34 +681,20 @@ abstract class GenericEventProtocolCoder { this, reverseKey, key, - toolsets.first()); + toolset); - List> reverseMappings = + List reverseMappings = new ArrayList<>(); - reverseMappings.add(toolsets); + reverseMappings.add(toolset); reverseCoders.put(reverseKey, reverseMappings); } return; } - GsonProtocolCoderToolset gsonCoderTools = + GsonProtocolCoderToolset coderTools = new GsonProtocolCoderToolset(eventProtocolParams, key); - JacksonProtocolCoderToolset jacksonCoderTools = - new JacksonProtocolCoderToolset(eventProtocolParams, key); - - // Use Gson as the first priority encoding/decoding toolset, and Jackson - // as second. This is because it has been observed that they can diverge - // somewhat in the encoding/decoding data types, which can produce json - // that may result incompatible with what some network elements are - // expecting. As decoding takes place, this element will reconfigure - // itself to set the jackson one as the favoured one first, if errors - // are detected in the gson encoding - - Pair coderTools = - new Pair<>(gsonCoderTools, jacksonCoderTools); - - logger.info("{}: adding coders for new {}: {}", this, key, coderTools.first()); + logger.info("{}: adding coders for new {}: {}", this, key, coderTools); coders.put(key, coderTools); @@ -736,12 +702,12 @@ abstract class GenericEventProtocolCoder { // There is another controller (different group id/artifact id/topic) // that shares the class and the topic. - List> toolsets = + List toolsets = reverseCoders.get(reverseKey); boolean present = false; - for (Pair parserSet : toolsets) { + for (ProtocolCoderToolset parserSet : toolsets) { // just doublecheck - present = parserSet.first().getControllerId().equals(key); + present = parserSet.getControllerId().equals(key); if (present) { /* anomaly */ logger.error( @@ -749,18 +715,18 @@ abstract class GenericEventProtocolCoder { this, reverseKey, key, - parserSet.first()); + parserSet); } } if (present) { return; } else { - logger.info("{}: adding coder set for {}: {} ", this, reverseKey, coderTools.getFirst()); + logger.info("{}: adding coder set for {}: {} ", this, reverseKey, coderTools); toolsets.add(coderTools); } } else { - List> toolsets = new ArrayList<>(); + List toolsets = new ArrayList<>(); toolsets.add(coderTools); logger.info("{}: adding toolset for reverse key {}: {}", this, reverseKey, toolsets); @@ -818,21 +784,21 @@ abstract class GenericEventProtocolCoder { synchronized (this) { if (coders.containsKey(key)) { - Pair pair = coders.remove(key); + ProtocolCoderToolset coderToolset = coders.remove(key); - logger.info("{}: removed toolset for {}: {}", this, key, pair.getFirst()); + logger.info("{}: removed toolset for {}: {}", this, key, coderToolset); - for (CoderFilters codeFilter : pair.first().getCoders()) { + for (CoderFilters codeFilter : coderToolset.getCoders()) { String className = codeFilter.getCodedClass(); String reverseKey = this.reverseCodersKey(topic, className); if (this.reverseCoders.containsKey(reverseKey)) { - List> toolsets = + List toolsets = this.reverseCoders.get(reverseKey); - Iterator> toolsetsIter = + Iterator toolsetsIter = toolsets.iterator(); while (toolsetsIter.hasNext()) { - Pair toolset = toolsetsIter.next(); - if (toolset.first().getControllerId().equals(key)) { + ProtocolCoderToolset toolset = toolsetsIter.next(); + if (toolset.getControllerId().equals(key)) { logger.info( "{}: removed coder from toolset for {} from reverse mapping", this, reverseKey); toolsetsIter.remove(); @@ -896,9 +862,9 @@ abstract class GenericEventProtocolCoder { } String key = this.codersKey(groupId, artifactId, topic); - Pair coderTools = coders.get(key); + ProtocolCoderToolset coderTools = coders.get(key); try { - Object event = coderTools.first().decode(json); + Object event = coderTools.decode(json); if (event != null) { return event; } @@ -906,27 +872,7 @@ abstract class GenericEventProtocolCoder { logger.debug("{}, cannot decode {}", this, json, e); } - if (multipleToolsetRetries) { - // try the less favored toolset - try { - Object event = coderTools.second().decode(json); - if (event != null) { - // change the priority of the toolset - synchronized (this) { - ProtocolCoderToolset first = coderTools.first(); - ProtocolCoderToolset second = coderTools.second(); - coderTools.first(second); - coderTools.second(first); - } - - return event; - } - } catch (Exception e) { - throw new UnsupportedOperationException(e); - } - } - - throw new UnsupportedOperationException("Cannot decode neither with gson or jackson"); + throw new UnsupportedOperationException("Cannot decode with gson"); } /** @@ -979,12 +925,12 @@ abstract class GenericEventProtocolCoder { throw new IllegalArgumentException("no reverse coder has been found"); } - List> toolsets = + List toolsets = this.reverseCoders.get(reverseKey); String key = codersKey( - toolsets.get(0).first().getGroupId(), toolsets.get(0).first().getArtifactId(), topic); + toolsets.get(0).getGroupId(), toolsets.get(0).getArtifactId(), topic); return this.encodeInternal(key, event); } @@ -1024,9 +970,9 @@ abstract class GenericEventProtocolCoder { logger.debug("{}: encode for {}: {}", this, key, event); - Pair coderTools = coders.get(key); + ProtocolCoderToolset coderTools = coders.get(key); try { - String json = coderTools.first().encode(event); + String json = coderTools.encode(event); if (json != null && !json.isEmpty()) { return json; } @@ -1034,28 +980,7 @@ abstract class GenericEventProtocolCoder { logger.warn("{}: cannot encode (first) for {}: {}", this, key, event, e); } - if (multipleToolsetRetries) { - // try the less favored toolset - try { - String json = coderTools.second().encode(event); - if (json != null) { - // change the priority of the toolset - synchronized (this) { - ProtocolCoderToolset first = coderTools.first(); - ProtocolCoderToolset second = coderTools.second(); - coderTools.first(second); - coderTools.second(first); - } - - return json; - } - } catch (Exception e) { - logger.error("{}: cannot encode (second) for {}: {}", this, key, event, e); - throw new UnsupportedOperationException(e); - } - } - - throw new UnsupportedOperationException("Cannot decode neither with gson or jackson"); + throw new UnsupportedOperationException("Cannot decode with gson"); } /** @@ -1077,10 +1002,10 @@ abstract class GenericEventProtocolCoder { return droolsControllers; } - List> toolsets = + List toolsets = this.reverseCoders.get(reverseKey); - // There must be multiple toolset pairs associated with reverseKey + // There must be multiple toolsets associated with reverseKey // case 2 different controllers use the same models and register the same encoder for // the same topic. This is assumed not to occur often but for the purpose of encoding // but there should be no side-effects. Ownership is crosscheck against classname and @@ -1094,11 +1019,11 @@ abstract class GenericEventProtocolCoder { + encodedClass.getClass().getCanonicalName()); } - for (Pair encoderSet : toolsets) { + for (ProtocolCoderToolset encoderSet : toolsets) { // figure out the right toolset - String groupId = encoderSet.first().getGroupId(); - String artifactId = encoderSet.first().getArtifactId(); - List coderFilters = encoderSet.first().getCoders(); + String groupId = encoderSet.getGroupId(); + String artifactId = encoderSet.getArtifactId(); + List coderFilters = encoderSet.getCoders(); for (CoderFilters coder : coderFilters) { if (coder.getCodedClass().equals(encodedClass.getClass().getCanonicalName())) { DroolsController droolsController = DroolsController.factory.get(groupId, artifactId, ""); @@ -1137,8 +1062,8 @@ abstract class GenericEventProtocolCoder { } String key = this.codersKey(groupId, artifactId, topic); - Pair coderTools = coders.get(key); - return coderTools.first().getCoders(); + ProtocolCoderToolset coderTools = coders.get(key); + return coderTools.getCoders(); } /** @@ -1162,10 +1087,10 @@ abstract class GenericEventProtocolCoder { String key = this.codersKey(groupId, artifactId, ""); List codersFilters = new ArrayList<>(); - for (Map.Entry> entry : + for (Map.Entry entry : coders.entrySet()) { if (entry.getKey().startsWith(key)) { - codersFilters.addAll(entry.getValue().first().getCoders()); + codersFilters.addAll(entry.getValue().getCoders()); } } @@ -1194,8 +1119,8 @@ abstract class GenericEventProtocolCoder { } String key = this.codersKey(groupId, artifactId, topic); - Pair coderTools = coders.get(key); - return coderTools.first().getCoder(classname); + ProtocolCoderToolset coderTools = coders.get(key); + return coderTools.getCoder(classname); } /** @@ -1207,7 +1132,7 @@ abstract class GenericEventProtocolCoder { * @return list of coders * @throws IllegalArgumentException if invalid input */ - public Pair getCoders( + public ProtocolCoderToolset getCoders( String groupId, String artifactId, String topic) { if (!isCodingSupported(groupId, artifactId, topic)) { @@ -1226,7 +1151,7 @@ abstract class GenericEventProtocolCoder { * @return list of coders * @throws IllegalArgumentException if invalid input */ - public List> getCoders( + public List getCoders( String groupId, String artifactId) { if (groupId == null || groupId.isEmpty()) { @@ -1239,8 +1164,8 @@ abstract class GenericEventProtocolCoder { String key = this.codersKey(groupId, artifactId, ""); - List> coderToolset = new ArrayList<>(); - for (Map.Entry> entry : + List coderToolset = new ArrayList<>(); + for (Map.Entry entry : coders.entrySet()) { if (entry.getKey().startsWith(key)) { coderToolset.add(entry.getValue()); @@ -1268,14 +1193,14 @@ abstract class GenericEventProtocolCoder { } String key = this.reverseCodersKey(topic, codedClass); - List> toolsets = this.reverseCoders.get(key); + List toolsets = this.reverseCoders.get(key); if (toolsets == null) { throw new IllegalArgumentException("No Coder found for " + key); } List coderFilters = new ArrayList<>(); - for (Pair toolset : toolsets) { - coderFilters.addAll(toolset.first().getCoders()); + for (ProtocolCoderToolset toolset : toolsets) { + coderFilters.addAll(toolset.getCoders()); } return coderFilters; @@ -1360,7 +1285,7 @@ abstract class GenericEventProtocolCoder { class EventProtocolDecoder extends GenericEventProtocolCoder { public EventProtocolDecoder() { - super(false); + super(); } @Override @@ -1372,7 +1297,7 @@ class EventProtocolDecoder extends GenericEventProtocolCoder { class EventProtocolEncoder extends GenericEventProtocolCoder { public EventProtocolEncoder() { - super(false); + super(); } @Override diff --git a/policy-management/src/main/java/org/onap/policy/drools/protocol/coders/EventProtocolParams.java b/policy-management/src/main/java/org/onap/policy/drools/protocol/coders/EventProtocolParams.java index e8a140e0..810562cd 100644 --- a/policy-management/src/main/java/org/onap/policy/drools/protocol/coders/EventProtocolParams.java +++ b/policy-management/src/main/java/org/onap/policy/drools/protocol/coders/EventProtocolParams.java @@ -1,6 +1,7 @@ /*- * ============LICENSE_START======================================================= * Copyright (C) 2018 Samsung Electronics Co., Ltd. All rights reserved. + * Modifications Copyright (C) 2019 AT&T Intellectual Property. * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -29,7 +30,6 @@ public class EventProtocolParams { private String eventClass; private JsonProtocolFilter protocolFilter; private TopicCoderFilterConfiguration.CustomGsonCoder customGsonCoder; - private TopicCoderFilterConfiguration.CustomJacksonCoder customJacksonCoder; private int modelClassLoaderHash; public String getGroupId() { @@ -56,10 +56,6 @@ public class EventProtocolParams { return customGsonCoder; } - public TopicCoderFilterConfiguration.CustomJacksonCoder getCustomJacksonCoder() { - return customJacksonCoder; - } - public int getModelClassLoaderHash() { return modelClassLoaderHash; } @@ -136,18 +132,6 @@ public class EventProtocolParams { return this; } - /** - * Setter method. - * - * @param customJacksonCoder custom Jackson coder - * @return EventProtocolParams - */ - public EventProtocolParams customJacksonCoder( - TopicCoderFilterConfiguration.CustomJacksonCoder customJacksonCoder) { - this.customJacksonCoder = customJacksonCoder; - return this; - } - /** * Setter method. * @param modelClassLoaderHash integer representing model hash @@ -159,6 +143,6 @@ public class EventProtocolParams { } public CustomCoder getCustomCoder() { - return this.customGsonCoder != null ? this.customGsonCoder : this.customJacksonCoder; + return this.customGsonCoder; } } diff --git a/policy-management/src/main/java/org/onap/policy/drools/protocol/coders/ProtocolCoderToolset.java b/policy-management/src/main/java/org/onap/policy/drools/protocol/coders/ProtocolCoderToolset.java index bc4fe142..97598df4 100644 --- a/policy-management/src/main/java/org/onap/policy/drools/protocol/coders/ProtocolCoderToolset.java +++ b/policy-management/src/main/java/org/onap/policy/drools/protocol/coders/ProtocolCoderToolset.java @@ -2,7 +2,7 @@ * ============LICENSE_START======================================================= * ONAP * ================================================================================ - * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved. + * Copyright (C) 2017-2019 AT&T Intellectual Property. All rights reserved. * Modifications Copyright (C) 2018 Samsung Electronics Co., Ltd. * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); @@ -22,10 +22,6 @@ package org.onap.policy.drools.protocol.coders; import com.fasterxml.jackson.annotation.JsonIgnore; -import com.fasterxml.jackson.core.JsonProcessingException; -import com.fasterxml.jackson.databind.DeserializationFeature; -import com.fasterxml.jackson.databind.ObjectMapper; -import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule; import com.google.gson.Gson; import com.google.gson.GsonBuilder; import com.google.gson.JsonDeserializationContext; @@ -330,146 +326,9 @@ public abstract class ProtocolCoderToolset { } -/** - * Tools used for encoding/decoding using Jackson. - */ -class JacksonProtocolCoderToolset extends ProtocolCoderToolset { - private static final String WARN_FETCH_FAILED = "{}: cannot fetch application class {}"; - private static final String WARN_FETCH_FAILED_BECAUSE = "{}: cannot fetch application class {} because of {}"; - private static final String FETCH_FAILED = "cannot fetch application class "; - private static final String ENCODE_FAILED = "event cannot be encoded"; - private static Logger logger = LoggerFactory.getLogger(JacksonProtocolCoderToolset.class); - - /** - * decoder. - */ - @JsonIgnore - protected final ObjectMapper decoder = new ObjectMapper(); - - /** - * encoder. - */ - @JsonIgnore - protected final ObjectMapper encoder = new ObjectMapper(); - - /** - * Toolset to encode/decode tools associated with a topic. - * - * @param eventProtocolParams parameter object for event encoder - * @param controllerId controller id - */ - public JacksonProtocolCoderToolset(EventProtocolParams eventProtocolParams, String controllerId) { - super(eventProtocolParams, controllerId); - this.decoder.registerModule(new JavaTimeModule()); - this.decoder.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false); - } - - /** - * gets the Jackson decoder. - * - * @return the Jackson decoder - */ - @JsonIgnore - protected ObjectMapper getDecoder() { - return this.decoder; - } - - /** - * gets the Jackson encoder. - * - * @return the Jackson encoder - */ - @JsonIgnore - protected ObjectMapper getEncoder() { - return this.encoder; - } - - /** - * {@inheritDoc}. - */ - @Override - public Object decode(String json) { - - // 0. Use custom coder if available - - if (this.customCoder != null) { - throw new UnsupportedOperationException( - "Jackon Custom Decoder is not supported at this time"); - } - - final DroolsController droolsController = - DroolsController.factory.get(this.groupId, this.artifactId, ""); - if (droolsController == null) { - logger.warn("{}: no drools-controller to process {}", this, json); - throw new IllegalStateException("no drools-controller to process event"); - } - - final CoderFilters decoderFilter = this.filter(json); - if (decoderFilter == null) { - logger.debug("{}: no decoder to process {}", this, json); - throw new UnsupportedOperationException("no decoder to process event"); - } - - Class decoderClass; - try { - decoderClass = droolsController.fetchModelClass(decoderFilter.getCodedClass()); - if (decoderClass == null) { - logger.warn(WARN_FETCH_FAILED, this, decoderFilter.getCodedClass()); - throw new IllegalStateException( - FETCH_FAILED + decoderFilter.getCodedClass()); - } - } catch (final Exception e) { - logger.warn(WARN_FETCH_FAILED_BECAUSE, this, - decoderFilter.getCodedClass(), e.getMessage()); - throw new UnsupportedOperationException( - FETCH_FAILED + decoderFilter.getCodedClass(), e); - } - - - try { - return this.decoder.readValue(json, decoderClass); - } catch (final Exception e) { - logger.warn("{} cannot decode {} into {} because of {}", this, json, decoderClass.getName(), - e.getMessage(), e); - throw new UnsupportedOperationException( - "cannont decode into " + decoderFilter.getCodedClass(), e); - } - } - - /** - * {@inheritDoc}. - */ - @Override - public String encode(Object event) { - - // 0. Use custom coder if available - - if (this.customCoder != null) { - throw new UnsupportedOperationException( - "Jackon Custom Encoder is not supported at this time"); - } - - try { - return this.encoder.writeValueAsString(event); - } catch (final JsonProcessingException e) { - logger.error("{} cannot encode {} because of {}", this, event, e.getMessage(), e); - throw new UnsupportedOperationException(ENCODE_FAILED); - } - } - - @Override - public String toString() { - final StringBuilder builder = new StringBuilder(); - builder.append("JacksonProtocolCoderToolset [toString()=").append(super.toString()).append("]"); - return builder.toString(); - } - -} - - /** - * Tools used for encoding/decoding using Jackson. + * Tools used for encoding/decoding using GSON. */ class GsonProtocolCoderToolset extends ProtocolCoderToolset { /** diff --git a/policy-management/src/main/java/org/onap/policy/drools/protocol/coders/TopicCoderFilterConfiguration.java b/policy-management/src/main/java/org/onap/policy/drools/protocol/coders/TopicCoderFilterConfiguration.java index f7fc4d21..35a49a1d 100644 --- a/policy-management/src/main/java/org/onap/policy/drools/protocol/coders/TopicCoderFilterConfiguration.java +++ b/policy-management/src/main/java/org/onap/policy/drools/protocol/coders/TopicCoderFilterConfiguration.java @@ -2,7 +2,7 @@ * ============LICENSE_START======================================================= * policy-management * ================================================================================ - * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved. + * Copyright (C) 2017-2019 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. @@ -145,24 +145,6 @@ public class TopicCoderFilterConfiguration { } } - public static class CustomJacksonCoder extends CustomCoder { - - public CustomJacksonCoder(String className, String staticCoderField) { - super(className, staticCoderField); - } - - public CustomJacksonCoder(String customJackson) { - super(customJackson); - } - - @Override - public String toString() { - StringBuilder builder = new StringBuilder(); - builder.append("CustomJacksonCoder [toString()=").append(super.toString()).append("]"); - return builder.toString(); - } - } - /** * Coder/Decoder class and Filter container. The decoder class is potential, in order to be * operational needs to be fetched from an available class loader. @@ -243,24 +225,20 @@ public class TopicCoderFilterConfiguration { /* custom gson coder that this controller prefers to use instead of the framework ones */ protected CustomGsonCoder customGsonCoder; - /* custom jackson coder that this controller prefers to use instead of the framework ones */ - protected CustomJacksonCoder customJacksonCoder; - /** * Constructor. * - * @param decoderFilters list of decoders and associated filters * @param topic the topic + * @param decoderFilters list of decoders and associated filters + * @param customGsonCoder GSON coder */ public TopicCoderFilterConfiguration( String topic, List decoderFilters, - CustomGsonCoder customGsonCoder, - CustomJacksonCoder customJacksonCoder) { + CustomGsonCoder customGsonCoder) { this.coderFilters = decoderFilters; this.topic = topic; this.customGsonCoder = customGsonCoder; - this.customJacksonCoder = customJacksonCoder; } /** @@ -297,22 +275,6 @@ public class TopicCoderFilterConfiguration { this.customGsonCoder = customGsonCoder; } - /** Get custom jackson coder. - * - * @return the customJacksonCoder - **/ - public CustomJacksonCoder getCustomJacksonCoder() { - return customJacksonCoder; - } - - /** - * Set custom Jackson coder. - * @param customJacksonCoder the customJacksonCoder to set - **/ - public void setCustomJacksonCoder(CustomJacksonCoder customJacksonCoder) { - this.customJacksonCoder = customJacksonCoder; - } - @Override public String toString() { StringBuilder builder = new StringBuilder(); @@ -323,8 +285,6 @@ public class TopicCoderFilterConfiguration { .append(coderFilters) .append(", customGsonCoder=") .append(customGsonCoder) - .append(", customJacksonCoder=") - .append(customJacksonCoder) .append("]"); return builder.toString(); } -- cgit 1.2.3-korg