2 * ============LICENSE_START=======================================================
3 * Copyright (C) 2016-2018 Ericsson. All rights reserved.
4 * Modifications Copyright (C) 2019-2020 Nordix Foundation.
5 * ================================================================================
6 * Licensed under the Apache License, Version 2.0 (the "License");
7 * you may not use this file except in compliance with the License.
8 * You may obtain a copy of the License at
10 * http://www.apache.org/licenses/LICENSE-2.0
12 * Unless required by applicable law or agreed to in writing, software
13 * distributed under the License is distributed on an "AS IS" BASIS,
14 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15 * See the License for the specific language governing permissions and
16 * limitations under the License.
18 * SPDX-License-Identifier: Apache-2.0
19 * ============LICENSE_END=========================================================
22 package org.onap.policy.apex.service.parameters.carriertechnology;
24 import java.util.Arrays;
25 import java.util.HashSet;
27 import java.util.regex.Matcher;
28 import java.util.regex.Pattern;
29 import java.util.regex.PatternSyntaxException;
31 import javax.ws.rs.core.MultivaluedHashMap;
32 import javax.ws.rs.core.MultivaluedMap;
37 import org.apache.commons.lang3.StringUtils;
38 import org.onap.policy.common.parameters.GroupValidationResult;
39 import org.onap.policy.common.parameters.ValidationStatus;
40 import org.onap.policy.common.utils.validation.ParameterValidationUtils;
41 import org.slf4j.Logger;
42 import org.slf4j.LoggerFactory;
46 * Apex plugin parameters for REST as an event carrier technology with Apex.
48 * <p>The parameters for this plugin are:
50 * <li>url: The URL that the Apex Rest client will connect to over REST for event reception or event sending. This
51 * parameter is mandatory.
52 * <li>httpMethod: The HTTP method to use when sending events over REST, legal values are POST (default) and PUT. When
53 * receiving events, the REST client plugin always uses the HTTP GET method.
54 * <li>httpHeaders, the HTTP headers to send on REST requests, optional parameter, defaults to none.
55 * <li>httpCodeFilter: a regular expression filter for returned HTTP codes, if the returned HTTP code passes this
56 * filter, then the request is assumed to have succeeded by the plugin, optional, defaults to allowing 2xx codes
57 * through, that is a regular expression of "[2][0-9][0-9]"
60 * @author Ning Xi(ning.xi@ericsson.com)
65 public class RestPluginCarrierTechnologyParameters extends CarrierTechnologyParameters {
66 // Get a reference to the logger
67 private static final Logger LOGGER = LoggerFactory.getLogger(RestPluginCarrierTechnologyParameters.class);
69 /** The supported HTTP methods. */
70 public enum HttpMethod {
77 /** The default HTTP code filter, allows 2xx HTTP codes through. */
78 public static final String DEFAULT_HTTP_CODE_FILTER = "[2][0-9][0-9]";
80 // Commonly occurring strings
81 private static final String HTTP_HEADERS = "httpHeaders";
82 private static final String HTTP_CODE_FILTER = "httpCodeFilter";
84 // Regular expression patterns for finding and checking keys in URLs
85 private static final Pattern patternProperKey = Pattern.compile("(?<=\\{)[^}]*(?=\\})");
86 protected static final Pattern patternErrorKey =
87 Pattern.compile("(\\{[^\\{}]*.?\\{)|(\\{[^\\{}]*$)|(\\}[^\\{}]*.?\\})|(^[^\\{}]*.?\\})|\\{\\s*\\}");
90 protected String url = null;
91 protected HttpMethod httpMethod = null;
92 protected String[][] httpHeaders = null;
93 protected String httpCodeFilter = DEFAULT_HTTP_CODE_FILTER;
96 * Constructor to create a REST carrier technology parameters instance and register the instance with the parameter
99 public RestPluginCarrierTechnologyParameters() {
104 * Check if http headers have been set for the REST request.
106 * @return true if headers have been set
108 public boolean checkHttpHeadersSet() {
109 return httpHeaders != null && httpHeaders.length > 0;
113 * Gets the http headers for the REST request as a multivalued map.
115 * @return the headers
117 public MultivaluedMap<String, Object> getHttpHeadersAsMultivaluedMap() {
118 if (httpHeaders == null) {
122 // Load the HTTP headers into the map
123 MultivaluedMap<String, Object> httpHeaderMap = new MultivaluedHashMap<>();
125 for (String[] httpHeader : httpHeaders) {
126 httpHeaderMap.putSingle(httpHeader[0], httpHeader[1]);
129 return httpHeaderMap;
133 * Sets the header for the REST request.
135 * @param httpHeaders the incoming HTTP headers
137 public void setHttpHeaders(final String[][] httpHeaders) {
138 this.httpHeaders = httpHeaders;
142 * Get the tag for the REST Producer Properties.
144 * @return set of the tags
146 public Set<String> getKeysFromUrl() {
147 Matcher matcher = patternProperKey.matcher(getUrl());
148 Set<String> key = new HashSet<>();
149 while (matcher.find()) {
150 key.add(matcher.group());
159 public GroupValidationResult validate() {
160 GroupValidationResult result = super.validate();
163 validateHttpHeaders(result);
165 return validateHttpCodeFilter(result);
173 * http://www.blah.com/{par1/somethingelse (Missing end tag) use {[^\\{}]*$
174 * http://www.blah.com/{par1/{some}thingelse (Nested tag) use {[^}]*{
175 * http://www.blah.com/{par1}/some}thingelse (Missing start tag1) use }[^{}]*.}
176 * http://www.blah.com/par1}/somethingelse (Missing start tag2) use }[^{}]*}
177 * http://www.blah.com/{}/somethingelse (Empty tag) use {[\s]*}
178 * @param result the result of the validation
181 public GroupValidationResult validateUrl(final GroupValidationResult result) {
182 // Check if the URL has been set for event output
183 String urlErrorMessage = "no URL has been set for event sending on " + getLabel();
184 if (getUrl() == null) {
185 result.setResult("url", ValidationStatus.INVALID, urlErrorMessage);
189 Matcher matcher = patternErrorKey.matcher(getUrl());
190 if (matcher.find()) {
191 result.setResult("url", ValidationStatus.INVALID, urlErrorMessage);
198 * Validate the HTTP headers.
200 * @param result the result of the validation
202 private GroupValidationResult validateHttpHeaders(final GroupValidationResult result) {
203 if (httpHeaders == null) {
207 for (String[] httpHeader : httpHeaders) {
208 if (httpHeader == null) {
209 result.setResult(HTTP_HEADERS, ValidationStatus.INVALID, "HTTP header array entry is null");
210 } else if (httpHeader.length != 2) {
211 result.setResult(HTTP_HEADERS, ValidationStatus.INVALID,
212 "HTTP header array entries must have one key and one value: "
213 + Arrays.deepToString(httpHeader));
214 } else if (!ParameterValidationUtils.validateStringParameter(httpHeader[0])) {
215 result.setResult(HTTP_HEADERS, ValidationStatus.INVALID,
216 "HTTP header key is null or blank: " + Arrays.deepToString(httpHeader));
217 } else if (!ParameterValidationUtils.validateStringParameter(httpHeader[1])) {
218 result.setResult(HTTP_HEADERS, ValidationStatus.INVALID,
219 "HTTP header value is null or blank: " + Arrays.deepToString(httpHeader));
227 * Validate the HTTP code filter.
229 * @param result the result of the validation
231 public GroupValidationResult validateHttpCodeFilter(final GroupValidationResult result) {
232 if (httpCodeFilter == null) {
233 httpCodeFilter = DEFAULT_HTTP_CODE_FILTER;
235 } else if (StringUtils.isBlank(httpCodeFilter)) {
236 result.setResult(HTTP_CODE_FILTER, ValidationStatus.INVALID,
237 "HTTP code filter must be specified as a three digit regular expression");
240 Pattern.compile(httpCodeFilter);
241 } catch (PatternSyntaxException pse) {
243 "Invalid HTTP code filter, the filter must be specified as a three digit regular expression: "
245 result.setResult(HTTP_CODE_FILTER, ValidationStatus.INVALID, message);
246 LOGGER.debug(message, pse);
257 public String toString() {
258 return getLabel() + "CarrierTechnologyParameters [url=" + url + ", httpMethod=" + httpMethod + ", httpHeaders="
259 + Arrays.deepToString(httpHeaders) + ", httpCodeFilter=" + httpCodeFilter + "]";