catalog-be/src/main/resources/scripts/import/tosca/importONAPNormativeAll.py

   1 import pycurl
   2 import sys, getopt, os
   3 from StringIO import StringIO
   4 import json
   5 import copy
   6 import time
   7 #from importNormativeElements import createNormativeElement
   8 from importNormativeElements import *
   9 from importNormativeTypes import importNormativeTypes
  10 from importHeatTypes import importHeatTypes
  11 from importNfvTypes import importNfvTypes
  12 from importOnapTypes import importOnapTypes
  13 from importSolTypes import importSolTypes
  14 from importNormativeCapabilities import importNormativeCapabilities
  15 from importNormativeRelationships import importNormativeRelationships
  16 from importCategoryTypes import importCategories
  17 from importNormativeInterfaceLifecycleTypes import importNormativeInterfaceLifecycleType
  18 from importDataTypes import importDataTypes
  19 from importGroupTypes import importGroupTypes
  20 from importPolicyTypes import importPolicyTypes
  21 from importCommon import *
  22 import importCommon
  23
  24 #################################################################################################################################################################################################
  25 #                                                                                                                                                                                                                                                                                                                                                                                       #
  26 # Import all users from a given file                                                                                                                                                                                                                                                                                                                    #
  27 #                                                                                                                                                                                                                                                                                                                                                                                               #
  28 # activation :                                                                                                                                                                                                                                                                                                                                                                  #
  29 #       python importNormativeAll.py [-s <scheme> | --scheme=<scheme> ] [-i <be host> | --ip=<be host>] [-p <be port> | --port=<be port> ] [-u <user userId> | --user=<user userId> ] [-d <true|false> | --debug=<true|false>]  #
  30 #                                                                        [-v <true|false> | --updateversion=<true|false>]                                                                                                                                                                                                                       #
  31 #                                                                                                                                                                                                                                                                                                                                                                                               #
  32 # shortest activation (be host = localhost, be port = 8080, user = jh0003):                                                                                                                                                                                                                                     #       #                                                                                                                                                                                                                                                                                                                                                                                       #
  33 #               python importNormativeAll.py                                                                                                                                                                                                                                                                                                            #
  34 #                                                                                                                                                                                                                                                                                                                                                                                       #
  35 #################################################################################################################################################################################################
  36
  37 def usage():
  38         print sys.argv[0], '[-s <scheme> | --scheme=<scheme> ] [-i <be host> | --ip=<be host>] [-p <be port> | --port=<be port> ] [-u <user userId> | --user=<user userId> ] [-d <true|false> | --debug=<true|false>] [-v <true|false> | --updateversion=<true|false>]'
  39
  40 def handleResults(results, updateversion):
  41     if results is not None:
  42             print_frame_line()
  43             for result in results:
  44                 print_name_and_return_code(result[0], result[1])
  45             print_frame_line()
  46
  47             responseCodes = [200, 201]
  48
  49             if(updateversion == 'false'):
  50                 responseCodes = [200, 201, 409]
  51
  52             failedResults = filter(lambda x: x[1] == None or x[1] not in responseCodes, results)
  53             if (len(failedResults) > 0):
  54                 error_and_exit(1, None)
  55
  56 def main(argv):
  57         print 'Number of arguments:', len(sys.argv), 'arguments.'
  58
  59         beHost = 'localhost'
  60         bePort = '8080'
  61         adminUser = 'jh0003'
  62         debugf = None
  63         updateversion = 'true'
  64         importCommon.debugFlag = False
  65         scheme = 'http'
  66         opts = []
  67
  68         try:
  69                 opts, args = getopt.getopt(argv, "i:p:u:d:v:h:s:",
  70                                            ["ip=", "port=", "user=", "debug=", "updateversion=", "scheme="])
  71         except getopt.GetoptError:
  72                 usage()
  73                 error_and_exit(2, 'Invalid input')
  74
  75         for opt, arg in opts:
  76         #print opt, arg
  77                 if opt == '-h':
  78                         usage()
  79                         sys.exit(3)
  80                 elif opt in ("-i", "--ip"):
  81                         beHost = arg
  82                 elif opt in ("-p", "--port"):
  83                         bePort = arg
  84                 elif opt in ("-u", "--user"):
  85                         adminUser = arg
  86                 elif opt in ("-s", "--scheme"):
  87                         scheme = arg
  88                 elif opt in ("-d", "--debug"):
  89                         print arg
  90                         debugf = bool(arg.lower() == "true" or arg.lower() == "yes")
  91                 elif opt in ("-v", "--updateversion"):
  92                         print arg
  93                         if (arg.lower() == "false" or arg.lower() == "no"):
  94                                 updateversion = 'false'
  95
  96         print 'scheme =',scheme,',be host =',beHost,', be port =', bePort,', user =', adminUser, ', debug =', debugf, ', updateversion =', updateversion
  97
  98         if (debugf != None):
  99                 print 'set debug mode to ' + str(debugf)
 100                 importCommon.debugFlag = debugf
 101
 102         if ( beHost == None ):
 103                 usage()
 104                 sys.exit(3)
 105
 106         print sys.argv[0]
 107         pathdir = os.path.dirname(os.path.realpath(sys.argv[0]))
 108         debug("path dir =" + pathdir)
 109
 110         baseFileLocation = pathdir + "/../../../import/tosca/"
 111
 112         fileLocation = baseFileLocation + "data-types/"
 113         importDataTypes(scheme, beHost, bePort, adminUser, False, fileLocation)
 114
 115         print 'sleep until data type cache is updated'
 116         time.sleep( 70 )
 117
 118         fileLocation = baseFileLocation + "capability-types/"
 119         importNormativeCapabilities(scheme, beHost, bePort, adminUser, False, fileLocation)
 120
 121         fileLocation = baseFileLocation + "relationship-types/"
 122         importNormativeRelationships(scheme, beHost, bePort, adminUser, False, fileLocation)
 123
 124         fileLocation = baseFileLocation + "interface-lifecycle-types/"
 125         importNormativeInterfaceLifecycleType(scheme, beHost, bePort, adminUser, False, fileLocation)
 126
 127         fileLocation = baseFileLocation + "categories/"
 128         importCategories(scheme, beHost, bePort, adminUser, False, fileLocation)
 129
 130         fileLocation = baseFileLocation + "normative-types/"
 131         results = importNormativeTypes(scheme, beHost, bePort, adminUser, fileLocation, updateversion)
 132         handleResults(results, updateversion)
 133
 134         fileLocation = baseFileLocation + "heat-types/"
 135         resultsHeat = importHeatTypes(scheme, beHost, bePort, adminUser, fileLocation, updateversion)
 136         handleResults(resultsHeat, updateversion)
 137
 138         fileLocation = baseFileLocation + "nfv-types/"
 139         resultsHeat = importNfvTypes(scheme, beHost, bePort, adminUser, fileLocation, updateversion)
 140         handleResults(resultsHeat, updateversion)
 141
 142         fileLocation = baseFileLocation + "onap-types/"
 143         resultsHeat = importOnapTypes(scheme, beHost, bePort, adminUser, fileLocation, updateversion)
 144         handleResults(resultsHeat, updateversion)
 145
 146         fileLocation = baseFileLocation + "sol-types/"
 147         resultsHeat = importSolTypes(scheme, beHost, bePort, adminUser, fileLocation, updateversion)
 148         handleResults(resultsHeat, updateversion)
 149
 150         fileLocation = baseFileLocation + "group-types/"
 151         importGroupTypes(scheme, beHost, bePort, adminUser, False, fileLocation)
 152
 153         fileLocation = baseFileLocation + "policy-types/"
 154         importPolicyTypes(scheme, beHost, bePort, adminUser, False, fileLocation)
 155
 156         error_and_exit(0, None)
 157
 158 if __name__ == "__main__":
 159                 main(sys.argv[1:])
 160