Migrate Python 2 files to Python 3

Issue-ID: SDC-4498
Signed-off-by: eschcam <cameron.scholes@est.tech>
Change-Id: I6b55fcd799371dd209898607c90d5c348e242c36

7 files changed, 168 insertions, 155 deletions

diff --git a/openecomp-be/lib/openecomp-sdc-translator-lib/openecomp-sdc-translator-core/src/test/resources/mock/services/heattotosca/securityrulestoportconnection/securityRulesToPortGetResource/inputfiles/call_home.py b/openecomp-be/lib/openecomp-sdc-translator-lib/openecomp-sdc-translator-core/src/test/resources/mock/services/heattotosca/securityrulestoportconnection/securityRulesToPortGetResource/inputfiles/call_home.py
index 54f2a69c09..0b120983eb 100644
--- a/openecomp-be/lib/openecomp-sdc-translator-lib/openecomp-sdc-translator-core/src/test/resources/mock/services/heattotosca/securityrulestoportconnection/securityRulesToPortGetResource/inputfiles/call_home.py
+++ b/openecomp-be/lib/openecomp-sdc-translator-lib/openecomp-sdc-translator-core/src/test/resources/mock/services/heattotosca/securityrulestoportconnection/securityRulesToPortGetResource/inputfiles/call_home.py
@@ -6,7 +6,6 @@ from socket import getfqdn
 from sys import platform
 from time import sleep
 
-
 PARSER = argparse.ArgumentParser()
 PARSER.add_argument("manager_ip", help="The IPv4 Address where one can read the MaveriQConductor.")
 PARSER.add_argument("--mockupfile", type=str, help="The path of the json mockupfile to use.")
@@ -43,7 +42,7 @@ def check_availability():
     is_connected = False
     while is_connected is False:
         try:
-            if requests.get(URL_AVAIL, headers={'Connection': 'close'}).status_code is 200:
+            if requests.get(URL_AVAIL, headers={'Connection': 'close'}).status_code == 200:
                 is_connected = True
             sleep(2)
         except requests.exceptions.ConnectionError:
@@ -90,8 +89,9 @@ def main():
 
         # Perform any replacement needed.
         json_data = multiple_replace(regex_dict, json_data)
-        print json_data
+        print(json_data)
         check_availability()
         return post_request(p_json_data=json_data, p_headers=HEADERS)
 
-print main()
+
+print(main())
diff --git a/openecomp-be/lib/openecomp-sdc-translator-lib/openecomp-sdc-translator-core/src/test/resources/mock/services/heattotosca/securityrulestoportconnection/securityRulesToPortGetResource/inputfiles/check_availability.py b/openecomp-be/lib/openecomp-sdc-translator-lib/openecomp-sdc-translator-core/src/test/resources/mock/services/heattotosca/securityrulestoportconnection/securityRulesToPortGetResource/inputfiles/check_availability.py
index e93b372f15..09098b23d0 100644
--- a/openecomp-be/lib/openecomp-sdc-translator-lib/openecomp-sdc-translator-core/src/test/resources/mock/services/heattotosca/securityrulestoportconnection/securityRulesToPortGetResource/inputfiles/check_availability.py
+++ b/openecomp-be/lib/openecomp-sdc-translator-lib/openecomp-sdc-translator-core/src/test/resources/mock/services/heattotosca/securityrulestoportconnection/securityRulesToPortGetResource/inputfiles/check_availability.py
@@ -15,20 +15,20 @@ PARSER.add_argument("ScribeIP", type=str,
                     help="The Stage the application is currently in")
 ARGS = PARSER.parse_args()
 
