From 9b30373a6f1b1bc123250a9a598bc7a164b7e9b7 Mon Sep 17 00:00:00 2001
From: Vijay Venkatesh Kumar <vv770d@att.com>
Date: Wed, 8 Jan 2020 17:13:22 +0000
Subject: bp-gen code clone from cli repo

dcaegen2/platform/mod will host all design component code
cli/component-json-schemas and cli/dcae-cli already moved

original cli repo will be marked as RO after this is merged

Change-Id: Ie88dbd273d218c89a95afe0e58742a948c04eae5
Signed-off-by: Vijay Venkatesh Kumar <vv770d@att.com>
Issue-ID: DCAEGEN2-1852
Issue-ID: DCAEGEN2-1860
Signed-off-by: Vijay Venkatesh Kumar <vv770d@att.com>
---
 .../models/dmaapbp/DmaapStreams.java               | 103 +++++++++++++++++++++
 1 file changed, 103 insertions(+)
 create mode 100644 mod/bpgenerator/src/main/java/org/onap/blueprintgenerator/models/dmaapbp/DmaapStreams.java

(limited to 'mod/bpgenerator/src/main/java/org/onap/blueprintgenerator/models/dmaapbp/DmaapStreams.java')

diff --git a/mod/bpgenerator/src/main/java/org/onap/blueprintgenerator/models/dmaapbp/DmaapStreams.java b/mod/bpgenerator/src/main/java/org/onap/blueprintgenerator/models/dmaapbp/DmaapStreams.java
new file mode 100644
index 0000000..1640a6e
--- /dev/null
+++ b/mod/bpgenerator/src/main/java/org/onap/blueprintgenerator/models/dmaapbp/DmaapStreams.java
@@ -0,0 +1,103 @@
+/**============LICENSE_START=======================================================
+ org.onap.dcae
+ ================================================================================
+ Copyright (c) 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.blueprintgenerator.models.dmaapbp;
+
+import java.util.LinkedHashMap;
+import java.util.TreeMap;
+
+import org.onap.blueprintgenerator.models.blueprint.Appconfig;
+import org.onap.blueprintgenerator.models.blueprint.GetInput;
+import org.onap.blueprintgenerator.models.componentspec.ComponentSpec;
+import org.onap.blueprintgenerator.models.componentspec.HealthCheck;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonInclude.Include;
+
+import lombok.Getter;
+import lombok.Setter;
+
+@Getter @Setter
+@JsonInclude(value=Include.NON_NULL)
+public class DmaapStreams {
+
+	private String name;
+	private GetInput location;
+	private GetInput client_role;
+	private String type;
+
+	private GetInput username;
+	private GetInput password;
+	//private GetInput delivery_url;
+	private String route;
+	private String scheme;
+
+	public TreeMap<String, LinkedHashMap<String, Object>> createStreams(TreeMap<String, LinkedHashMap<String, Object>> inps, ComponentSpec cs, String name, String type, String key, String route, char o){
+		TreeMap<String, LinkedHashMap<String, Object>> retInputs = inps;
+		LinkedHashMap<String, Object> stringType = new LinkedHashMap();
+		stringType.put("type", "string");
+
+		//set the name
+		this.setName(name);
+
+		//set the type
+		this.setType(type);
+
+		//set the location
+		GetInput location = new GetInput();
+		location.setGet_input(key + "_" + name + "_location");
+		retInputs.put(key + "_" + name + "_location", stringType);
+		this.setLocation(location);
+
+		//if its data router we need to add some more
+		if(type.equals("data_router") || type.equals("data router")) {
+			if(o == 's') {
+				//set the username
+				GetInput username = new GetInput();
+				username.setGet_input(key + "_" + name + "_username");
+				this.setUsername(username);
+				retInputs.put(key + "_" + name + "_username", stringType);
+
+				//set the password
+				GetInput password = new GetInput();
+				password.setGet_input(key + "_" + name + "_password");
+				this.setPassword(password);
+				retInputs.put(key + "_" + name + "_password", stringType);
+
+				this.setRoute(route);
+				this.setScheme("https");
+			}
+
+//			//set the delivery url
+//			GetInput delivery = new GetInput();
+//			delivery.setGet_input(name + "_delivery_url");
+//			this.setDelivery_url(delivery);
+//			retInputs.put(name + "delivery_url", stringType);
+
+		} else {
+			//set the client role
+			GetInput client = new GetInput();
+			client.setGet_input(key + "_" + name + "_client_role");
+			this.setClient_role(client);
+			retInputs.put(key + "_" + name + "_client_role", stringType);
+		}
+		return retInputs;
+	}
+}
\ No newline at end of file
-- 
cgit 1.2.3-korg