error when trying to archive\restore

fix bug: getting server error when trying to archive\restore VLM\VSP

Change-Id: I7abefd2d8ac368d590329071a56f200c203cf966
Issue-ID: SDC-1667
Signed-off-by: avigaffa <avi.gaffa@amdocs.com>

3 files changed, 285 insertions, 0 deletions

diff --git a/openecomp-be/api/openecomp-sdc-rest-webapp/item-rest/item-rest-services/src/main/java/org/openecomp/sdcrests/item/rest/services/catalog/notification/http/HttpConfiguration.java b/openecomp-be/api/openecomp-sdc-rest-webapp/item-rest/item-rest-services/src/main/java/org/openecomp/sdcrests/item/rest/services/catalog/notification/http/HttpConfiguration.java
new file mode 100644
index 0000000000..4403bd840b
--- /dev/null
+++ b/openecomp-be/api/openecomp-sdc-rest-webapp/item-rest/item-rest-services/src/main/java/org/openecomp/sdcrests/item/rest/services/catalog/notification/http/HttpConfiguration.java
@@ -0,0 +1,43 @@
+/*
+ * Copyright © 2016-2018 European Support Limited
+ *
+ * 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.openecomp.sdcrests.item.rest.services.catalog.notification.http;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+import lombok.ToString;
+
+/**
+ * Represents configuration for sending notifications to the Catalog side.
+ *
+ * @author evitaliy
+ * @since 21 Nov 2018
+ */
+@Setter
+@Getter
+@NoArgsConstructor
+@AllArgsConstructor
+@ToString
+public class HttpConfiguration {
+
+    private String catalogBeProtocol;
+    private String catalogBeHttpPort;
+    private String catalogBeSslPort;
+    private String catalogBeFqdn;
+    private String catalogNotificationUrl;
+}
diff --git a/openecomp-be/api/openecomp-sdc-rest-webapp/item-rest/item-rest-services/src/main/java/org/openecomp/sdcrests/item/rest/services/catalog/notification/http/HttpNotificationTask.java b/openecomp-be/api/openecomp-sdc-rest-webapp/item-rest/item-rest-services/src/main/java/org/openecomp/sdcrests/item/rest/services/catalog/notification/http/HttpNotificationTask.java
new file mode 100644
index 0000000000..c88ac4ecce
--- /dev/null
+++ b/openecomp-be/api/openecomp-sdc-rest-webapp/item-rest/item-rest-services/src/main/java/org/openecomp/sdcrests/item/rest/services/catalog/notification/http/HttpNotificationTask.java
@@ -0,0 +1,135 @@
+/*
+ * Copyright © 2016-2018 European Support Limited
+ *
+ * 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.openecomp.sdcrests.item.rest.services.catalog.notification.http;
+
+import static org.openecomp.sdcrests.item.rest.services.catalog.notification.AsyncNotifier.NextAction.DONE;
+import static org.openecomp.sdcrests.item.rest.services.catalog.notification.AsyncNotifier.NextAction.RETRY;
+
+import java.io.UnsupportedEncodingException;
+import java.util.Collection;
+import java.util.concurrent.Callable;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+import lombok.ToString;
+import org.apache.http.HttpEntity;
+import org.apache.http.HttpHeaders;
+import org.apache.http.HttpStatus;
+import org.apache.http.StatusLine;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.entity.ContentType;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.openecomp.core.utilities.json.JsonUtil;
+import org.openecomp.sdc.logging.api.Logger;
+import org.openecomp.sdc.logging.api.LoggerFactory;
+import org.openecomp.sdcrests.item.rest.services.catalog.notification.AsyncNotifier;
+
+/**
+ * HTTP client for notifying the Catalog of an action on items. The items are referenced by their IDs. The client can
+ * run multiple times, in which case only failed IDs will be re-attempted.
+ *
+ * @author evitaliy
+ * @since 21 Nov 2018
+ */
+@ToString
+class HttpNotificationTask implements Callable<AsyncNotifier.NextAction> {
+
+    private static final Logger LOGGER = LoggerFactory.getLogger(HttpNotificationTask.class);
+
+    private static final String APPLICATION_JSON = ContentType.APPLICATION_JSON.getMimeType();
+    private static final String USER_ID_HEADER_PARAM = "USER_ID";
+
+    private final String endpoint;
+    private final String userId;
+    private volatile Collection<String> itemIds;
+
+    HttpNotificationTask(String endpoint, String userId, Collection<String> itemIds) {
+        this.endpoint = endpoint;
+        this.userId = userId;
+        this.itemIds = itemIds;
+    }
+
+    @Override
+    public synchronized AsyncNotifier.NextAction call() {
+
+        try (CloseableHttpClient client = HttpClients.createDefault()) {
+
+            HttpPost request = createPostRequest(endpoint, itemIds, userId);
+
+            try (CloseableHttpResponse response = client.execute(request)) {
+
+                StatusLine status = response.getStatusLine();
+
+                LOGGER.debug("Catalog notification on VSP IDs: {}, endpoint: {}, response: {}",
+                        itemIds, endpoint, status);
+
+                itemIds = getFailedIds(itemIds, response.getEntity());
+
+                if ((status.getStatusCode() == HttpStatus.SC_INTERNAL_SERVER_ERROR)
+                            && (itemIds != null) && !itemIds.isEmpty()) {
+
+                    LOGGER.debug("Catalog notification on VSP IDs {} failed. Endpoint: {}. Retry", itemIds, endpoint);
+                    return RETRY;
+                }
+
+                return DONE;
+            }
+
+        } catch (Exception e) {
+            LOGGER.error("Catalog notification on VSP IDs {} failed. Endpoint: {}", itemIds, endpoint, e);
+            return DONE;
+        }
+    }
+
+    private HttpPost createPostRequest(String postUrl, Collection<String> itemIds, String userId)
+            throws UnsupportedEncodingException {
+
+        HttpPost request = new HttpPost(postUrl);
+
+        request.addHeader(HttpHeaders.ACCEPT, APPLICATION_JSON);
+        request.addHeader(HttpHeaders.CONTENT_TYPE, APPLICATION_JSON);
+        request.addHeader(USER_ID_HEADER_PARAM, userId);
+
+        HttpEntity entity = new StringEntity(JsonUtil.object2Json(itemIds));
+        request.setEntity(entity);
+        return request;
+    }
+
+    private Collection<String> getFailedIds(Collection<String> itemIds, HttpEntity responseBody) {
+
+        try {
+            NotificationResponse response = JsonUtil.json2Object(responseBody.getContent(), NotificationResponse.class);
+            return response != null ? response.failedIds : null;
+        } catch (Exception e) {
+            LOGGER.error("Error getting failed IDs from response", e);
+        }
+
+        return itemIds;
+    }
+
+    @Setter
+    @Getter
+    @ToString
+    @NoArgsConstructor
+    private static class NotificationResponse {
+
+        private Collection<String> failedIds;
+    }
+}
diff --git a/openecomp-be/api/openecomp-sdc-rest-webapp/item-rest/item-rest-services/src/main/java/org/openecomp/sdcrests/item/rest/services/catalog/notification/http/HttpTaskProducer.java b/openecomp-be/api/openecomp-sdc-rest-webapp/item-rest/item-rest-services/src/main/java/org/openecomp/sdcrests/item/rest/services/catalog/notification/http/HttpTaskProducer.java
new file mode 100644
index 0000000000..c6abd346ff
--- /dev/null
+++ b/openecomp-be/api/openecomp-sdc-rest-webapp/item-rest/item-rest-services/src/main/java/org/openecomp/sdcrests/item/rest/services/catalog/notification/http/HttpTaskProducer.java
@@ -0,0 +1,107 @@
+/*
+ * Copyright © 2016-2018 European Support Limited
+ *
+ * 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.openecomp.sdcrests.item.rest.services.catalog.notification.http;
+
+import java.util.Collection;
+import java.util.concurrent.Callable;
+import java.util.function.BiFunction;
+import org.openecomp.sdc.common.session.SessionContextProviderFactory;
+import org.openecomp.sdc.logging.api.Logger;
+import org.openecomp.sdc.logging.api.LoggerFactory;
+import org.openecomp.sdcrests.item.rest.services.catalog.notification.AsyncNotifier;
+import org.openecomp.sdcrests.item.rest.services.catalog.notification.EntryNotConfiguredException;
+import org.openecomp.sdcrests.item.rest.services.catalog.notification.Notifier;
+import org.openecomp.sdcrests.item.types.ItemAction;
+
+/**
+ * Notifies the Catalog via an HTTP.
+ *
+ * @author evitaliy
+ * @since 21 Nov 2018
+ */
+public class HttpTaskProducer
+        implements BiFunction<Collection<String>, ItemAction, Callable<AsyncNotifier.NextAction>>, Notifier {
+
+    private static final Logger LOGGER = LoggerFactory.getLogger(HttpTaskProducer.class);
+
+    private static final String CATALOG_HTTP_PROTOCOL = "HTTP";
+    private static final String CATALOG_HTTPS_PROTOCOL = "HTTPS";
+
+    private final String notifyCatalogUrl;
+
+    /**
+     * Initializes the producer from a provided configuration.
+     *
+     * @param config HTTP-specific configuration, cannot be null
+     */
+    public HttpTaskProducer(HttpConfiguration config) {
+        String protocol = ensureEntryConfigured(config.getCatalogBeProtocol(), "Protocol");
+        String host = ensureEntryConfigured(config.getCatalogBeFqdn(), "Catalog host");
+        String url = ensureEntryConfigured(config.getCatalogNotificationUrl(), "Notification URL");
+        String port = getPortConfiguration(protocol, config);
+        this.notifyCatalogUrl = String.format(url, protocol, host, port);
+    }
+
+    private static String ensureEntryConfigured(String value, String entryName) {
+
+        if (value == null) {
+            throw new EntryNotConfiguredException(entryName);
+        }
+
+        return value;
+    }
+
+    private static String getPortConfiguration(String protocol, HttpConfiguration config) {
+
+        if (CATALOG_HTTP_PROTOCOL.equalsIgnoreCase(protocol)) {
+            return ensureEntryConfigured(config.getCatalogBeHttpPort(), "HTTP port");
+        } else if (CATALOG_HTTPS_PROTOCOL.equalsIgnoreCase(protocol)) {
+            return ensureEntryConfigured(config.getCatalogBeSslPort(), "SSL port");
+        } else {
+            throw new IllegalArgumentException("Unsupported protocol: " + protocol);
+        }
+    }
+
+    @Override
+    public Callable<AsyncNotifier.NextAction> apply(Collection<String> itemIds, ItemAction action) {
+        return createNotificationTask(itemIds, action);
+    }
+
+    private static String getEndpoint(ItemAction action) {
+
+        if (action == ItemAction.ARCHIVE) {
+            return "archived";
+        } else if (action == ItemAction.RESTORE) {
+            return "restored";
+        } else {
+            throw new IllegalArgumentException("Unsupported action: " + action.name());
+        }
+    }
+
+    @Override
+    public void execute(Collection<String> itemIds, ItemAction action) {
+        HttpNotificationTask task = createNotificationTask(itemIds, action);
+        task.call();
+    }
+
+    private HttpNotificationTask createNotificationTask(Collection<String> itemIds, ItemAction action) {
+        String userId = SessionContextProviderFactory.getInstance().createInterface().get().getUser().getUserId();
+        String notificationEndpoint = notifyCatalogUrl + getEndpoint(action);
+        LOGGER.debug("Catalog notification URL: " + notificationEndpoint);
+        return new HttpNotificationTask(notificationEndpoint, userId, itemIds);
+    }
+}