-print "Begining check availability check!"
+print("Beginning check availability check!")
 isConnected = False
 while isConnected is False:
     try:
         sys.stdout.write('.')
         sleep(2)
         if requests.get(conductor_url.format(ARGS.ScribeIP),
-                        headers={'Connection': 'close'}).status_code is 200 and requests.get(
+                        headers={'Connection': 'close'}).status_code == 200 and requests.get(
             check_api.format(ARGS.ScribeIP,
                              headers={'Connection': 'close'}),
             auth=requests.auth.HTTPBasicAuth(check_user,
-                                             check_password)).status_code is 200:
+                                             check_password)).status_code == 200:
             isConnected = True
     except requests.exceptions.ConnectionError as e:
         sleep(2)
 
-print 'Conductor and Scribe are ready!'
+print('Conductor and Scribe are ready!')
diff --git a/openecomp-be/lib/openecomp-sdc-translator-lib/openecomp-sdc-translator-core/src/test/resources/mock/services/heattotosca/securityrulestoportconnection/securityRulesToPortGetResource/inputfiles/register_status.py b/openecomp-be/lib/openecomp-sdc-translator-lib/openecomp-sdc-translator-core/src/test/resources/mock/services/heattotosca/securityrulestoportconnection/securityRulesToPortGetResource/inputfiles/register_status.py
index 98adafaf2f..55be22daf5 100644
--- a/openecomp-be/lib/openecomp-sdc-translator-lib/openecomp-sdc-translator-core/src/test/resources/mock/services/heattotosca/securityrulestoportconnection/securityRulesToPortGetResource/inputfiles/register_status.py
+++ b/openecomp-be/lib/openecomp-sdc-translator-lib/openecomp-sdc-translator-core/src/test/resources/mock/services/heattotosca/securityrulestoportconnection/securityRulesToPortGetResource/inputfiles/register_status.py
@@ -12,7 +12,6 @@ from socket import getfqdn
 import sys
 from time import time
 
-
 parser = argparse.ArgumentParser()
 parser.add_argument("scribe_ip", type=str,
                     help="The IP where the Scribe can be reached.")
@@ -88,22 +87,24 @@ def build_add_json():
     ADD_COMPONENT_BODY["OAM_IP"] = OAM_DIRECT_IP
 
     for interface in netifaces.interfaces():
-        ADD_COMPONENT_BODY["machineNetworkInterfaces"].append({"name": interface, "value": netifaces.ifaddresses(interface)[2][0]['addr']})
+        ADD_COMPONENT_BODY["machineNetworkInterfaces"].append(
+            {"name": interface, "value": netifaces.ifaddresses(interface)[2][0]['addr']})
 
-    if PROBE_ID is not "":
-        ADD_COMPONENT_BODY["machineID"] = REGION + '_' + TENANT + '_' +\
-            CLUSTER_NAME + '_' + MACHINE_NAME + '_' + PROBE_ID
+    if PROBE_ID != "":
+        ADD_COMPONENT_BODY["machineID"] = REGION + '_' + TENANT + '_' + \
+                                          CLUSTER_NAME + '_' + MACHINE_NAME + '_' + PROBE_ID
     else:
-        ADD_COMPONENT_BODY["machineID"] = REGION + '_' + TENANT + '_' +\
-            CLUSTER_NAME + '_' + MACHINE_NAME
+        ADD_COMPONENT_BODY["machineID"] = REGION + '_' + TENANT + '_' + \
+                                          CLUSTER_NAME + '_' + MACHINE_NAME
     return ADD_COMPONENT_BODY
 
 
 def send_postage(p_url, p_url_user, p_url_password, p_json_data):
     json_header = {'Content-type': 'application/json'}
-    request = requests.post(p_url, json.dumps(p_json_data), json_header, auth=requests.auth.HTTPBasicAuth(p_url_user, p_url_password))
-    print request.status_code
-    if (request.status_code != 200):
+    request = requests.post(p_url, json.dumps(p_json_data), json_header,
+                            auth=requests.auth.HTTPBasicAuth(p_url_user, p_url_password))
+    print(request.status_code)
+    if request.status_code != 200:
         sys.exit(1)
     return request.status_code
 
@@ -118,9 +119,10 @@ def post_add_machine():
     read_metadata()
     return send_postage(add_machine_ip, user, password, build_add_json())
 
