diff options
author | Ravi Mantena <rx908f@att.com> | 2020-12-21 11:31:55 -0500 |
---|---|---|
committer | Ravi Mantena <rx908f@att.com> | 2020-12-21 11:32:34 -0500 |
commit | a520d00e005db1b232b9dae0c70d4dc5d73b33e1 (patch) | |
tree | 9c0e16ce5fab9bc12da138c4d8c613bcff54516b /mod/bpgenerator/onap/src/main | |
parent | 2f551ba584dbb70568a69144b39e6da7c55c517f (diff) |
BpGen refactor Code Quality Issue-ID: DCAEGEN2-2502
Issue-ID: DCAEGEN2-2502
Change-Id: If6e08f0bb88c9039fb27898d50d2645f79175ba4
Signed-off-by: Ravi Mantena <rx908f@att.com>
Diffstat (limited to 'mod/bpgenerator/onap/src/main')
51 files changed, 1062 insertions, 787 deletions
diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/BlueprintGeneratorMainApplication.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/BlueprintGeneratorMainApplication.java index 3b9dd49..d680919 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/BlueprintGeneratorMainApplication.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/BlueprintGeneratorMainApplication.java @@ -23,7 +23,6 @@ package org.onap.blueprintgenerator; - import org.onap.blueprintgenerator.model.base.Blueprint; import org.onap.blueprintgenerator.model.common.Input; import org.onap.blueprintgenerator.model.componentspec.OnapComponentSpec; @@ -43,12 +42,10 @@ import static java.lang.System.exit; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * ONAP - Blueprint Generator Main Application to create Policy Models or Blueprints + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP - Blueprint Generator Main + * Application to create Policy Models or Blueprints */ - -@ComponentScan({"org.onap.blueprintgenerator","org.onap.policycreate"}) +@ComponentScan({"org.onap.blueprintgenerator", "org.onap.policycreate"}) @SpringBootApplication public class BlueprintGeneratorMainApplication implements CommandLineRunner { @@ -76,35 +73,53 @@ public class BlueprintGeneratorMainApplication implements CommandLineRunner { @Autowired private DmaapBlueprintService dmaapBlueprintService; + /** + * Main Application to run BPGen to generate Policies/Blueprint based on Input Arguments values + * + * @param args Input Arguments + */ public static void main(String[] args) { SpringApplication.run(BlueprintGeneratorMainApplication.class, args); } + /** + * Creates Policies/Blueprint based on Input Arguments values + * + * @param args Input Arguments + */ @Override public void run(String... args) { - if (args.length >=2 && args[0].equals("app") && args[1].equals("ONAP")) { + if (args.length >= 2 && args[0].equals("app") && args[1].equals("ONAP")) { onapCommonUtils.printInstructions(); - if(args.length >=4 && args[2].equals("-type") && args[3].equals("policycreate")){ + if (args.length >= 4 && args[2].equals("-type") && args[3].equals("policycreate")) { Input input = onapCommonUtils.parseInputs(args); - ComponentSpec componentSpec = componentSpecService.createComponentSpecFromFile(input.getComponentSpecPath()); - onapPolicyModelNodeService.createPolicyModels(componentSpec.getParameters(), input.getOutputPath()); - } - else { + ComponentSpec componentSpec = + componentSpecService.createComponentSpecFromFile(input.getComponentSpecPath()); + onapPolicyModelNodeService.createPolicyModels( + componentSpec.getParameters(), input.getOutputPath()); + } else { Input input = onapCommonUtils.parseInputs(args); - OnapComponentSpec onapComponentSpec = onapComponentSpecService.createComponentSpecFromFile(input.getComponentSpecPath()); + OnapComponentSpec onapComponentSpec = + onapComponentSpecService + .createComponentSpecFromFile(input.getComponentSpecPath()); if (input.getBpType().equals("o")) { - Blueprint blueprint = onapBlueprintService.createBlueprint(onapComponentSpec, input); + Blueprint blueprint = onapBlueprintService + .createBlueprint(onapComponentSpec, input); onapBlueprintService.blueprintToYaml(onapComponentSpec, blueprint, input); - System.out.println(onapBlueprintService.blueprintToString(onapComponentSpec, blueprint, input)); + System.out.println( + onapBlueprintService + .blueprintToString(onapComponentSpec, blueprint, input)); } else if (input.getBpType().equals("d")) { - Blueprint blueprint = dmaapBlueprintService.createBlueprint(onapComponentSpec, input); + Blueprint blueprint = dmaapBlueprintService + .createBlueprint(onapComponentSpec, input); dmaapBlueprintService.blueprintToYaml(onapComponentSpec, blueprint, input); - System.out.println(dmaapBlueprintService.blueprintToString(onapComponentSpec, blueprint, input)); + System.out.println( + dmaapBlueprintService + .blueprintToString(onapComponentSpec, blueprint, input)); } } } exit(0); } - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/ExternalCertificateParameters.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/ExternalCertificateParameters.java index d7c76a9..5655d70 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/ExternalCertificateParameters.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/ExternalCertificateParameters.java @@ -29,12 +29,9 @@ import lombok.Data; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * ONAP Common Model used by both ONAP and DMAAP: External Certificate Parameters + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP Common Model: A model class which + * represents External Certificate Parameters */ - - @Data public class ExternalCertificateParameters { @@ -43,5 +40,4 @@ public class ExternalCertificateParameters { @JsonProperty(Constants.SANS_FIELD) private GetInput sans; - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/ExternalTlsInfo.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/ExternalTlsInfo.java index 197104d..0b1b414 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/ExternalTlsInfo.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/ExternalTlsInfo.java @@ -31,12 +31,9 @@ import lombok.Data; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * ONAP Common Model used by both ONAP and DMAAP: External TLS Info + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP Common Model: A model class which + * represents External TLS Info */ - - @Data @JsonInclude(value = JsonInclude.Include.NON_NULL) @JsonIgnoreProperties(ignoreUnknown = true) @@ -56,5 +53,4 @@ public class ExternalTlsInfo { @JsonProperty(Constants.EXTERNAL_CERTIFICATE_PARAMETERS_FIELD) private ExternalCertificateParameters externalCertificateParameters; - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/GetAttribute.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/GetAttribute.java index 2d5bca7..3e08cc2 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/GetAttribute.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/GetAttribute.java @@ -1,4 +1,3 @@ - /* * * * ============LICENSE_START======================================================= @@ -29,16 +28,12 @@ import lombok.Data; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * ONAP Common Model used by both ONAP and DMAAP: Get Attribute + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP Common Model: A model class which + * represents Get Attribute */ - - @Data public class GetAttribute { @JsonProperty("get_attribute") private Object attribute; - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/Info.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/Info.java index 3721d55..8f0b909 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/Info.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/Info.java @@ -29,26 +29,22 @@ import lombok.Data; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * ONAP Common Model used by both ONAP and DMAAP: Info + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP Common Model: A model class which + * represents Info */ - - @Data -@JsonInclude(value= Include.NON_NULL) +@JsonInclude(value = Include.NON_NULL) public class Info { - private GetInput topic_url; - - private GetInput username; + private GetInput topic_url; - private GetInput password; + private GetInput username; - private GetInput location; + private GetInput password; - private GetInput delivery_url; + private GetInput location; - private GetInput subscriber_id; + private GetInput delivery_url; + private GetInput subscriber_id; } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/Interfaces.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/Interfaces.java index 04ef7e7..c0536de 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/Interfaces.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/Interfaces.java @@ -23,20 +23,15 @@ package org.onap.blueprintgenerator.model.common; - import lombok.Data; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * ONAP Common Model used by both ONAP and DMAAP: Interfaces + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP Common Model: A model class which + * represents Interfaces */ - - @Data public class Interfaces { - private Start start; - + private Start start; } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/Node.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/Node.java index ea28d62..9387d42 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/Node.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/Node.java @@ -32,12 +32,9 @@ import java.util.Map; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * ONAP Common Model used by both ONAP and DMAAP: Node derived from Common Module Node Model used by both DCAE and ONAP + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP Common Model: A model class which + * represents Node derived from Common Module Node Model */ - - @Data @JsonInclude(value = JsonInclude.Include.NON_NULL) @JsonIgnoreProperties(ignoreUnknown = true) diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/OnapBlueprint.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/OnapBlueprint.java index 4dd7b0f..198a43e 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/OnapBlueprint.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/OnapBlueprint.java @@ -32,17 +32,13 @@ import java.util.Map; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * ONAP Common Model used by both ONAP and DMAAP: Blueprint derived from Common Module Blueprint Model used by both DCAE and ONAP + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP Common Model: A model class which + * represents Blueprint derived from Common Module Blueprint Model */ - - @Data @JsonInclude(value = JsonInclude.Include.NON_NULL) @JsonIgnoreProperties(ignoreUnknown = true) public class OnapBlueprint extends Blueprint { private Map<String, Node> node_templates; - -}
\ No newline at end of file +} diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PgaasNode.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PgaasNode.java index af6fb54..daa9c74 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PgaasNode.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PgaasNode.java @@ -23,24 +23,19 @@ package org.onap.blueprintgenerator.model.common; - import com.fasterxml.jackson.annotation.JsonProperty; import lombok.Data; import lombok.NoArgsConstructor; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * ONAP Common Model used by both ONAP and DMAAP: Pgaas Node + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP Common Model: A model class which + * represents Pgaas Node */ - - @Data @NoArgsConstructor public class PgaasNode extends Node { @JsonProperty("properties") private PgaasNodeProperties pgaasNodeProperties; - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PgaasNodeProperties.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PgaasNodeProperties.java index 37ddb73..36ab1a8 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PgaasNodeProperties.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PgaasNodeProperties.java @@ -28,13 +28,9 @@ import lombok.Data; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * ONAP Common Model used by both ONAP and DMAAP: Pgaas Node Properties + * @date 10/16/2020 Application: ONAP - Blueprint Generator OONAP Common Model: A model class which + * represents Pgaas Node Properties */ - - - @Data public class PgaasNodeProperties { diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PolicyModel.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PolicyModel.java index 08b9096..c432ae9 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PolicyModel.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PolicyModel.java @@ -30,19 +30,14 @@ import java.util.Map; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * ONAP Common Model used by both ONAP and DMAAP: Policy Model + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP Common Model: A model class which + * represents Policy Model */ - - @Data @JsonInclude(JsonInclude.Include.NON_NULL) public class PolicyModel { - - private String tosca_definition_version; - private Map<String, PolicyModelNode> node_types; - private Map<String, PolicyModelNode> data_types; - + private String tosca_definition_version; + private Map<String, PolicyModelNode> node_types; + private Map<String, PolicyModelNode> data_types; } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PolicyModelNode.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PolicyModelNode.java index c418b8e..54a5b20 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PolicyModelNode.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PolicyModelNode.java @@ -30,18 +30,14 @@ import java.util.Map; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * ONAP Common Model used by both ONAP and DMAAP: Policy Model Node + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP Common Model: A model class which + * represents Policy Model Node */ - - @Data @JsonInclude(JsonInclude.Include.NON_NULL) public class PolicyModelNode { - - private String derived_from; - private Map<String, PolicyProperties> properties; + private String derived_from; + private Map<String, PolicyProperties> properties; } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PolicyNode.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PolicyNode.java index cc08814..3e518c0 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PolicyNode.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PolicyNode.java @@ -23,24 +23,19 @@ package org.onap.blueprintgenerator.model.common; - import com.fasterxml.jackson.annotation.JsonProperty; import lombok.Data; import lombok.NoArgsConstructor; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * ONAP Common Model used by both ONAP and DMAAP: Policy Node derived from Common Module Node Model used by both DCAE and ONAP + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP Common Model: A model class which + * represents Policy Node derived from Common Module Node Model */ - - @Data @NoArgsConstructor public class PolicyNode extends Node { @JsonProperty("properties") private PolicyNodeProperties policyNodeProperties; - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PolicyNodeProperties.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PolicyNodeProperties.java index 3f472c8..169c7d5 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PolicyNodeProperties.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PolicyNodeProperties.java @@ -29,12 +29,9 @@ import lombok.NoArgsConstructor; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * ONAP Common Model used by both ONAP and DMAAP: Policy Node Properties + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP Common Model: A model class which + * represents Policy Node Properties */ - - @Data @NoArgsConstructor public class PolicyNodeProperties { @@ -44,5 +41,4 @@ public class PolicyNodeProperties { @JsonProperty("policy_model_id") private String policyModelId; - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PolicyProperties.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PolicyProperties.java index 5a63b00..7e3060b 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PolicyProperties.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/PolicyProperties.java @@ -28,18 +28,14 @@ import lombok.Data; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * ONAP Common Model used by both ONAP and DMAAP: Policy Properties + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP Common Model: A model class which + * represents Policy Properties */ - - @Data @JsonInclude(JsonInclude.Include.NON_NULL) public class PolicyProperties { - - private String type; - private Object entry_schema; - + private String type; + + private Object entry_schema; } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/Properties.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/Properties.java index 11fc06e..a9675f5 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/Properties.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/Properties.java @@ -37,53 +37,49 @@ import java.util.Map; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * ONAP Common Model used by both ONAP and DMAAP: Properties + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP Common Model: A model class which + * represents Properties */ - - @Data @JsonInclude(value = Include.NON_NULL) public class Properties { - private Appconfig application_config; - - private OnapAuxilary docker_config; + private Appconfig application_config; - private Object image; + private OnapAuxilary docker_config; - private GetInput location_id; + private Object image; - private String service_component_type; + private GetInput location_id; - private Map<String, Object> log_info; + private String service_component_type; - private String dns_name; + private Map<String, Object> log_info; - private Object replicas; + private String dns_name; - private String name; + private Object replicas; - private GetInput topic_name; + private String name; - private GetInput feed_name; + private GetInput topic_name; - private List<Streams> streams_publishes; + private GetInput feed_name; - private List<Streams> streams_subscribes; + private List<Streams> streams_publishes; - private TlsInfo tls_info; + private List<Streams> streams_subscribes; - private ResourceConfig resource_config; + private TlsInfo tls_info; - private GetInput always_pull_image; + private ResourceConfig resource_config; - private Boolean useExisting; + private GetInput always_pull_image; - @JsonIgnore - private ExternalTlsInfoFactoryService externalCertFactory; + private Boolean useExisting; - private ExternalTlsInfo external_cert; + @JsonIgnore + private ExternalTlsInfoFactoryService externalCertFactory; + private ExternalTlsInfo external_cert; } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/ResourceConfig.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/ResourceConfig.java index 8b41fd2..cda8458 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/ResourceConfig.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/ResourceConfig.java @@ -29,17 +29,13 @@ import java.util.Map; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * ONAP Common Model used by both ONAP and DMAAP: Resource Config + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP Common Model: A model class which + * represents Resource Config */ - - @Data public class ResourceConfig { - private Map<String, GetInput> limits; - - private Map<String, GetInput> requests; + private Map<String, GetInput> limits; -}
\ No newline at end of file + private Map<String, GetInput> requests; +} diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/Services.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/Services.java index 7aa1566..abf1fb5 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/Services.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/Services.java @@ -32,19 +32,15 @@ import lombok.Data; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * ONAP Common Model used by both ONAP and DMAAP: Services + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP Common Model: A model class which + * represents Services */ - - @Data -@JsonInclude(value=Include.NON_NULL) +@JsonInclude(value = Include.NON_NULL) @JsonIgnoreProperties(ignoreUnknown = true) -public class Services { - - private Calls[] calls; +public class Services { - private Provides[] provides; + private Calls[] calls; + private Provides[] provides; } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/Start.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/Start.java index 3740668..7714d94 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/Start.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/Start.java @@ -31,19 +31,15 @@ import java.util.Map; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * ONAP Common Model used by both ONAP and DMAAP: Start + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP Common Model: A model class which + * represents Start */ - - @Data -@JsonInclude(value= JsonInclude.Include.NON_NULL) +@JsonInclude(value = JsonInclude.Include.NON_NULL) @JsonIgnoreProperties(ignoreUnknown = true) public class Start { private StartInputs inputs; private Map<String, Object> envs; - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/StartInputs.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/StartInputs.java index 458852e..6b35cc2 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/StartInputs.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/common/StartInputs.java @@ -31,19 +31,15 @@ import java.util.List; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * ONAP Common Model used by both ONAP and DMAAP: Start Inputs under Start + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP Common Model: A model class which + * represents Start Inputs under Start */ - - @Data -@JsonInclude(value= JsonInclude.Include.NON_NULL) +@JsonInclude(value = JsonInclude.Include.NON_NULL) @JsonIgnoreProperties(ignoreUnknown = true) public class StartInputs { private Object envs; private List<String> ports; - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/componentspec/OnapAuxilary.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/componentspec/OnapAuxilary.java index 0923195..f59ee74 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/componentspec/OnapAuxilary.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/componentspec/OnapAuxilary.java @@ -35,12 +35,9 @@ import java.util.Map; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * Component Spec Model for ONAP Auxillary derived from Common Module Auxillary used by both DCAE and ONAP + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP Component Spec Model: A model class + * which represents ONAP Auxillary derived from Common Module Auxillary */ - - @Data @JsonInclude(value = JsonInclude.Include.NON_NULL) @JsonIgnoreProperties(ignoreUnknown = true) @@ -56,5 +53,4 @@ public class OnapAuxilary extends Auxilary { private Map<String, Object> tls_info; private Volumes[] volumes; - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/componentspec/OnapComponentSpec.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/componentspec/OnapComponentSpec.java index 5a64366..24095e7 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/componentspec/OnapComponentSpec.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/componentspec/OnapComponentSpec.java @@ -31,12 +31,9 @@ import lombok.Data; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * Component Spec Model for ONAP Component Spec derived from Common Module Component Spec used by both DCAE and ONAP + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP Component Spec Model: A model class + * which represents ONAP Component Spec derived from Common Module Component Spec */ - - @Data @JsonInclude(value = JsonInclude.Include.NON_NULL) @JsonIgnoreProperties(ignoreUnknown = true) @@ -48,5 +45,4 @@ public class OnapComponentSpec extends ComponentSpec { @JsonProperty("policy_info") private PolicyInfo policyInfo; - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/componentspec/PolicyInfo.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/componentspec/PolicyInfo.java index 3ec5fe3..903925b 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/componentspec/PolicyInfo.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/componentspec/PolicyInfo.java @@ -30,16 +30,12 @@ import java.util.List; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * Component Spec Model for Policy Info + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP Component Spec Model: A model class + * which represents Policy Info */ - - @Data public class PolicyInfo { @JsonProperty("policy") private List<TypePolicy> typePolicyList; - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/componentspec/Services.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/componentspec/Services.java index b7d32a4..d854be5 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/componentspec/Services.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/componentspec/Services.java @@ -23,7 +23,6 @@ package org.onap.blueprintgenerator.model.componentspec; - import org.onap.blueprintgenerator.model.componentspec.common.Calls; import org.onap.blueprintgenerator.model.componentspec.common.Provides; import com.fasterxml.jackson.annotation.JsonIgnoreProperties; @@ -33,19 +32,15 @@ import lombok.Data; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * Component Spec Model for Services + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP Component Spec Model: A model class + * which represents Services */ - - @Data -@JsonInclude(value= Include.NON_NULL) +@JsonInclude(value = Include.NON_NULL) @JsonIgnoreProperties(ignoreUnknown = true) public class Services { - private Calls[] calls; - - private Provides[] provides; + private Calls[] calls; + private Provides[] provides; } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/componentspec/TypePolicy.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/componentspec/TypePolicy.java index 6ba7daf..dd10687 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/componentspec/TypePolicy.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/componentspec/TypePolicy.java @@ -27,17 +27,13 @@ import lombok.Data; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * Component Spec Model for Type Policy + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP Component Spec Model: A model class + * which represents Type Policy */ - - @Data public class TypePolicy { private String node_label; private String policy_id; private String policy_model_id; - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/dmaap/Streams.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/dmaap/Streams.java index 14d0c51..6ca089d 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/dmaap/Streams.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/dmaap/Streams.java @@ -30,37 +30,32 @@ import lombok.Data; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * DMAAP Model for Streams + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP DMAAP Spec Model: A model class + * which represents Streams */ - - @Data -@JsonInclude(value= Include.NON_NULL) +@JsonInclude(value = Include.NON_NULL) public class Streams { - private String name; - - private GetInput location; - - private GetInput client_role; + private String name; - private String type; + private GetInput location; - private GetInput username; + private GetInput client_role; - private GetInput password; + private String type; - //private GetInput delivery_url; + private GetInput username; - private GetInput privileged; + private GetInput password; - private GetInput decompress; + // private GetInput delivery_url; - private String route; + private GetInput privileged; - private String scheme; + private GetInput decompress; + private String route; -}
\ No newline at end of file + private String scheme; +} diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/dmaap/TlsInfo.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/dmaap/TlsInfo.java index 9290bf9..cfc9c45 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/dmaap/TlsInfo.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/model/dmaap/TlsInfo.java @@ -30,12 +30,9 @@ import lombok.NoArgsConstructor; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * DMAAP Model for TLS Info + * @date 10/16/2020 Application: ONAP - Blueprint Generator ONAP DMAAP Spec Model: A model class + * which represents TLS Info */ - - @Data @NoArgsConstructor public class TlsInfo { @@ -45,5 +42,4 @@ public class TlsInfo { @JsonProperty("use_tls") private GetInput useTls; - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/InfoService.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/InfoService.java index fed3707..66f71da 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/InfoService.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/InfoService.java @@ -35,32 +35,37 @@ import java.util.Map; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * Service to create Message Router and Data Router Information + * @date 10/16/2020 Application: ONAP - Blueprint Generator Service to create Message Router and + * Data Router Information */ - @Service public class InfoService { @Autowired private BlueprintHelperService blueprintHelperService; - // Method to create info for Message Router - public Map<String,Object> createMessageRouterInfo(Map<String, LinkedHashMap<String, Object>> inputs, String config, char type) { - - Map<String,Object> response = new HashMap<>(); + /** + * Creates info for Message Router + * + * @param inputs Inputs + * @param config Config + * @param type BP Type + * @return + */ + public Map<String, Object> createMessageRouterInfo( + Map<String, LinkedHashMap<String, Object>> inputs, String config, char type) { + + Map<String, Object> response = new HashMap<>(); Info info = new Info(); LinkedHashMap<String, Object> stringType = new LinkedHashMap<>(); stringType.put("type", "string"); config = config.replaceAll("-", "_"); - if(type == 'p') { + if (type == 'p') { config = config + "_publish_url"; - } - else if(type == 's') { - config = config+ "_subscribe_url"; + } else if (type == 's') { + config = config + "_subscribe_url"; } GetInput topic = new GetInput(); @@ -74,10 +79,17 @@ public class InfoService { return response; } - // Method to create info for Data Router - public Map<String,Object> createDataRouterInfo(Map<String, LinkedHashMap<String, Object>> inputs, String config) { - - Map<String,Object> response = new HashMap<>(); + /** + * Creates info for Data Router + * + * @param inputs Inputs + * @param config Config + * @return + */ + public Map<String, Object> createDataRouterInfo( + Map<String, LinkedHashMap<String, Object>> inputs, String config) { + + Map<String, Object> response = new HashMap<>(); Info info = new Info(); LinkedHashMap<String, Object> stringType = new LinkedHashMap<>(); @@ -98,12 +110,14 @@ public class InfoService { info.setLocation(location); inputs.put(userlocationInputName, stringType); - String userdeliveryUrlInputName = blueprintHelperService.joinUnderscore(config, "delivery_url"); + String userdeliveryUrlInputName = blueprintHelperService + .joinUnderscore(config, "delivery_url"); GetInput deliveryUrl = new GetInput(userdeliveryUrlInputName); info.setDelivery_url(deliveryUrl); inputs.put(userdeliveryUrlInputName, stringType); - String usersubscriberIDInputName = blueprintHelperService.joinUnderscore(config, "subscriber_id"); + String usersubscriberIDInputName = + blueprintHelperService.joinUnderscore(config, "subscriber_id"); GetInput subscriberID = new GetInput(usersubscriberIDInputName); info.setSubscriber_id(subscriberID); inputs.put(usersubscriberIDInputName, stringType); @@ -112,5 +126,4 @@ public class InfoService { response.put("inputs", inputs); return response; } - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/OnapBlueprintService.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/OnapBlueprintService.java index f25c18c..748facf 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/OnapBlueprintService.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/OnapBlueprintService.java @@ -23,7 +23,6 @@ package org.onap.blueprintgenerator.service; - import org.onap.blueprintgenerator.constants.Constants; import org.onap.blueprintgenerator.exception.BlueprintException; import org.onap.blueprintgenerator.model.common.Input; @@ -46,11 +45,8 @@ import java.util.TreeMap; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * Service to create ONAP Blueprint + * @date 10/16/2020 Application: ONAP - Blueprint Generator Service to create ONAP Blueprint */ - @Service public class OnapBlueprintService extends BlueprintService { @@ -69,43 +65,51 @@ public class OnapBlueprintService extends BlueprintService { @Autowired protected ImportsService importsService; - // Method to generate Onap Blueprint + /** + * Creates Onap Blueprint + * + * @param onapComponentSpec OnapComponentSpec + * @param input Inputs + * @return + */ public OnapBlueprint createBlueprint(OnapComponentSpec onapComponentSpec, Input input) { try { OnapBlueprint blueprint = new OnapBlueprint(); blueprint.setTosca_definitions_version(Constants.TOSCA_DEF_VERSION); - //if (!"".equals(input.getImportPath())) - if (!StringUtils.isEmpty(input.getImportPath())) + // if (!"".equals(input.getImportPath())) + if (!StringUtils.isEmpty(input.getImportPath())) { blueprint.setImports(importsService.createImportsFromFile(input.getImportPath())); - else + } else { blueprint.setImports(importsService.createImports(input.getBpType())); + } Map<String, Node> nodeTemplate = new TreeMap<>(); String nodeName = onapComponentSpec.getSelf().getName(); Map<String, LinkedHashMap<String, Object>> inputs = new TreeMap<>(); - Map<String, Object> onapNodeResponse = nodeService.createOnapNode(inputs, onapComponentSpec, input.getServiceNameOverride()); + Map<String, Object> onapNodeResponse = + nodeService + .createOnapNode(inputs, onapComponentSpec, input.getServiceNameOverride()); inputs = (Map<String, LinkedHashMap<String, Object>>) onapNodeResponse.get("inputs"); nodeTemplate.put(nodeName, (Node) onapNodeResponse.get("onapNode")); blueprint.setNode_templates(nodeTemplate); - if (onapComponentSpec.getPolicyInfo() != null) + if (onapComponentSpec.getPolicyInfo() != null) { policyNodeService.addPolicyNodesAndInputs(onapComponentSpec, nodeTemplate, inputs); + } - if (onapComponentSpec.getAuxilary() != null && onapComponentSpec.getAuxilary().getDatabases() != null) + if (onapComponentSpec.getAuxilary() != null + && onapComponentSpec.getAuxilary().getDatabases() != null) { pgaasNodeService.addPgaasNodesAndInputs(onapComponentSpec, nodeTemplate, inputs); + } blueprint.setInputs(inputs); return quotationService.setQuotations(blueprint); } catch (Exception ex) { - throw new BlueprintException("Unable to create ONAP Blueprint Object from given input parameters", ex); + throw new BlueprintException( + "Unable to create ONAP Blueprint Object from given input parameters", ex); } } - - } - - - diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/AppConfigService.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/AppConfigService.java index c6d744c..7c87af7 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/AppConfigService.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/AppConfigService.java @@ -43,12 +43,9 @@ import java.util.TreeMap; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * Common ONAP Service used by ONAP and DMAAP Blueprint to create App Config + * @date 10/16/2020 Application: ONAP - Blueprint Generator Common ONAP Service used to create App + * Config */ - - @Service("onapAppConfigService") public class AppConfigService { @@ -58,31 +55,52 @@ public class AppConfigService { @Autowired private BlueprintHelperService blueprintHelperService; - public Map<String,Object> createAppconfig(Map<String, LinkedHashMap<String, Object>> inputs, OnapComponentSpec onapComponentSpec, String override, boolean isDmaap) { - - Map<String,Object> response = new HashMap<>(); + /** + * Creates Inputs section under App Config with Publishes, Subscribes, Parameters sections by + * checking Datarouter/MessageRouter/override/Dmaap values + * + * @param inputs Inputs + * @param onapComponentSpec Onap Component Specification + * @param override Parameter to Service Component Override + * @param isDmaap Dmaap Argument + * @return + */ + public Map<String, Object> createAppconfig( + Map<String, LinkedHashMap<String, Object>> inputs, + OnapComponentSpec onapComponentSpec, + String override, + boolean isDmaap) { + + Map<String, Object> response = new HashMap<>(); Appconfig appconfig = new Appconfig(); Calls[] call = new Calls[0]; appconfig.setService_calls(call); Map<String, Dmaap> streamPublishes = new TreeMap<>(); - if(onapComponentSpec.getStreams() != null) { + if (onapComponentSpec.getStreams() != null) { if (onapComponentSpec.getStreams().getPublishes() != null) { for (Publishes publishes : onapComponentSpec.getStreams().getPublishes()) { if (blueprintHelperService.isDataRouterType(publishes.getType())) { String config = publishes.getConfig_key(); String name = config + Constants._FEED; - Map<String, Object> dmaapDataRouterResponse = dmaapService.createDmaapDataRouter(inputs, config, name, isDmaap); - inputs = (Map<String, LinkedHashMap<String, Object>>) dmaapDataRouterResponse.get("inputs"); + Map<String, Object> dmaapDataRouterResponse = + dmaapService.createDmaapDataRouter(inputs, config, name, isDmaap); + inputs = + (Map<String, LinkedHashMap<String, Object>>) dmaapDataRouterResponse + .get("inputs"); Dmaap dmaap = (Dmaap) dmaapDataRouterResponse.get("dmaap"); dmaap.setType(publishes.getType()); streamPublishes.put(config, dmaap); } else if (blueprintHelperService.isMessageRouterType(publishes.getType())) { String config = publishes.getConfig_key(); String name = config + Constants._TOPIC; - Map<String, Object> dmaapDataRouterResponse = dmaapService.createDmaapMessageRouter(inputs, config, 'p', name, name, isDmaap); - inputs = (Map<String, LinkedHashMap<String, Object>>) dmaapDataRouterResponse.get("inputs"); + Map<String, Object> dmaapDataRouterResponse = + dmaapService + .createDmaapMessageRouter(inputs, config, 'p', name, name, isDmaap); + inputs = + (Map<String, LinkedHashMap<String, Object>>) dmaapDataRouterResponse + .get("inputs"); Dmaap dmaap = (Dmaap) dmaapDataRouterResponse.get("dmaap"); dmaap.setType(publishes.getType()); streamPublishes.put(config, dmaap); @@ -93,22 +111,29 @@ public class AppConfigService { Map<String, Dmaap> streamSubscribes = new TreeMap<>(); - if(onapComponentSpec.getStreams() != null) { + if (onapComponentSpec.getStreams() != null) { if (onapComponentSpec.getStreams().getSubscribes() != null) { for (Subscribes subscribes : onapComponentSpec.getStreams().getSubscribes()) { if (blueprintHelperService.isDataRouterType(subscribes.getType())) { String config = subscribes.getConfig_key(); String name = config + Constants._FEED; - Map<String, Object> dmaapDataRouterResponse = dmaapService.createDmaapDataRouter(inputs, config, name, isDmaap); - inputs = (Map<String, LinkedHashMap<String, Object>>) dmaapDataRouterResponse.get("inputs"); + Map<String, Object> dmaapDataRouterResponse = + dmaapService.createDmaapDataRouter(inputs, config, name, isDmaap); + inputs = + (Map<String, LinkedHashMap<String, Object>>) dmaapDataRouterResponse + .get("inputs"); Dmaap dmaap = (Dmaap) dmaapDataRouterResponse.get("dmaap"); dmaap.setType(subscribes.getType()); streamSubscribes.put(config, dmaap); } else if (blueprintHelperService.isMessageRouterType(subscribes.getType())) { String config = subscribes.getConfig_key(); String name = config + Constants._TOPIC; - Map<String, Object> dmaapDataRouterResponse = dmaapService.createDmaapMessageRouter(inputs, config, 's', name, name, isDmaap); - inputs = (Map<String, LinkedHashMap<String, Object>>) dmaapDataRouterResponse.get("inputs"); + Map<String, Object> dmaapDataRouterResponse = + dmaapService + .createDmaapMessageRouter(inputs, config, 's', name, name, isDmaap); + inputs = + (Map<String, LinkedHashMap<String, Object>>) dmaapDataRouterResponse + .get("inputs"); Dmaap dmaap = (Dmaap) dmaapDataRouterResponse.get("dmaap"); dmaap.setType(subscribes.getType()); streamSubscribes.put(config, dmaap); @@ -121,14 +146,15 @@ public class AppConfigService { appconfig.setStreams_subscribes(streamSubscribes); Map<String, Object> parameters = new TreeMap<>(); - for(Parameters p: onapComponentSpec.getParameters()) { + for (Parameters p : onapComponentSpec.getParameters()) { String pName = p.getName(); - if(p.isSourced_at_deployment()) { + if (p.isSourced_at_deployment()) { GetInput paramInput = new GetInput(); paramInput.setBpInputName(pName); parameters.put(pName, paramInput); - if(!"".equals(p.getValue())) { - LinkedHashMap<String, Object> pInputs = blueprintHelperService.createStringInput( p.getValue()); + if (!"".equals(p.getValue())) { + LinkedHashMap<String, Object> pInputs = + blueprintHelperService.createStringInput(p.getValue()); inputs.put(pName, pInputs); } else { LinkedHashMap<String, Object> pInputs = new LinkedHashMap<>(); @@ -136,23 +162,23 @@ public class AppConfigService { inputs.put(pName, pInputs); } } else { - if("string".equals(p.getType())) { - String val =(String) p.getValue(); + if ("string".equals(p.getType())) { + String val = (String) p.getValue(); val = '"' + val + '"'; parameters.put(pName, val); - } - else { + } else { parameters.put(pName, p.getValue()); // Updated code to resolve the issue of missing \ for collector.schema.file - //parameters.put(pName, pName.equals("collector.schema.file") ? ((String)p.getValue()).replace("\"", "\\\"") : p.getValue()); + // parameters.put(pName, pName.equals("collector.schema.file") ? + // ((String)p.getValue()).replace("\"", "\\\"") : p.getValue()); } } } - if(override != null) { + if (override != null) { GetInput ov = new GetInput(); ov.setBpInputName(Constants.SERVICE_COMPONENT_NAME_OVERRIDE); parameters.put(Constants.SERVICE_COMPONENT_NAME_OVERRIDE, ov); - LinkedHashMap<String, Object> over = blueprintHelperService.createStringInput( override); + LinkedHashMap<String, Object> over = blueprintHelperService.createStringInput(override); inputs.put(Constants.SERVICE_COMPONENT_NAME_OVERRIDE, over); } appconfig.setParams(parameters); @@ -160,7 +186,5 @@ public class AppConfigService { response.put("appconfig", appconfig); response.put("inputs", inputs); return response; - } - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/CommonUtils.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/CommonUtils.java index 97ed47f..2bfa43e 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/CommonUtils.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/CommonUtils.java @@ -23,8 +23,6 @@ package org.onap.blueprintgenerator.service.common; - - import org.apache.commons.cli.CommandLineParser; import org.apache.commons.cli.HelpFormatter; import org.apache.commons.cli.ParseException; @@ -40,106 +38,163 @@ import static java.lang.System.exit; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * Common ONAP Service used by ONAP and DMAAP Blueprint to Print Instructions and Parse Inputs + * @date 10/16/2020 Application: ONAP - Blueprint Generator Common ONAP Service used by ONAP and + * DMAAP Blueprint to Print Instructions and Parse Inputs */ - - @Service("onapCommonUtilsService") public class CommonUtils { + /** + * Prints input arguments options to run the Blueprint Application + */ public void printInstructions() { System.out.println("OPTIONS:"); - System.out.println("-i OR --component-spec: The path of the ONAP Blueprint INPUT JSON SPEC FILE (Required)"); - System.out.println("-p OR --blueprint-path: The path of the ONAP Blueprint OUTPUT where it will be saved (Required)"); - System.out.println("-n OR --blueprint-name: The NAME of the ONAP Blueprint OUTPUT that will be created (Optional)"); - System.out.println("-t OR --imports: The path of the ONAP Blueprint IMPORT FILE (Optional)"); - System.out.println("-o OR --service-name-override: The Value used to OVERRIDE the SERVICE NAME of the ONAP Blueprint (Optional)"); - System.out.println("-d OR --dmaap-plugin: The option to create a ONAP Blueprint with DMAAP Plugin (Optional)"); - System.out.println("Syntax to run from command line: \n For Blueprint : java -jar target/<JAR Filename>.jar app ONAP -i componentspec -p OutputBlueprintPath -n Blueprintname -d \n For PolicyCreate: java -jar target/<JAR Filename>.jar app ONAP -type policycreate -i componentspec -p OutputPolicyPath"); + System.out.println( + "-i OR --component-spec: The path of the ONAP Blueprint INPUT JSON SPEC FILE (Required)"); + System.out.println( + "-p OR --blueprint-path: The path of the ONAP Blueprint OUTPUT where it will be saved (Required)"); + System.out.println( + "-n OR --blueprint-name: The NAME of the ONAP Blueprint OUTPUT that will be created (Optional)"); + System.out + .println("-t OR --imports: The path of the ONAP Blueprint IMPORT FILE (Optional)"); + System.out.println( + "-o OR --service-name-override: The Value used to OVERRIDE the SERVICE NAME of the ONAP Blueprint (Optional)"); + System.out.println( + "-d OR --dmaap-plugin: The option to create a ONAP Blueprint with DMAAP Plugin (Optional)"); + System.out.println( + "Syntax to run from command line: \n For Blueprint : java -jar target/<JAR Filename>.jar app ONAP -i componentspec -p OutputBlueprintPath -n Blueprintname -d \n For PolicyCreate: java -jar target/<JAR Filename>.jar app ONAP -type policycreate -i componentspec -p OutputPolicyPath"); } + /** + * Parses Input Arguments and validates is reuired arguments are provided or not + * + * @param args Input Arguments + * @return + */ public Input parseInputs(String[] args) { String[] modArgs = new String[args.length]; - for(int i=0; i<args.length; i++){ - if(args[i].contains("--component-spec")) + for (int i = 0; i < args.length; i++) { + if (args[i].contains("--component-spec")) { modArgs[i] = "-_component_spec"; - else if(args[i].contains("--blueprint-path")) + } else if (args[i].contains("--blueprint-path")) { modArgs[i] = "-_blueprint_path"; - else if(args[i].contains("--blueprint-name")) + } else if (args[i].contains("--blueprint-name")) { modArgs[i] = "-_blueprint_name"; - else if(args[i].contains("--imports")) + } else if (args[i].contains("--imports")) { modArgs[i] = "-_imports"; - else if(args[i].contains("--service-name-override")) + } else if (args[i].contains("--service-name-override")) { modArgs[i] = "-_service_name_override"; - else if(args[i].contains("--dmaap-plugin")) + } else if (args[i].contains("--dmaap-plugin")) { modArgs[i] = "-_dmaap_plugin"; - else + } else { modArgs[i] = args[i]; + } } - String commands = " "; - for (String s : modArgs) { - commands = commands + " " + s; + StringBuilder commandsBuf = new StringBuilder(""); + String sep = ""; + for (String s : modArgs) { + commandsBuf.append(sep).append(s); + sep = " "; } + String commands = commandsBuf.toString(); - //checks if the required inputs are present or not - if (!(commands.contains(" -i ")|| commands.contains(" -_component_spec ")) - && !(commands.contains(" -p ") || commands.contains(" -_blueprint_path ") ) ) { - System.out.println("\n Please enter the ONAP Blueprint required inputs for: \n -i (The path of the ONAP Blueprint INPUT JSON SPEC FILE), \n -p (The path of the ONAP Blueprint OUTPUT where it will be saved)"); + // checks if the required inputs are present or not + if (!(commands.contains(" -i ") || commands.contains(" -_component_spec ")) + && !(commands.contains(" -p ") || commands.contains(" -_blueprint_path "))) { + System.out.println( + "\n Please enter the ONAP Blueprint required inputs for: \n -i (The path of the ONAP Blueprint INPUT JSON SPEC FILE), \n -p (The path of the ONAP Blueprint OUTPUT where it will be saved)"); exit(-1); } - CommandLineParser parser = new DefaultParser(); HelpFormatter formatter = new HelpFormatter(); Options options = new Options(); options.addOption("i", "Spec", true, "ComponentSpec Input File of the ONAP Blueprint"); - options.addOption("_component_spec", "Spec", true, "ComponentSpec Input File of the ONAP Blueprint"); + options.addOption( + "_component_spec", "Spec", true, "ComponentSpec Input File of the ONAP Blueprint"); options.addOption("p", "Path", true, "Path of the ONAP Blueprint OUTPUT"); options.addOption("_blueprint_path", "Path", true, "Path of the ONAP Blueprint OUTPUT"); options.addOption("n", "name", true, "NAME of the ONAP Blueprint OUTPUT"); options.addOption("_blueprint_name", "name", true, "NAME of the ONAP Blueprint OUTPUT"); options.addOption("t", "Import File", true, "Import file for the OUTPUT Blueprint Imports"); - options.addOption("_imports", "Import File", true, "Import file for the OUTPUT Blueprint Imports"); - options.addOption("o", "Service name Override", true, "Value used to override the OUTPUT Blueprint service name"); - options.addOption("_service_name_override", "Service name Override", true, "Value used to override the OUTPUT Blueprint service name"); - options.addOption("d", "Dmaap Plugin", false, "Flag used to indicate ONAP Blueprint OUTPUT uses the DMaaP plugin"); - options.addOption("_dmaap_plugin", "Dmaap Plugin", false, "Flag used to indicate ONAP Blueprint OUTPUT uses the DMaaP plugin"); + options.addOption( + "_imports", "Import File", true, "Import file for the OUTPUT Blueprint Imports"); + options.addOption( + "o", + "Service name Override", + true, + "Value used to override the OUTPUT Blueprint service name"); + options.addOption( + "_service_name_override", + "Service name Override", + true, + "Value used to override the OUTPUT Blueprint service name"); + options.addOption( + "d", + "Dmaap Plugin", + false, + "Flag used to indicate ONAP Blueprint OUTPUT uses the DMaaP plugin"); + options.addOption( + "_dmaap_plugin", + "Dmaap Plugin", + false, + "Flag used to indicate ONAP Blueprint OUTPUT uses the DMaaP plugin"); Input input = new Input(); try { CommandLine commandLine = parser.parse(options, modArgs); - input.setComponentSpecPath(commandLine.getOptionValue("i") == null ? commandLine.getOptionValue("_component_spec") : commandLine.getOptionValue("i")); - input.setOutputPath(commandLine.getOptionValue("p") == null ? commandLine.getOptionValue("_blueprint_path") : commandLine.getOptionValue("p")); - input.setBluePrintName(commandLine.getOptionValue("n") == null ? commandLine.getOptionValue("_blueprint_name") : commandLine.getOptionValue("n")); - input.setImportPath(commandLine.getOptionValue("t") == null ? commandLine.getOptionValue("_imports") : commandLine.getOptionValue("t")); - input.setBpType((commands.contains(" -d ") || commands.contains(" -_dmaap_plugin ") ) ? "d" : "o"); - input.setServiceNameOverride(commandLine.getOptionValue("o") == null ? commandLine.getOptionValue("_service_name_override") == null ? "" : commandLine.getOptionValue("_service_name_override") : commandLine.getOptionValue("o")); + input.setComponentSpecPath( + commandLine.getOptionValue("i") == null + ? commandLine.getOptionValue("_component_spec") + : commandLine.getOptionValue("i")); + input.setOutputPath( + commandLine.getOptionValue("p") == null + ? commandLine.getOptionValue("_blueprint_path") + : commandLine.getOptionValue("p")); + input.setBluePrintName( + commandLine.getOptionValue("n") == null + ? commandLine.getOptionValue("_blueprint_name") + : commandLine.getOptionValue("n")); + input.setImportPath( + commandLine.getOptionValue("t") == null + ? commandLine.getOptionValue("_imports") + : commandLine.getOptionValue("t")); + input.setBpType( + (commands.contains(" -d ") || commands.contains(" -_dmaap_plugin ")) ? "d" : "o"); + input.setServiceNameOverride( + commandLine.getOptionValue("o") == null + ? commandLine.getOptionValue("_service_name_override") == null + ? "" + : commandLine.getOptionValue("_service_name_override") + : commandLine.getOptionValue("o")); } catch (ParseException ex) { ex.printStackTrace(); System.out.println(ex.getMessage()); - formatter.printHelp("Required/Valid Inputs to create ONAP Blueprint are not provided", options); + formatter.printHelp( + "Required/Valid Inputs to create ONAP Blueprint are not provided", options); exit(-1); } if (StringUtils.isEmpty(input.getComponentSpecPath())) { - System.out.println("The path of the ONAP Blueprint INPUT JSON SPEC FILE is not specified"); + System.out + .println("The path of the ONAP Blueprint INPUT JSON SPEC FILE is not specified"); exit(-1); } if (StringUtils.isEmpty(input.getOutputPath())) { - System.out.println("The path of the ONAP Blueprint OUTPUT where it will be saved is not specified"); + System.out.println( + "The path of the ONAP Blueprint OUTPUT where it will be saved is not specified"); exit(-1); } if (commands.contains(" -n ") || commands.contains(" -_blueprint_name ")) { if (StringUtils.isEmpty(input.getBluePrintName())) { - System.out.println("The NAME of the ONAP Blueprint OUTPUT that will be created is not specified"); + System.out.println( + "The NAME of the ONAP Blueprint OUTPUT that will be created is not specified"); exit(-1); } } - if (commands.contains(" -t ")|| commands.contains(" -_imports ")) { + if (commands.contains(" -t ") || commands.contains(" -_imports ")) { if (StringUtils.isEmpty(input.getImportPath())) { System.out.println("The path of the ONAP Blueprint Imports File is not specified"); exit(-1); @@ -148,5 +203,4 @@ public class CommonUtils { return input; } - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/ComponentSpecService.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/ComponentSpecService.java index 4991bda..7145ac8 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/ComponentSpecService.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/ComponentSpecService.java @@ -23,6 +23,7 @@ package org.onap.blueprintgenerator.service.common; +import java.io.IOException; import org.onap.blueprintgenerator.exception.ComponentSpecException; import org.onap.blueprintgenerator.model.componentspec.OnapComponentSpec; import com.fasterxml.jackson.databind.ObjectMapper; @@ -51,7 +52,7 @@ public class ComponentSpecService { /** * Creates ComponentSpec from given file path and validates if the input is json file or not * - * @param componentSpecPath + * @param componentSpecPath Path of Component Spec File Location * @return */ public OnapComponentSpec createComponentSpecFromFile(String componentSpecPath) { @@ -63,7 +64,9 @@ public class ComponentSpecService { componentSpec = componentMapper.readValue(new File(componentSpecPath), OnapComponentSpec.class); } } catch (Exception ex) { - throw new ComponentSpecException("Unable to create ONAP Component Spec from the input file: "+ componentSpecPath, ex); + throw new ComponentSpecException( + "Unable to create ONAP Component Spec from the input file: " + componentSpecPath, + ex); } return componentSpec; } @@ -71,7 +74,8 @@ public class ComponentSpecService { /** * Creates the component spec from string. * This method is used by RuntimeAPI - * @param specString the spec string + * @param specString the spec string of Component Spec + * @return */ public OnapComponentSpec createComponentSpecFromString(String specString) { OnapComponentSpec componentSpec; diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/DmaapService.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/DmaapService.java index d4b2c42..e21b852 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/DmaapService.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/DmaapService.java @@ -35,63 +35,87 @@ import java.util.Map; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * Common ONAP Service used by ONAP and DMAAP Blueprint to add DMAAP Message and Data Routers + * @date 10/16/2020 Application: ONAP - Blueprint Generator Common ONAP Service to add DMAAP Message + * and Data Routers */ - - @Service public class DmaapService { @Autowired private InfoService infoService; - // Method is used to create the Dmaap Message Router - public Map<String,Object> createDmaapMessageRouter(Map<String, LinkedHashMap<String, Object>> inputs,String config, char type, String counter, String num, boolean isDmaap) { - - Map<String,Object> response = new HashMap<>(); + /** + * Creates Dmaap Message Router from given inputs + * + * @param inputs Input Arguments + * @param config Configuration + * @param type BP Type + * @param counter Counter + * @param num Number Incrementor + * @param isDmaap Dmaap Argument + * @return + */ + public Map<String, Object> createDmaapMessageRouter( + Map<String, LinkedHashMap<String, Object>> inputs, + String config, + char type, + String counter, + String num, + boolean isDmaap) { + + Map<String, Object> response = new HashMap<>(); Dmaap dmaap = new Dmaap(); LinkedHashMap<String, Object> stringType = new LinkedHashMap(); stringType.put("type", "string"); - if(!isDmaap){ - Map<String, Object> infoResponse = infoService.createMessageRouterInfo(inputs, config, type); + if (!isDmaap) { + Map<String, Object> infoResponse = infoService + .createMessageRouterInfo(inputs, config, type); inputs = (Map<String, LinkedHashMap<String, Object>>) infoResponse.get("inputs"); dmaap.setDmaap_info(infoResponse.get("info")); - } - else{ + } else { String infoType = "<<" + counter + ">>"; dmaap.setDmaap_info(infoType); GetInput u = new GetInput(); - u.setBpInputName(config + "_" + num +"_aaf_username"); + u.setBpInputName(config + "_" + num + "_aaf_username"); dmaap.setUser(u); - inputs.put(config + "_" + num +"_aaf_username", stringType); + inputs.put(config + "_" + num + "_aaf_username", stringType); GetInput p = new GetInput(); - p.setBpInputName(config + "_" + num +"_aaf_password"); + p.setBpInputName(config + "_" + num + "_aaf_password"); dmaap.setPass(p); - inputs.put(config + "_" + num +"_aaf_password", stringType); + inputs.put(config + "_" + num + "_aaf_password", stringType); } response.put("dmaap", dmaap); response.put("inputs", inputs); return response; } - // Method is used to create the Dmaap Data Router - public Map<String,Object> createDmaapDataRouter(Map<String, LinkedHashMap<String, Object>> inputs, String config, String counter, boolean isDmaap) { - - Map<String,Object> response = new HashMap<>(); + /** + * Creates Dmaap Data Router from given inputs + * + * @param inputs Input Arguments + * @param config Configuration + * @param counter Counter + * @param isDmaap Dmaap Argument + * @return + */ + public Map<String, Object> createDmaapDataRouter( + Map<String, LinkedHashMap<String, Object>> inputs, + String config, + String counter, + boolean isDmaap) { + + Map<String, Object> response = new HashMap<>(); Dmaap dmaap = new Dmaap(); - if(!isDmaap){ + if (!isDmaap) { Map<String, Object> infoResponse = infoService.createDataRouterInfo(inputs, config); inputs = (Map<String, LinkedHashMap<String, Object>>) infoResponse.get("inputs"); dmaap.setDmaap_info(infoResponse.get("info")); - } - else { + } else { String infoType = "<<" + counter + ">>"; dmaap.setDmaap_info(infoType); } @@ -99,5 +123,4 @@ public class DmaapService { response.put("inputs", inputs); return response; } - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/ExternalCertificateDataFactoryService.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/ExternalCertificateDataFactoryService.java index ab48ada..f81da68 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/ExternalCertificateDataFactoryService.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/ExternalCertificateDataFactoryService.java @@ -30,21 +30,19 @@ import org.springframework.stereotype.Service; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * Common ONAP Service used by ONAP and DMAAP Blueprint to add External Certificate Data Factory + * @date 10/16/2020 Application: ONAP - Blueprint Generator Common ONAP Service to add External + * Certificate Data Factory */ - - @Service public abstract class ExternalCertificateDataFactoryService { - // Method to concatenate Constant with field + // Method to concatenate Constant with field protected static GetInput createPrefixedGetInput(String fieldName) { return new GetInput(addPrefix(fieldName)); } // Method to concatenate the Constant INPUT_PREFIX to the input field - protected static String addPrefix(String fieldName) { return Constants.INPUT_PREFIX + fieldName; } - + protected static String addPrefix(String fieldName) { + return Constants.INPUT_PREFIX + fieldName; + } } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/ExternalCertificateParametersFactoryService.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/ExternalCertificateParametersFactoryService.java index 300aa5d..226a319 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/ExternalCertificateParametersFactoryService.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/ExternalCertificateParametersFactoryService.java @@ -35,40 +35,52 @@ import java.util.Map; /** * @author : Ravi Mantena - * @date 10/16/2020 Application: ONAP - Blueprint Generator Common ONAP Service used by ONAP and DMAAP Blueprint to add - * External Certificate Parameters + * @date 10/16/2020 Application: ONAP - Blueprint Generator Common ONAP Service used by ONAP and + * DMAAP Blueprint to add Common ONAP Service to add External Certificate Parameters Factory */ - - @Service -public class ExternalCertificateParametersFactoryService extends ExternalCertificateDataFactoryService { +public class ExternalCertificateParametersFactoryService + extends ExternalCertificateDataFactoryService { @Autowired private BlueprintHelperService blueprintHelperService; - // method to create external certificate parameters + /** + * Creates external certificate parameters + * + * @return + */ public ExternalCertificateParameters create() { - ExternalCertificateParameters externalCertificateParameters = new ExternalCertificateParameters(); - externalCertificateParameters.setCommonName(createPrefixedGetInput(Constants.COMMON_NAME_FIELD)); + ExternalCertificateParameters externalCertificateParameters = + new ExternalCertificateParameters(); + externalCertificateParameters.setCommonName( + createPrefixedGetInput(Constants.COMMON_NAME_FIELD)); externalCertificateParameters.setSans(createPrefixedGetInput(Constants.SANS_FIELD)); return externalCertificateParameters; } - // method to create input list for external certificate parameters factory + /** + * Creates input list for external certificate parameters factory + * + * @return + */ public Map<String, LinkedHashMap<String, Object>> createInputList() { Map<String, LinkedHashMap<String, Object>> retInputs = new LinkedHashMap<>(); - LinkedHashMap<String, Object> commonNameInputMap = blueprintHelperService - .createStringInput("Common name which should be present in certificate.", Constants.DEFAULT_COMMON_NAME); + LinkedHashMap<String, Object> commonNameInputMap = + blueprintHelperService.createStringInput( + "Common name which should be present in certificate.", + Constants.DEFAULT_COMMON_NAME); retInputs.put(addPrefix(Constants.COMMON_NAME_FIELD), commonNameInputMap); - LinkedHashMap<String, Object> sansInputMap = blueprintHelperService - .createStringInput("\"List of Subject Alternative Names (SANs) which should be present in certificate. " + - "Delimiter - , Should contain a common_name value and other FQDNs under which the given " - + "component is accessible.\"", Constants.DEFAULT_SANS); + LinkedHashMap<String, Object> sansInputMap = + blueprintHelperService.createStringInput( + "\"List of Subject Alternative Names (SANs) which should be present in certificate. " + + "Delimiter - , Should contain a common_name value and other FQDNs under which the given " + + "component is accessible.\"", + Constants.DEFAULT_SANS); retInputs.put(addPrefix(Constants.SANS_FIELD), sansInputMap); return retInputs; } - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/ExternalTlsInfoFactoryService.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/ExternalTlsInfoFactoryService.java index 10364ab..0694821 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/ExternalTlsInfoFactoryService.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/ExternalTlsInfoFactoryService.java @@ -36,12 +36,9 @@ import java.util.Map; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * Common ONAP Service used by ONAP and DMAAP Blueprint to add External TLS Info + * @date 10/16/2020 Application: ONAP - Blueprint Generator Common ONAP Service to add External TLS + * Info */ - - @Service public class ExternalTlsInfoFactoryService extends ExternalCertificateDataFactoryService { @@ -51,37 +48,58 @@ public class ExternalTlsInfoFactoryService extends ExternalCertificateDataFactor @Autowired private BlueprintHelperService blueprintHelperService; - //Method to create External TLS Info from Component Spec + /** + * Creates External TLS Info from Component Spec + * + * @param cs ComponentSpec + * @return + */ public ExternalTlsInfo createFromComponentSpec(OnapComponentSpec cs) { ExternalTlsInfo externalTlsInfoBp = new ExternalTlsInfo(); Map<String, Object> tlsInfoCs = cs.getAuxilary().getTls_info(); - externalTlsInfoBp.setExternalCertDirectory((String) tlsInfoCs.get(Constants.CERT_DIRECTORY_FIELD)); - externalTlsInfoBp.setUseExternalTls(createPrefixedGetInput(Constants.USE_EXTERNAL_TLS_FIELD)); + externalTlsInfoBp.setExternalCertDirectory( + (String) tlsInfoCs.get(Constants.CERT_DIRECTORY_FIELD)); + externalTlsInfoBp + .setUseExternalTls(createPrefixedGetInput(Constants.USE_EXTERNAL_TLS_FIELD)); externalTlsInfoBp.setCaName(createPrefixedGetInput(Constants.CA_NAME_FIELD)); externalTlsInfoBp.setCertType(createPrefixedGetInput(Constants.CERT_TYPE_FIELD)); - externalTlsInfoBp.setExternalCertificateParameters(externalCertificateParametersFactoryService.create()); + externalTlsInfoBp.setExternalCertificateParameters( + externalCertificateParametersFactoryService.create()); return externalTlsInfoBp; } - //Method to create Input List for External TLS Info from Component Spec - public Map<String, LinkedHashMap<String, Object>> createInputListFromComponentSpec(OnapComponentSpec cs) { + /** + * Creates Input List for External TLS Info from Component Spec + * + * @param cs ComponentSpec + * @return + */ + public Map<String, LinkedHashMap<String, Object>> createInputListFromComponentSpec( + OnapComponentSpec cs) { Map<String, LinkedHashMap<String, Object>> retInputs = new HashMap<>(); Map<String, Object> externalTlsInfoCs = cs.getAuxilary().getTls_info(); - LinkedHashMap<String, Object> useTlsFlagInput = blueprintHelperService.createBooleanInput("Flag to indicate external tls enable/disable.",externalTlsInfoCs.get(Constants.USE_EXTERNAL_TLS_FIELD)); + LinkedHashMap<String, Object> useTlsFlagInput = + blueprintHelperService.createBooleanInput( + "Flag to indicate external tls enable/disable.", + externalTlsInfoCs.get(Constants.USE_EXTERNAL_TLS_FIELD)); retInputs.put(addPrefix(Constants.USE_EXTERNAL_TLS_FIELD), useTlsFlagInput); - LinkedHashMap<String, Object> caNameInputMap = blueprintHelperService.createStringInput("Name of Certificate Authority configured on CertService side.",Constants.DEFAULT_CA); + LinkedHashMap<String, Object> caNameInputMap = + blueprintHelperService.createStringInput( + "Name of Certificate Authority configured on CertService side.", + Constants.DEFAULT_CA); retInputs.put(addPrefix(Constants.CA_NAME_FIELD), caNameInputMap); - LinkedHashMap<String, Object> certTypeInputMap = blueprintHelperService.createStringInput("Format of provided certificates",Constants.DEFAULT_CERT_TYPE); + LinkedHashMap<String, Object> certTypeInputMap = + blueprintHelperService.createStringInput( + "Format of provided certificates", Constants.DEFAULT_CERT_TYPE); retInputs.put(addPrefix(Constants.CERT_TYPE_FIELD), certTypeInputMap); retInputs.putAll(externalCertificateParametersFactoryService.createInputList()); return retInputs; } - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/ImportsService.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/ImportsService.java index cb9c03c..6fa43da 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/ImportsService.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/ImportsService.java @@ -37,12 +37,9 @@ import java.util.List; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: DCAE/ONAP - Blueprint Generator - * Common Module: Used by ONAP Blueprint Application - * Service: For Imports + * @date 10/16/2020 Application: DCAE/ONAP - Blueprint Generator Common Module: Used by ONAP + * Blueprint Application Service: For Imports */ - @Service public class ImportsService { @@ -64,11 +61,16 @@ public class ImportsService { @Value("${import.Clamp}") private String importClamp; - @Qualifier("yamlObjectMapper") @Autowired protected ObjectMapper yamlObjectMapper; + /** + * Creates Imports for Blueprint based on Blueprint Type + * + * @param bpType Blueprint Type + * @return + */ public List<String> createImports(String bpType) { List<String> imports = new ArrayList<>(); if (bpType.equals("o")) { @@ -77,8 +79,7 @@ public class ImportsService { imports.add(importsOnapK8sDcaepolicyplugin); imports.add(importPostgres); imports.add(importClamp); - } - else { + } else { imports.add(importsOnapTypes); imports.add(importsOnapK8sPlugintypes); imports.add(importsDmaapDmaapplugin); @@ -88,11 +89,16 @@ public class ImportsService { return imports; } + /** + * Creates Imports for Blueprint from the file path provided + * + * @param path Path of Import File + * @return + */ public List<String> createImportsFromFile(String path) throws IOException { File importPath = new File(path); Imports imports = yamlObjectMapper.readValue(importPath, Imports.class); imports.getImports().removeIf(String::isBlank); return imports.getImports(); } - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/InterfacesService.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/InterfacesService.java index bfd14a4..a14204f 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/InterfacesService.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/InterfacesService.java @@ -35,22 +35,26 @@ import java.util.Map; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * Common ONAP Service used by ONAP and DMAAP Blueprint to add Interfaces + * @date 10/16/2020 Application: ONAP - Blueprint Generator Common ONAP Service to add Interfaces */ - - @Service public class InterfacesService { @Autowired private StartService startService; - // Method to create Interface to include Start and Start inputs sections in BP - public Map<String,Object> createInterface(Map<String, LinkedHashMap<String, Object>> inputs, OnapComponentSpec onapComponentSpec){ + /** + * Creates Interface to include Start and Start inputs sections in BP for given Inputs and + * ComponentSpec + * + * @param inputs Inputs + * @param onapComponentSpec OnapComponentSpec + * @return + */ + public Map<String, Object> createInterface( + Map<String, LinkedHashMap<String, Object>> inputs, OnapComponentSpec onapComponentSpec) { - Map<String,Object> response = new HashMap<>(); + Map<String, Object> response = new HashMap<>(); Interfaces interfaces = new Interfaces(); Map<String, Object> startResponse = startService.createStart(inputs, onapComponentSpec); @@ -62,6 +66,4 @@ public class InterfacesService { response.put("inputs", inputs); return response; } - } - diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/NodeService.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/NodeService.java index b8da0d7..ab1b7f2 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/NodeService.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/NodeService.java @@ -42,15 +42,11 @@ import java.util.HashMap; import java.util.TreeMap; import java.util.List; - /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * Common ONAP Service used by ONAP and DMAAP Blueprint to add ONAP/DMAAP/Feed/Topic Nodes + * @date 10/16/2020 Application: ONAP - Blueprint Generator Common ONAP Service to add + * ONAP/DMAAP/Feed/Topic Nodes */ - - @Service public class NodeService { @@ -69,68 +65,97 @@ public class NodeService { @Autowired private BlueprintHelperService blueprintHelperService; - // method to create Onap Node to include interface - public Map<String,Object> createOnapNode(Map<String, LinkedHashMap<String, Object>> inputs, OnapComponentSpec onapComponentSpec, String override) { - - Map<String,Object> response = new HashMap<>(); + /** + * Creates Onap Node to include interface + * + * @param inputs Inputs + * @param onapComponentSpec OnapComponentSpec + * @param override Service Name Override + * @return + */ + public Map<String, Object> createOnapNode( + Map<String, LinkedHashMap<String, Object>> inputs, + OnapComponentSpec onapComponentSpec, + String override) { + + Map<String, Object> response = new HashMap<>(); Node onapNode = new Node(); - Map<String, Object> onapResponse = interfacesService.createInterface(inputs, onapComponentSpec); + Map<String, Object> onapResponse = interfacesService + .createInterface(inputs, onapComponentSpec); inputs = (Map<String, LinkedHashMap<String, Object>>) onapResponse.get("inputs"); Map<String, Interfaces> interfaces = new TreeMap<>(); - interfaces.put(Constants.CLOUDIFY_INTERFACES_LEFECYCLE, (Interfaces) onapResponse.get("interfaces")); + interfaces.put( + Constants.CLOUDIFY_INTERFACES_LEFECYCLE, (Interfaces) onapResponse.get("interfaces")); onapNode.setInterfaces(interfaces); onapNode.setType(Constants.DCAE_NODES_CONTAINERIZED_SERVICE_COMPONENT); List<Map<String, String>> relationships = new ArrayList(); - if(onapComponentSpec.getPolicyInfo() != null){ - List<Map<String, String>> policyRelationshipsList = policyNodeService.getPolicyRelationships(onapComponentSpec); + if (onapComponentSpec.getPolicyInfo() != null) { + List<Map<String, String>> policyRelationshipsList = + policyNodeService.getPolicyRelationships(onapComponentSpec); relationships.addAll(policyRelationshipsList); } - if(onapComponentSpec.getAuxilary().getDatabases() != null){ - List<Map<String, String>> pgaasRelationshipsList = pgaasNodeService.getPgaasNodeRelationships(onapComponentSpec); + if (onapComponentSpec.getAuxilary().getDatabases() != null) { + List<Map<String, String>> pgaasRelationshipsList = + pgaasNodeService.getPgaasNodeRelationships(onapComponentSpec); relationships.addAll(pgaasRelationshipsList); } onapNode.setRelationships(relationships); - Map<String, Object> propertiesResponse = propertiesService.createOnapProperties(inputs, onapComponentSpec, override); + Map<String, Object> propertiesResponse = + propertiesService.createOnapProperties(inputs, onapComponentSpec, override); inputs = (Map<String, LinkedHashMap<String, Object>>) propertiesResponse.get("inputs"); - onapNode.setProperties((org.onap.blueprintgenerator.model.common.Properties)propertiesResponse.get("properties")); + onapNode.setProperties( + (org.onap.blueprintgenerator.model.common.Properties) propertiesResponse + .get("properties")); response.put("onapNode", onapNode); response.put("inputs", inputs); return response; } - // method to create Dmaap Node to include interface - public Map<String,Object> createDmaapNode(OnapComponentSpec onapComponentSpec, Map<String, LinkedHashMap<String, Object>> inputs, String override) { - - Map<String,Object> response = new HashMap<>(); + /** + * Creates Dmaap Node to include interface + * + * @param inputs Inputs + * @param onapComponentSpec OnapComponentSpec + * @param override Service Name Override + * @return + */ + public Map<String, Object> createDmaapNode( + OnapComponentSpec onapComponentSpec, + Map<String, LinkedHashMap<String, Object>> inputs, + String override) { + + Map<String, Object> response = new HashMap<>(); Node dmaapNode = new Node(); dmaapNode.setType(Constants.DCAE_NODES_CONTAINERIZED_SERVICE_COMPONENT_USING_DMAAP); - Map<String, Object> dmaapResponse = interfacesService.createInterface(inputs, onapComponentSpec); + Map<String, Object> dmaapResponse = + interfacesService.createInterface(inputs, onapComponentSpec); inputs = (Map<String, LinkedHashMap<String, Object>>) dmaapResponse.get("inputs"); Map<String, Interfaces> interfaces = new TreeMap<>(); - interfaces.put(Constants.CLOUDIFY_INTERFACES_LEFECYCLE, (Interfaces) dmaapResponse.get("interfaces")); + interfaces.put( + Constants.CLOUDIFY_INTERFACES_LEFECYCLE, (Interfaces) dmaapResponse.get("interfaces")); dmaapNode.setInterfaces(interfaces); List<Map<String, String>> relationships = new ArrayList(); - if(onapComponentSpec.getStreams().getPublishes() != null) { - for(Publishes publishes: onapComponentSpec.getStreams().getPublishes()) { + if (onapComponentSpec.getStreams().getPublishes() != null) { + for (Publishes publishes : onapComponentSpec.getStreams().getPublishes()) { Map<String, String> pubRelations = new LinkedHashMap(); - if(blueprintHelperService.isMessageRouterType(publishes.getType())){ + if (blueprintHelperService.isMessageRouterType(publishes.getType())) { pubRelations.put("type", Constants.PUBLISH_EVENTS); pubRelations.put("target", publishes.getConfig_key() + Constants._TOPIC); - } else if(blueprintHelperService.isDataRouterType(publishes.getType())){ + } else if (blueprintHelperService.isDataRouterType(publishes.getType())) { pubRelations.put("type", Constants.PUBLISH_FILES); pubRelations.put("target", publishes.getConfig_key() + Constants._FEED); } @@ -138,13 +163,13 @@ public class NodeService { } } - if(onapComponentSpec.getStreams().getSubscribes() != null) { - for(Subscribes subscribes: onapComponentSpec.getStreams().getSubscribes()) { - Map<String, String> subRelations = new LinkedHashMap(); - if(blueprintHelperService.isMessageRouterType(subscribes.getType())){ + if (onapComponentSpec.getStreams().getSubscribes() != null) { + for (Subscribes subscribes : onapComponentSpec.getStreams().getSubscribes()) { + Map<String, String> subRelations = new LinkedHashMap(); + if (blueprintHelperService.isMessageRouterType(subscribes.getType())) { subRelations.put("type", Constants.SUBSCRIBE_TO_EVENTS); subRelations.put("target", subscribes.getConfig_key() + Constants._TOPIC); - } else if(blueprintHelperService.isDataRouterType(subscribes.getType())){ + } else if (blueprintHelperService.isDataRouterType(subscribes.getType())) { subRelations.put("type", Constants.SUBSCRIBE_TO_FILES); subRelations.put("target", subscribes.getConfig_key() + Constants._FEED); } @@ -152,30 +177,42 @@ public class NodeService { } } - if(onapComponentSpec.getPolicyInfo() != null){ - List<Map<String, String>> policyRelationshipsList = policyNodeService.getPolicyRelationships(onapComponentSpec); + if (onapComponentSpec.getPolicyInfo() != null) { + List<Map<String, String>> policyRelationshipsList = + policyNodeService.getPolicyRelationships(onapComponentSpec); relationships.addAll(policyRelationshipsList); } - if(onapComponentSpec.getAuxilary().getDatabases() != null){ - List<Map<String, String>> pgaasRelationshipsList = pgaasNodeService.getPgaasNodeRelationships(onapComponentSpec); + if (onapComponentSpec.getAuxilary().getDatabases() != null) { + List<Map<String, String>> pgaasRelationshipsList = + pgaasNodeService.getPgaasNodeRelationships(onapComponentSpec); relationships.addAll(pgaasRelationshipsList); } dmaapNode.setRelationships(relationships); - Map<String, Object> propertiesResponse = propertiesService.createDmaapProperties(inputs, onapComponentSpec, override); + Map<String, Object> propertiesResponse = + propertiesService.createDmaapProperties(inputs, onapComponentSpec, override); inputs = (Map<String, LinkedHashMap<String, Object>>) propertiesResponse.get("inputs"); - dmaapNode.setProperties((org.onap.blueprintgenerator.model.common.Properties)propertiesResponse.get("properties")); + dmaapNode.setProperties( + (org.onap.blueprintgenerator.model.common.Properties) propertiesResponse + .get("properties")); response.put("dmaapNode", dmaapNode); response.put("inputs", inputs); return response; } - // method to create Feed Node for Streams - public Map<String,Object> createFeedNode(Map<String, LinkedHashMap<String, Object>> inputs, String name){ - Map<String,Object> response = new HashMap<>(); + /** + * Creates Feed Node for Streams + * + * @param inputs Inputs + * @param name Name + * @return + */ + public Map<String, Object> createFeedNode( + Map<String, LinkedHashMap<String, Object>> inputs, String name) { + Map<String, Object> response = new HashMap<>(); Node feedNode = new Node(); LinkedHashMap<String, Object> stringType = new LinkedHashMap(); @@ -183,7 +220,8 @@ public class NodeService { feedNode.setType(Constants.FEED); - org.onap.blueprintgenerator.model.common.Properties props = new org.onap.blueprintgenerator.model.common.Properties(); + org.onap.blueprintgenerator.model.common.Properties props = + new org.onap.blueprintgenerator.model.common.Properties(); GetInput topicInput = new GetInput(); topicInput.setBpInputName(name + "_name"); props.setFeed_name(topicInput); @@ -196,9 +234,16 @@ public class NodeService { return response; } - // method to create Topic Node for Streams - public Map<String,Object> createTopicNode(Map<String, LinkedHashMap<String, Object>> inputs, String name){ - Map<String,Object> response = new HashMap<>(); + /** + * Creates Topic Node for Streams + * + * @param inputs Inpts + * @param name Name + * @return + */ + public Map<String, Object> createTopicNode( + Map<String, LinkedHashMap<String, Object>> inputs, String name) { + Map<String, Object> response = new HashMap<>(); Node topicNode = new Node(); LinkedHashMap<String, Object> stringType = new LinkedHashMap(); @@ -217,6 +262,4 @@ public class NodeService { response.put("inputs", inputs); return response; } - - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/PgaasNodeService.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/PgaasNodeService.java index ff45701..d18ca92 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/PgaasNodeService.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/PgaasNodeService.java @@ -26,7 +26,6 @@ package org.onap.blueprintgenerator.service.common; import org.onap.blueprintgenerator.constants.Constants; import org.onap.blueprintgenerator.exception.DatabasesNotFoundException; - import org.onap.blueprintgenerator.model.common.Node; import org.onap.blueprintgenerator.model.common.PgaasNode; import org.onap.blueprintgenerator.model.common.GetInput; @@ -45,30 +44,43 @@ import java.util.List; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * Common ONAP Service used by ONAP and DMAAP Blueprint to add Pgaas Node + * @date 10/16/2020 Application: ONAP - Blueprint Generator Common ONAP Service to add Pgaas Node */ - - @Service public class PgaasNodeService { @Autowired private BlueprintHelperService blueprintHelperService; - // method to create Pgaas Nodes and Inputs for Databases - public void addPgaasNodesAndInputs(OnapComponentSpec onapComponentSpec, Map<String, Node> nodeTemplate, Map<String, LinkedHashMap<String, Object>> inputs) { + /** + * Creates Pgaas Nodes and Inputs for Databases + * + * @param onapComponentSpec OnapComponentSpec + * @param nodeTemplate Node template + * @param inputs Inputs + * @return + */ + public void addPgaasNodesAndInputs( + OnapComponentSpec onapComponentSpec, + Map<String, Node> nodeTemplate, + Map<String, LinkedHashMap<String, Object>> inputs) { Map<String, String> databases = onapComponentSpec.getAuxilary().getDatabases(); - for(Map.Entry<String, String> database : databases.entrySet()){ - addPgaasNode(database, nodeTemplate); - addPgaasInputs(database, inputs); + if (databases != null) { + for (Map.Entry<String, String> database : databases.entrySet()) { + addPgaasNode(database, nodeTemplate); + addPgaasInputs(database, inputs); + } } } - private void addPgaasInputs(Map.Entry<String, String> database, Map<String, LinkedHashMap<String, Object>> inputs) { - inputs.put(database.getKey() + Constants.NAME_POSTFIX, blueprintHelperService.createStringInput( "db name", "")); - inputs.put(database.getKey() + Constants.WRITER_FQDN_POSTFIX, blueprintHelperService.createStringInput( "db writerfqdn", "")); + private void addPgaasInputs( + Map.Entry<String, String> database, Map<String, LinkedHashMap<String, Object>> inputs) { + inputs.put( + database.getKey() + Constants.NAME_POSTFIX, + blueprintHelperService.createStringInput("db name", "")); + inputs.put( + database.getKey() + Constants.WRITER_FQDN_POSTFIX, + blueprintHelperService.createStringInput("db writerfqdn", "")); } private void addPgaasNode(Map.Entry<String, String> database, Map<String, Node> nodeTemplate) { @@ -76,7 +88,7 @@ public class PgaasNodeService { String dbName = database.getKey(); pgaasNode.setType(Constants.PGAAS_NODE_TYPE); pgaasNode.setPgaasNodeProperties(buildPgaasNodeProperties(dbName)); - nodeTemplate.put(dbName + Constants.PGAAS_NODE_NAME_POSTFIX , pgaasNode); + nodeTemplate.put(dbName + Constants.PGAAS_NODE_NAME_POSTFIX, pgaasNode); } private PgaasNodeProperties buildPgaasNodeProperties(String dbName) { @@ -95,10 +107,17 @@ public class PgaasNodeService { return pgaasNodeProperties; } - // method to create Pgaas Node Relationships for Databases - public List<Map<String, String>> getPgaasNodeRelationships(OnapComponentSpec onapComponentSpec) { + /** + * Creates Pgaas Nodes Relationships for Databases + * + * @param onapComponentSpec OnapComponentSpec + * @return + */ + public List<Map<String, String>> getPgaasNodeRelationships( + OnapComponentSpec onapComponentSpec) { List<Map<String, String>> relationships = new ArrayList<>(); - for(Map.Entry<String, String> database : onapComponentSpec.getAuxilary().getDatabases().entrySet()){ + for (Map.Entry<String, String> database : + onapComponentSpec.getAuxilary().getDatabases().entrySet()) { Map<String, String> relationship = new LinkedHashMap<>(); relationship.put("type", Constants.DB_RELATIONSHIP_TYPE); relationship.put("target", database.getKey() + Constants.PGAAS_NODE_NAME_POSTFIX); @@ -107,10 +126,15 @@ public class PgaasNodeService { return relationships; } - // method to create Env Variables for Databases + /** + * Creates Env Variables for Databases + * + * @param databases Database + * @return + */ public Map<String, Object> getEnvVariables(Map<String, String> databases) { Map<String, Object> envVariables = new LinkedHashMap<>(); - for(Map.Entry<String, String> database : databases.entrySet()){ + for (Map.Entry<String, String> database : databases.entrySet()) { String name = database.getKey().toUpperCase(); envVariables.put("<<", "*envs"); @@ -118,21 +142,25 @@ public class PgaasNodeService { nameValue.setBpInputName(name.toLowerCase() + Constants.NAME_POSTFIX); envVariables.put(name + "_DB_NAME", nameValue); - GetAttribute adminHostValue = buildGetAttributeValue(name.toLowerCase(), "admin", "host"); - envVariables.put( name.toUpperCase() + "_DB_ADMIN_HOST", adminHostValue); + GetAttribute adminHostValue = buildGetAttributeValue(name.toLowerCase(), "admin", + "host"); + envVariables.put(name.toUpperCase() + "_DB_ADMIN_HOST", adminHostValue); - GetAttribute adminUserValue = buildGetAttributeValue(name.toLowerCase(), "admin", "user"); - envVariables.put( name.toUpperCase() + "_DB_ADMIN_USER", adminUserValue); + GetAttribute adminUserValue = buildGetAttributeValue(name.toLowerCase(), "admin", + "user"); + envVariables.put(name.toUpperCase() + "_DB_ADMIN_USER", adminUserValue); - GetAttribute adminPasswordValue = buildGetAttributeValue(name.toLowerCase(), "admin", "password"); - envVariables.put( name.toUpperCase() + "_DB_ADMIN_PASS", adminPasswordValue); + GetAttribute adminPasswordValue = + buildGetAttributeValue(name.toLowerCase(), "admin", "password"); + envVariables.put(name.toUpperCase() + "_DB_ADMIN_PASS", adminPasswordValue); } return envVariables; } private GetAttribute buildGetAttributeValue(String dbName, String owner, String type) { GetAttribute attribute = new GetAttribute(); - attribute.setAttribute(Arrays.asList(dbName + Constants.PGAAS_NODE_NAME_POSTFIX, owner, type)); + attribute + .setAttribute(Arrays.asList(dbName + Constants.PGAAS_NODE_NAME_POSTFIX, owner, type)); return attribute; } } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/PolicyNodeService.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/PolicyNodeService.java index 7f6c63d..43d819f 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/PolicyNodeService.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/PolicyNodeService.java @@ -41,31 +41,40 @@ import java.util.Map; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * Common ONAP Service used by ONAP and DMAAP Blueprint to add Policy Node + * @date 10/16/2020 Application: ONAP - Blueprint Generator Common ONAP Service to add Policy Node */ - - @Service("onapPolicyNodeService") public class PolicyNodeService { @Autowired private BlueprintHelperService blueprintHelperService; - // Method to add Policy Nodes and Inputs - public void addPolicyNodesAndInputs(OnapComponentSpec onapComponentSpec, Map<String, Node> nodeTemplate, Map<String, LinkedHashMap<String, Object>> inputs) { + /** + * Creates Policy Nodes and Inputs + * + * @param onapComponentSpec OnapComponentSpec + * @param nodeTemplate Node Template + * @param inputs Inputs + * @return + */ + public void addPolicyNodesAndInputs( + OnapComponentSpec onapComponentSpec, + Map<String, Node> nodeTemplate, + Map<String, LinkedHashMap<String, Object>> inputs) { List<TypePolicy> policyList = onapComponentSpec.getPolicyInfo().getTypePolicyList(); - for(TypePolicy policy: policyList){ + for (TypePolicy policy : policyList) { addPolicyNodesToNodeTemplate(policy, nodeTemplate); addPolicyInputs(policy, inputs); } } - private void addPolicyInputs(TypePolicy policy, Map<String, LinkedHashMap<String, Object>> inputs) { + private void addPolicyInputs( + TypePolicy policy, Map<String, LinkedHashMap<String, Object>> inputs) { String defaultValue = policy.getPolicy_id(); defaultValue = defaultValue != null ? defaultValue : ""; - inputs.put(policy.getNode_label() + "_policy_id", blueprintHelperService.createStringInput("policy_id", defaultValue)); + inputs.put( + policy.getNode_label() + "_policy_id", + blueprintHelperService.createStringInput("policy_id", defaultValue)); } private void addPolicyNodesToNodeTemplate(TypePolicy policy, Map<String, Node> nodeTemplate) { @@ -84,11 +93,16 @@ public class PolicyNodeService { return policyNodeProperties; } - // Method to add Policy Relationships + /** + * Creates Policy Relationships + * + * @param onapComponentSpec OnapComponentSpec + * @return + */ public List<Map<String, String>> getPolicyRelationships(OnapComponentSpec onapComponentSpec) { List<Map<String, String>> relationships = new ArrayList<>(); List<TypePolicy> policyList = onapComponentSpec.getPolicyInfo().getTypePolicyList(); - for(TypePolicy policy: policyList){ + for (TypePolicy policy : policyList) { Map<String, String> relationship = new LinkedHashMap<>(); relationship.put("type", Constants.POLICY_RELATIONSHIP_TYPE); relationship.put("target", policy.getNode_label()); diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/PropertiesService.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/PropertiesService.java index e858d88..3c36cca 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/PropertiesService.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/PropertiesService.java @@ -47,13 +47,9 @@ import java.util.List; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * Common ONAP Service used by ONAP and DMAAP Blueprint to create Properties Node + * @date 10/16/2020 Application: ONAP - Blueprint Generator Common ONAP Service to create Properties + * Node */ - - - @Service("onapPropertiesService") public class PropertiesService { @@ -72,18 +68,30 @@ public class PropertiesService { @Autowired private BlueprintHelperService blueprintHelperService; - // Method to create ONAP properties - public Map<String,Object> createOnapProperties(Map<String, LinkedHashMap<String, Object>> inputs, OnapComponentSpec onapComponentSpec, String override) { - Map<String,Object> response = new HashMap<>(); - org.onap.blueprintgenerator.model.common.Properties properties = new org.onap.blueprintgenerator.model.common.Properties(); + /** + * Creates ONAP properties + * + * @param inputs Inputs + * @param onapComponentSpec OnapComponentSpec + * @param override Override + * @return + */ + public Map<String, Object> createOnapProperties( + Map<String, LinkedHashMap<String, Object>> inputs, + OnapComponentSpec onapComponentSpec, + String override) { + Map<String, Object> response = new HashMap<>(); + org.onap.blueprintgenerator.model.common.Properties properties = + new org.onap.blueprintgenerator.model.common.Properties(); GetInput image = new GetInput(); image.setBpInputName("image"); properties.setImage(image); LinkedHashMap<String, Object> img = new LinkedHashMap<>(); - inputs.put("image", blueprintHelperService.createStringInput(onapComponentSpec.getArtifacts()[0].getUri())); - + inputs.put( + "image", + blueprintHelperService.createStringInput(onapComponentSpec.getArtifacts()[0].getUri())); GetInput location = new GetInput(); location.setBpInputName("location_id"); @@ -98,14 +106,16 @@ public class PropertiesService { replica.setBpInputName("replicas"); properties.setReplicas(replica); - LinkedHashMap<String, Object> replicas = blueprintHelperService.createIntegerInput("number of instances", 1); + LinkedHashMap<String, Object> replicas = + blueprintHelperService.createIntegerInput("number of instances", 1); inputs.put("replicas", replicas); OnapAuxilary onapAuxilary = onapComponentSpec.getAuxilary(); properties.setDocker_config(onapAuxilary); - Map<String, Object> appConfigResponse = appConfigService.createAppconfig(inputs, onapComponentSpec, override, false); + Map<String, Object> appConfigResponse = + appConfigService.createAppconfig(inputs, onapComponentSpec, override, false); inputs = (Map<String, LinkedHashMap<String, Object>>) appConfigResponse.get("inputs"); properties.setApplication_config((Appconfig) appConfigResponse.get("appconfig")); @@ -114,7 +124,9 @@ public class PropertiesService { properties.setAlways_pull_image(always_pull_image); - LinkedHashMap<String, Object> inputAlwaysPullImage = blueprintHelperService.createBooleanInput("Set to true if the image should always be pulled",true); + LinkedHashMap<String, Object> inputAlwaysPullImage = + blueprintHelperService.createBooleanInput( + "Set to true if the image should always be pulled", true); inputs.put("always_pull_image", inputAlwaysPullImage); String sType = onapComponentSpec.getSelf().getName(); @@ -122,33 +134,49 @@ public class PropertiesService { properties.setService_component_type(sType); Map<String, Object> tls_info = onapComponentSpec.getAuxilary().getTls_info(); - if(tls_info != null) { + if (tls_info != null) { addTlsInfo(onapComponentSpec, inputs, properties); if (tls_info.get(Constants.USE_EXTERNAL_TLS_FIELD) != null) { - inputs.putAll(addExternalTlsInfo(onapComponentSpec,properties)); + inputs.putAll(addExternalTlsInfo(onapComponentSpec, properties)); } } - Map<String, Object> resourceConfigResponse = resourceConfigService.createResourceConfig(inputs, onapComponentSpec.getSelf().getName()); + Map<String, Object> resourceConfigResponse = + resourceConfigService + .createResourceConfig(inputs, onapComponentSpec.getSelf().getName()); inputs = (Map<String, LinkedHashMap<String, Object>>) resourceConfigResponse.get("inputs"); - properties.setResource_config((ResourceConfig) resourceConfigResponse.get("resourceConfig")); + properties + .setResource_config((ResourceConfig) resourceConfigResponse.get("resourceConfig")); response.put("properties", properties); response.put("inputs", inputs); return response; } - // Method to create Dmaap properties - public Map<String,Object> createDmaapProperties(Map<String, LinkedHashMap<String, Object>> inputs, OnapComponentSpec onapComponentSpec, String override) { - Map<String,Object> response = new HashMap<>(); - org.onap.blueprintgenerator.model.common.Properties properties = new org.onap.blueprintgenerator.model.common.Properties(); + /** + * Creates Dmaap properties + * + * @param inputs Inputs + * @param onapComponentSpec OnapComponentSpec + * @param override Override + * @return + */ + public Map<String, Object> createDmaapProperties( + Map<String, LinkedHashMap<String, Object>> inputs, + OnapComponentSpec onapComponentSpec, + String override) { + Map<String, Object> response = new HashMap<>(); + org.onap.blueprintgenerator.model.common.Properties properties = + new org.onap.blueprintgenerator.model.common.Properties(); GetInput image = new GetInput(); image.setBpInputName("tag_version"); properties.setImage(image); LinkedHashMap<String, Object> img = new LinkedHashMap<>(); - inputs.put("tag_version", blueprintHelperService.createStringInput(onapComponentSpec.getArtifacts()[0].getUri())); + inputs.put( + "tag_version", + blueprintHelperService.createStringInput(onapComponentSpec.getArtifacts()[0].getUri())); GetInput location = new GetInput(); location.setBpInputName("location_id"); @@ -164,10 +192,10 @@ public class PropertiesService { properties.setService_component_type(sType); Map<String, Object> tls_info = onapComponentSpec.getAuxilary().getTls_info(); - if(tls_info != null) { + if (tls_info != null) { addTlsInfo(onapComponentSpec, inputs, properties); if (tls_info.get(Constants.USE_EXTERNAL_TLS_FIELD) != null) { - inputs.putAll(addExternalTlsInfo(onapComponentSpec,properties)); + inputs.putAll(addExternalTlsInfo(onapComponentSpec, properties)); } } @@ -175,31 +203,50 @@ public class PropertiesService { replica.setBpInputName("replicas"); properties.setReplicas(replica); - LinkedHashMap<String, Object> rep = blueprintHelperService.createIntegerInput( "number of instances", 1); + LinkedHashMap<String, Object> rep = + blueprintHelperService.createIntegerInput("number of instances", 1); inputs.put("replicas", rep); OnapAuxilary onapAuxilary = onapComponentSpec.getAuxilary(); properties.setDocker_config(onapAuxilary); - Map<String, Object> appConfigResponse = appConfigService.createAppconfig(inputs, onapComponentSpec, override, true); + Map<String, Object> appConfigResponse = + appConfigService.createAppconfig(inputs, onapComponentSpec, override, true); inputs = (Map<String, LinkedHashMap<String, Object>>) appConfigResponse.get("inputs"); properties.setApplication_config((Appconfig) appConfigResponse.get("appconfig")); - List<Streams> pubStreams = new ArrayList(); - if(onapComponentSpec.getStreams() != null) { + if (onapComponentSpec.getStreams() != null) { if (onapComponentSpec.getStreams().getPublishes() != null) { for (Publishes publishes : onapComponentSpec.getStreams().getPublishes()) { if (blueprintHelperService.isMessageRouterType(publishes.getType())) { String topic = publishes.getConfig_key() + Constants._TOPIC; - Map<String, Object> streamsMessageRouterResponse = streamsService.createStreams(inputs, topic, publishes.getType(), publishes.getConfig_key(), publishes.getRoute(), 'p'); - inputs = (Map<String, LinkedHashMap<String, Object>>) streamsMessageRouterResponse.get("inputs"); + Map<String, Object> streamsMessageRouterResponse = + streamsService.createStreams( + inputs, + topic, + publishes.getType(), + publishes.getConfig_key(), + publishes.getRoute(), + 'p'); + inputs = + (Map<String, LinkedHashMap<String, Object>>) + streamsMessageRouterResponse.get("inputs"); pubStreams.add((Streams) streamsMessageRouterResponse.get("streams")); } else if (blueprintHelperService.isDataRouterType(publishes.getType())) { String feed = publishes.getConfig_key() + Constants._FEED; - Map<String, Object> streamsDataRouterResponse = streamsService.createStreams(inputs, feed, publishes.getType(), publishes.getConfig_key(), publishes.getRoute(), 'p'); - inputs = (Map<String, LinkedHashMap<String, Object>>) streamsDataRouterResponse.get("inputs"); + Map<String, Object> streamsDataRouterResponse = + streamsService.createStreams( + inputs, + feed, + publishes.getType(), + publishes.getConfig_key(), + publishes.getRoute(), + 'p'); + inputs = + (Map<String, LinkedHashMap<String, Object>>) + streamsDataRouterResponse.get("inputs"); pubStreams.add((Streams) streamsDataRouterResponse.get("streams")); } } @@ -207,53 +254,84 @@ public class PropertiesService { } ArrayList<Streams> subStreams = new ArrayList(); - if(onapComponentSpec.getStreams() != null) { + if (onapComponentSpec.getStreams() != null) { if (onapComponentSpec.getStreams().getSubscribes() != null) { for (Subscribes subscribes : onapComponentSpec.getStreams().getSubscribes()) { if (blueprintHelperService.isMessageRouterType(subscribes.getType())) { String topic = subscribes.getConfig_key() + Constants._TOPIC; - Map<String, Object> streamsMessageRouterResponse = streamsService.createStreams(inputs, topic, subscribes.getType(), subscribes.getConfig_key(), subscribes.getRoute(), 's'); - inputs = (Map<String, LinkedHashMap<String, Object>>) streamsMessageRouterResponse.get("inputs"); + Map<String, Object> streamsMessageRouterResponse = + streamsService.createStreams( + inputs, + topic, + subscribes.getType(), + subscribes.getConfig_key(), + subscribes.getRoute(), + 's'); + inputs = + (Map<String, LinkedHashMap<String, Object>>) + streamsMessageRouterResponse.get("inputs"); subStreams.add((Streams) streamsMessageRouterResponse.get("streams")); } else if (blueprintHelperService.isDataRouterType(subscribes.getType())) { String feed = subscribes.getConfig_key() + Constants._FEED; - Map<String, Object> streamsDataRouterResponse = streamsService.createStreams(inputs, feed, subscribes.getType(), subscribes.getConfig_key(), subscribes.getRoute(), 's'); - inputs = (Map<String, LinkedHashMap<String, Object>>) streamsDataRouterResponse.get("inputs"); + Map<String, Object> streamsDataRouterResponse = + streamsService.createStreams( + inputs, + feed, + subscribes.getType(), + subscribes.getConfig_key(), + subscribes.getRoute(), + 's'); + inputs = + (Map<String, LinkedHashMap<String, Object>>) + streamsDataRouterResponse.get("inputs"); subStreams.add((Streams) streamsDataRouterResponse.get("streams")); } } } } - if(!pubStreams.isEmpty()) + if (!pubStreams.isEmpty()) { properties.setStreams_publishes(pubStreams); + } - if(!subStreams.isEmpty()) + if (!subStreams.isEmpty()) { properties.setStreams_subscribes(subStreams); + } - Map<String, Object> resourceConfigResponse = resourceConfigService.createResourceConfig(inputs, onapComponentSpec.getSelf().getName()); + Map<String, Object> resourceConfigResponse = + resourceConfigService + .createResourceConfig(inputs, onapComponentSpec.getSelf().getName()); inputs = (Map<String, LinkedHashMap<String, Object>>) resourceConfigResponse.get("inputs"); - properties.setResource_config((ResourceConfig) resourceConfigResponse.get("resourceConfig")); + properties + .setResource_config((ResourceConfig) resourceConfigResponse.get("resourceConfig")); response.put("properties", properties); response.put("inputs", inputs); return response; } - private void addTlsInfo(OnapComponentSpec onapComponentSpec, Map<String, LinkedHashMap<String, Object>> inputs, Properties properties) { + private void addTlsInfo( + OnapComponentSpec onapComponentSpec, + Map<String, LinkedHashMap<String, Object>> inputs, + Properties properties) { TlsInfo tlsInfo = new TlsInfo(); - tlsInfo.setCertDirectory((String) onapComponentSpec.getAuxilary().getTls_info().get("cert_directory")); + tlsInfo.setCertDirectory( + (String) onapComponentSpec.getAuxilary().getTls_info().get("cert_directory")); GetInput useTLSFlag = new GetInput(); useTLSFlag.setBpInputName("use_tls"); tlsInfo.setUseTls(useTLSFlag); properties.setTls_info(tlsInfo); - LinkedHashMap<String, Object> useTlsFlagInput = blueprintHelperService.createBooleanInput("flag to indicate tls enable/disable",onapComponentSpec.getAuxilary().getTls_info().get("use_tls")); + LinkedHashMap<String, Object> useTlsFlagInput = + blueprintHelperService.createBooleanInput( + "flag to indicate tls enable/disable", + onapComponentSpec.getAuxilary().getTls_info().get("use_tls")); inputs.put("use_tls", useTlsFlagInput); } - private Map<String, LinkedHashMap<String, Object>> addExternalTlsInfo(OnapComponentSpec onapComponentSpec, Properties properties) { - properties.setExternal_cert(externalTlsInfoFactoryService.createFromComponentSpec(onapComponentSpec)); - return externalTlsInfoFactoryService.createInputListFromComponentSpec(onapComponentSpec); - } - + private Map<String, LinkedHashMap<String, Object>> addExternalTlsInfo( + OnapComponentSpec onapComponentSpec, Properties properties) { + properties.setExternal_cert( + externalTlsInfoFactoryService.createFromComponentSpec(onapComponentSpec)); + return externalTlsInfoFactoryService.createInputListFromComponentSpec(onapComponentSpec); + } } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/QuotationService.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/QuotationService.java index c79ec56..642a13e 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/QuotationService.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/QuotationService.java @@ -30,22 +30,24 @@ import java.util.LinkedHashMap; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * Common ONAP Service used by ONAP and DMAAP Blueprint to set Quotations of generated Blueprint + * @date 10/16/2020 Application: ONAP - Blueprint Generator Common ONAP Service to set Quotations of + * generated Blueprint */ - - @Service public class QuotationService { - // Method to add Quotes for String Types + /** + * Adds Quotes for String Types for generated Blueprint + * + * @param bp Blueprint + * @return + */ public OnapBlueprint setQuotations(OnapBlueprint bp) { - for(String s: bp.getInputs().keySet()) { + for (String s : bp.getInputs().keySet()) { LinkedHashMap<String, Object> temp = bp.getInputs().get(s); - if(temp.get("type") == "string") { + if (temp.get("type") == "string") { String def = (String) temp.get("default"); - if(def != null){ + if (def != null) { def = def.replaceAll("\"$", "").replaceAll("^\"", ""); } def = '"' + def + '"'; @@ -55,5 +57,4 @@ public class QuotationService { } return bp; } - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/ResourceConfigService.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/ResourceConfigService.java index 7b03372..a3a9c97 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/ResourceConfigService.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/ResourceConfigService.java @@ -37,26 +37,32 @@ import java.util.TreeMap; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * Common ONAP Service used by ONAP and DMAAP Blueprint to add ResourceConfig + * @date 10/16/2020 Application: ONAP - Blueprint Generator Common ONAP Service to add + * ResourceConfig */ - - @Service("onapResourceConfigService") public class ResourceConfigService { @Autowired private BlueprintHelperService blueprintHelperService; - //Method to create Resouce Config for properties - public Map<String,Object> createResourceConfig(Map<String, LinkedHashMap<String, Object>> inputs, String name){ - Map<String,Object> response = new HashMap<>(); + /** + * Creates Resouce Config for properties + * + * @param inputs Inputs + * @param name Name + * @return + */ + public Map<String, Object> createResourceConfig( + Map<String, LinkedHashMap<String, Object>> inputs, String name) { + Map<String, Object> response = new HashMap<>(); ResourceConfig resourceConfig = new ResourceConfig(); - LinkedHashMap<String, Object> memoryLimit = blueprintHelperService.createStringInput(Constants.MEMORY_LIMIT_128Mi); + LinkedHashMap<String, Object> memoryLimit = + blueprintHelperService.createStringInput(Constants.MEMORY_LIMIT_128Mi); - LinkedHashMap<String, Object> cpuLimit = blueprintHelperService.createStringInput( Constants.CPU_LIMIT_250m); + LinkedHashMap<String, Object> cpuLimit = + blueprintHelperService.createStringInput(Constants.CPU_LIMIT_250m); name = blueprintHelperService.getNamePrefix(name); @@ -94,5 +100,4 @@ public class ResourceConfigService { response.put("inputs", inputs); return response; } - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/StartInputsService.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/StartInputsService.java index 20c3656..8ec0024 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/StartInputsService.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/StartInputsService.java @@ -38,22 +38,26 @@ import java.util.List; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * Common ONAP Service used by ONAP and DMAAP Blueprint to add Start Inputs Node under Start + * @date 10/16/2020 Application: ONAP - Blueprint Generator Common ONAP Service to add Start Inputs + * Node under Start */ - - @Service public class StartInputsService { @Autowired private PgaasNodeService pgaasNodeService; - //Method to create Start Inputs for Start in Interfaces - public Map<String, Object> createStartInputs(Map<String, LinkedHashMap<String, Object>> inputs, OnapComponentSpec onapComponentSpec){ - - Map<String,Object> response = new HashMap<>(); + /** + * Creates Start Inputs for Start in Interfaces + * + * @param inputs Inputs + * @param onapComponentSpec OnapComponentSpec + * @return + */ + public Map<String, Object> createStartInputs( + Map<String, LinkedHashMap<String, Object>> inputs, OnapComponentSpec onapComponentSpec) { + + Map<String, Object> response = new HashMap<>(); StartInputs startInputs = new StartInputs(); int count = 0; @@ -61,9 +65,11 @@ public class StartInputsService { OnapAuxilary aux = onapComponentSpec.getAuxilary(); if (aux.getPorts() != null) { - for(Object p : aux.getPorts()) { + for (Object p : aux.getPorts()) { String[] ports = p.toString().split(":"); - portList.add(String.format("concat: [\"%s:\", {get_input: external_port_%d}]" , ports[0], count)); + portList.add( + String.format("concat: [\"%s:\", {get_input: external_port_%d}]", ports[0], + count)); LinkedHashMap<String, Object> portType = new LinkedHashMap(); portType.put("type", "string"); @@ -76,12 +82,12 @@ public class StartInputsService { startInputs.setPorts(portList); LinkedHashMap<String, Object> envMap = new LinkedHashMap(); - if(onapComponentSpec.getAuxilary().getDatabases() != null){ - Map<String, Object> envVars = pgaasNodeService.getEnvVariables(onapComponentSpec.getAuxilary().getDatabases()); + if (onapComponentSpec.getAuxilary().getDatabases() != null) { + Map<String, Object> envVars = + pgaasNodeService.getEnvVariables(onapComponentSpec.getAuxilary().getDatabases()); startInputs.setEnvs(envVars); envMap.put("default", "&envs {}"); - } - else { + } else { GetInput env = new GetInput(); env.setBpInputName("envs"); startInputs.setEnvs(env); @@ -93,5 +99,4 @@ public class StartInputsService { response.put("inputs", inputs); return response; } - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/StartService.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/StartService.java index 3fbfdb1..6c92c6f 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/StartService.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/StartService.java @@ -23,7 +23,6 @@ package org.onap.blueprintgenerator.service.common; - import org.onap.blueprintgenerator.model.common.Start; import org.onap.blueprintgenerator.model.common.StartInputs; import org.onap.blueprintgenerator.model.componentspec.OnapComponentSpec; @@ -36,24 +35,28 @@ import java.util.Map; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * Common ONAP Service used by ONAP and DMAAP Blueprint to add Start Node + * @date 10/16/2020 Application: ONAP - Blueprint Generator Common ONAP Service to add Start Node */ - - @Service public class StartService { @Autowired private StartInputsService startInputsService; - // Method to create Start for Interfaces - public Map<String,Object> createStart(Map<String, LinkedHashMap<String, Object>> inputs, OnapComponentSpec onapComponentSpec) { - Map<String,Object> response = new HashMap<>(); + /** + * Creates Start for Interfaces + * + * @param inputs Inputs + * @param onapComponentSpec OnapComponentSpec + * @return + */ + public Map<String, Object> createStart( + Map<String, LinkedHashMap<String, Object>> inputs, OnapComponentSpec onapComponentSpec) { + Map<String, Object> response = new HashMap<>(); Start start = new Start(); - Map<String, Object> startInputsResponse = startInputsService.createStartInputs(inputs, onapComponentSpec); + Map<String, Object> startInputsResponse = + startInputsService.createStartInputs(inputs, onapComponentSpec); inputs = (Map<String, LinkedHashMap<String, Object>>) startInputsResponse.get("inputs"); start.setInputs((StartInputs) startInputsResponse.get("startInputs")); @@ -61,5 +64,4 @@ public class StartService { response.put("inputs", inputs); return response; } - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/dmaap/DmaapBlueprintService.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/dmaap/DmaapBlueprintService.java index 002bd6c..9da2074 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/dmaap/DmaapBlueprintService.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/dmaap/DmaapBlueprintService.java @@ -48,97 +48,116 @@ import java.util.TreeMap; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * Service to create DMAAP Blueprint + * @date 10/16/2020 Application: ONAP - Blueprint Generator Service to create DMAAP Blueprint */ - @Service public class DmaapBlueprintService extends BlueprintService { - @Autowired - protected ImportsService importsService; - - @Autowired - private NodeService nodeService; - - @Autowired - private PolicyNodeService policyNodeService; - - @Autowired - private PgaasNodeService pgaasNodeService; - - @Autowired - private QuotationService quotationService; - - @Autowired - private BlueprintHelperService blueprintHelperService; - - // method to generate Dmaap Blueprint - public OnapBlueprint createBlueprint(OnapComponentSpec onapComponentSpec, Input input) { - try { - OnapBlueprint blueprint = new OnapBlueprint(); - blueprint.setTosca_definitions_version(Constants.TOSCA_DEF_VERSION); - blueprint.setDescription(onapComponentSpec.getSelf().getDescription()); - - Map<String, LinkedHashMap<String, Object>> inputs = new TreeMap<>(); - - //if (!"".equals(input.getImportPath())) - if (!StringUtils.isEmpty(input.getImportPath()) ) - blueprint.setImports(importsService.createImportsFromFile(input.getImportPath())); - else - blueprint.setImports(importsService.createImports(input.getBpType())); - - Map<String, Node> nodeTemplate = new TreeMap(); - - Map<String, Object> dmaapNodeResponse = nodeService.createDmaapNode(onapComponentSpec, inputs, input.getServiceNameOverride()); - inputs = (Map<String, LinkedHashMap<String, Object>>) dmaapNodeResponse.get("inputs"); - nodeTemplate.put(onapComponentSpec.getSelf().getName(), (Node) dmaapNodeResponse.get("dmaapNode")); - - if (onapComponentSpec.getStreams() != null) { - if (onapComponentSpec.getStreams().getPublishes() != null) { - for (Publishes publishes : onapComponentSpec.getStreams().getPublishes()) { - if (blueprintHelperService.isMessageRouterType(publishes.getType())) { - String topic = publishes.getConfig_key() + Constants._TOPIC; - Map<String, Object> topicNodeResponse = nodeService.createTopicNode(inputs, topic); - inputs = (Map<String, LinkedHashMap<String, Object>>) topicNodeResponse.get("inputs"); - nodeTemplate.put(topic, (Node) topicNodeResponse.get("topicNode")); - } else if (blueprintHelperService.isDataRouterType(publishes.getType())) { - String feed = publishes.getConfig_key() + Constants._FEED; - Map<String, Object> feedNodeResponse = nodeService.createFeedNode(inputs, feed); - inputs = (Map<String, LinkedHashMap<String, Object>>) feedNodeResponse.get("inputs"); - nodeTemplate.put(feed, (Node) feedNodeResponse.get("feedNode")); - } - } - } - if (onapComponentSpec.getStreams().getSubscribes() != null) { - for (Subscribes s : onapComponentSpec.getStreams().getSubscribes()) { - if (blueprintHelperService.isMessageRouterType(s.getType())) { - String topic = s.getConfig_key() + Constants._TOPIC; - Map<String, Object> topicNodeResponse = nodeService.createTopicNode(inputs, topic); - inputs = (Map<String, LinkedHashMap<String, Object>>) topicNodeResponse.get("inputs"); - nodeTemplate.put(topic, (Node) topicNodeResponse.get("topicNode")); - } else if (blueprintHelperService.isDataRouterType(s.getType())) { - String feed = s.getConfig_key() + Constants._FEED; - Map<String, Object> feedNodeResponse = nodeService.createFeedNode(inputs, feed); - inputs = (Map<String, LinkedHashMap<String, Object>>) feedNodeResponse.get("inputs"); - nodeTemplate.put(feed, (Node) feedNodeResponse.get("feedNode")); - } - } + @Autowired + protected ImportsService importsService; + + @Autowired + private NodeService nodeService; + + @Autowired + private PolicyNodeService policyNodeService; + + @Autowired + private PgaasNodeService pgaasNodeService; + + @Autowired + private QuotationService quotationService; + + @Autowired + private BlueprintHelperService blueprintHelperService; + + /** + * Creates Dmaap Blueprint + * + * @param onapComponentSpec OnapComponentSpec + * @param input Inputs + * @return + */ + public OnapBlueprint createBlueprint(OnapComponentSpec onapComponentSpec, Input input) { + try { + OnapBlueprint blueprint = new OnapBlueprint(); + blueprint.setTosca_definitions_version(Constants.TOSCA_DEF_VERSION); + blueprint.setDescription(onapComponentSpec.getSelf().getDescription()); + + Map<String, LinkedHashMap<String, Object>> inputs = new TreeMap<>(); + + // if (!"".equals(input.getImportPath())) + if (!StringUtils.isEmpty(input.getImportPath())) { + blueprint.setImports(importsService.createImportsFromFile(input.getImportPath())); + } else { + blueprint.setImports(importsService.createImports(input.getBpType())); + } + + Map<String, Node> nodeTemplate = new TreeMap(); + + Map<String, Object> dmaapNodeResponse = + nodeService + .createDmaapNode(onapComponentSpec, inputs, input.getServiceNameOverride()); + inputs = (Map<String, LinkedHashMap<String, Object>>) dmaapNodeResponse.get("inputs"); + nodeTemplate.put( + onapComponentSpec.getSelf().getName(), (Node) dmaapNodeResponse.get("dmaapNode")); + + if (onapComponentSpec.getStreams() != null) { + if (onapComponentSpec.getStreams().getPublishes() != null) { + for (Publishes publishes : onapComponentSpec.getStreams().getPublishes()) { + if (blueprintHelperService.isMessageRouterType(publishes.getType())) { + String topic = publishes.getConfig_key() + Constants._TOPIC; + Map<String, Object> topicNodeResponse = nodeService + .createTopicNode(inputs, topic); + inputs = (Map<String, LinkedHashMap<String, Object>>) topicNodeResponse + .get("inputs"); + nodeTemplate.put(topic, (Node) topicNodeResponse.get("topicNode")); + } else if (blueprintHelperService.isDataRouterType(publishes.getType())) { + String feed = publishes.getConfig_key() + Constants._FEED; + Map<String, Object> feedNodeResponse = nodeService + .createFeedNode(inputs, feed); + inputs = (Map<String, LinkedHashMap<String, Object>>) feedNodeResponse + .get("inputs"); + nodeTemplate.put(feed, (Node) feedNodeResponse.get("feedNode")); + } + } + } + if (onapComponentSpec.getStreams().getSubscribes() != null) { + for (Subscribes s : onapComponentSpec.getStreams().getSubscribes()) { + if (blueprintHelperService.isMessageRouterType(s.getType())) { + String topic = s.getConfig_key() + Constants._TOPIC; + Map<String, Object> topicNodeResponse = nodeService + .createTopicNode(inputs, topic); + inputs = (Map<String, LinkedHashMap<String, Object>>) topicNodeResponse + .get("inputs"); + nodeTemplate.put(topic, (Node) topicNodeResponse.get("topicNode")); + } else if (blueprintHelperService.isDataRouterType(s.getType())) { + String feed = s.getConfig_key() + Constants._FEED; + Map<String, Object> feedNodeResponse = nodeService + .createFeedNode(inputs, feed); + inputs = (Map<String, LinkedHashMap<String, Object>>) feedNodeResponse + .get("inputs"); + nodeTemplate.put(feed, (Node) feedNodeResponse.get("feedNode")); + } + } + } + } + + if (onapComponentSpec.getPolicyInfo() != null) { + policyNodeService.addPolicyNodesAndInputs(onapComponentSpec, nodeTemplate, inputs); + } + + if (onapComponentSpec.getAuxilary() != null + && onapComponentSpec.getAuxilary().getDatabases() != null) { + pgaasNodeService.addPgaasNodesAndInputs(onapComponentSpec, nodeTemplate, inputs); + } + + blueprint.setNode_templates(nodeTemplate); + blueprint.setInputs(inputs); + return quotationService.setQuotations(blueprint); + } catch (Exception ex) { + throw new BlueprintException( + "Unable to create ONAP DMAAP Blueprint Object from given input parameters", ex); + } } - } - - if (onapComponentSpec.getPolicyInfo() != null) - policyNodeService.addPolicyNodesAndInputs(onapComponentSpec, nodeTemplate, inputs); - - if (onapComponentSpec.getAuxilary() != null && onapComponentSpec.getAuxilary().getDatabases() != null) - pgaasNodeService.addPgaasNodesAndInputs(onapComponentSpec, nodeTemplate, inputs); - - blueprint.setNode_templates(nodeTemplate); - blueprint.setInputs(inputs); - return quotationService.setQuotations(blueprint); - } catch (Exception ex) { - throw new BlueprintException("Unable to create ONAP DMAAP Blueprint Object from given input parameters", ex); - } - } -}
\ No newline at end of file +} diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/dmaap/StreamsService.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/dmaap/StreamsService.java index 16687fc..051b060 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/dmaap/StreamsService.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/dmaap/StreamsService.java @@ -35,21 +35,33 @@ import java.util.Map; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * Service to create Streams + * @date 10/16/2020 Application: ONAP - Blueprint Generator Service to create Streams */ - - @Service public class StreamsService { @Autowired private BlueprintHelperService blueprintHelperService; - //Methos to create streams for Dmaap Blueprint - public Map<String, Object> createStreams(Map<String, LinkedHashMap<String, Object>> inputs, String name, String type, String key, String route, char o){ - Map<String,Object> response = new HashMap<>(); + /** + * Creates streams for Dmaap Blueprint + * + * @param inputs Inputs + * @param name Name + * @param type Type + * @param key Key + * @param route Route + * @param o For Data Router Type s + * @return + */ + public Map<String, Object> createStreams( + Map<String, LinkedHashMap<String, Object>> inputs, + String name, + String type, + String key, + String route, + char o) { + Map<String, Object> response = new HashMap<>(); Streams streams = new Streams(); LinkedHashMap<String, Object> stringType = new LinkedHashMap(); @@ -63,8 +75,8 @@ public class StreamsService { inputs.put(key + "_" + name + "_location", stringType); streams.setLocation(location); - if(blueprintHelperService.isDataRouterType(type)) { - if('s' == o) { + if (blueprintHelperService.isDataRouterType(type)) { + if ('s' == o) { GetInput username = new GetInput(); username.setBpInputName(key + "_" + name + "_username"); streams.setUsername(username); @@ -89,7 +101,6 @@ public class StreamsService { streams.setScheme("https"); } - } else { GetInput client = new GetInput(); client.setBpInputName(key + "_" + name + "_client_role"); @@ -100,5 +111,4 @@ public class StreamsService { response.put("inputs", inputs); return response; } - } diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/policycreate/service/PolicyModelNodeService.java b/mod/bpgenerator/onap/src/main/java/org/onap/policycreate/service/PolicyModelNodeService.java index 05dbcae..14c33d8 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/policycreate/service/PolicyModelNodeService.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/policycreate/service/PolicyModelNodeService.java @@ -39,39 +39,41 @@ import java.util.List; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * To create Node Type, Data Type and Translate Entry Schema for Policy Model Node + * @date 10/16/2020 Application: ONAP - Blueprint Generator To create Node Type, Data Type and + * Translate Entry Schema for Policy Model Node */ - - @Service("onapPolicyModelNodeService") public class PolicyModelNodeService { - // Method to create Nodes for Policy - public Map<String,Object> creatNodeType(String policyName, Parameters[] params) { + /** + * Creates Nodes for Policy + * + * @param policyName Policy Name + * @param params Paramaeters + * @return + */ + public Map<String, Object> creatNodeType(String policyName, Parameters[] params) { String hasEntrySchema = ""; - Map<String,Object> response = new HashMap<>(); + Map<String, Object> response = new HashMap<>(); PolicyModelNode policyModelNode = new PolicyModelNode(); Map<String, PolicyProperties> props = new TreeMap<>(); - for(Parameters p: params) { - if(p.getPolicy_group() != null && p.getPolicy_group().equals(policyName)) { - String name = p.getName(); - String type = p.getType(); - PolicyProperties polProps = new PolicyProperties(); - if(p.getPolicy_schema() != null) { - polProps.setType("map"); - ArrayList<String> entrySchema = new ArrayList<String>(); - entrySchema.add("type: onap.datatypes." + name); - polProps.setEntry_schema(entrySchema); - hasEntrySchema = name; - props.put(name, polProps); - } - else { - polProps.setType(type); - props.put(name, polProps); - } + for (Parameters p : params) { + if (p.getPolicy_group() != null && p.getPolicy_group().equals(policyName)) { + String name = p.getName(); + String type = p.getType(); + PolicyProperties polProps = new PolicyProperties(); + if (p.getPolicy_schema() != null) { + polProps.setType("map"); + ArrayList<String> entrySchema = new ArrayList<String>(); + entrySchema.add("type: onap.datatypes." + name); + polProps.setEntry_schema(entrySchema); + hasEntrySchema = name; + props.put(name, polProps); + } else { + polProps.setType(type); + props.put(name, polProps); + } } } policyModelNode.setDerived_from(Constants.TOSCA_DATATYPES_ROOT); @@ -81,32 +83,37 @@ public class PolicyModelNodeService { return response; } - // Method to create Data Types for Policy - public Map<String, PolicyModelNode> createDataTypes(String param, Parameters[] parameters){ + /** + * Creates Data Types for Policy + * + * @param param Param + * @param parameters Parameters + * @return + */ + public Map<String, PolicyModelNode> createDataTypes(String param, Parameters[] parameters) { Map<String, PolicyModelNode> dataType = new TreeMap<>(); PolicyModelNode node = new PolicyModelNode(); node.setDerived_from(Constants.TOSCA_DATATYPES_ROOT); Map<String, PolicyProperties> properties = new TreeMap<>(); Parameters par = new Parameters(); - for(Parameters p: parameters) { - if(param.equals(p.getName())) { + for (Parameters p : parameters) { + if (param.equals(p.getName())) { par = p; break; } } - for(PolicySchema pol: par.getPolicy_schema()) { - if(pol.getEntry_schema() != null) { - PolicyProperties prop =new PolicyProperties(); + for (PolicySchema pol : par.getPolicy_schema()) { + if (pol.getEntry_schema() != null) { + PolicyProperties prop = new PolicyProperties(); prop.setType("map"); - ArrayList<String> schema = new ArrayList<String>(); + List<String> schema = new ArrayList<>(); schema.add("type: onap.datatypes." + pol.getName()); prop.setEntry_schema(schema); properties.put(pol.getName(), prop); dataType = translateEntrySchema(dataType, pol.getEntry_schema(), pol.getName()); - } - else { + } else { PolicyProperties prop = new PolicyProperties(); prop.setType(pol.getType()); properties.put(pol.getName(), prop); @@ -118,14 +125,15 @@ public class PolicyModelNodeService { return dataType; } - private Map<String, PolicyModelNode> translateEntrySchema(Map<String, PolicyModelNode> dataType, EntrySchema[] entry, String name){ + private Map<String, PolicyModelNode> translateEntrySchema( + Map<String, PolicyModelNode> dataType, EntrySchema[] entry, String name) { Map<String, PolicyModelNode> data = dataType; PolicyModelNode node = new PolicyModelNode(); node.setDerived_from(Constants.TOSCA_NODES_ROOT); Map<String, PolicyProperties> properties = new TreeMap<>(); - for(EntrySchema e: entry) { - if(e.getEntry_schema() != null) { + for (EntrySchema e : entry) { + if (e.getEntry_schema() != null) { PolicyProperties prop = new PolicyProperties(); prop.setType("list"); List<String> schema = new ArrayList<>(); @@ -145,6 +153,4 @@ public class PolicyModelNodeService { dataType.put("onap.datatypes." + name, node); return data; } - } - diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/policycreate/service/PolicyModelService.java b/mod/bpgenerator/onap/src/main/java/org/onap/policycreate/service/PolicyModelService.java index bbc6259..28a0035 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/policycreate/service/PolicyModelService.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/policycreate/service/PolicyModelService.java @@ -42,12 +42,9 @@ import java.util.TreeMap; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * Service for Policy Model to create Policy Models, Policy Group Names and Convert Policy to Yaml + * @date 10/16/2020 Application: ONAP - Blueprint Generator Service for Policy Model to create + * Policy Models, Policy Group Names and Convert Policy to Yaml */ - - @Service("onapPolicyModelService") public class PolicyModelService { @@ -58,7 +55,13 @@ public class PolicyModelService { @Autowired private PolicyModelNodeService policyModelNodeService; - // Method to create Policy Models + /** + * Creates Policy Models + * + * @param params Parameters + * @param filePath File path + * @return + */ public void createPolicyModels(Parameters[] params, String filePath) { try { List<String> policyGroups = getPolicyGroupNames(params); @@ -72,12 +75,16 @@ public class PolicyModelService { nodeType.put(nodeTypeName, (PolicyModelNode) response.get("policyModelNode")); model.setNode_types(nodeType); - if (!"".equals(response.get("hasEntrySchema"))) - model.setData_types(policyModelNodeService.createDataTypes((String) response.get("hasEntrySchema"), params)); + if (!"".equals(response.get("hasEntrySchema"))) { + model.setData_types( + policyModelNodeService.createDataTypes( + (String) response.get("hasEntrySchema"), params)); + } policyModelToYaml(filePath, model, s); } } catch (Exception ex) { - throw new PolicyCreateException("Unable to create Policies from given input parameters", ex); + throw new PolicyCreateException("Unable to create Policies from given input parameters", + ex); } } @@ -88,7 +95,7 @@ public class PolicyModelService { if (names.isEmpty()) { names.add(p.getPolicy_group()); } else if (!names.contains(p.getPolicy_group())) { - names.add(p.getPolicy_group()); + names.add(p.getPolicy_group()); } } } @@ -100,6 +107,4 @@ public class PolicyModelService { outputFile.getParentFile().mkdirs(); yamlObjectMapper.writeValue(outputFile, model); } - } - diff --git a/mod/bpgenerator/onap/src/main/resources/application.properties b/mod/bpgenerator/onap/src/main/resources/application.properties index 3b70df6..f7155a5 100644 --- a/mod/bpgenerator/onap/src/main/resources/application.properties +++ b/mod/bpgenerator/onap/src/main/resources/application.properties @@ -20,16 +20,12 @@ # */ # # - spring.main.banner-mode=off spring.output.ansi.enabled=ALWAYS - imports.onap.types=https://www.getcloudify.org/spec/cloudify/4.5.5/types.yaml imports.onap.K8s.plugintypes=plugin:k8splugin?version=3.4.2 imports.onap.K8s.dcaepolicyplugin=plugin:dcaepolicyplugin?version=2.4.0 - imports.dmaap.dmaapplugin=plugin:dmaap?version=1.5.0 - import.Postgres=plugin:pgaas?version=1.3.0 import.Clamp=plugin:clamppolicyplugin?version=1.1.0 |