add manual handling to rainy day handling for bbs

Initial Manual Handling addition to Rainy Day BB handling.
Reenable task API, add task variable setup.
TaskTimeout will come from the configuration settings.
Update the base path for the APIH manual tasks junit.
Additional JUNIT tests for manual handling
Add Manual as a primary policy for Change Management BBs.
Error handling changes and robot tests for manual handling.
Correct failure data retrieval when serviceSubscription is unavailable.
Correct failure data retrieval when serviceSubscription is unavailable.
Keep WorkflowException when manual pause gets invoked; improved error
reporting.

Issue-ID: SO-2616
Signed-off-by: Benjamin, Max (mb388a) <mb388a@att.com>
Change-Id: I98a84c1a489bb7b24b68e567f604aeb074fd7bf9

5 files changed, 0 insertions, 469 deletions

diff --git a/common/src/main/java/org/onap/so/client/ruby/RubyClient.java b/common/src/main/java/org/onap/so/client/ruby/RubyClient.java
deleted file mode 100644
index 6c8f48884d..0000000000
--- a/common/src/main/java/org/onap/so/client/ruby/RubyClient.java
+++ /dev/null
@@ -1,87 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * ONAP - SO
- * ================================================================================
- * Copyright (C) 2017 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.so.client.ruby;
-
-import java.io.IOException;
-import java.time.ZoneOffset;
-import java.time.ZonedDateTime;
-import java.time.format.DateTimeFormatter;
-import org.onap.so.client.dmaap.DmaapPublisher;
-import org.onap.so.client.ruby.beans.Event;
-import org.onap.so.client.ruby.beans.MsoRequest;
-import org.onap.so.client.ruby.beans.Ruby;
-import org.onap.so.client.ruby.dmaap.RubyCreateTicketRequestPublisher;
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.databind.ObjectMapper;
-
-
-public class RubyClient {
-
-    private static final String REQUEST_CLIENT_NAME = "MSO";
-    private static final String ACTION = "Create Ticket";
-
-    protected String buildRequest(String requestId, String sourceName, String reason, String workflowId,
-            String notification) throws JsonProcessingException {
-        final MsoRequest request = new MsoRequest();
-        request.withRequestClientName(REQUEST_CLIENT_NAME).withRequestId(requestId).withSourceName(sourceName)
-                .withWorkflowId(workflowId).withAction(ACTION);
-
-        request.withRequestTime(this.getTime());
-
-        if (reason.length() <= 255) {
-            request.withReason(reason);
-        } else {
-            throw new IllegalArgumentException("reason exceeds 255 characters");
-        }
-        if (notification.length() <= 1024) {
-            request.withNotification(notification);
-        } else {
-            throw new IllegalArgumentException("notification exceeds 1024 characters");
-        }
-        final Event event = new Event();
-        event.setMsoRequest(request);
-        final Ruby ruby = new Ruby();
-        ruby.setEvent(event);
-        return this.getJson(ruby);
-    }
-
-    protected String getJson(Ruby obj) throws JsonProcessingException {
-        final ObjectMapper mapper = new ObjectMapper();
-        return mapper.writeValueAsString(obj);
-    }
-
-    protected DmaapPublisher getPublisher() throws IOException {
-        return new RubyCreateTicketRequestPublisher();
-    }
-
-    protected String getTime() {
-        final ZonedDateTime currentDateTime = ZonedDateTime.now(ZoneOffset.UTC);
-        final DateTimeFormatter format = DateTimeFormatter.ofPattern("EEE, dd MMM yyyy HH:mm:ss Z");
-        return currentDateTime.format(format);
-    }
-
-    public void rubyCreateTicketCheckRequest(String requestId, String sourceName, String reason, String workflowId,
-            String notification) throws Exception {
-        String request = this.buildRequest(requestId, sourceName, reason, workflowId, notification);
-        final DmaapPublisher publisher = this.getPublisher();
-        publisher.send(request);
-    }
-}
diff --git a/common/src/main/java/org/onap/so/client/ruby/beans/Event.java b/common/src/main/java/org/onap/so/client/ruby/beans/Event.java
deleted file mode 100644
index 2737342adc..0000000000
--- a/common/src/main/java/org/onap/so/client/ruby/beans/Event.java
+++ /dev/null
@@ -1,64 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * ONAP - SO
- * ================================================================================
- * Copyright (C) 2017 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.so.client.ruby.beans;
-
-import com.fasterxml.jackson.annotation.JsonInclude;
-import com.fasterxml.jackson.annotation.JsonProperty;
-import com.fasterxml.jackson.annotation.JsonPropertyOrder;
-
-@JsonInclude(JsonInclude.Include.NON_NULL)
-@JsonPropertyOrder({"msoRequest"})
-public class Event {
-
-    @JsonProperty("msoRequest")
-    private MsoRequest msoRequest;
-
-    /**
-     * No args constructor for use in serialization
-     * 
-     */
-    public Event() {}
-
-    /**
-     * 
-     * @param msoRequest
-     */
-    public Event(MsoRequest msoRequest) {
-        super();
-        this.msoRequest = msoRequest;
-    }
-
-    @JsonProperty("msoRequest")
-    public MsoRequest getMsoRequest() {
-        return msoRequest;
-    }
-
-    @JsonProperty("msoRequest")
-    public void setMsoRequest(MsoRequest msoRequest) {
-        this.msoRequest = msoRequest;
-    }
-
-    public Event withMsoRequest(MsoRequest msoRequest) {
-        this.msoRequest = msoRequest;
-        return this;
-    }
-
-}
diff --git a/common/src/main/java/org/onap/so/client/ruby/beans/MsoRequest.java b/common/src/main/java/org/onap/so/client/ruby/beans/MsoRequest.java
deleted file mode 100644
index 15cfc9222f..0000000000
--- a/common/src/main/java/org/onap/so/client/ruby/beans/MsoRequest.java
+++ /dev/null
@@ -1,199 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * ONAP - SO
- * ================================================================================
- * Copyright (C) 2017 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.so.client.ruby.beans;
-
-import com.fasterxml.jackson.annotation.JsonInclude;
-import com.fasterxml.jackson.annotation.JsonProperty;
-import com.fasterxml.jackson.annotation.JsonPropertyOrder;
-
-@JsonInclude(JsonInclude.Include.NON_NULL)
-@JsonPropertyOrder({"requestClientName", "requestId", "requestTime", "sourceName", "reason", "action", "workflowId",
-        "notification"})
-public class MsoRequest {
-
-    @JsonProperty("requestClientName")
-    private String requestClientName;
-    @JsonProperty("requestId")
-    private String requestId;
-    @JsonProperty("requestTime")
-    private String requestTime;
-    @JsonProperty("sourceName")
-    private String sourceName;
-    @JsonProperty("reason")
-    private String reason;
-    @JsonProperty("action")
-    private String action;
-    @JsonProperty("workflowId")
-    private String workflowId;
-    @JsonProperty("notification")
-    private String notification;
-
-    /**
-     * No args constructor for use in serialization
-     * 
-     */
-    public MsoRequest() {}
-
-    /**
-     * 
-     * @param requestClientName
-     * @param requestTime
-     * @param reason
-     * @param requestId
-     * @param workflowId
-     * @param sourceName
-     * @param action
-     * @param notification
-     */
-    public MsoRequest(String requestClientName, String requestId, String requestTime, String sourceName, String reason,
-            String action, String workflowId, String notification) {
-        super();
-        this.requestClientName = requestClientName;
-        this.requestId = requestId;
-        this.requestTime = requestTime;
-        this.sourceName = sourceName;
-        this.reason = reason;
-        this.action = action;
-        this.workflowId = workflowId;
-        this.notification = notification;
-    }
-
-    @JsonProperty("requestClientName")
-    public String getRequestClientName() {
-        return requestClientName;
-    }
-
-    @JsonProperty("requestClientName")
-    public void setRequestClientName(String requestClientName) {
-        this.requestClientName = requestClientName;
-    }
-
-    public MsoRequest withRequestClientName(String requestClientName) {
-        this.requestClientName = requestClientName;
-        return this;
-    }
-
-    @JsonProperty("requestId")
-    public String getRequestId() {
-        return requestId;
-    }
-
-    @JsonProperty("requestId")
-    public void setRequestId(String requestId) {
-        this.requestId = requestId;
-    }
-
-    public MsoRequest withRequestId(String requestId) {
-        this.requestId = requestId;
-        return this;
-    }
-
-    @JsonProperty("requestTime")
-    public String getRequestTime() {
-        return requestTime;
-    }
-
-    @JsonProperty("requestTime")
-    public void setRequestTime(String requestTime) {
-        this.requestTime = requestTime;
-    }
-
-    public MsoRequest withRequestTime(String requestTime) {
-        this.requestTime = requestTime;
-        return this;
-    }
-
-    @JsonProperty("sourceName")
-    public String getSourceName() {
-        return sourceName;
-    }
-
-    @JsonProperty("sourceName")
-    public void setSourceName(String sourceName) {
-        this.sourceName = sourceName;
-    }
-
-    public MsoRequest withSourceName(String sourceName) {
-        this.sourceName = sourceName;
-        return this;
-    }
-
-    @JsonProperty("reason")
-    public String getReason() {
-        return reason;
-    }
-
-    @JsonProperty("reason")
-    public void setReason(String reason) {
-        this.reason = reason;
-    }
-
-    public MsoRequest withReason(String reason) {
-        this.reason = reason;
-        return this;
-    }
-
-    @JsonProperty("action")
-    public String getAction() {
-        return action;
-    }
-
-    @JsonProperty("action")
-    public void setAction(String action) {
-        this.action = action;
-    }
-
-    public MsoRequest withAction(String action) {
-        this.action = action;
-        return this;
-    }
-
-    @JsonProperty("workflowId")
-    public String getWorkflowId() {
-        return workflowId;
-    }
-
-    @JsonProperty("workflowId")
-    public void setWorkflowId(String workflowId) {
-        this.workflowId = workflowId;
-    }
-
-    public MsoRequest withWorkflowId(String workflowId) {
-        this.workflowId = workflowId;
-        return this;
-    }
-
-    @JsonProperty("notification")
-    public String getNotification() {
-        return notification;
-    }
-
-    @JsonProperty("notification")
-    public void setNotification(String notification) {
-        this.notification = notification;
-    }
-
-    public MsoRequest withNotification(String notification) {
-        this.notification = notification;
-        return this;
-    }
-
-}
diff --git a/common/src/main/java/org/onap/so/client/ruby/beans/Ruby.java b/common/src/main/java/org/onap/so/client/ruby/beans/Ruby.java
deleted file mode 100644
index 708b91638b..0000000000
--- a/common/src/main/java/org/onap/so/client/ruby/beans/Ruby.java
+++ /dev/null
@@ -1,64 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * ONAP - SO
- * ================================================================================
- * Copyright (C) 2017 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.so.client.ruby.beans;
-
-import com.fasterxml.jackson.annotation.JsonInclude;
-import com.fasterxml.jackson.annotation.JsonProperty;
-import com.fasterxml.jackson.annotation.JsonPropertyOrder;
-
-@JsonInclude(JsonInclude.Include.NON_NULL)
-@JsonPropertyOrder({"event"})
-public class Ruby {
-
-    @JsonProperty("event")
-    private Event event;
-
-    /**
-     * No args constructor for use in serialization
-     * 
-     */
-    public Ruby() {}
-
-    /**
-     * 
-     * @param event
-     */
-    public Ruby(Event event) {
-        super();
-        this.event = event;
-    }
-
-    @JsonProperty("event")
-    public Event getEvent() {
-        return event;
-    }
-
-    @JsonProperty("event")
-    public void setEvent(Event event) {
-        this.event = event;
-    }
-
-    public Ruby withEvent(Event event) {
-        this.event = event;
-        return this;
-    }
-
-}
diff --git a/common/src/main/java/org/onap/so/client/ruby/dmaap/RubyCreateTicketRequestPublisher.java b/common/src/main/java/org/onap/so/client/ruby/dmaap/RubyCreateTicketRequestPublisher.java
deleted file mode 100644
index 10402d9921..0000000000
--- a/common/src/main/java/org/onap/so/client/ruby/dmaap/RubyCreateTicketRequestPublisher.java
+++ /dev/null
@@ -1,55 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * ONAP - SO
- * ================================================================================
- * Copyright (C) 2017 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.so.client.ruby.dmaap;
-
-import java.io.FileNotFoundException;
-import java.io.IOException;
-import java.util.Optional;
-import org.onap.so.client.dmaap.DmaapPublisher;
-
-public class RubyCreateTicketRequestPublisher extends DmaapPublisher {
-    public RubyCreateTicketRequestPublisher() throws FileNotFoundException, IOException {
-        super();
-    }
-
-    @Override
-    public String getAuth() {
-        return msoProperties.get("ruby.create-ticket-request.dmaap.auth");
-    }
-
-    @Override
-    public String getKey() {
-        return msoProperties.get("mso.msoKey");
-    }
-
-    @Override
-    public String getTopic() {
-        return msoProperties.get("ruby.create-ticket-request.publisher.topic");
-    }
-
-    @Override
-    public Optional<String> getHost() {
-        return Optional.ofNullable(msoProperties.get("ruby.create-ticket-request.publisher.host"));
-    }
-
-}
-
-