+
 if args.stage is None and args.status is None and args.description is None:
-    print "adding machine"
-    print post_add_machine()
+    print("adding machine")
+    print(post_add_machine())
 else:
-    print "logging health"
-    print post_health()
+    print("logging health")
+    print(post_health())
diff --git a/openecomp-be/lib/openecomp-sdc-translator-lib/openecomp-sdc-translator-core/src/test/resources/mock/services/heattotosca/securityrulestoportconnection/securityRulesToPortGetResource/inputfiles/wait_for_resources.py b/openecomp-be/lib/openecomp-sdc-translator-lib/openecomp-sdc-translator-core/src/test/resources/mock/services/heattotosca/securityrulestoportconnection/securityRulesToPortGetResource/inputfiles/wait_for_resources.py
index 5d960d659e..5abf961f75 100644
--- a/openecomp-be/lib/openecomp-sdc-translator-lib/openecomp-sdc-translator-core/src/test/resources/mock/services/heattotosca/securityrulestoportconnection/securityRulesToPortGetResource/inputfiles/wait_for_resources.py
+++ b/openecomp-be/lib/openecomp-sdc-translator-lib/openecomp-sdc-translator-core/src/test/resources/mock/services/heattotosca/securityrulestoportconnection/securityRulesToPortGetResource/inputfiles/wait_for_resources.py
@@ -16,9 +16,9 @@ def parse_json_file(json_path):
 
 def check_network_interfaces():
     for interface in netifaces.interfaces():
-        if(sys.platform != 'win32' or netifaces.ifaddresses(interface)[-1000][0]['addr'] != '00:00:00:00:00:00:00:e0'):
+        if sys.platform != 'win32' or netifaces.ifaddresses(interface)[-1000][0]['addr'] != '00:00:00:00:00:00:00:e0':
             while 2 not in netifaces.ifaddresses(interface).keys() and 23 not in netifaces.ifaddresses(interface).keys():
-                print "Still waiting for interface:", interface
+                print("Still waiting for interface:", interface)
                 time.sleep(TIME_INTERVAL)
 
 
@@ -29,7 +29,7 @@ def check_connectivity():
         ping_str = "ping -n 1 "
 
     while os.system(ping_str + component_ip) != 0:
-        print "No connectivity to", component_ip, "waiting", TIME_INTERVAL, "seconds"
+        print("No connectivity to", component_ip, "waiting", TIME_INTERVAL, "seconds")
         time.sleep(TIME_INTERVAL)
 
 
@@ -51,7 +51,7 @@ def check_cinder_mounts():
         cinder_attached = os.popen("wmic diskdrive get DeviceID | find /i \"PHYSICALDRIVE\" | find /V \"0\" /C").read()
 
     while (int(cinder_attached) < cinder_count) and (cinder_count != 0):
-        print "Missing a cinder mount, waiting", TIME_INTERVAL, "seconds"
+        print("Missing a cinder mount, waiting", TIME_INTERVAL, "seconds")
         time.sleep(TIME_INTERVAL)
 
         if sys.platform.startswith('linux'):
@@ -62,7 +62,7 @@ def check_cinder_mounts():
                 "wmic diskdrive get DeviceID | find /i \"PHYSICALDRIVE\" | find /V \"0\" /C").read()
 
         if int(cinder_attached) == cinder_count:
-            print "All cinder are attached and ready to be formatted and mounted"
+            print("All cinder are attached and ready to be formatted and mounted")
 
 
 def main():
@@ -72,7 +72,7 @@ def main():
     if component_ip is not None:
         check_connectivity()
 
-    print "All resources are ready"
+    print("All resources are ready")
 
 
 if __name__ == "__main__":
