jenkins pipeline

drip_planner2/.idea/workspace.xml

 <?xml version="1.0" encoding="UTF-8"?>
 <project version="4">
   <component name="ChangeListManager">
-    <list default="true" id="462ede19-adfe-472b-975e-fefefa973fe0" name="Default Changelist" comment="">
-      <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/src/planner/planner.py" beforeDir="false" afterPath="$PROJECT_DIR$/src/planner/planner.py" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/src/planner/simple_spec_alayzer.py" beforeDir="false" afterPath="$PROJECT_DIR$/src/planner/simple_spec_alayzer.py" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/src/planner/specification_analyzer.py" beforeDir="false" afterPath="$PROJECT_DIR$/src/planner/specification_analyzer.py" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/src/rpc_server.py" beforeDir="false" afterPath="$PROJECT_DIR$/src/rpc_server.py" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/src/tests/test_planner.py" beforeDir="false" afterPath="$PROJECT_DIR$/src/tests/test_planner.py" afterDir="false" />
-    </list>
+    <list default="true" id="462ede19-adfe-472b-975e-fefefa973fe0" name="Default Changelist" comment="" />
     <option name="EXCLUDED_CONVERTED_TO_IGNORED" value="true" />
     <option name="SHOW_DIALOG" value="false" />
     <option name="HIGHLIGHT_CONFLICTS" value="true" />
@@ -293,7 +286,14 @@
       <option name="project" value="LOCAL" />
       <updated>1572451502431</updated>
     </task>
-    <option name="localTasksCounter" value="20" />
+    <task id="LOCAL-00020" summary="fix run tests">
+      <created>1573057850179</created>
+      <option name="number" value="00020" />
+      <option name="presentableId" value="LOCAL-00020" />
+      <option name="project" value="LOCAL" />
+      <updated>1573057850180</updated>
+    </task>
+    <option name="localTasksCounter" value="21" />
     <servers />
   </component>
   <component name="Vcs.Log.Tabs.Properties">
@@ -328,7 +328,8 @@
     <MESSAGE value="added test" />
     <MESSAGE value="check if topology node has properties" />
     <MESSAGE value="we have a bug with setting default properties" />
-    <option name="LAST_COMMIT_MESSAGE" value="we have a bug with setting default properties" />
+    <MESSAGE value="fix run tests" />
+    <option name="LAST_COMMIT_MESSAGE" value="fix run tests" />
   </component>
   <component name="XDebuggerManager">
     <breakpoint-manager>

drip_planner2/nb-configuration.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project-shared-configuration>
+    <!--
+This file contains additional configuration written by modules in the NetBeans IDE.
+The configuration is intended to be shared among all the users of project and
+therefore it is assumed to be part of version control checkout.
+Without this configuration present, some functionality in the IDE may be limited or fail altogether.
+-->
+    <python-data xmlns="http://nbpython.dev.java.net/ns/php-project/1">
+        <main.file>rpc_server.py</main.file>
+        <platform.active>Python_3.6.6</platform.active>
+    </python-data>
+</project-shared-configuration>

drip_planner2/rpc_server.py

