[DCAEGEN2-74] Push up initial CDAP plugin

Change-Id: I2bad410e5c55a59950cabe8fc13066954c4f5c92
Signed-off-by: Tommy Carpenter <tommy@research.att.com>

5 files changed, 406 insertions, 0 deletions

diff --git a/cdap/demo_blueprints/cdap_hello_world.yaml b/cdap/demo_blueprints/cdap_hello_world.yaml
new file mode 100644
index 0000000..1b7ff90
--- /dev/null
+++ b/cdap/demo_blueprints/cdap_hello_world.yaml
@@ -0,0 +1,40 @@
+tosca_definitions_version: cloudify_dsl_1_3
+
+imports:
+  - http://www.getcloudify.org/spec/cloudify/3.4/types.yaml
+  - {{ ONAPTEMPLATE_RAWREPOURL_org_onap_dcaegen2 }}/type_files/cdap/14.0.2/cdap_types.yaml
+
+inputs:
+  hello_world_jar_url:
+    type: string
+  connected_broker_dns_name:
+    type: string
+    default : "cdap_broker"
+
+node_templates:
+
+  hw_cdap_app:
+    type: dcae.nodes.MicroService.cdap
+    properties:
+      service_component_type:
+        'hello_world'
+      jar_url: { get_input : hello_world_jar_url }
+      artifact_name: "HelloWorld"
+      artifact_version: "3.4.3"
+      namespace: "cloudifyhwtest"
+      programs:
+        [{"program_type" : "flows", "program_id" : "WhoFlow"}, {"program_type" : "services", "program_id" : "Greeting"}]
+      streamname:
+        'who'
+      service_endpoints:
+        [{"service_name" : "Greeting", "service_endpoint" : "greet", "endpoint_method" : "GET"}]
+    interfaces:
+      cloudify.interfaces.lifecycle:
+        create:
+          inputs:
+            connected_broker_dns_name: { get_input: connected_broker_dns_name }
+   
+outputs: 
+  hw_cdap_app_name:
+    value:
+      {get_attribute:[hw_cdap_app, service_component_name]}
diff --git a/cdap/demo_blueprints/cdap_hello_world_reconfigure.sh b/cdap/demo_blueprints/cdap_hello_world_reconfigure.sh
new file mode 100755
index 0000000..c5df2f5
--- /dev/null
+++ b/cdap/demo_blueprints/cdap_hello_world_reconfigure.sh
@@ -0,0 +1,4 @@
+#!/bin/bash
+cfy executions start -d cdap-hello-world -w execute_operation -p '{"operation" : "reconfiguration.app_config_reconfigure", "node_ids" : ["hw_cdap_app"], "operation_kwargs" : {"new_config_template" : {"foo":"bar"}}, "allow_kwargs_override": true}'
+cfy executions start -d cdap-hello-world -w execute_operation -p '{"operation" : "reconfiguration.app_preferences_reconfigure", "node_ids" : ["hw_cdap_app"], "operation_kwargs" : {"new_config_template" : {"fooprefs":"barprefs"}}, "allow_kwargs_override": true}'
+cfy executions start -d cdap-hello-world -w execute_operation -p '{"operation" : "reconfiguration.app_smart_reconfigure", "node_ids" : ["hw_cdap_app"], "operation_kwargs" : {"new_config_template" : {"fooprefs":"SO SMARTTTTTT", "foo":"SO SMART AGAINNNNN"}}, "allow_kwargs_override": true}'
diff --git a/cdap/demo_blueprints/cdap_hello_world_with_dmaap.yaml b/cdap/demo_blueprints/cdap_hello_world_with_dmaap.yaml
new file mode 100644
index 0000000..ea02543
--- /dev/null
+++ b/cdap/demo_blueprints/cdap_hello_world_with_dmaap.yaml
@@ -0,0 +1,148 @@
+tosca_definitions_version: cloudify_dsl_1_3
+
+imports:
+  - http://www.getcloudify.org/spec/cloudify/3.4/types.yaml
+  - {{ ONAPTEMPLATE_RAWREPOURL_org_onap_dcaegen2 }}/type_files/cdap/14.0.2/cdap_types.yaml
+  - {{ ONAPTEMPLATE_RAWREPOURL_org_onap_dcaegen2 }}/type_files/dmaap/1.1.0/dmaap.yaml
+
+inputs:
+  hello_world_jar_url:
+    type: string
+  connected_broker_dns_name:
+    type: string
+    default : "cdap_broker"
+
+  #aaf inputs
+  client_role:
+    type: string
+  topic00fqtn:
+    type: string
+  topic01fqtn:
+    type: string
+  aafu0: 
+    type: string
+    default: "foo0"
+  aafp0:
+    type: string
+    default: "bar0"
+  aafu1:
+    type: string
+    default : "foo1"
+  aafp1:
+    type: string
+    default : "bar1"
+  aafu2: 
+    type: string
+    default: "foo2"
+  aafp2:
+    type: string
+    default: "bar2"
+  aafu3:
+    type: string
+    default : "foo3"
+  aafp3:
+    type: string
+    default : "bar3"
+  
+node_templates:
+  topic00:
+    type: dcae.nodes.ExistingTopic
+    properties:
+      fqtn: { get_input : topic00fqtn } 
+  topic01:
+    type: dcae.nodes.ExistingTopic
+    properties:
+      fqtn: { get_input : topic01fqtn }
+  feed00:
+     type: dcae.nodes.Feed
+     properties: 
+        feed_name: "FEEDME-12"
+        feed_description: "Tommy Test feed for CDAP Publishes"
+        feed_version: 6.6.6
+        aspr_classification: "unclassified"
+
+  hw_cdap_app:
+    type: dcae.nodes.MicroService.cdap
+    properties:
+      service_component_type: 'hello_world'
+      jar_url: { get_input : hello_world_jar_url }
+      artifact_name: "HelloWorld"
+      artifact_version: "3.4.3"
+      namespace: "cloudifyhwtest"
+      programs:
+        [{"program_type" : "flows", "program_id" : "WhoFlow"}, {"program_type" : "services", "program_id" : "Greeting"}]
+      streamname:
+        'who'
+      service_endpoints:
+        [{"service_name" : "Greeting", "service_endpoint" : "greet", "endpoint_method" : "GET"}]
+      
+      #special key for CDAP plugin
+      connections:
+        streams_publishes: 
+          - name: topic00                       #MR pub 1
+            location: mtc5
+            client_role: { get_input: client_role }
+            type: message_router
+            config_key:   "myconfigkey0"
+            aaf_username: { get_input: aafu0 }
+            aaf_password: { get_input: aafp0 }
+          - name: topic01                       #MR pub 2
+            location: mtc5
+            client_role: { get_input: client_role }
+            type: message_router
+            config_key:  "myconfigkey1"
+            aaf_username: { get_input: aafu1 }
+            aaf_password: { get_input: aafp1 }
+          - name: feed00                      #Feed pub 1
+            location: mtc5
+            type: data_router
+            config_key: "mydrconfigkey"
+        streams_subscribes: 
+          - name: topic00                        #MEANT FOR DEMO ONLY! Subscribing and publishing to same topic. Not real example.
+            location: mtc5
+            client_role: { get_input: client_role }
+            type: message_router
+            config_key:   "myconfigkey2"
+            aaf_username: { get_input: aafu2 }
+            aaf_password: { get_input: aafp2 }
+          - name: topic01
+            location: mtc5
+            client_role: { get_input: client_role }
+            type: message_router
+            config_key:  "myconfigkey3"
+            aaf_username: { get_input: aafu3 }
+            aaf_password: { get_input: aafp3 }
+
+    relationships:
+      - type: dcae.relationships.publish_events
+        target: topic00                           #MEANT FOR DEMO ONLY! Subscribing and publishing to same topic. Not real example.
+      - type: dcae.relationships.publish_events
+        target: topic01
+      - type: dcae.relationships.subscribe_to_events
+        target: topic00
+      - type: dcae.relationships.subscribe_to_events
+        target: topic01
+      - type: dcae.relationships.publish_files
+        target: feed00
+
+    interfaces:
+      cloudify.interfaces.lifecycle:
+        create:
+          inputs:
+            connected_broker_dns_name: { get_input: connected_broker_dns_name }
+   
+outputs: 
+  hw_cdap_app_name:
+    value: {get_attribute:[hw_cdap_app, service_component_name]}
+  
+  topic00_data:
+    description: "Topic 00 data"
+    value: { get_attribute: [hw_cdap_app, topic00]}
+   
+  topic01_data:
+    description: "Topic 01 data"
+    value: { get_attribute: [hw_cdap_app, topic01]}
+
+
+
+
diff --git a/cdap/demo_blueprints/cdap_hello_world_with_laika.yaml b/cdap/demo_blueprints/cdap_hello_world_with_laika.yaml
new file mode 100644
index 0000000..4587a47
--- /dev/null
+++ b/cdap/demo_blueprints/cdap_hello_world_with_laika.yaml
@@ -0,0 +1,80 @@
+tosca_definitions_version: cloudify_dsl_1_3
+
+imports:
+  - http://www.getcloudify.org/spec/cloudify/3.4/types.yaml
+  - {{ ONAPTEMPLATE_RAWREPOURL_org_onap_dcaegen2 }}/type_files/cdap/14.0.2/cdap_types.yaml
+  - {{ ONAPTEMPLATE_RAWREPOURL_org_onap_dcaegen2 }}/type_files/docker/2.1.0/node-type.yaml
+  - {{ ONAPTEMPLATE_RAWREPOURL_org_onap_dcaegen2 }}/type_files/relationship/1.0.0/node-type.yaml
+
+inputs:
+  hello_world_jar_url:
+    type: string
+  laika_image:
+    type: string
+  connected_broker_dns_name:
+    type: string
+    default : "cdap_broker"
+ 
+node_templates:
+
+  hw_cdap_app:
+    type: dcae.nodes.MicroService.cdap
+    properties:
+      service_component_type:
+        'hello_world'
+      jar_url: { get_input : hello_world_jar_url }
+      artifact_name: "HelloWorld"
+      artifact_version: "3.4.3"
+      namespace: "cloudifyhwtest"
+      programs:
+        [{"program_type" : "flows", "program_id" : "WhoFlow"}, {"program_type" : "services", "program_id" : "Greeting"}]
+      streamname:
+        'who'
+      service_endpoints:
+        [{"service_name" : "Greeting", "service_endpoint" : "greet", "endpoint_method" : "GET"}]
+      
+      connections:
+        services_calls:
+          - service_component_type: laika
+            config_key: "laika_handle"
+
+    relationships:
+      - type: dcae.relationships.component_connected_to
+        target: laika-one
+
+    interfaces:
+      cloudify.interfaces.lifecycle:
+        create:
+          inputs:
+            connected_broker_dns_name: { get_input: connected_broker_dns_name }
+
+  laika-one:
+    type: dcae.nodes.DockerContainerForComponents
+    properties:
+        service_component_type: 'laika'
+        service_id: 'this_is_dumb'
+        location_id: 'this_is_dumb'
+        image: { get_input : laika_image }
+        # Trying without health check
+    relationships:
+      - type: dcae.relationships.component_contained_in
+        target: docker_host
+    interfaces:
+      cloudify.interfaces.lifecycle:
+        stop:
+          inputs:
+            cleanup_image:
+              False
+
+  docker_host:
+    type: dcae.nodes.SelectedDockerHost
+    properties:
+      location_id: 'this is dumb'
+      docker_host_override: 'platform_dockerhost'
+   
+outputs: 
+  hw_cdap_app_name:
+    value: {get_attribute:[hw_cdap_app, service_component_name]}
+  
+
+
diff --git a/cdap/demo_blueprints/cdap_hello_world_with_mr.yaml b/cdap/demo_blueprints/cdap_hello_world_with_mr.yaml
new file mode 100644
index 0000000..e1e0adb
--- /dev/null
+++ b/cdap/demo_blueprints/cdap_hello_world_with_mr.yaml
@@ -0,0 +1,134 @@
+tosca_definitions_version: cloudify_dsl_1_3
+
+imports:
+  - http://www.getcloudify.org/spec/cloudify/3.4/types.yaml
+  - {{ ONAPTEMPLATE_RAWREPOURL_org_onap_dcaegen2 }}/type_files/cdap/14.0.2/cdap_types.yaml
+  - {{ ONAPTEMPLATE_RAWREPOURL_org_onap_dcaegen2 }}/type_files/dmaap/1.1.0/dmaap.yaml
+
+inputs:
+  hello_world_jar_url:
+    type: string
+  connected_broker_dns_name:
+    type: string
+    default : "cdap_broker"
+  
+  #aaf inputs
+  client_role:
+    type: string
+  topic00fqtn:
+    type: string
+  topic01fqtn:
+    type: string
+  aafu0: 
+    type: string
+    default: "foo0"
+  aafp0:
+    type: string
+    default: "bar0"
+  aafu1:
+    type: string
+    default : "foo1"
+  aafp1:
+    type: string
+    default : "bar1"
+  aafu2: 
+    type: string
+    default: "foo2"
+  aafp2:
+    type: string
+    default: "bar2"
+  aafu3:
+    type: string
+    default : "foo3"
+  aafp3:
+    type: string
+    default : "bar3"
+  
+node_templates:
+  topic00:
+    type: dcae.nodes.ExistingTopic
+    properties:
+      fqtn: { get_input : topic00fqtn }
+  
+  topic01:
+    type: dcae.nodes.ExistingTopic
+    properties:
+      fqtn: { get_input : topic01fqtn }
+
+  hw_cdap_app:
+    type: dcae.nodes.MicroService.cdap
+    properties:
+      service_component_type:
+        'hello_world'
+      jar_url: { get_input : hello_world_jar_url }
+      artifact_name: "HelloWorld"
+      artifact_version: "3.4.3"
+      namespace: "cloudifyhwtest"
+      programs:
+        [{"program_type" : "flows", "program_id" : "WhoFlow"}, {"program_type" : "services", "program_id" : "Greeting"}]
+      streamname:
+        'who'
+      service_endpoints:
+        [{"service_name" : "Greeting", "service_endpoint" : "greet", "endpoint_method" : "GET"}]
+      
+      #special key for CDAP plugin
+      connections:
+        streams_publishes: 
+          - name: topic00                       #MR pub 1
+            location: mtc5
+            client_role: { get_input: client_role }
+            type: message_router
+            config_key:   "myconfigkey0"
+            aaf_username: { get_input: aafu0 }
+            aaf_password: { get_input: aafp0 }
+          - name: topic01                       #MR pub 2
+            location: mtc5
+            client_role: { get_input: client_role }
+            type: message_router
+            config_key:  "myconfigkey1"
+            aaf_username: { get_input: aafu1 }
+            aaf_password: { get_input: aafp1 }
+        streams_subscribes: 
+          - name: topic00                        #MEANT FOR DEMO ONLY! Subscribing and publishing to same topic. Not real example.
+            location: mtc5
+            client_role: { get_input: client_role }
+            type: message_router
+            config_key:   "myconfigkey2"
+            aaf_username: { get_input: aafu2 }
+            aaf_password: { get_input: aafp2 }
+          - name: topic01
+            location: mtc5
+            client_role: { get_input: client_role }
+            type: message_router
+            config_key:  "myconfigkey3"
+            aaf_username: { get_input: aafu3 }
+            aaf_password: { get_input: aafp3 }
+
+    relationships:
+      - type: dcae.relationships.publish_events
+        target: topic00                           #MEANT FOR DEMO ONLY! Subscribing and publishing to same topic. Not real example.
+      - type: dcae.relationships.publish_events
+        target: topic01
+      - type: dcae.relationships.subscribe_to_events
+        target: topic00
+      - type: dcae.relationships.subscribe_to_events
+        target: topic01
+
+    interfaces:
+      cloudify.interfaces.lifecycle:
+        create:
+          inputs:
+            connected_broker_dns_name: { get_input: connected_broker_dns_name }
+   
+outputs: 
+  hw_cdap_app_name:
+    value: {get_attribute:[hw_cdap_app, service_component_name]}
+  
+  topic00_data:
+    description: "Topic 00 data"
+    value: { get_attribute: [hw_cdap_app, topic00]}
+   
+  topic01_data:
+    description: "Topic 01 data"
+    value: { get_attribute: [hw_cdap_app, topic01]}
+