diff --git a/openecomp-be/tools/build/scripts/action_library_client/action_library_client.py b/openecomp-be/tools/build/scripts/action_library_client/action_library_client.py
index 7f513afe86..0537128665 100644
--- a/openecomp-be/tools/build/scripts/action_library_client/action_library_client.py
+++ b/openecomp-be/tools/build/scripts/action_library_client/action_library_client.py
@@ -147,6 +147,7 @@ class FinalizeStatus(object):
 
 class ArgsDict(dict):
     """A dict which makes attributes accessible as properties."""
+
     def __getattr__(self, attr):
         return self[attr]
 
@@ -221,33 +222,33 @@ class ArgumentParser(object):
     def usage():
         """Print usage message."""
         print("" +
-            "Usage: action_library_client.py [--help] [--url <url>] [--in <filename>]\n" +
-            "                                 [--out <filename>] [--config <filename>]\n" +
-            "                                 [--log <filename>] [--uuid <uuid>]\n" +
-            "                                 [--curl] [--dryrun] [--verbose] [--version]\n" +
-            "                                 [--list | --create | --update= | --delete |\n" +
-            "                                  --checkout | --undocheckout | --checkin | --submit]\n" +
-            "\n" +
-            "Optional arguments:\n" +
-            "  --help                Show this help message and exit\n" +
-            "  --url <url>           REST endpoint URL\n" +
-            "  --in <filename>       Path to JSON input file (else STDIN)\n" +
-            "  --out <filename>      Path to JSON output file (else STDOUT or logfile)\n" +
-            "  --config <filename>   Path to configuration file\n" +
-            "  --log <filename>      Path to logfile (else STDOUT)\n" +
-            "  --uuid <uuid>         Action UUID, (=='actionInvariantUUID')\n" +
-            "  --curl                Use curl transport impl\n" +
-            "  --dryrun              Describe what will happen, execute nothing\n" +
-            "  --verbose             Verbose diagnostic output\n" +
-            "  --version             Print script version and exit\n" +
-            "  --list                List actions\n" +
-            "  --create              Create new action (requires --in)\n" +
-            "  --update              Update existing action (requires --uuid, --in)\n" +
-            "  --delete              Delete existing action (requires --uuid)\n" +
-            "  --checkout            Create minor version candidate (requires --uuid)\n" +
-            "  --undocheckout        Discard minor version candidate (requires --uuid)\n" +
-            "  --checkin             Create minor version from candidate (requires --uuid)\n" +
-            "  --submit              Create next major version (requires --uuid)")
+              "Usage: action_library_client.py [--help] [--url <url>] [--in <filename>]\n" +
+              "                                 [--out <filename>] [--config <filename>]\n" +
+              "                                 [--log <filename>] [--uuid <uuid>]\n" +
+              "                                 [--curl] [--dryrun] [--verbose] [--version]\n" +
+              "                                 [--list | --create | --update= | --delete |\n" +
+              "                                  --checkout | --undocheckout | --checkin | --submit]\n" +
+              "\n" +
+              "Optional arguments:\n" +
+              "  --help                Show this help message and exit\n" +
+              "  --url <url>           REST endpoint URL\n" +
+              "  --in <filename>       Path to JSON input file (else STDIN)\n" +
+              "  --out <filename>      Path to JSON output file (else STDOUT or logfile)\n" +
+              "  --config <filename>   Path to configuration file\n" +
+              "  --log <filename>      Path to logfile (else STDOUT)\n" +
+              "  --uuid <uuid>         Action UUID, (=='actionInvariantUUID')\n" +
+              "  --curl                Use curl transport impl\n" +
+              "  --dryrun              Describe what will happen, execute nothing\n" +
+              "  --verbose             Verbose diagnostic output\n" +
+              "  --version             Print script version and exit\n" +
+              "  --list                List actions\n" +
+              "  --create              Create new action (requires --in)\n" +
+              "  --update              Update existing action (requires --uuid, --in)\n" +
+              "  --delete              Delete existing action (requires --uuid)\n" +
+              "  --checkout            Create minor version candidate (requires --uuid)\n" +
+              "  --undocheckout        Discard minor version candidate (requires --uuid)\n" +
+              "  --checkin             Create minor version from candidate (requires --uuid)\n" +
+              "  --submit              Create next major version (requires --uuid)")
 
 
 ###############################################################################