+# To change this license header, choose License Headers in Project Properties.
+# To change this template file, choose Tools | Templates
+# and open the template in the editor.
+import json
+import os
+import os.path
+import tempfile
+import time
+
+import pika
+import yaml
+
+from planner.basic_planner import *
+from planner.planner import *
+from planner.spec_service import SpecService
+
+logger = logging.getLogger(__name__)
+
+
+# if not getattr(logger, 'handler_set', None):
+# logger.setLevel(logging.INFO)
+# h = logging.StreamHandler()
+# formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')
+# h.setFormatter(formatter)
+# logger.addHandler(h)
+# logger.handler_set = True
+
+
+def init_chanel(args):
+    global rabbitmq_host
+    if len(args) > 1:
+        rabbitmq_host = args[1]
+        queue_name = args[2]  # planner
+    else:
+        rabbitmq_host = '127.0.0.1'
+
+    connection = pika.BlockingConnection(pika.ConnectionParameters(host=rabbitmq_host))
+    channel = connection.channel()
+    channel.queue_declare(queue=queue_name)
+    return channel
+
+
+def start(this_channel):
+    this_channel.basic_qos(prefetch_count=1)
+    this_channel.basic_consume(queue=queue_name, on_message_callback=on_request)
+    logger.info(" [x] Awaiting RPC requests")
+    this_channel.start_consuming()
+
+
+def on_request(ch, method, props, body):
+    response = handle_delivery(body)
+
+    ch.basic_publish(exchange='',
+                     routing_key=props.reply_to,
+                     properties=pika.BasicProperties(correlation_id=
+                                                     props.correlation_id),
+                     body=str(response))
+    ch.basic_ack(delivery_tag=method.delivery_tag)
+
+
+def handle_delivery(message):
+    logger.info("Got: " + str(message))
+    try:
+        message = message.decode()
+    except (UnicodeDecodeError, AttributeError):
+        pass
+    parsed_json_message = json.loads(message)
+    owner = parsed_json_message['owner']
+    tosca_file_name = 'tosca_template'
+    tosca_template_json = parsed_json_message['toscaTemplate']
+
+    input_current_milli_time = lambda: int(round(time.time() * 1000))
+
+    # rabbit = DRIPLoggingHandler(host=rabbitmq_host, port=5672, user=owner)
+    # logger.addHandler(rabbit)
+
+    try:
+        tosca_folder_path = os.path.join(tempfile.gettempdir(), "planner_files", str(input_current_milli_time()))
+    except NameError:
+        import sys
+        tosca_folder_path = os.path.dirname(os.path.abspath(sys.argv[0])) + os.path.join(tempfile.gettempdir(),
+                                                                                         "planner_files",
+                                                                                         str(current_milli_time()))
+
+    if not os.path.exists(tosca_folder_path):
+        os.makedirs(tosca_folder_path)
+    input_tosca_file_path = os.path.join(tosca_folder_path, tosca_file_name + ".yml")
+    with open(input_tosca_file_path, 'w') as outfile:
+        outfile.write(yaml.dump(tosca_template_json))
+
+    conf = {'url': "http://host"}
+    spec_service = SpecService(conf)
+    test_planner = Planner(input_tosca_file_path, spec_service)
+    tosca_template = test_planner.resolve_requirements()
+    tosca_template = test_planner.set_infrastructure_specifications()
+    template_dict = tosca_util.get_tosca_template_2_topology_template_dictionary(tosca_template)
+    logger.info("template ----: \n" + yaml.dump(template_dict))
+
+    response = {'toscaTemplate': template_dict}
+    output_current_milli_time = int(round(time.time() * 1000))
+    response["creationDate"] = output_current_milli_time
+    response["parameters"] = []
+    if queue_name == "planner_queue":
+        logger.info("Planning")
+    logger.info("Returning plan")
+    logger.info("Output message:" + json.dumps(response))
+    return json.dumps(response)
+
+
+if __name__ == "__main__":
+    logging.basicConfig(level=logging.INFO)
+    if sys.argv[1] == "test_local":
+        tosca_path = "../../TOSCA/"
+        input_tosca_file_path = tosca_path + '/application_example_2_topologies.yaml'
+        conf = {'url': "http://host"}
+        spec_service = SpecService(conf)
+        test_planner = Planner(input_tosca_file_path, spec_service)
+        test_tosca_template = test_planner.resolve_requirements()
+        test_tosca_template = test_planner.set_infrastructure_specifications()
+        template_dict = tosca_util.get_tosca_template_2_topology_template_dictionary(test_tosca_template)
+        # logger.info("template ----: \n" + yaml.dump(template))
+
+        try:
+            tosca_folder_path = os.path.join(tempfile.gettempdir(), tosca_path)
+        except NameError:
+            import sys
+
+            tosca_folder_path = os.path.dirname(os.path.abspath(sys.argv[0])) + os.path.join(tempfile.gettempdir(),
+                                                                                             tosca_path)
+        tosca_file_name = 'tosca_template'
+        input_tosca_file_path = tosca_path + '/application_example_output.yaml'
+
+        with open(input_tosca_file_path, 'w') as outfile:
+            outfile.write(yaml.dump(template_dict))
+
+        ToscaTemplate(input_tosca_file_path)
+
+        test_response = {'toscaTemplate': template_dict}
+        logger.info("Output message:" + json.dumps(test_response))
+    else:
+        logger.info("Input args: " + sys.argv[0] + ' ' + sys.argv[1] + ' ' + sys.argv[2])
+        channel = init_chanel(sys.argv)
+        global queue_name
+        queue_name = sys.argv[2]
+        start(channel)

drip_planner2/setup.py

+from setuptools import setup, find_packages
+
+setup(
+    name='drip_planner2',
+    version='0.1',
+    packages=find_packages(),
+
+    # Declare your packages' dependencies here, for eg:
+    install_requires=['matplotlib==3.1.1', 'pika==1.1.0', 'tosca-parser==1.6.0', 'names==0.3.0', 'networkx==2.4',
+                      'matplotlib==3.1.1'],
+
+    # Fill in these to make your Egg ready for upload to
+    # PyPI
+    author='S. Koulouzis',
+    author_email='',
+
+    # summary = 'Just another Python package for the cheese shop',
+    url='',
+    license='',
+    long_description='Long description of the package',
+
+    # could also include long_description, download_url, classifiers, etc.
+
+)

jenkins_pipeline

+pipeline {
+    agent any
+   tools {
+      // Install the Maven version configured as "M3" and add it to the path.
+      maven "maven-3.6.2"
+      jdk "openjdk-11"
+   }
+    stages {
+        stage('Build') {
+            steps {
+                echo 'Building'
+         steps {
+             git branch: 'DRIP_3.0', url: 'https://github.com/skoulouzis/DRIP.git'
+             sh "mvn clean install"                
+            }
+        }
+        stage('Test') {
+            steps {
+                echo 'Testing'
+            }
+        }
+        stage('Deploy') {
+            steps {
+                echo 'Deploying'
+            }
+        }
+    }
+    post {
+        always {
+            echo 'This will always run'
+        }
+        success {
+            echo 'This will run only if successful'
+        }
+        failure {
+            echo 'This will run only if failed'
+        }
+        unstable {
+            echo 'This will run only if the run was marked as unstable'
+        }
+        changed {
+            echo 'This will run only if the state of the Pipeline has changed'
+            echo 'For example, if the Pipeline was previously failing but is now successful'
+        }
+    }
+}