updating

Author: katzy687

.gitignore

@@ -3,3 +3,4 @@ DEBUG/
 quali_api_sanity_exe/
 *.zip
 Orchestration-Templates/
+Bug-exploration/

automation_api_scripts/create_resources.py

@@ -0,0 +1,20 @@
+from cloudshell.api.cloudshell_api import CloudShellAPISession
+
+user = "admin"
+password = "admin"
+server = "localhost"
+domain = "Global"
+
+TOTAL_RESOURCES = 1000
+
+api = CloudShellAPISession(host=server, username=user, password=password, domain=domain)
+
+print("building resources...")
+for i in range(TOTAL_RESOURCES):
+    print("resource" + str(i + 1))
+    api.CreateResource(resourceModel="Generic Dut",
+                       resourceName="generic_dummy_b_{}".format(str(i + 1)),
+                       resourceAddress="{0}.{0}.{0}.{0}".format(str(i)),
+                       folderFullPath="dummy resources 2")
+
+print("done")

generic-orchestration-samples/setup_demo_flow/first_module.py

@@ -12,6 +12,9 @@ def first_module_flow(sandbox, components=None):
     :param components
     :return:
     """
+    if not components:
+        pass
+
     api = sandbox.automation_api
     res_id = sandbox.id
     warn_print(api, sandbox.id, "=== Hello from sandbox!!!! ===")

generic-orchestration-samples/setup_send_mail/sb_rest/sandbox_rest_api.py

@@ -192,6 +192,12 @@ def get_user_token(self, user_name):
         response = requests.post(url=url, data=json.dumps(body), headers=self._auth_headers)
         return self._handle_res_json(response)
 
+    def invalidate_token(self, token):
+        url = self._no_version_base_url + "/token/{}".format(token)
+        response = requests.delete(url=url, headers=self._auth_headers)
+        return self._handle_res_json(response)
+
+
 
 if __name__ == "__main__":
     server = "localhost"
@@ -200,7 +206,6 @@ def get_user_token(self, user_name):
     domain = "Global"
 
     sb_rest = SandboxRest(server, cs_user, password, domain)
-    sandbox_info = sb_rest.get_sandboxes()
-    info_json = json.dumps(sandbox_info, indent=2)
-    print(info_json)
+    delete_res = sb_rest.invalidate_token("PZc7BIDg40KnqY87p98MRQ2")
+    sandbox_info = sb_rest.get_user_token("admin")
     pass

packaging-api-samples/create_blueprint.py

@@ -0,0 +1,53 @@
+from quali_utils.quali_packaging import PackageEditor, TopologyApp, AppResource, AppResourceInner, DeploymentService
+import requests
+from copy import deepcopy
+
+# Create a new package in the local file system
+package_base_path = "C:\\quali_package_demo"
+# package_name = "demo_apps_blueprint.zip"
+package_name = "empty_blueprint.zip"
+p = PackageEditor()
+
+package_path = "{}\\{}".format(package_base_path, package_name)
+
+# create empty package
+p.create(package_path)
+
+# Load the package and prepare for edit
+p.load(package_path)
+
+# Edit the package: f.e add new family
+# p.add_topology(topology_name="temp_blueprint", is_public="True", image_file_path="", default_duration="15",
+#                instructions="", categories="", diagram_zoom="0")
+
+topology_name = p.get_topology_names()[0]
+# p.change_topology_name_and_alias(topology_name=names[0], new_name="new blueprint name")
+# names_new = p.get_topology_names()
+
+p.add_topology("my_bp", True, "", "30", "", "", "100")
+
+apps = p.get_apps(topology_name)
+app1 = apps[0]
+
+new_app_copy = deepcopy(app1)
+new_app_copy.templateName = "my template from api"
+new_app_copy.appResource.name = "my temp app"
+
+
+p.add_app(topology_name, new_app_copy)
+pass
+
+# ==== IMPORT PACKAGE INTO CLOUDSHELL =====
+# authenticate quali api
+r = requests.put('http://localhost:9000/Api/Auth/Login', {"username": "admin", "password": "admin", "domain": "Global"})
+authcode = "Basic " + r._content[1:-1]
+
+# 2 Open the package before import
+fileobj = open(package_path, 'rb')
+
+# 3 Send to CloudShell by calling Import Package REST API
+r = requests.post('http://localhost:9000/API/Package/ImportPackage',
+                  headers={"Authorization": authcode},
+                  files={"file": fileobj})
+print(r._content)
+print(r.ok)

packaging-api-samples/packaging_api_demo.py

@@ -58,5 +58,5 @@
 r = requests.post('http://localhost:9000/API/Package/ImportPackage',
                   headers={"Authorization": authcode},
                   files={"file": fileobj})
-print r._content
-print r.ok
+print(r._content)
+print(r.ok)

quali_api/hidden quali api/PY3_quali_api_wrapper/multipart_formdata.py

@@ -0,0 +1,69 @@
+# Many thanks to https://pymotw.com/2/urllib2/#uploading-files
+
+import mimetools
+import mimetypes
+import itertools
+
+
+class MultiPartForm(object):
+    """Accumulate the data to be used when posting a form."""
+
+    def __init__(self):
+        self.form_fields = []
+        self.files = []
+        self.boundary = mimetools.choose_boundary()
+        return
+
+    def get_content_type(self):
+        return 'multipart/form-data; boundary=%s' % self.boundary
+
+    def add_field(self, name, value):
+        """Add a simple field to the form data."""
+        self.form_fields.append((name, value))
+        return
+
+    def add_file(self, fieldname, filename, fileHandle, mimetype=None):
+        """Add a file to be uploaded."""
+        body = fileHandle.read()
+        if mimetype is None:
+            mimetype = mimetypes.guess_type(filename)[0] or 'application/octet-stream'
+        self.files.append((fieldname, filename, mimetype, body))
+        return
+
+    def __str__(self):
+        """Return a string representing the form data, including attached files."""
+        # Build a list of lists, each containing "lines" of the
+        # request.  Each part is separated by a boundary string.
+        # Once the list is built, return a string where each
+        # line is separated by '\r\n'.
+        parts = []
+        part_boundary = '--' + self.boundary
+
+        # Add the form fields
+        parts.extend(
+            [part_boundary,
+             'Content-Disposition: form-data; name="%s"' % name,
+             '',
+             value,
+             ]
+            for name, value in self.form_fields
+        )
+
+        # Add the files to upload
+        parts.extend(
+            [part_boundary,
+             'Content-Disposition: file; name="%s"; filename="%s"' % \
+             (field_name, filename),
+             'Content-Type: %s' % content_type,
+             '',
+             body,
+             ]
+            for field_name, filename, content_type, body in self.files
+        )
+
+        # Flatten the list and add closing boundary marker,
+        # then return CR+LF separated data
+        flattened = list(itertools.chain(*parts))
+        flattened.append('--' + self.boundary + '--')
+        flattened.append('')
+        return '\r\n'.join(flattened)

quali_api/hidden quali api/PY3_quali_api_wrapper/quali_api_wrapper.py

@@ -0,0 +1,109 @@
+from urllib.request import urlopen, Request, build_opener, HTTPHandler
+import re
+import ntpath
+
+from multipart_formdata import MultiPartForm
+
+
+class QualiApi(object):
+    def __init__(self, host, username, password, domain="Global", port="9000"):
+        self.host = host
+        self.port = port
+
+        self.opener = build_opener(HTTPHandler)
+
+        login_url = 'http://{0}:{1}/API/Auth/Login'.format(host, port)
+        data = 'username={0}&password={1}&domain={2}' \
+            .format(username,
+                    password.replace('+', '%2B').replace('/', '%2F').replace('=', '%3D'),
+                    domain)
+        request = Request(url=login_url, data=bytes(data))
+        request.add_header('Content-Type', 'application/x-www-form-urlencoded')
+        backup = request.get_method
+        request.get_method = lambda: 'PUT'
+        url = self.opener.open(request)
+        self.token = url.read()
+        self.token = re.sub(r'^"', '', self.token)
+        self.token = re.sub(r'"$', '', self.token)
+        request.get_method = backup
+
+    def upload_test_to_shared(self, test_location, target_location):
+        """
+        :param test_location:
+        :param target_location: folder hierarchy in shared folder. the path should be separated with /.
+         if empty, test will be created in root shared folder.
+        :type test_location: str
+        :type target_location: str
+        :return:
+        """
+        if target_location.startswith('Shared'):
+            target_location = target_location.lstrip('Shared').lstrip('/')
+
+        head, tail = ntpath.split(test_location)
+        filename = tail or ntpath.basename(head)
+
+        form = MultiPartForm()
+
+        with open(test_location) as file_handle:
+            form.add_file('test', filename, fileHandle=file_handle)
+
+        body = str(form)
+        url = 'http://{0}:{1}/API/Scheduling/Tests/Shared/{2}'.format(self.host, self.port, target_location)
+        request = Request(url)
+        request.add_header('Content-type', form.get_content_type())
+        request.add_header('Content-length', str(len(body)))
+        request.add_header('Authorization', 'Basic {}'.format(self.token))
+        request.data = body
+
+        try:
+            response = self.opener.open(request)
+            result = response.read()
+        except Exception as e:
+            print(str(e))
+            raise e
+
+        return result
+
+    def delete_test_from_shared(self, test_location):
+        url = 'http://{0}:{1}/API/Scheduling/Tests/Shared/{2}'.format(self.host, self.port, test_location)
+        request = Request(url)
+        request.get_method = lambda: 'DELETE'
+        request.add_header('Authorization', 'Basic {}'.format(self.token))
+
+        try:
+            response = self.opener.open(request)
+            result = response.read()
+        except Exception as e:
+            print(str(e))
+            raise e
+
+        return result
+
+    """
+    def delete_single_test_from_shared(test_location):
+        api = QualiApi('localhost', '9000', 'admin', 'admin', 'Global')
+        result = api.delete_test_from_shared(test_location)
+        # verify response (result)
+        print 'success'
+    """
+
+    def get_tests_from_shared(self, test_location):
+        url = 'http://{0}:{1}/API/Scheduling/Explorer/Shared/{2}'.format(self.host, self.port, test_location)
+        request = Request(url)
+        request.get_method = lambda: 'GET'
+        request.add_header('Authorization', 'Basic {}'.format(self.token))
+
+        try:
+            response = self.opener.open(request)
+            result = response.read()
+        except Exception as e:
+            print(str(e))
+            raise e
+
+        return result
+
+
+if __name__ == "__main__":
+    api = QualiApi("localhost", "admin", "admin")
+    tests = api.get_tests_from_shared("Demo")
+    pass

quali_api/hidden quali api/quali_api_wrapper/multipart_formdata.py

@@ -0,0 +1,69 @@
+# Many thanks to https://pymotw.com/2/urllib2/#uploading-files
+
+import mimetools
+import mimetypes
+import itertools
+
+
+class MultiPartForm(object):
+    """Accumulate the data to be used when posting a form."""
+
+    def __init__(self):
+        self.form_fields = []
+        self.files = []
+        self.boundary = mimetools.choose_boundary()
+        return
+
+    def get_content_type(self):
+        return 'multipart/form-data; boundary=%s' % self.boundary
+
+    def add_field(self, name, value):
+        """Add a simple field to the form data."""
+        self.form_fields.append((name, value))
+        return
+
+    def add_file(self, fieldname, filename, fileHandle, mimetype=None):
+        """Add a file to be uploaded."""
+        body = fileHandle.read()
+        if mimetype is None:
+            mimetype = mimetypes.guess_type(filename)[0] or 'application/octet-stream'
+        self.files.append((fieldname, filename, mimetype, body))
+        return
+
+    def __str__(self):
+        """Return a string representing the form data, including attached files."""
+        # Build a list of lists, each containing "lines" of the
+        # request.  Each part is separated by a boundary string.
+        # Once the list is built, return a string where each
+        # line is separated by '\r\n'.
+        parts = []
+        part_boundary = '--' + self.boundary
+
+        # Add the form fields
+        parts.extend(
+            [part_boundary,
+             'Content-Disposition: form-data; name="%s"' % name,
+             '',
+             value,
+             ]
+            for name, value in self.form_fields
+        )
+
+        # Add the files to upload
+        parts.extend(
+            [part_boundary,
+             'Content-Disposition: file; name="%s"; filename="%s"' % \
+             (field_name, filename),
+             'Content-Type: %s' % content_type,
+             '',
+             body,
+             ]
+            for field_name, filename, content_type, body in self.files
+        )
+
+        # Flatten the list and add closing boundary marker,
+        # then return CR+LF separated data
+        flattened = list(itertools.chain(*parts))
+        flattened.append('--' + self.boundary + '--')
+        flattened.append('')
+        return '\r\n'.join(flattened)