@@ -533,7 +534,7 @@ class CURLRESTClient(IRESTClient):
         """Debug curl command, for diags and dryrun."""
         buf = ""
         for token in cmd:
-            if token is "curl" or token.startswith("-"):
+            if token == "curl" or token.startswith("-"):
                 buf = "{0}{1} ".format(buf, token)
             else:
                 buf = "{0}\"{1}\" ".format(buf, token)
@@ -556,7 +557,7 @@ class CURLRESTClient(IRESTClient):
             try:
                 separator = output.index("\r\n\r\n{")
                 self.logger.debug("HTTP preamble:\n{0}".format(output[:separator]))
-                json_body = json.loads(output[(separator+4):])
+                json_body = json.loads(output[(separator + 4):])
                 self.log_json_response(method, json_body)
                 return json_body
             except ValueError:
diff --git a/openecomp-be/tools/build/scripts/parse-json.py b/openecomp-be/tools/build/scripts/parse-json.py
index 46537ceac5..83c70aac01 100644
--- a/openecomp-be/tools/build/scripts/parse-json.py
+++ b/openecomp-be/tools/build/scripts/parse-json.py
@@ -41,17 +41,19 @@ from collections import OrderedDict
 
 
 def readJsonFile(file, type):
-  with open(file, 'r') as f:
-     data = json.load(f, object_pairs_hook=OrderedDict)
-     return data[type]
+    with open(file, 'r') as f:
+        data = json.load(f, object_pairs_hook=OrderedDict)
+        return data[type]
+
 
 def printJsonTypeEntries(jsonData):
-        for i in jsonData.keys():
-                print jsonData[i] + ';'
+    for i in jsonData.keys():
+        print(jsonData[i] + ';')
 
 
 def usage():
-    print 'parseJsonFile.py [-f <json-file> & -t <cql-type: drop|create|insert|update|select]'
+    print('parseJsonFile.py [-f <json-file> & -t <cql-type: drop|create|insert|update|select]')
+
 
 def main(argv):
     action = ''
diff --git a/openecomp-be/tools/migration/1607_to_1610.py b/openecomp-be/tools/migration/1607_to_1610.py
index f46cb3a4b8..e817e3b1e6 100644
--- a/openecomp-be/tools/migration/1607_to_1610.py
+++ b/openecomp-be/tools/migration/1607_to_1610.py
@@ -1,6 +1,6 @@
 #!/usr/bin/python
 import os
-import sys,json,datetime,time,types,httplib,re
+import sys, json, datetime, time, types, httplib, re
 import mimetypes
 
 DEFAULT_HOST = "127.0.0.1"
@@ -13,49 +13,50 @@ DEFAULT_PASSWORD = "cs0008"
 
 ONBOARD_BASE_PATH = "/onboarding-api/v1.0"
 VSP_LIST_PATH = "{0}/vendor-software-products".format(ONBOARD_BASE_PATH)
-VSP_ACTIONS_PATH =  "{0}/vendor-software-products/{{vspId}}/actions".format(ONBOARD_BASE_PATH)
+VSP_ACTIONS_PATH = "{0}/vendor-software-products/{{vspId}}/actions".format(ONBOARD_BASE_PATH)
 VSP_UPLOAD_PATH = "{0}/vendor-software-products/{{vspId}}/upload".format(ONBOARD_BASE_PATH)
 VSP_DOWNLOAD_PATH = "{0}/vendor-software-products/{{vspId}}/downloadHeat".format(ONBOARD_BASE_PATH)
 VSP_GET_URL = "{0}/vendor-software-products/{{vspId}}".format(ONBOARD_BASE_PATH)
 
+
 def main(argv):
-    username=DEFAULT_USERNAME
-    password=DEFAULT_PASSWORD
-    host=DEFAULT_HOST
+    username = DEFAULT_USERNAME
+    password = DEFAULT_PASSWORD
+    host = DEFAULT_HOST
 
     if not argv:
