summaryrefslogtreecommitdiffstats
path: root/controlloop/common/model-impl/rest/src/main
diff options
context:
space:
mode:
authorJim Hahn <jrh3@att.com>2019-05-08 14:33:57 -0400
committerJim Hahn <jrh3@att.com>2019-05-08 16:24:35 -0400
commit10b21aae2bde224ab7f91f4b5ab1b89369c8fd1c (patch)
tree0417099e379e8be69f90221e8fd066fc40def62b /controlloop/common/model-impl/rest/src/main
parent01841878936986bc80a974977ccdeaceaf7f9a78 (diff)
Add payload to vFW policy yaml
Added new "streams" payload to vFW policy yaml files. Removed references to pg-streams. Also deleted directories that were moved to policy/models. Also removed references to trafficgenerator. Updated licenses. Removed some trailing whitespace. Change-Id: I6becaa573628eee677f0959fadf86f9a9f032f88 Issue-ID: POLICY-1752 Signed-off-by: Jim Hahn <jrh3@att.com>
Diffstat (limited to 'controlloop/common/model-impl/rest/src/main')
-rw-r--r--controlloop/common/model-impl/rest/src/main/java/org/onap/policy/rest/HttpDeleteWithBody.java52
-rw-r--r--controlloop/common/model-impl/rest/src/main/java/org/onap/policy/rest/RestManager.java192
2 files changed, 0 insertions, 244 deletions
diff --git a/controlloop/common/model-impl/rest/src/main/java/org/onap/policy/rest/HttpDeleteWithBody.java b/controlloop/common/model-impl/rest/src/main/java/org/onap/policy/rest/HttpDeleteWithBody.java
deleted file mode 100644
index 3e52d4f10..000000000
--- a/controlloop/common/model-impl/rest/src/main/java/org/onap/policy/rest/HttpDeleteWithBody.java
+++ /dev/null
@@ -1,52 +0,0 @@
-/*
- * ============LICENSE_START=======================================================
- * rest
- * ================================================================================
- * Copyright (C) 2018 Amdocs. All rights reserved.
- * Modifications Copyright (C) 2018 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.rest;
-
-import java.net.URI;
-import org.apache.http.client.methods.HttpEntityEnclosingRequestBase;
-
-/**
- * Allows for HTTP DELETE requests to contain a body, which the HttpDelete
- * class does not support.
- */
-public class HttpDeleteWithBody extends HttpEntityEnclosingRequestBase {
- public static final String METHOD_NAME = "DELETE";
-
- public HttpDeleteWithBody(final String uri) {
- super();
- setURI(URI.create(uri));
- }
-
- public HttpDeleteWithBody(final URI uri) {
- super();
- setURI(uri);
- }
-
- public HttpDeleteWithBody() {
- super();
- }
-
- public String getMethod() {
- return METHOD_NAME;
- }
-
-}
diff --git a/controlloop/common/model-impl/rest/src/main/java/org/onap/policy/rest/RestManager.java b/controlloop/common/model-impl/rest/src/main/java/org/onap/policy/rest/RestManager.java
deleted file mode 100644
index 84a220b9a..000000000
--- a/controlloop/common/model-impl/rest/src/main/java/org/onap/policy/rest/RestManager.java
+++ /dev/null
@@ -1,192 +0,0 @@
-/*
- * ============LICENSE_START=======================================================
- * rest
- * ================================================================================
- * 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.
- * 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.rest;
-
-import java.nio.charset.Charset;
-import java.util.Map;
-import java.util.Map.Entry;
-import javax.xml.bind.DatatypeConverter;
-
-import org.apache.http.HttpHeaders;
-import org.apache.http.HttpResponse;
-import org.apache.http.client.methods.HttpGet;
-import org.apache.http.client.methods.HttpPost;
-import org.apache.http.client.methods.HttpRequestBase;
-import org.apache.http.conn.ssl.NoopHostnameVerifier;
-import org.apache.http.entity.StringEntity;
-import org.apache.http.impl.client.CloseableHttpClient;
-import org.apache.http.impl.client.HttpClientBuilder;
-import org.apache.http.util.EntityUtils;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class RestManager {
-
- private static final Logger logger = LoggerFactory.getLogger(RestManager.class);
-
- public class Pair<A, B> {
- public final A first;
- public final B second;
-
- public Pair(A first, B second) {
- this.first = first;
- this.second = second;
- }
- }
-
- /**
- * Perform REST Post.
- *
- * @param url the url
- * @param username the user name
- * @param password the password
- * @param headers any headers
- * @param contentType what the content type is
- * @param body body to send
- * @return the response status code and the body
- */
- public Pair<Integer, String> post(String url, String username, String password,
- Map<String, String> headers, String contentType, String body) {
- HttpPost post = new HttpPost(url);
- addHeaders(post, username, password, headers);
- post.addHeader("Content-Type", contentType);
- try {
- StringEntity input = new StringEntity(body);
- input.setContentType(contentType);
- post.setEntity(input);
- } catch (Exception e) {
- logger.error("post threw: ", e);
- return null;
- }
- return sendRequest(post);
- }
-
- /**
- * Do a REST get.
- *
- * @param url URL
- * @param username user name
- * @param password password
- * @param headers any headers to add
- * @return a Pair for the response status and the body
- */
- public Pair<Integer, String> get(String url, String username, String password,
- Map<String, String> headers) {
- HttpGet get = new HttpGet(url);
- addHeaders(get, username, password, headers);
- return sendRequest(get);
- }
-
- /**
- * Perform REST Delete.
- *
- * @param url the url
- * @param username the user name
- * @param password the password
- * @param headers any headers
- * @param contentType what the content type is
- * @param body body (optional) to send
- * @return the response status code and the body
- */
- public Pair<Integer, String> delete(String url, String username, String password, Map<String, String> headers,
- String contentType, String body) {
- HttpDeleteWithBody delete = new HttpDeleteWithBody(url);
- addHeaders(delete, username, password, headers);
- delete.addHeader("Content-Type", contentType);
- if (body != null && !body.isEmpty()) {
- try {
- StringEntity input = new StringEntity(body);
- input.setContentType(contentType);
- delete.setEntity(input);
- } catch (Exception e) {
- logger.error("delete threw: ", e);
- return null;
- }
- }
- return sendRequest(delete);
- }
-
- /**
- * Send REST request.
- *
- * @param request http request to send
- * @return the response status code and the body
- */
- private Pair<Integer, String> sendRequest(HttpRequestBase request) {
- if (logger.isDebugEnabled()) {
- logger.debug("***** sendRequest to url {}:", request.getURI());
- }
-
- try (CloseableHttpClient client =
- HttpClientBuilder
- .create()
- .setSSLHostnameVerifier(NoopHostnameVerifier.INSTANCE)
- .build()) {
- HttpResponse response = client.execute(request);
- if (response != null) {
- String returnBody = EntityUtils.toString(response.getEntity(), "UTF-8");
- logger.debug("HTTP Response Status Code: {}",
- response.getStatusLine().getStatusCode());
- logger.debug("HTTP Response Body:");
- logger.debug(returnBody);
-
- return new Pair<>(response.getStatusLine().getStatusCode(),
- returnBody);
- } else {
- logger.error("Response from {} is null", request.getURI());
- return null;
- }
- } catch (Exception e) {
- logger.error("Request failed to {}", request.getURI(), e);
- return null;
- }
- }
-
- /**
- * Add header to the request.
- *
- * @param request http request to send
- * @param username the user name
- * @param password the password
- * @param headers any headers
- */
- private void addHeaders(HttpRequestBase request, String username, String password, Map<String,
- String> headers) {
- String authHeader = makeAuthHeader(username, password);
- if (headers != null) {
- for (Entry<String, String> entry : headers.entrySet()) {
- request.addHeader(entry.getKey(), headers.get(entry.getKey()));
- }
- }
- if (authHeader != null) {
- request.setHeader(HttpHeaders.AUTHORIZATION, authHeader);
- }
- }
-
- private String makeAuthHeader(String username, String password) {
- if (username == null || username.isEmpty()) {
- return null;
- }
-
- String auth = username + ":" + (password == null ? "" : password);
- return "Basic " + DatatypeConverter.printBase64Binary(auth.getBytes(Charset.forName("ISO-8859-1")));
- }
-}