diff options
Diffstat (limited to 'common/src/main/java/org/openecomp/mso/client/ruby')
5 files changed, 0 insertions, 488 deletions
diff --git a/common/src/main/java/org/openecomp/mso/client/ruby/RubyClient.java b/common/src/main/java/org/openecomp/mso/client/ruby/RubyClient.java deleted file mode 100644 index a4adcb23f7..0000000000 --- a/common/src/main/java/org/openecomp/mso/client/ruby/RubyClient.java +++ /dev/null @@ -1,90 +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.openecomp.mso.client.ruby; - -import java.io.IOException; -import java.time.ZoneOffset; -import java.time.ZonedDateTime; -import java.time.format.DateTimeFormatter; - -import org.openecomp.mso.client.dmaap.DmaapPublisher; -import org.openecomp.mso.client.ruby.beans.Event; -import org.openecomp.mso.client.ruby.beans.MsoRequest; -import org.openecomp.mso.client.ruby.beans.Ruby; -import org.openecomp.mso.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); - } -}
\ No newline at end of file diff --git a/common/src/main/java/org/openecomp/mso/client/ruby/beans/Event.java b/common/src/main/java/org/openecomp/mso/client/ruby/beans/Event.java deleted file mode 100644 index b9263596be..0000000000 --- a/common/src/main/java/org/openecomp/mso/client/ruby/beans/Event.java +++ /dev/null @@ -1,67 +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.openecomp.mso.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; - } - -}
\ No newline at end of file diff --git a/common/src/main/java/org/openecomp/mso/client/ruby/beans/MsoRequest.java b/common/src/main/java/org/openecomp/mso/client/ruby/beans/MsoRequest.java deleted file mode 100644 index d00adae88a..0000000000 --- a/common/src/main/java/org/openecomp/mso/client/ruby/beans/MsoRequest.java +++ /dev/null @@ -1,207 +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.openecomp.mso.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; - } - -}
\ No newline at end of file diff --git a/common/src/main/java/org/openecomp/mso/client/ruby/beans/Ruby.java b/common/src/main/java/org/openecomp/mso/client/ruby/beans/Ruby.java deleted file mode 100644 index 1b81043faf..0000000000 --- a/common/src/main/java/org/openecomp/mso/client/ruby/beans/Ruby.java +++ /dev/null @@ -1,68 +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.openecomp.mso.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/openecomp/mso/client/ruby/dmaap/RubyCreateTicketRequestPublisher.java b/common/src/main/java/org/openecomp/mso/client/ruby/dmaap/RubyCreateTicketRequestPublisher.java deleted file mode 100644 index 521318f822..0000000000 --- a/common/src/main/java/org/openecomp/mso/client/ruby/dmaap/RubyCreateTicketRequestPublisher.java +++ /dev/null @@ -1,56 +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.openecomp.mso.client.ruby.dmaap; - -import java.io.FileNotFoundException; -import java.io.IOException; -import java.util.Optional; - -import org.openecomp.mso.client.dmaap.DmaapPublisher; - -public class RubyCreateTicketRequestPublisher extends DmaapPublisher{ - public RubyCreateTicketRequestPublisher() throws FileNotFoundException, IOException { - super(); - } - - @Override - public String getUserName() { - return msoProperties.get("ruby.create-ticket-request.dmaap.username"); - } - - @Override - public String getPassword() { - return msoProperties.get("ruby.create-ticket-request.dmaap.password"); - } - - @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")); - } - -} - - |