-        print "Going to use default values"
+        print("Going to use default values")
     else:
-    	if argv[0].lower() == 'h' or argv[0].lower() == '-h':
-        	printHelp()
-        	return
-
-       	if argv[0] == '-ip':
-                host=argv[1]
-	else:
-		if argv[0].lower() == '-a' and '/' not in argv[1]:
-        		print '\n>>> Error: Credentials required (username/password)\n'
-			printHelp()
-        		return
-
-		else:
-                        creds = argv[1].split('/')
-                        username = creds[0]
-                        password = creds[1] # not used
-
-               	try:
-                       	cmdIp=argv[2]
-                       	host=argv[3]
-               	except IndexError:
-                       	host=DEFAULT_HOST
-	print "Going to use user defined values"
+        if argv[0].lower() == 'h' or argv[0].lower() == '-h':
+            printHelp()
+            return
+
+        if argv[0] == '-ip':
+            host = argv[1]
+        else:
+            if argv[0].lower() == '-a' and '/' not in argv[1]:
+                print('\n>>> Error: Credentials required (username/password)\n')
+                printHelp()
+                return
+
+            else:
+                creds = argv[1].split('/')
+                username = creds[0]
+                password = creds[1]  # not used
+
+            try:
+                cmdIp = argv[2]
+                host = argv[3]
+            except IndexError:
+                host = DEFAULT_HOST
+        print("Going to use user defined values")
     Service.server(host)
 
-    webHandler=WebHandler(host=host, port=DEFAULT_PORT)
+    webHandler = WebHandler(host=host, port=DEFAULT_PORT)
     response, headers = webHandler.rest(url=VSP_LIST_PATH, method='GET', data=None, userId=username)
     jResult = json.loads(response)
     jSrvices = jResult["results"]
-    reportFileName = 'upgradereport.csv'  #datetime.now()
+    reportFileName = 'upgradereport.csv'  # datetime.now()
     reportFile = open(reportFileName, 'w')
     reportFile.write(Service.header())
 
@@ -69,85 +70,91 @@ def main(argv):
         else:
             lockingUser = jService["lockingUser"]
 
-        service = Service(serviceName=serviceName, vspId=vspId, vendorName=vendorName, lockingUser=lockingUser )
-        print service
-	# Will try to GET the service
+        service = Service(serviceName=serviceName, vspId=vspId, vendorName=vendorName, lockingUser=lockingUser)
+        print(service)
+        # Will try to GET the service
         res = service.Get()
         if res == 500:
-           serviceMigration(service, status, username)
+            serviceMigration(service, status, username)
         else:
-           print "Service {0} was tested and does not need a migration".format(serviceName)
+            print("Service {0} was tested and does not need a migration".format(serviceName))
 
         reportFile.write(service.line())
     reportFile.close()
 
 
 def serviceMigration(service, serviceStatus, username):
-        print "Service {0} was tested and it needs a migration".format(service.serviceName)
-        print "Service {0} - Migration start"
-        if serviceStatus == "Locked":
-           print "Service {0} is locked - forcing checkin".format(service.serviceName)
-           service.Checkin()
-        print "Doing new checkout"
-        service.Checkout(username)
-
-        zipName = service.DownloadHeat()
-        if not zipName:
-            print "no heat found"
-            service.uploadStatus = "no heat found"
-        else:
-            uploadResponse = service.UploadHeat(zipName)
-            uploadResults = json.loads(uploadResponse)
-            if uploadResults['status'] == 'Success' and uploadResults['errors'].__len__() == 0:
-                service.uploadStatus = "Heat uploaded successfully"
-            else:
-                service.uploadStatus = "Heat uploaded with errors"
-        print "Doing new checkin"
+    print("Service {0} was tested and it needs a migration".format(service.serviceName))
+    print("Service {0} - Migration start")
+    if serviceStatus == "Locked":
+        print("Service {0} is locked - forcing checkin".format(service.serviceName))
         service.Checkin()
+    print("Doing new checkout")
+    service.Checkout(username)
+
+    zipName = service.DownloadHeat()
+    if not zipName:
+        print("no heat found")
+        service.uploadStatus = "no heat found"
+    else:
+        uploadResponse = service.UploadHeat(zipName)
+        uploadResults = json.loads(uploadResponse)
+        if uploadResults['status'] == 'Success' and uploadResults['errors'].__len__() == 0:
+            service.uploadStatus = "Heat uploaded successfully"
+        else:
+            service.uploadStatus = "Heat uploaded with errors"
+    print("Doing new checkin")
+    service.Checkin()
 
-        print "Service {0} - Migration end"
+    print("Service {0} - Migration end")
 
 
-def  printHelp():
+def printHelp():
     print("Upgrade script Help:")
     print("==================================")
     print("1607_to_1610 -h                            --> get help")
     print("1607_to_1610 -a <username>/<password> [-ip {ip}]")
     print("Example: 1607_to_1610 -a root/secret")
 
+
 class Service(object):
-    def __init__(self, serviceName, vspId ,vendorName, lockingUser):
+    def __init__(self, serviceName, vspId, vendorName, lockingUser):
         self.serviceName = serviceName
         self.vspId = vspId
         self.vendorName = vendorName
         self.lockingUser = lockingUser
-        self.webHandler = WebHandler(host=Service.serveraddress, port=DEFAULT_PORT) # Schema?
+        self.webHandler = WebHandler(host=Service.serveraddress, port=DEFAULT_PORT)  # Schema?
         self.uploadStatus = "not started"
 
     def __repr__(self):
-        return 'Name: {0}, Id: {1}, Vendor: {2}, locked by: {3}, status {4}'.format(self.serviceName, self.vspId ,self.vendorName, self.lockingUser, self.uploadStatus)
+        return 'Name: {0}, Id: {1}, Vendor: {2}, locked by: {3}, status {4}'.format(self.serviceName, self.vspId,
+                                                                                    self.vendorName, self.lockingUser,
+                                                                                    self.uploadStatus)
+
     @classmethod
     def header(cls):
         return 'Name,Id,Vendor,locked-by,status\n'
 
     @classmethod
     def server(cls, address):
-        cls.serveraddress=address
+        cls.serveraddress = address
 
     def line(self):
-        return '{0},{1},{2},{3},{4}\n'.format(self.serviceName, self.vspId ,self.vendorName, self.lockingUser, self.uploadStatus)
+        return '{0},{1},{2},{3},{4}\n'.format(self.serviceName, self.vspId, self.vendorName, self.lockingUser,
+                                              self.uploadStatus)
 
     def Checkout(self, userId):
         # /v1.0/vendor-software-products/{vspId}/actions
-        urlpath=VSP_ACTIONS_PATH.format(vspId=self.vspId)
-        response, headers = self.webHandler.rest( url=urlpath, method='PUT', data={"action": "Checkout"}, userId=userId)
-        self.lockingUser=userId #we will later use this user to checkin
+        urlpath = VSP_ACTIONS_PATH.format(vspId=self.vspId)
+        response, headers = self.webHandler.rest(url=urlpath, method='PUT', data={"action": "Checkout"}, userId=userId)
+        self.lockingUser = userId  # we will later use this user to checkin
         return response
 
     def Checkin(self):
         # /v1.0/vendor-software-products/{vspId}/actions
         urlpath = VSP_ACTIONS_PATH.format(vspId=self.vspId)
-        response, headers = self.webHandler.rest(url=urlpath, method='PUT', data={"action": "Checkin"}, userId=self.lockingUser)
+        response, headers = self.webHandler.rest(url=urlpath, method='PUT', data={"action": "Checkin"},
+                                                 userId=self.lockingUser)
         return response
 
     def Get(self):
@@ -156,38 +163,39 @@ class Service(object):
         try:
             response, headers = self.webHandler.rest(url=urlpath, method='GET', data=None, userId=self.lockingUser)
         except HttpError as e:
-            print e.message
+            print(e.message)
             response = e.status
         return response
 
     def UploadHeat(self, zipName):
-            #/v1.0/vendor-software-products/{vspId}/upload
-            urlpath = VSP_UPLOAD_PATH.format(vspId=self.vspId)
-            try:
-                fields = []
-                with open(zipName, 'rb') as fin:
-                    buffer = fin.read()
-                    fin.close()
-                files = [('upload', 'heatfile.zip', buffer)]
-                response = self.webHandler.post_multipart('HTTP', urlpath, fields, files, self.lockingUser)
-
-                return response
-            finally:
-                print "done upload"
+        # /v1.0/vendor-software-products/{vspId}/upload
+        urlpath = VSP_UPLOAD_PATH.format(vspId=self.vspId)
+        try:
+            fields = []
+            with open(zipName, 'rb') as fin:
+                buffer = fin.read()
+                fin.close()
+            files = [('upload', 'heatfile.zip', buffer)]
+            response = self.webHandler.post_multipart('HTTP', urlpath, fields, files, self.lockingUser)
+
+            return response
+        finally:
+            print("done upload")
 
     def DownloadHeat(self):
-        urlpath=VSP_DOWNLOAD_PATH.format(vspId=self.vspId)
+        urlpath = VSP_DOWNLOAD_PATH.format(vspId=self.vspId)
         try:
-            response, headers = self.webHandler.rest(url=urlpath, method='Get', data=None, userId=self.lockingUser, accept='application/octet-stream')
+            response, headers = self.webHandler.rest(url=urlpath, method='Get', data=None, userId=self.lockingUser,
+                                                     accept='application/octet-stream')
         except HttpError as e:
             if e.status == 404:
                 return ""
 
         for (key, value) in headers:
             if key.lower() == "content-disposition":
-                file_name = value[value.index('=')+1:]
+                file_name = value[value.index('=') + 1:]
                 break
-        heatsDir= os.path.join(os.path.dirname(__file__), 'heats')
+        heatsDir = os.path.join(os.path.dirname(__file__), 'heats')
         if not os.path.exists(heatsDir):
             os.makedirs(heatsDir)
         file_name = os.path.join(heatsDir, file_name)
@@ -198,7 +206,6 @@ class Service(object):
         return file_name
 
 
-
 class WebHandler(object):
     def __init__(self, host, port):
         self.host = host
@@ -208,13 +215,13 @@ class WebHandler(object):
         connection = httplib.HTTPConnection(host=self.host, port=self.port)
 
         try:
-            headers = {'Content-Type':content_type ,'Accept':accept}
+            headers = {'Content-Type': content_type, 'Accept': accept}
             headers['USER_ID'] = userId
 
             connection.request(method=method, headers=headers, body=json.dumps(data), url=url)
             response = connection.getresponse()
             if response.status not in range(200, 300):
-                raise HttpError(status= response.status, message=response.reason)
+                raise HttpError(status=response.status, message=response.reason)
 
             return response.read(), response.getheaders()
         finally:
@@ -241,7 +248,7 @@ class WebHandler(object):
         h.endheaders()
         h.send(body)
         errcode, errmsg, headers = h.getreply()
-        print errcode, errmsg, headers
+        print(errcode, errmsg, headers)
         return h.file.read()
 
     def encode_multipart_form_data(self, fields, files):
@@ -268,14 +275,15 @@ class WebHandler(object):
     def get_content_type(self, filename):
         return mimetypes.guess_type(filename)[0] or 'application/octet-stream'
 
+
 class HttpError(Exception):
     def __init__(self, status, message):
         self.status = status
-        self.message=message
+        self.message = message
+
     def __str__(self):
         return repr(self.value, self.message)
 
+
 if __name__ == "__main__":
     main(sys.argv[1:])
-
-