openmano

   1 #!/usr/bin/env python
   2 # -*- coding: utf-8 -*-
   3 # PYTHON_ARGCOMPLETE_OK
   4
   5 ##
   6 # Copyright 2015 Telefónica Investigación y Desarrollo, S.A.U.
   7 # This file is part of openmano
   8 # All Rights Reserved.
   9 #
  10 # Licensed under the Apache License, Version 2.0 (the "License"); you may
  11 # not use this file except in compliance with the License. You may obtain
  12 # a copy of the License at
  13 #
  14 #         http://www.apache.org/licenses/LICENSE-2.0
  15 #
  16 # Unless required by applicable law or agreed to in writing, software
  17 # distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
  18 # WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
  19 # License for the specific language governing permissions and limitations
  20 # under the License.
  21 #
  22 # For those usages not covered by the Apache License, Version 2.0 please
  23 # contact with: nfvlabs@tid.es
  24 ##
  25
  26 '''
  27 openmano client used to interact with openmano-server (openmanod)
  28 '''
  29 __author__ = "Alfonso Tierno, Gerardo Garcia, Pablo Montes"
  30 __date__ = "$09-oct-2014 09:09:48$"
  31 __version__ = "0.4.14-r521"
  32 version_date = "May 2017"
  33
  34 from argcomplete.completers import FilesCompleter
  35 import os
  36 import argparse
  37 import argcomplete
  38 import requests
  39 import json
  40 import yaml
  41 import logging
  42 #from jsonschema import validate as js_v, exceptions as js_e
  43
  44 class ArgumentParserError(Exception): pass
  45
  46 class OpenmanoCLIError(Exception): pass
  47
  48 class ThrowingArgumentParser(argparse.ArgumentParser):
  49     def error(self, message):
  50         print "Error: %s" %message
  51         print
  52         self.print_usage()
  53         #self.print_help()
  54         print
  55         print "Type 'openmano -h' for help"
  56         raise ArgumentParserError
  57
  58
  59 def config(args):
  60     print "OPENMANO_HOST: %s" %mano_host
  61     print "OPENMANO_PORT: %s" %mano_port
  62     if args.n:
  63         logger.debug("resolving tenant and datacenter names")
  64         mano_tenant_id = "None"
  65         mano_tenant_name = "None"
  66         mano_datacenter_id = "None"
  67         mano_datacenter_name = "None"
  68         try:
  69             mano_tenant_id = _get_item_uuid("tenants", mano_tenant)
  70             URLrequest = "http://%s:%s/openmano/tenants/%s" %(mano_host, mano_port, mano_tenant_id)
  71             mano_response = requests.get(URLrequest)
  72             logger.debug("openmano response: %s", mano_response.text )
  73             content = mano_response.json()
  74             mano_tenant_name = content["tenant"]["name"]
  75             URLrequest = "http://%s:%s/openmano/%s/datacenters/%s" %(mano_host, mano_port, mano_tenant_id, mano_datacenter)
  76             mano_response = requests.get(URLrequest)
  77             logger.debug("openmano response: %s", mano_response.text )
  78             content = mano_response.json()
  79             if "error" not in content:
  80                 mano_datacenter_id = content["datacenter"]["uuid"]
  81                 mano_datacenter_name = content["datacenter"]["name"]
  82         except OpenmanoCLIError:
  83             pass
  84         print "OPENMANO_TENANT: %s" %mano_tenant
  85         print "    Id: %s" %mano_tenant_id
  86         print "    Name: %s" %mano_tenant_name
  87         print "OPENMANO_DATACENTER: %s" %str (mano_datacenter)
  88         print "    Id: %s" %mano_datacenter_id
  89         print "    Name: %s" %mano_datacenter_name
  90     else:
  91         print "OPENMANO_TENANT: %s" %mano_tenant
  92         print "OPENMANO_DATACENTER: %s" %str (mano_datacenter)
  93
  94 def _print_verbose(mano_response, verbose_level=0):
  95     content = mano_response.json()
  96     result = 0 if mano_response.status_code==200 else mano_response.status_code
  97     if type(content)!=dict or len(content)!=1:
  98         #print "Non expected format output"
  99         print str(content)
 100         return result
 101
 102     val=content.values()[0]
 103     if type(val)==str:
 104         print val
 105         return result
 106     elif type(val) == list:
 107         content_list = val
 108     elif type(val)==dict:
 109         content_list = [val]
 110     else:
 111         #print "Non expected dict/list format output"
 112         print str(content)
 113         return result
 114
 115     #print content_list
 116     if verbose_level==None:
 117         verbose_level=0
 118     if verbose_level >= 3:
 119         print yaml.safe_dump(content, indent=4, default_flow_style=False)
 120         return result
 121
 122     if mano_response.status_code == 200:
 123         uuid = None
 124         for content in content_list:
 125             if "uuid" in content:
 126                 uuid = content['uuid']
 127             elif "id" in content:
 128                 uuid = content['id']
 129             elif "vim_id" in content:
 130                 uuid = content['vim_id']
 131             name = content.get('name');
 132             if not uuid:
 133                 uuid = ""
 134             if not name:
 135                 name = ""
 136             myoutput = "%s %s" %(uuid.ljust(38),name.ljust(20))
 137             if content.get("status"):
 138                 myoutput += " " + content['status'].ljust(20)
 139             elif "enabled" in content and not content["enabled"]:
 140                 myoutput += " enabled=False".ljust(20)
 141             if verbose_level >=1:
 142                 if content.get('created_at'):
 143                     myoutput += " " + content['created_at'].ljust(20)
 144                 if content.get('sdn_attached_ports'):
 145                     #myoutput += " " + str(content['sdn_attached_ports']).ljust(20)
 146                     myoutput += "\nsdn_attached_ports:\n" + yaml.safe_dump(content['sdn_attached_ports'], indent=4, default_flow_style=False)
 147                 if verbose_level >=2:
 148                     new_line='\n'
 149                     if content.get('type'):
 150                         myoutput += new_line + "  Type: " + content['type'].ljust(29)
 151                         new_line=''
 152                     if content.get('description'):
 153                         myoutput += new_line + "  Description: " + content['description'].ljust(20)
 154             print myoutput
 155     else:
 156         print content['error']['description']
 157     return result
 158
 159 def parser_json_yaml(file_name):
 160     try:
 161         f = file(file_name, "r")
 162         text = f.read()
 163         f.close()
 164     except Exception as e:
 165         return (False, str(e))
 166
 167     #Read and parse file
 168     if file_name[-5:]=='.yaml' or file_name[-4:]=='.yml' or (file_name[-5:]!='.json' and '\t' not in text):
 169         try:
 170             config = yaml.load(text)
 171         except yaml.YAMLError as exc:
 172             error_pos = ""
 173             if hasattr(exc, 'problem_mark'):
 174                 mark = exc.problem_mark
 175                 error_pos = " at line:%s column:%s" % (mark.line+1, mark.column+1)
 176             return (False, "Error loading file '"+file_name+"' yaml format error" + error_pos)
 177     else: #json
 178         try:
 179             config = json.loads(text)
 180         except Exception as e:
 181             return (False, "Error loading file '"+file_name+"' json format error " + str(e) )
 182
 183     return True, config
 184
 185 def _load_file_or_yaml(content):
 186     '''
 187     'content' can be or a yaml/json file or a text containing a yaml/json text format
 188     This function autodetect, trying to load and parse the file,
 189     if fails trying to parse the 'content' text
 190     Returns the dictionary once parsed, or print an error and finish the program
 191     '''
 192     #Check config file exists
 193     if os.path.isfile(content):
 194         r,payload = parser_json_yaml(content)
 195         if not r:
 196             print payload
 197             exit(-1)
 198     elif "{" in content or ":" in content:
 199         try:
 200             payload = yaml.load(content)
 201         except yaml.YAMLError as exc:
 202             error_pos = ""
 203             if hasattr(exc, 'problem_mark'):
 204                 mark = exc.problem_mark
 205                 error_pos = " at position: (%s:%s)" % (mark.line+1, mark.column+1)
 206             print "Error loading yaml/json text"+error_pos
 207             exit (-1)
 208     else:
 209         print "'%s' is neither a valid file nor a yaml/json content" % content
 210         exit(-1)
 211     return payload
 212
 213 def _get_item_uuid(item, item_name_id, tenant=None):
 214     if tenant:
 215         URLrequest = "http://%s:%s/openmano/%s/%s" %(mano_host, mano_port, tenant, item)
 216     else:
 217         URLrequest = "http://%s:%s/openmano/%s" %(mano_host, mano_port, item)
 218     mano_response = requests.get(URLrequest)
 219     logger.debug("openmano response: %s", mano_response.text )
 220     content = mano_response.json()
 221     #print content
 222     found = 0
 223     for i in content[item]:
 224         if i["uuid"] == item_name_id:
 225             return item_name_id
 226         if i["name"] == item_name_id:
 227             uuid = i["uuid"]
 228             found += 1
 229     if found == 0:
 230         raise OpenmanoCLIError("No %s found with name/uuid '%s'" %(item[:-1], item_name_id))
 231     elif found > 1:
 232         raise OpenmanoCLIError("%d %s found with name '%s'. uuid must be used" %(found, item, item_name_id))
 233     return uuid
 234 #
 235 # def check_valid_uuid(uuid):
 236 #     id_schema = {"type" : "string", "pattern": "^[a-fA-F0-9]{8}(-[a-fA-F0-9]{4}){3}-[a-fA-F0-9]{12}$"}
 237 #     try:
 238 #         js_v(uuid, id_schema)
 239 #         return True
 240 #     except js_e.ValidationError:
 241 #         return False
 242
 243 def _get_tenant(tenant_name_id = None):
 244     if not tenant_name_id:
 245         tenant_name_id = mano_tenant
 246         if not mano_tenant:
 247             raise OpenmanoCLIError("'OPENMANO_TENANT' environment variable is not set")
 248     return _get_item_uuid("tenants", tenant_name_id)
 249
 250 def _get_datacenter(datacenter_name_id = None, tenant = "any"):
 251     if not datacenter_name_id:
 252         datacenter_name_id = mano_datacenter
 253         if not datacenter_name_id:
 254             raise OpenmanoCLIError("neither 'OPENMANO_DATACENTER' environment variable is set nor --datacenter option is used")
 255     return _get_item_uuid("datacenters", datacenter_name_id, tenant)
 256
 257 def vnf_create(args):
 258     #print "vnf-create",args
 259     headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
 260     tenant = _get_tenant()
 261     myvnf = _load_file_or_yaml(args.file)
 262
 263     if args.name or args.description or args.image_path or args.image_name or args.image_checksum:
 264         #print args.name
 265         try:
 266             if args.name:
 267                 myvnf['vnf']['name'] = args.name
 268             if args.description:
 269                 myvnf['vnf']['description'] = args.description
 270             if args.image_path:
 271                 index=0
 272                 for image_path_ in args.image_path.split(","):
 273                     #print "image-path", image_path_
 274                     myvnf['vnf']['VNFC'][index]['VNFC image']=image_path_
 275                     if "image name" in myvnf['vnf']['VNFC'][index]:
 276                         del myvnf['vnf']['VNFC'][index]["image name"]
 277                     if "image checksum" in myvnf['vnf']['VNFC'][index]:
 278                         del myvnf['vnf']['VNFC'][index]["image checksum"]
 279                     index=index+1
 280             if args.image_name: #image name precedes if both are supplied
 281                 index=0
 282                 for image_name_ in args.image_name.split(","):
 283                     myvnf['vnf']['VNFC'][index]['image name']=image_name_
 284                     if "VNFC image" in myvnf['vnf']['VNFC'][index]:
 285                         del myvnf['vnf']['VNFC'][index]["VNFC image"]
 286                     index=index+1
 287             if args.image_checksum:
 288                 index=0
 289                 for image_checksum_ in args.image_checksum.split(","):
 290                     myvnf['vnf']['VNFC'][index]['image checksum']=image_checksum_
 291                     index=index+1
 292         except (KeyError, TypeError), e:
 293             if str(e)=='vnf':           error_pos= "missing field 'vnf'"
 294             elif str(e)=='name':        error_pos= "missing field  'vnf':'name'"
 295             elif str(e)=='description': error_pos= "missing field  'vnf':'description'"
 296             elif str(e)=='VNFC':        error_pos= "missing field  'vnf':'VNFC'"
 297             elif str(e)==str(index):    error_pos= "field  'vnf':'VNFC' must be an array"
 298             elif str(e)=='VNFC image':  error_pos= "missing field 'vnf':'VNFC'['VNFC image']"
 299             elif str(e)=='image name':  error_pos= "missing field 'vnf':'VNFC'['image name']"
 300             elif str(e)=='image checksum':  error_pos= "missing field 'vnf':'VNFC'['image checksum']"
 301             else:                       error_pos="wrong format"
 302             print "Wrong VNF descriptor: " + error_pos
 303             return -1
 304     payload_req = json.dumps(myvnf)
 305
 306     #print payload_req
 307
 308     URLrequest = "http://%s:%s/openmano/%s/vnfs" %(mano_host, mano_port, tenant)
 309     logger.debug("openmano request: %s", payload_req)
 310     mano_response = requests.post(URLrequest, headers = headers_req, data=payload_req)
 311     logger.debug("openmano response: %s", mano_response.text )
 312
 313     return _print_verbose(mano_response, args.verbose)
 314
 315 def vnf_list(args):
 316     #print "vnf-list",args
 317     if args.all:
 318         tenant = "any"
 319     else:
 320         tenant = _get_tenant()
 321     if args.name:
 322         toshow = _get_item_uuid("vnfs", args.name, tenant)
 323         URLrequest = "http://%s:%s/openmano/%s/vnfs/%s" %(mano_host, mano_port, tenant, toshow)
 324     else:
 325         URLrequest = "http://%s:%s/openmano/%s/vnfs" %(mano_host, mano_port, tenant)
 326     mano_response = requests.get(URLrequest)
 327     logger.debug("openmano response: %s", mano_response.text )
 328     content = mano_response.json()
 329     #print json.dumps(content, indent=4)
 330     if args.verbose==None:
 331         args.verbose=0
 332     result = 0 if mano_response.status_code==200 else mano_response.status_code
 333     if mano_response.status_code == 200:
 334         if not args.name:
 335             if args.verbose >= 3:
 336                 print yaml.safe_dump(content, indent=4, default_flow_style=False)
 337                 return result
 338             if len(content['vnfs']) == 0:
 339                 print "No VNFs were found."
 340                 return 404 #HTTP_Not_Found
 341             for vnf in content['vnfs']:
 342                 myoutput = "%s %s" %(vnf['uuid'].ljust(38),vnf['name'].ljust(20))
 343                 if args.verbose >=1:
 344                     myoutput = "%s %s" %(myoutput, vnf['created_at'].ljust(20))
 345                 print myoutput
 346                 if args.verbose >=2:
 347                     print "  Description: %s" %vnf['description']
 348                     print "  VNF descriptor file: %s" %vnf['path']
 349         else:
 350             if args.verbose:
 351                 print yaml.safe_dump(content, indent=4, default_flow_style=False)
 352                 return result
 353             vnf = content['vnf']
 354             print "%s %s %s" %(vnf['uuid'].ljust(38),vnf['name'].ljust(20), vnf['created_at'].ljust(20))
 355             print "  Description: %s" %vnf['description']
 356             #print "  VNF descriptor file: %s" %vnf['path']
 357             print "    VMs:"
 358             for vm in vnf['VNFC']:
 359                 #print "    %s %s %s" %(vm['name'].ljust(20), vm['uuid'].ljust(38), vm['description'].ljust(30))
 360                 print "        %s %s" %(vm['name'].ljust(20), vm['description'])
 361             if len(vnf['nets'])>0:
 362                 print "    Internal nets:"
 363                 for net in vnf['nets']:
 364                     print "        %s %s" %(net['name'].ljust(20), net['description'])
 365             if len(vnf['external-connections'])>0:
 366                 print "    External interfaces:"
 367                 for interface in vnf['external-connections']:
 368                     print "        %s %s %s %s" %(interface['external_name'].ljust(20), interface['vm_name'].ljust(20), interface['internal_name'].ljust(20), \
 369                                                   interface.get('vpci',"").ljust(14))
 370     else:
 371         print content['error']['description']
 372         if args.verbose:
 373             print yaml.safe_dump(content, indent=4, default_flow_style=False)
 374     return result
 375
 376 def vnf_delete(args):
 377     #print "vnf-delete",args
 378     if args.all:
 379         tenant = "any"
 380     else:
 381         tenant = _get_tenant()
 382     todelete = _get_item_uuid("vnfs", args.name, tenant=tenant)
 383     if not args.force:
 384         r = raw_input("Delete VNF %s (y/N)? " %(todelete))
 385         if  not (len(r)>0  and r[0].lower()=="y"):
 386             return 0
 387     URLrequest = "http://%s:%s/openmano/%s/vnfs/%s" %(mano_host, mano_port, tenant, todelete)
 388     mano_response = requests.delete(URLrequest)
 389     logger.debug("openmano response: %s", mano_response.text )
 390     result = 0 if mano_response.status_code==200 else mano_response.status_code
 391     content = mano_response.json()
 392     #print json.dumps(content, indent=4)
 393     if mano_response.status_code == 200:
 394         print content['result']
 395     else:
 396         print content['error']['description']
 397     return result
 398
 399 def scenario_create(args):
 400     #print "scenario-create",args
 401     tenant = _get_tenant()
 402     headers_req = {'content-type': 'application/yaml'}
 403     myscenario = _load_file_or_yaml(args.file)
 404
 405     if args.name:
 406         myscenario['name'] = args.name
 407     if args.description:
 408         myscenario['description'] = args.description
 409     payload_req = yaml.safe_dump(myscenario, explicit_start=True, indent=4, default_flow_style=False, tags=False, encoding='utf-8', allow_unicode=True)
 410
 411     #print payload_req
 412
 413     URLrequest = "http://%s:%s/openmano/%s/scenarios" %(mano_host, mano_port, tenant)
 414     logger.debug("openmano request: %s", payload_req)
 415     mano_response = requests.post(URLrequest, headers = headers_req, data=payload_req)
 416     logger.debug("openmano response: %s", mano_response.text )
 417     return _print_verbose(mano_response, args.verbose)
 418
 419 def scenario_list(args):
 420     #print "scenario-list",args
 421     if args.all:
 422         tenant = "any"
 423     else:
 424         tenant = _get_tenant()
 425     if args.name:
 426         toshow = _get_item_uuid("scenarios", args.name, tenant)
 427         URLrequest = "http://%s:%s/openmano/%s/scenarios/%s" %(mano_host, mano_port, tenant, toshow)
 428     else:
 429         URLrequest = "http://%s:%s/openmano/%s/scenarios" %(mano_host, mano_port, tenant)
 430     mano_response = requests.get(URLrequest)
 431     logger.debug("openmano response: %s", mano_response.text )
 432     content = mano_response.json()
 433     #print json.dumps(content, indent=4)
 434     if args.verbose==None:
 435         args.verbose=0
 436
 437     result = 0 if mano_response.status_code==200 else mano_response.status_code
 438     if mano_response.status_code == 200:
 439         if not args.name:
 440             if args.verbose >= 3:
 441                 print yaml.safe_dump(content, indent=4, default_flow_style=False)
 442                 return result
 443             if len(content['scenarios']) == 0:
 444                 print "No scenarios were found."
 445                 return 404 #HTTP_Not_Found
 446             for scenario in content['scenarios']:
 447                 myoutput = "%s %s" %(scenario['uuid'].ljust(38),scenario['name'].ljust(20))
 448                 if args.verbose >=1:
 449                     myoutput = "%s %s" %(myoutput, scenario['created_at'].ljust(20))
 450                 print myoutput
 451                 if args.verbose >=2:
 452                     print "  Description: %s" %scenario['description']
 453         else:
 454             if args.verbose:
 455                 print yaml.safe_dump(content, indent=4, default_flow_style=False)
 456                 return result
 457             scenario = content['scenario']
 458             myoutput = "%s %s %s" %(scenario['uuid'].ljust(38),scenario['name'].ljust(20), scenario['created_at'].ljust(20))
 459             print myoutput
 460             print "  Description: %s" %scenario['description']
 461             print "    VNFs:"
 462             for vnf in scenario['vnfs']:
 463                 print "        %s %s %s" %(vnf['name'].ljust(20), vnf['vnf_id'].ljust(38), vnf['description'])
 464             if len(scenario['nets'])>0:
 465                 print "    Internal nets:"
 466                 for net in scenario['nets']:
 467                     if net['description'] is None:   #if description does not exist, description is "-". Valid for external and internal nets.
 468                         net['description'] = '-'
 469                     if not net['external']:
 470                         print "        %s %s %s" %(net['name'].ljust(20), net['uuid'].ljust(38), net['description'].ljust(30))
 471                 print "    External nets:"
 472                 for net in scenario['nets']:
 473                     if net['external']:
 474                         print "        %s %s %s vim-id:%s" %(net['name'].ljust(20), net['uuid'].ljust(38), net['description'].ljust(30), net['vim_id'])
 475     else:
 476         print content['error']['description']
 477         if args.verbose:
 478             print yaml.safe_dump(content, indent=4, default_flow_style=False)
 479     return result
 480
 481 def scenario_delete(args):
 482     #print "scenario-delete",args
 483     if args.all:
 484         tenant = "any"
 485     else:
 486         tenant = _get_tenant()
 487     todelete = _get_item_uuid("scenarios", args.name, tenant=tenant)
 488     if not args.force:
 489         r = raw_input("Delete scenario %s (y/N)? " %(args.name))
 490         if  not (len(r)>0  and r[0].lower()=="y"):
 491             return 0
 492     URLrequest = "http://%s:%s/openmano/%s/scenarios/%s" %(mano_host, mano_port, tenant, todelete)
 493     mano_response = requests.delete(URLrequest)
 494     logger.debug("openmano response: %s", mano_response.text )
 495     result = 0 if mano_response.status_code==200 else mano_response.status_code
 496     content = mano_response.json()
 497     #print json.dumps(content, indent=4)
 498     if mano_response.status_code == 200:
 499         print content['result']
 500     else:
 501         print content['error']['description']
 502     return result
 503
 504 def scenario_deploy(args):
 505     print "This command is deprecated, use 'openmano instance-scenario-create --scenario %s --name %s' instead!!!" % (args.scenario, args.name)
 506     print
 507     args.file = None
 508     args.netmap_use = None
 509     args.netmap_create = None
 510     args.keypair = None
 511     args.keypair_auto = None
 512     return instance_create(args)
 513
 514 #     #print "scenario-deploy",args
 515 #     headers_req = {'content-type': 'application/json'}
 516 #     action = {}
 517 #     actionCmd="start"
 518 #     if args.nostart:
 519 #         actionCmd="reserve"
 520 #     action[actionCmd] = {}
 521 #     action[actionCmd]["instance_name"] = args.name
 522 #     if args.datacenter != None:
 523 #         action[actionCmd]["datacenter"] = args.datacenter
 524 #     elif mano_datacenter != None:
 525 #         action[actionCmd]["datacenter"] = mano_datacenter
 526 #
 527 #     if args.description:
 528 #         action[actionCmd]["description"] = args.description
 529 #     payload_req = json.dumps(action, indent=4)
 530 #     #print payload_req
 531 #
 532 #     URLrequest = "http://%s:%s/openmano/%s/scenarios/%s/action" %(mano_host, mano_port, mano_tenant, args.scenario)
 533 #     logger.debug("openmano request: %s", payload_req)
 534 #     mano_response = requests.post(URLrequest, headers = headers_req, data=payload_req)
 535 #     logger.debug("openmano response: %s", mano_response.text )
 536 #     if args.verbose==None:
 537 #         args.verbose=0
 538 #
 539 #     result = 0 if mano_response.status_code==200 else mano_response.status_code
 540 #     content = mano_response.json()
 541 #     #print json.dumps(content, indent=4)
 542 #     if args.verbose >= 3:
 543 #         print yaml.safe_dump(content, indent=4, default_flow_style=False)
 544 #         return result
 545 #
 546 #     if mano_response.status_code == 200:
 547 #         myoutput = "%s %s" %(content['uuid'].ljust(38),content['name'].ljust(20))
 548 #         if args.verbose >=1:
 549 #             myoutput = "%s %s" %(myoutput, content['created_at'].ljust(20))
 550 #         if args.verbose >=2:
 551 #             myoutput = "%s %s %s" %(myoutput, content['description'].ljust(30))
 552 #         print myoutput
 553 #         print ""
 554 #         print "To check the status, run the following command:"
 555 #         print "openmano instance-scenario-list <instance_id>"
 556 #     else:
 557 #         print content['error']['description']
 558 #     return result
 559
 560 def scenario_verify(args):
 561     #print "scenario-verify",args
 562     tenant = _get_tenant()
 563     headers_req = {'content-type': 'application/json'}
 564     action = {}
 565     action["verify"] = {}
 566     action["verify"]["instance_name"] = "scen-verify-return5"
 567     payload_req = json.dumps(action, indent=4)
 568     #print payload_req
 569
 570     URLrequest = "http://%s:%s/openmano/%s/scenarios/%s/action" %(mano_host, mano_port, tenant, args.scenario)
 571     logger.debug("openmano request: %s", payload_req)
 572     mano_response = requests.post(URLrequest, headers = headers_req, data=payload_req)
 573     logger.debug("openmano response: %s", mano_response.text )
 574
 575     result = 0 if mano_response.status_code==200 else mano_response.status_code
 576     content = mano_response.json()
 577     #print json.dumps(content, indent=4)
 578     if mano_response.status_code == 200:
 579         print content['result']
 580     else:
 581         print content['error']['description']
 582     return result
 583
 584 def instance_create(args):
 585     tenant = _get_tenant()
 586     headers_req = {'content-type': 'application/yaml'}
 587     myInstance={"instance": {}, "schema_version": "0.1"}
 588     if args.file:
 589         instance_dict = _load_file_or_yaml(args.file)
 590         if "instance" not in instance_dict:
 591             myInstance = {"instance": instance_dict, "schema_version": "0.1"}
 592         else:
 593             myInstance = instance_dict
 594     if args.name:
 595         myInstance["instance"]['name'] = args.name
 596     if args.description:
 597         myInstance["instance"]['description'] = args.description
 598     if args.nostart:
 599         myInstance["instance"]['action'] = "reserve"
 600     #datacenter
 601     datacenter = myInstance["instance"].get("datacenter")
 602     if args.datacenter != None:
 603         datacenter = args.datacenter
 604     myInstance["instance"]["datacenter"] = _get_datacenter(datacenter, tenant)
 605     #scenario
 606     scenario = myInstance["instance"].get("scenario")
 607     if args.scenario != None:
 608         scenario = args.scenario
 609     if not scenario:
 610         print "you must provide a scenario in the file descriptor or with --scenario"
 611         return -1
 612     myInstance["instance"]["scenario"] = _get_item_uuid("scenarios", scenario, tenant)
 613     if args.netmap_use:
 614         if "networks" not in myInstance["instance"]:
 615             myInstance["instance"]["networks"] = {}
 616         for net in args.netmap_use:
 617             net_comma_list = net.split(",")
 618             for net_comma in net_comma_list:
 619                 net_tuple = net_comma.split("=")
 620                 if len(net_tuple) != 2:
 621                     print "error at netmap-use. Expected net-scenario=net-datacenter. (%s)?" % net_comma
 622                     return
 623                 net_scenario   = net_tuple[0].strip()
 624                 net_datacenter = net_tuple[1].strip()
 625                 if net_scenario not in myInstance["instance"]["networks"]:
 626                     myInstance["instance"]["networks"][net_scenario] = {}
 627                 if "sites" not in myInstance["instance"]["networks"][net_scenario]:
 628                     myInstance["instance"]["networks"][net_scenario]["sites"] = [ {} ]
 629                 myInstance["instance"]["networks"][net_scenario]["sites"][0]["netmap-use"] = net_datacenter
 630     if args.netmap_create:
 631         if "networks" not in myInstance["instance"]:
 632             myInstance["instance"]["networks"] = {}
 633         for net in args.netmap_create:
 634             net_comma_list = net.split(",")
 635             for net_comma in net_comma_list:
 636                 net_tuple = net_comma.split("=")
 637                 if len(net_tuple) == 1:
 638                     net_scenario   = net_tuple[0].strip()
 639                     net_datacenter = None
 640                 elif len(net_tuple) == 2:
 641                     net_scenario   = net_tuple[0].strip()
 642                     net_datacenter = net_tuple[1].strip()
 643                 else:
 644                     print "error at netmap-create. Expected net-scenario=net-datacenter or net-scenario. (%s)?" % net_comma
 645                     return
 646                 if net_scenario not in myInstance["instance"]["networks"]:
 647                     myInstance["instance"]["networks"][net_scenario] = {}
 648                 if "sites" not in myInstance["instance"]["networks"][net_scenario]:
 649                     myInstance["instance"]["networks"][net_scenario]["sites"] = [ {} ]
 650                 myInstance["instance"]["networks"][net_scenario]["sites"][0]["netmap-create"] = net_datacenter
 651     if args.keypair:
 652         if "cloud-config" not in myInstance["instance"]:
 653             myInstance["instance"]["cloud-config"] = {}
 654         cloud_config = myInstance["instance"]["cloud-config"]
 655         for key in args.keypair:
 656             index = key.find(":")
 657             if index<0:
 658                 if "key-pairs" not in cloud_config:
 659                     cloud_config["key-pairs"] = []
 660                 cloud_config["key-pairs"].append(key)
 661             else:
 662                 user = key[:index]
 663                 key_ = key[index+1:]
 664                 key_list = key_.split(",")
 665                 if "users" not in cloud_config:
 666                     cloud_config["users"] = []
 667                 cloud_config["users"].append({"name": user, "key-pairs": key_list  })
 668     if args.keypair_auto:
 669         try:
 670             keys=[]
 671             home = os.getenv("HOME")
 672             user = os.getenv("USER")
 673             files = os.listdir(home+'/.ssh')
 674             for file in files:
 675                 if file[-4:] == ".pub":
 676                     with open(home+'/.ssh/'+file, 'r') as f:
 677                         keys.append(f.read())
 678             if not keys:
 679                 print "Cannot obtain any public ssh key from '{}'. Try not using --keymap-auto".format(home+'/.ssh')
 680                 return 1
 681         except Exception as e:
 682             print "Cannot obtain any public ssh key. Error '{}'. Try not using --keymap-auto".format(str(e))
 683             return 1
 684
 685         if "cloud-config" not in myInstance["instance"]:
 686             myInstance["instance"]["cloud-config"] = {}
 687         cloud_config = myInstance["instance"]["cloud-config"]
 688         if "key-pairs" not in cloud_config:
 689             cloud_config["key-pairs"] = []
 690         if user:
 691             if "users" not in cloud_config:
 692                 cloud_config["users"] = []
 693             cloud_config["users"].append({"name": user, "key-pairs": keys })
 694
 695     payload_req = yaml.safe_dump(myInstance, explicit_start=True, indent=4, default_flow_style=False, tags=False, encoding='utf-8', allow_unicode=True)
 696     logger.debug("openmano request: %s", payload_req)
 697     URLrequest = "http://%s:%s/openmano/%s/instances" %(mano_host, mano_port, tenant)
 698     mano_response = requests.post(URLrequest, headers = headers_req, data=payload_req)
 699     logger.debug("openmano response: %s", mano_response.text )
 700     if args.verbose==None:
 701         args.verbose=0
 702
 703     result = 0 if mano_response.status_code==200 else mano_response.status_code
 704     content = mano_response.json()
 705     #print json.dumps(content, indent=4)
 706     if args.verbose >= 3:
 707         print yaml.safe_dump(content, indent=4, default_flow_style=False)
 708         return result
 709
 710     if mano_response.status_code == 200:
 711         myoutput = "%s %s" %(content['uuid'].ljust(38),content['name'].ljust(20))
 712         if args.verbose >=1:
 713             myoutput = "%s %s" %(myoutput, content['created_at'].ljust(20))
 714         if args.verbose >=2:
 715             myoutput = "%s %s %s" %(myoutput, content['description'].ljust(30))
 716         print myoutput
 717     else:
 718         print content['error']['description']
 719     return result
 720
 721 def instance_scenario_list(args):
 722     #print "instance-scenario-list",args
 723     if args.all:
 724         tenant = "any"
 725     else:
 726         tenant = _get_tenant()
 727     if args.name:
 728         toshow = _get_item_uuid("instances", args.name, tenant)
 729         URLrequest = "http://%s:%s/openmano/%s/instances/%s" %(mano_host, mano_port, tenant, toshow)
 730     else:
 731         URLrequest = "http://%s:%s/openmano/%s/instances" %(mano_host, mano_port, tenant)
 732     mano_response = requests.get(URLrequest)
 733     logger.debug("openmano response: %s", mano_response.text )
 734     content = mano_response.json()
 735     #print json.dumps(content, indent=4)
 736     if args.verbose==None:
 737         args.verbose=0
 738
 739     result = 0 if mano_response.status_code==200 else mano_response.status_code
 740     if mano_response.status_code == 200:
 741         if not args.name:
 742             if args.verbose >= 3:
 743                 print yaml.safe_dump(content, indent=4, default_flow_style=False)
 744                 return result
 745             if len(content['instances']) == 0:
 746                 print "No scenario instances were found."
 747                 return result
 748             for instance in content['instances']:
 749                 myoutput = "%s %s" %(instance['uuid'].ljust(38),instance['name'].ljust(20))
 750                 if args.verbose >=1:
 751                     myoutput = "%s %s" %(myoutput, instance['created_at'].ljust(20))
 752                 print myoutput
 753                 if args.verbose >=2:
 754                     print "Description: %s" %instance['description']
 755         else:
 756             if args.verbose:
 757                 print yaml.safe_dump(content, indent=4, default_flow_style=False)
 758                 return result
 759             instance = content
 760             print "%s %s %s" %(instance['uuid'].ljust(38),instance['name'].ljust(20),instance['created_at'].ljust(20))
 761             print "Description: %s" %instance['description']
 762             print "Template scenario id: %s" %instance['scenario_id']
 763             print "Template scenario name: %s" %instance['scenario_name']
 764             print "---------------------------------------"
 765             print "VNF instances: %d" %len(instance['vnfs'])
 766             for vnf in instance['vnfs']:
 767                 #print "    %s %s Template vnf name: %s Template vnf id: %s" %(vnf['uuid'].ljust(38), vnf['name'].ljust(20), vnf['vnf_name'].ljust(20), vnf['vnf_id'].ljust(38))
 768                 print "    %s %s Template vnf id: %s" %(vnf['uuid'].ljust(38), vnf['vnf_name'].ljust(20), vnf['vnf_id'].ljust(38))
 769             if len(instance['nets'])>0:
 770                 print "---------------------------------------"
 771                 print "Internal nets:"
 772                 for net in instance['nets']:
 773                     if net['created']:
 774                         print "    %s %s VIM ID: %s" %(net['uuid'].ljust(38), net['status'].ljust(12), net['vim_net_id'])
 775                 print "---------------------------------------"
 776                 print "External nets:"
 777                 for net in instance['nets']:
 778                     if not net['created']:
 779                         print "    %s %s VIM ID: %s" %(net['uuid'].ljust(38), net['status'].ljust(12), net['vim_net_id'])
 780             print "---------------------------------------"
 781             print "VM instances:"
 782             for vnf in instance['vnfs']:
 783                 for vm in vnf['vms']:
 784                     print "    %s %s %s %s VIM ID: %s" %(vm['uuid'].ljust(38), vnf['vnf_name'].ljust(20), vm['name'].ljust(20), vm['status'].ljust(12), vm['vim_vm_id'])
 785     else:
 786         print content['error']['description']
 787         if args.verbose:
 788             print yaml.safe_dump(content, indent=4, default_flow_style=False)
 789     return result
 790
 791 def instance_scenario_status(args):
 792     print "instance-scenario-status"
 793     return 0
 794
 795 def instance_scenario_delete(args):
 796     if args.all:
 797         tenant = "any"
 798     else:
 799         tenant = _get_tenant()
 800     todelete = _get_item_uuid("instances", args.name, tenant=tenant)
 801     #print "instance-scenario-delete",args
 802     if not args.force:
 803         r = raw_input("Delete scenario instance %s (y/N)? " %(args.name))
 804         if  not (len(r)>0  and r[0].lower()=="y"):
 805             return
 806     URLrequest = "http://%s:%s/openmano/%s/instances/%s" %(mano_host, mano_port, tenant, todelete)
 807     mano_response = requests.delete(URLrequest)
 808     logger.debug("openmano response: %s", mano_response.text )
 809     result = 0 if mano_response.status_code==200 else mano_response.status_code
 810     content = mano_response.json()
 811     #print json.dumps(content, indent=4)
 812     if mano_response.status_code == 200:
 813         print content['result']
 814     else:
 815         print content['error']['description']
 816     return result
 817
 818 def instance_scenario_action(args):
 819     #print "instance-scenario-action", args
 820     tenant = _get_tenant()
 821     toact = _get_item_uuid("instances", args.name, tenant=tenant)
 822     action={}
 823     action[ args.action ] = args.param
 824     if args.vnf:
 825         action["vnfs"] = args.vnf
 826     if args.vm:
 827         action["vms"] = args.vm
 828
 829     headers_req = {'content-type': 'application/json'}
 830     payload_req = json.dumps(action, indent=4)
 831     URLrequest = "http://%s:%s/openmano/%s/instances/%s/action" %(mano_host, mano_port, tenant, toact)
 832     logger.debug("openmano request: %s", payload_req)
 833     mano_response = requests.post(URLrequest, headers = headers_req, data=payload_req)
 834     logger.debug("openmano response: %s", mano_response.text )
 835     result = 0 if mano_response.status_code==200 else mano_response.status_code
 836     content = mano_response.json()
 837     #print json.dumps(content, indent=4)
 838     if mano_response.status_code == 200:
 839         if args.verbose:
 840             print yaml.safe_dump(content, indent=4, default_flow_style=False)
 841             return result
 842         for uuid,c in content.iteritems():
 843             print "%s %s %s" %(uuid.ljust(38), c['name'].ljust(20),c['description'].ljust(20))
 844     else:
 845         print content['error']['description']
 846     return result
 847
 848
 849 def instance_vnf_list(args):
 850     print "instance-vnf-list"
 851     return 0
 852
 853 def instance_vnf_status(args):
 854     print "instance-vnf-status"
 855     return 0
 856
 857 def tenant_create(args):
 858     headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
 859     tenant_dict={"name": args.name}
 860     if args.description!=None:
 861         tenant_dict["description"] = args.description
 862     payload_req = json.dumps( {"tenant": tenant_dict })
 863
 864     #print payload_req
 865
 866     URLrequest = "http://%s:%s/openmano/tenants" %(mano_host, mano_port)
 867     logger.debug("openmano request: %s", payload_req)
 868     mano_response = requests.post(URLrequest, headers=headers_req, data=payload_req)
 869     logger.debug("openmano response: %s", mano_response.text )
 870     return _print_verbose(mano_response, args.verbose)
 871
 872 def tenant_list(args):
 873     #print "tenant-list",args
 874     if args.name:
 875         toshow = _get_item_uuid("tenants", args.name)
 876         URLrequest = "http://%s:%s/openmano/tenants/%s" %(mano_host, mano_port, toshow)
 877     else:
 878         URLrequest = "http://%s:%s/openmano/tenants" %(mano_host, mano_port)
 879     mano_response = requests.get(URLrequest)
 880     logger.debug("openmano response: %s", mano_response.text )
 881     if args.verbose==None:
 882         args.verbose=0
 883     if args.name!=None:
 884         args.verbose += 1
 885     return _print_verbose(mano_response, args.verbose)
 886
 887 def tenant_delete(args):
 888     #print "tenant-delete",args
 889     todelete = _get_item_uuid("tenants", args.name)
 890     if not args.force:
 891         r = raw_input("Delete tenant %s (y/N)? " %(args.name))
 892         if  not (len(r)>0  and r[0].lower()=="y"):
 893             return 0
 894     URLrequest = "http://%s:%s/openmano/tenants/%s" %(mano_host, mano_port, todelete)
 895     mano_response = requests.delete(URLrequest)
 896     logger.debug("openmano response: %s", mano_response.text )
 897     result = 0 if mano_response.status_code==200 else mano_response.status_code
 898     content = mano_response.json()
 899     #print json.dumps(content, indent=4)
 900     if mano_response.status_code == 200:
 901         print content['result']
 902     else:
 903         print content['error']['description']
 904     return result
 905
 906 def datacenter_attach(args):
 907     tenant = _get_tenant()
 908     datacenter = _get_datacenter(args.name)
 909     headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
 910
 911     datacenter_dict={}
 912     if args.vim_tenant_id != None:
 913         datacenter_dict['vim_tenant'] = args.vim_tenant_id
 914     if args.vim_tenant_name != None:
 915         datacenter_dict['vim_tenant_name'] = args.vim_tenant_name
 916     if args.user != None:
 917         datacenter_dict['vim_username'] = args.user
 918     if args.password != None:
 919         datacenter_dict['vim_password'] = args.password
 920     if args.config!=None:
 921         datacenter_dict["config"] = _load_file_or_yaml(args.config)
 922     payload_req = json.dumps( {"datacenter": datacenter_dict })
 923
 924     #print payload_req
 925
 926     URLrequest = "http://%s:%s/openmano/%s/datacenters/%s" %(mano_host, mano_port, tenant, datacenter)
 927     logger.debug("openmano request: %s", payload_req)
 928     mano_response = requests.post(URLrequest, headers=headers_req, data=payload_req)
 929     logger.debug("openmano response: %s", mano_response.text )
 930     result = _print_verbose(mano_response, args.verbose)
 931     #provide addional information if error
 932     if mano_response.status_code != 200:
 933         content = mano_response.json()
 934         if "already in use for  'name'" in content['error']['description'] and \
 935                 "to database vim_tenants table" in content['error']['description']:
 936             print "Try to specify a different name with --vim-tenant-name"
 937     return result
 938
 939
 940 def datacenter_edit_vim_tenant(args):
 941     tenant = _get_tenant()
 942     datacenter = _get_datacenter(args.name)
 943     headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
 944
 945     if not (args.vim_tenant_id or args.vim_tenant_name or args.user or args.password or args.config):
 946         raise OpenmanoCLIError("Error. At least one parameter must be updated.")
 947
 948     datacenter_dict = {}
 949     if args.vim_tenant_id != None:
 950         datacenter_dict['vim_tenant'] = args.vim_tenant_id
 951     if args.vim_tenant_name != None:
 952         datacenter_dict['vim_tenant_name'] = args.vim_tenant_name
 953     if args.user != None:
 954         datacenter_dict['vim_username'] = args.user
 955     if args.password != None:
 956         datacenter_dict['vim_password'] = args.password
 957     if args.config != None:
 958         datacenter_dict["config"] = _load_file_or_yaml(args.config)
 959     payload_req = json.dumps({"datacenter": datacenter_dict})
 960
 961     # print payload_req
 962
 963     URLrequest = "http://%s:%s/openmano/%s/datacenters/%s" % (mano_host, mano_port, tenant, datacenter)
 964     logger.debug("openmano request: %s", payload_req)
 965     mano_response = requests.put(URLrequest, headers=headers_req, data=payload_req)
 966     logger.debug("openmano response: %s", mano_response.text)
 967     result = _print_verbose(mano_response, args.verbose)
 968
 969     return result
 970
 971 def datacenter_detach(args):
 972     if args.all:
 973         tenant = "any"
 974     else:
 975         tenant = _get_tenant()
 976     datacenter = _get_datacenter(args.name, tenant)
 977     headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
 978     URLrequest = "http://%s:%s/openmano/%s/datacenters/%s" %(mano_host, mano_port, tenant, datacenter)
 979     mano_response = requests.delete(URLrequest, headers=headers_req)
 980     logger.debug("openmano response: %s", mano_response.text )
 981     content = mano_response.json()
 982     #print json.dumps(content, indent=4)
 983     result = 0 if mano_response.status_code==200 else mano_response.status_code
 984     if mano_response.status_code == 200:
 985         print content['result']
 986     else:
 987         print content['error']['description']
 988     return result
 989
 990 def datacenter_create(args):
 991     headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
 992     datacenter_dict={"name": args.name, "vim_url": args.url}
 993     if args.description!=None:
 994         datacenter_dict["description"] = args.description
 995     if args.type!=None:
 996         datacenter_dict["type"] = args.type
 997     if args.url!=None:
 998         datacenter_dict["vim_url_admin"] = args.url_admin
 999     if args.config!=None:
1000         datacenter_dict["config"] = _load_file_or_yaml(args.config)
1001     if args.sdn_controller!=None:
1002         tenant = _get_tenant()
1003         sdn_controller = _get_item_uuid("sdn_controllers", args.sdn_controller, tenant)
1004         if not 'config' in datacenter_dict:
1005             datacenter_dict['config'] = {}
1006         datacenter_dict['config']['sdn-controller'] = sdn_controller
1007     payload_req = json.dumps( {"datacenter": datacenter_dict })
1008
1009     #print payload_req
1010
1011     URLrequest = "http://%s:%s/openmano/datacenters" %(mano_host, mano_port)
1012     logger.debug("openmano request: %s", payload_req)
1013     mano_response = requests.post(URLrequest, headers=headers_req, data=payload_req)
1014     logger.debug("openmano response: %s", mano_response.text )
1015     return _print_verbose(mano_response, args.verbose)
1016
1017 def datacenter_delete(args):
1018     #print "datacenter-delete",args
1019     todelete = _get_item_uuid("datacenters", args.name, "any")
1020     if not args.force:
1021         r = raw_input("Delete datacenter %s (y/N)? " %(args.name))
1022         if  not (len(r)>0  and r[0].lower()=="y"):
1023             return 0
1024     URLrequest = "http://%s:%s/openmano/datacenters/%s" %(mano_host, mano_port, todelete)
1025     mano_response = requests.delete(URLrequest)
1026     logger.debug("openmano response: %s", mano_response.text )
1027     result = 0 if mano_response.status_code==200 else mano_response.status_code
1028     content = mano_response.json()
1029     #print json.dumps(content, indent=4)
1030     if mano_response.status_code == 200:
1031         print content['result']
1032     else:
1033         print content['error']['description']
1034     return result
1035
1036 def datacenter_list(args):
1037     #print "datacenter-list",args
1038     tenant='any' if args.all else _get_tenant()
1039
1040     if args.name:
1041         toshow = _get_item_uuid("datacenters", args.name, tenant)
1042         URLrequest = "http://%s:%s/openmano/%s/datacenters/%s" %(mano_host, mano_port, tenant, toshow)
1043     else:
1044         URLrequest = "http://%s:%s/openmano/%s/datacenters" %(mano_host, mano_port, tenant)
1045     mano_response = requests.get(URLrequest)
1046     logger.debug("openmano response: %s", mano_response.text )
1047     if args.verbose==None:
1048         args.verbose=0
1049     if args.name!=None:
1050         args.verbose += 1
1051     return _print_verbose(mano_response, args.verbose)
1052
1053 def datacenter_sdn_port_mapping_set(args):
1054     tenant = _get_tenant()
1055     datacenter = _get_datacenter(args.name, tenant)
1056     headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1057
1058     if not args.file:
1059         raise OpenmanoCLIError(
1060             "No yaml/json has been provided specifying the SDN port mapping")
1061
1062     port_mapping = yaml.load(datacenter_sdn_port_mapping_list(args))
1063     if 'error' in port_mapping:
1064         raise OpenmanoCLIError("openmano client error: {}".format(port_mapping['error']['description']))
1065     if len(port_mapping["sdn_port_mapping"]["ports_mapping"]) > 0:
1066         if not args.force:
1067             r = raw_input("Datacenter %s already contains a port mapping. Overwrite? (y/N)? " % (datacenter))
1068             if not (len(r) > 0 and r[0].lower() == "y"):
1069                 return 0
1070         args.force = True
1071         print datacenter_sdn_port_mapping_clear(args)
1072
1073     sdn_port_mapping = _load_file_or_yaml(args.file)
1074     payload_req = json.dumps({"sdn_port_mapping": sdn_port_mapping})
1075
1076     URLrequest = "http://%s:%s/openmano/%s/datacenters/%s/sdn_mapping" % (mano_host, mano_port, tenant, datacenter)
1077     logger.debug("openmano request: %s", payload_req)
1078     mano_response = requests.post(URLrequest, headers=headers_req, data=payload_req)
1079     logger.debug("openmano response: %s", mano_response.text)
1080
1081     if mano_response.status_code == 200:
1082         return yaml.safe_dump(mano_response.json())
1083     else:
1084         return mano_response.content
1085
1086 def datacenter_sdn_port_mapping_list(args):
1087     tenant = _get_tenant()
1088     datacenter = _get_datacenter(args.name, tenant)
1089
1090     URLrequest = "http://%s:%s/openmano/%s/datacenters/%s/sdn_mapping" % (mano_host, mano_port, tenant, datacenter)
1091     mano_response = requests.get(URLrequest)
1092     logger.debug("openmano response: %s", mano_response.text)
1093
1094     if mano_response.status_code != 200:
1095         return mano_response.content
1096
1097     return yaml.safe_dump(mano_response.json())
1098
1099 def datacenter_sdn_port_mapping_clear(args):
1100     tenant = _get_tenant()
1101     datacenter = _get_datacenter(args.name, tenant)
1102
1103     if not args.force:
1104         r = raw_input("Clean SDN port mapping for datacenter %s (y/N)? " %(datacenter))
1105         if  not (len(r)>0  and r[0].lower()=="y"):
1106             return 0
1107
1108     URLrequest = "http://%s:%s/openmano/%s/datacenters/%s/sdn_mapping" % (mano_host, mano_port, tenant, datacenter)
1109     mano_response = requests.delete(URLrequest)
1110     logger.debug("openmano response: %s", mano_response.text)
1111
1112     if mano_response.status_code != 200:
1113         if "No port mapping for datacenter" in mano_response.content:
1114             return "No port mapping for datacenter " + datacenter + " has been found"
1115         return mano_response.content
1116
1117     return yaml.safe_dump(mano_response.json())
1118
1119 def sdn_controller_create(args):
1120     tenant = _get_tenant()
1121     headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1122
1123     if not (args.ip and args.port and args.dpid and args.type):
1124         raise OpenmanoCLIError("The following arguments are required: ip, port, dpid, type")
1125
1126     controller_dict = {}
1127     controller_dict['name'] = args.name
1128     controller_dict['ip'] = args.ip
1129     controller_dict['port'] = int(args.port)
1130     controller_dict['dpid'] = args.dpid
1131     controller_dict['type'] = args.type
1132     if args.description != None:
1133         controller_dict['description'] = args.description
1134     if args.user != None:
1135         controller_dict['user'] = args.user
1136     if args.password != None:
1137         controller_dict['password'] = args.password
1138
1139     payload_req = json.dumps({"sdn_controller": controller_dict})
1140
1141     # print payload_req
1142
1143     URLrequest = "http://%s:%s/openmano/%s/sdn_controllers" % (mano_host, mano_port, tenant)
1144     logger.debug("openmano request: %s", payload_req)
1145     mano_response = requests.post(URLrequest, headers=headers_req, data=payload_req)
1146     logger.debug("openmano response: %s", mano_response.text)
1147     result = _print_verbose(mano_response, args.verbose)
1148
1149     return result
1150
1151 def sdn_controller_edit(args):
1152     tenant = _get_tenant()
1153     controller_uuid = _get_item_uuid("sdn_controllers", args.name, tenant)
1154     headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1155
1156     if not (args.new_name or args.ip or args.port or args.dpid or args.type):
1157         raise OpenmanoCLIError("At least one parameter must be editd")
1158
1159     if not args.force:
1160         r = raw_input("Update SDN controller %s (y/N)? " %(args.name))
1161         if  not (len(r)>0  and r[0].lower()=="y"):
1162             return 0
1163
1164     controller_dict = {}
1165     if args.new_name != None:
1166         controller_dict['name'] = args.new_name
1167     if args.ip != None:
1168         controller_dict['ip'] = args.ip
1169     if args.port != None:
1170         controller_dict['port'] = int(args.port)
1171     if args.dpid != None:
1172         controller_dict['dpid'] = args.dpid
1173     if args.type != None:
1174         controller_dict['type'] = args.type
1175     if args.description != None:
1176         controller_dict['description'] = args.description
1177     if args.user != None:
1178         controller_dict['user'] = args.user
1179     if args.password != None:
1180         controller_dict['password'] = args.password
1181
1182     payload_req = json.dumps({"sdn_controller": controller_dict})
1183
1184     # print payload_req
1185
1186     URLrequest = "http://%s:%s/openmano/%s/sdn_controllers/%s" % (mano_host, mano_port, tenant, controller_uuid)
1187     logger.debug("openmano request: %s", payload_req)
1188     mano_response = requests.put(URLrequest, headers=headers_req, data=payload_req)
1189     logger.debug("openmano response: %s", mano_response.text)
1190     result = _print_verbose(mano_response, args.verbose)
1191
1192     return result
1193
1194 def sdn_controller_list(args):
1195     tenant = _get_tenant()
1196     headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1197
1198     if args.name:
1199         toshow = _get_item_uuid("sdn_controllers", args.name, tenant)
1200         URLrequest = "http://%s:%s/openmano/%s/sdn_controllers/%s" %(mano_host, mano_port, tenant, toshow)
1201     else:
1202         URLrequest = "http://%s:%s/openmano/%s/sdn_controllers" %(mano_host, mano_port, tenant)
1203     #print URLrequest
1204     mano_response = requests.get(URLrequest)
1205     logger.debug("openmano response: %s", mano_response.text )
1206     if args.verbose==None:
1207         args.verbose=0
1208     if args.name!=None:
1209         args.verbose += 1
1210
1211     result = json.dumps(mano_response.json(), indent=4)
1212     return result
1213
1214 def sdn_controller_delete(args):
1215     tenant = _get_tenant()
1216     controller_uuid = _get_item_uuid("sdn_controllers", args.name, tenant)
1217
1218     if not args.force:
1219         r = raw_input("Delete SDN controller %s (y/N)? " % (args.name))
1220         if not (len(r) > 0 and r[0].lower() == "y"):
1221             return 0
1222
1223     URLrequest = "http://%s:%s/openmano/%s/sdn_controllers/%s" % (mano_host, mano_port, tenant, controller_uuid)
1224     mano_response = requests.delete(URLrequest)
1225     logger.debug("openmano response: %s", mano_response.text)
1226     result = _print_verbose(mano_response, args.verbose)
1227
1228     return result
1229
1230 def vim_action(args):
1231     #print "datacenter-net-action",args
1232     tenant = _get_tenant()
1233     datacenter = _get_datacenter(args.datacenter, tenant)
1234     if args.verbose==None:
1235         args.verbose=0
1236     if args.action=="list":
1237         URLrequest = "http://%s:%s/openmano/%s/vim/%s/%ss" %(mano_host, mano_port, tenant, datacenter, args.item)
1238         if args.name!=None:
1239             args.verbose += 1
1240             URLrequest += "/" + args.name
1241         mano_response = requests.get(URLrequest)
1242         logger.debug("openmano response: %s", mano_response.text )
1243         return _print_verbose(mano_response, args.verbose)
1244     elif args.action=="delete":
1245         URLrequest = "http://%s:%s/openmano/%s/vim/%s/%ss/%s" %(mano_host, mano_port, tenant, datacenter, args.item, args.name)
1246         mano_response = requests.delete(URLrequest)
1247         logger.debug("openmano response: %s", mano_response.text )
1248         result = 0 if mano_response.status_code==200 else mano_response.status_code
1249         content = mano_response.json()
1250         #print json.dumps(content, indent=4)
1251         if mano_response.status_code == 200:
1252             print content['result']
1253         else:
1254             print content['error']['description']
1255         return result
1256     elif args.action=="create":
1257         headers_req = {'content-type': 'application/yaml'}
1258         if args.file:
1259             create_dict = _load_file_or_yaml(args.file)
1260             if args.item not in create_dict:
1261                 create_dict = {args.item: create_dict}
1262         else:
1263             create_dict = {args.item:{}}
1264         if args.name:
1265             create_dict[args.item]['name'] = args.name
1266         #if args.description:
1267         #    create_dict[args.item]['description'] = args.description
1268         if args.item=="network":
1269             if args.bind_net:
1270                 create_dict[args.item]['bind_net'] = args.bind_net
1271             if args.type:
1272                 create_dict[args.item]['type'] = args.type
1273             if args.shared:
1274                 create_dict[args.item]['shared'] = args.shared
1275         if "name" not in create_dict[args.item]:
1276             print "You must provide a name in the descriptor file or with the --name option"
1277             return
1278         payload_req = yaml.safe_dump(create_dict, explicit_start=True, indent=4, default_flow_style=False, tags=False, encoding='utf-8', allow_unicode=True)
1279         logger.debug("openmano request: %s", payload_req)
1280         URLrequest = "http://%s:%s/openmano/%s/vim/%s/%ss" %(mano_host, mano_port, tenant, datacenter, args.item)
1281         mano_response = requests.post(URLrequest, headers = headers_req, data=payload_req)
1282         logger.debug("openmano response: %s", mano_response.text )
1283         if args.verbose==None:
1284             args.verbose=0
1285         return _print_verbose(mano_response, args.verbose)
1286
1287 def _get_items(item, item_name_id=None, datacenter=None, tenant=None):
1288     URLrequest = "http://%s:%s/openmano" %(mano_host, mano_port)
1289     if tenant:
1290         URLrequest += "/" + tenant
1291     if datacenter:
1292         URLrequest += "/vim/" + datacenter
1293     if item:
1294         URLrequest += "/" + item +"s"
1295     if item_name_id:
1296         URLrequest += "/" + item_name_id
1297     mano_response = requests.get(URLrequest)
1298     logger.debug("openmano response: %s", mano_response.text )
1299
1300     return mano_response
1301
1302 def vim_net_sdn_attach(args):
1303     #Verify the network exists in the vim
1304     tenant = _get_tenant()
1305     datacenter = _get_datacenter(args.datacenter, tenant)
1306     result = _get_items('network', item_name_id=args.vim_net, datacenter=datacenter, tenant=tenant)
1307     content = yaml.load(result.content)
1308     if 'networks' in content:
1309         raise OpenmanoCLIError('More than one network in the vim named ' + args.vim_net + '. Use uuid instead')
1310     if 'error' in content:
1311         raise OpenmanoCLIError(yaml.safe_dump(content))
1312     network_uuid = content['network']['id']
1313
1314     #Make call to attach the dataplane port to the SND network associated to the vim network
1315     headers_req = {'content-type': 'application/yaml'}
1316     payload_req = {'port': args.port}
1317     if args.vlan:
1318         payload_req['vlan'] = int(args.vlan)
1319     if args.mac:
1320         payload_req['mac'] = args.mac
1321
1322     URLrequest = "http://%s:%s/openmano/%s/vim/%s/network/%s/attach" % (mano_host, mano_port, tenant, datacenter, network_uuid)
1323     logger.debug("openmano request: %s", payload_req)
1324     mano_response = requests.post(URLrequest, headers=headers_req, data=json.dumps(payload_req))
1325     logger.debug("openmano response: %s", mano_response.text)
1326     result = _print_verbose(mano_response, args.verbose)
1327
1328     return
1329
1330
1331 def vim_net_sdn_detach(args):
1332     if not args.all and not args.id:
1333         print "--all or --id must be used"
1334         return 1
1335
1336     # Verify the network exists in the vim
1337     tenant = _get_tenant()
1338     datacenter = _get_datacenter(args.datacenter, tenant)
1339     result = _get_items('network', item_name_id=args.vim_net, datacenter=datacenter, tenant=tenant)
1340     content = yaml.load(result.content)
1341     if 'networks' in content:
1342         raise OpenmanoCLIError('More than one network in the vim named ' + args.vim_net + '. Use uuid instead')
1343     if 'error' in content:
1344         raise OpenmanoCLIError(yaml.safe_dump(content))
1345     network_uuid = content['network']['id']
1346
1347     if not args.force:
1348         r = raw_input("Confirm action' (y/N)? ")
1349         if len(r) == 0 or r[0].lower() != "y":
1350             return 0
1351
1352     if args.id:
1353         URLrequest = "http://%s:%s/openmano/%s/vim/%s/network/%s/detach/%s" % (
1354             mano_host, mano_port, tenant, datacenter, network_uuid, args.id)
1355     else:
1356         URLrequest = "http://%s:%s/openmano/%s/vim/%s/network/%s/detach" % (
1357             mano_host, mano_port, tenant, datacenter, network_uuid)
1358     mano_response = requests.delete(URLrequest)
1359     logger.debug("openmano response: %s", mano_response.text)
1360     result = _print_verbose(mano_response, args.verbose)
1361
1362     return
1363
1364 def datacenter_net_action(args):
1365     if args.action == "net-update":
1366         print "This command is deprecated, use 'openmano datacenter-netmap-delete --all' and 'openmano datacenter-netmap-import' instead!!!"
1367         print
1368         args.action = "netmap-delete"
1369         args.netmap = None
1370         args.all = True
1371         r = datacenter_netmap_action(args)
1372         if r == 0:
1373             args.force = True
1374             args.action = "netmap-import"
1375             r = datacenter_netmap_action(args)
1376         return r
1377
1378     if args.action == "net-edit":
1379         args.netmap = args.net
1380         args.name = None
1381     elif args.action == "net-list":
1382         args.netmap = None
1383     elif args.action == "net-delete":
1384         args.netmap = args.net
1385         args.all = False
1386
1387     args.action = "netmap" + args.action[3:]
1388     args.vim_name=None
1389     args.vim_id=None
1390     print "This command is deprecated, use 'openmano datacenter-%s' instead!!!" % args.action
1391     print
1392     return datacenter_netmap_action(args)
1393
1394 def datacenter_netmap_action(args):
1395     tenant = _get_tenant()
1396     datacenter = _get_datacenter(args.datacenter, tenant)
1397     #print "datacenter_netmap_action",args
1398     payload_req = None
1399     if args.verbose==None:
1400         args.verbose=0
1401     headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1402     URLrequest = "http://%s:%s/openmano/%s/datacenters/%s/netmaps" %(mano_host, mano_port, tenant, datacenter)
1403
1404     if args.action=="netmap-list":
1405         if args.netmap:
1406             URLrequest += "/" + args.netmap
1407             args.verbose += 1
1408         mano_response = requests.get(URLrequest)
1409
1410     elif args.action=="netmap-delete":
1411         if args.netmap and args.all:
1412             print "you can not use a netmap name and the option --all at the same time"
1413             return 1
1414         if args.netmap:
1415             force_text= "Delete default netmap '%s' from datacenter '%s' (y/N)? " % (args.netmap, datacenter)
1416             URLrequest += "/" + args.netmap
1417         elif args.all:
1418             force_text="Delete all default netmaps from datacenter '%s' (y/N)? " % (datacenter)
1419         else:
1420             print "you must specify a netmap name or the option --all"
1421             return 1
1422         if not args.force:
1423             r = raw_input(force_text)
1424             if  len(r)>0  and r[0].lower()=="y":
1425                 pass
1426             else:
1427                 return 0
1428         mano_response = requests.delete(URLrequest, headers=headers_req)
1429     elif args.action=="netmap-import":
1430         if not args.force:
1431             r = raw_input("Create all the available networks from datacenter '%s' as default netmaps (y/N)? " % (datacenter))
1432             if  len(r)>0  and r[0].lower()=="y":
1433                 pass
1434             else:
1435                 return 0
1436         URLrequest += "/upload"
1437         mano_response = requests.post(URLrequest, headers=headers_req)
1438     elif args.action=="netmap-edit" or args.action=="netmap-create":
1439         if args.file:
1440             payload = _load_file_or_yaml(args.file)
1441         else:
1442             payload = {}
1443         if "netmap" not in payload:
1444             payload = {"netmap": payload}
1445         if args.name:
1446             payload["netmap"]["name"] = args.name
1447         if args.vim_id:
1448             payload["netmap"]["vim_id"] = args.vim_id
1449         if args.action=="netmap-create" and args.vim_name:
1450             payload["netmap"]["vim_name"] = args.vim_name
1451         payload_req = json.dumps(payload)
1452         logger.debug("openmano request: %s", payload_req)
1453
1454         if args.action=="netmap-edit" and not args.force:
1455             if len(payload["netmap"]) == 0:
1456                 print "You must supply some parameter to edit"
1457                 return 1
1458             r = raw_input("Edit default netmap '%s' from datacenter '%s' (y/N)? " % (args.netmap, datacenter))
1459             if  len(r)>0  and r[0].lower()=="y":
1460                 pass
1461             else:
1462                 return 0
1463             URLrequest += "/" + args.netmap
1464             mano_response = requests.put(URLrequest, headers=headers_req, data=payload_req)
1465         else: #netmap-create
1466             if "vim_name" not in payload["netmap"] and "vim_id" not in payload["netmap"]:
1467                 print "You must supply either --vim-id or --vim-name option; or include one of them in the file descriptor"
1468                 return 1
1469             mano_response = requests.post(URLrequest, headers=headers_req, data=payload_req)
1470
1471     logger.debug("openmano response: %s", mano_response.text )
1472     return _print_verbose(mano_response, args.verbose)
1473
1474 def element_edit(args):
1475     element = _get_item_uuid(args.element, args.name)
1476     headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1477     URLrequest = "http://%s:%s/openmano/%s/%s" %(mano_host, mano_port, args.element, element)
1478     payload=_load_file_or_yaml(args.file)
1479     if args.element[:-1] not in payload:
1480         payload = {args.element[:-1]: payload }
1481     payload_req = json.dumps(payload)
1482
1483     #print payload_req
1484     if not args.force or (args.name==None and args.filer==None):
1485         r = raw_input(" Edit " + args.element[:-1] + " " + args.name + " (y/N)? ")
1486         if  len(r)>0  and r[0].lower()=="y":
1487             pass
1488         else:
1489             return 0
1490     logger.debug("openmano request: %s", payload_req)
1491     mano_response = requests.put(URLrequest, headers=headers_req, data=payload_req)
1492     logger.debug("openmano response: %s", mano_response.text )
1493     if args.verbose==None:
1494         args.verbose=0
1495     if args.name!=None:
1496         args.verbose += 1
1497     return _print_verbose(mano_response, args.verbose)
1498
1499
1500 def datacenter_edit(args):
1501     tenant = _get_tenant()
1502     element = _get_item_uuid('datacenters', args.name, tenant)
1503     headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1504     URLrequest = "http://%s:%s/openmano/datacenters/%s" % (mano_host, mano_port, element)
1505
1506     has_arguments = False
1507     if args.file != None:
1508         has_arguments = True
1509         payload = _load_file_or_yaml(args.file)
1510     else:
1511         payload = {}
1512
1513     if args.sdn_controller != None:
1514         has_arguments = True
1515         if not 'config' in payload:
1516             payload['config'] = {}
1517         if not 'sdn-controller' in payload['config']:
1518             payload['config']['sdn-controller'] = {}
1519         if args.sdn_controller == 'null':
1520             payload['config']['sdn-controller'] = None
1521         else:
1522             payload['config']['sdn-controller'] = _get_item_uuid("sdn_controllers", args.sdn_controller, tenant)
1523
1524     if not has_arguments:
1525         raise OpenmanoCLIError("At least one argument must be provided to modify the datacenter")
1526
1527     if 'datacenter' not in payload:
1528         payload = {'datacenter': payload}
1529     payload_req = json.dumps(payload)
1530
1531     # print payload_req
1532     if not args.force or (args.name == None and args.filer == None):
1533         r = raw_input(" Edit datacenter " + args.name + " (y/N)? ")
1534         if len(r) > 0 and r[0].lower() == "y":
1535             pass
1536         else:
1537             return 0
1538     logger.debug("openmano request: %s", payload_req)
1539     mano_response = requests.put(URLrequest, headers=headers_req, data=payload_req)
1540     logger.debug("openmano response: %s", mano_response.text)
1541     if args.verbose == None:
1542         args.verbose = 0
1543     if args.name != None:
1544         args.verbose += 1
1545     return _print_verbose(mano_response, args.verbose)
1546
1547 def version(args):
1548     headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1549     URLrequest = "http://%s:%s/openmano/version" % (mano_host, mano_port)
1550
1551     mano_response = requests.get(URLrequest, headers=headers_req)
1552     logger.debug("openmano response: %s", mano_response.text)
1553     print mano_response.text
1554
1555
1556 global mano_host
1557 global mano_port
1558 global mano_tenant
1559
1560 if __name__=="__main__":
1561
1562     mano_tenant = os.getenv('OPENMANO_TENANT', None)
1563     mano_host = os.getenv('OPENMANO_HOST',"localhost")
1564     mano_port = os.getenv('OPENMANO_PORT',"9090")
1565     mano_datacenter = os.getenv('OPENMANO_DATACENTER',None)
1566
1567     main_parser = ThrowingArgumentParser(description='User program to interact with OPENMANO-SERVER (openmanod)')
1568     main_parser.add_argument('--version', action='version', help="get version of this client",
1569                             version='%(prog)s client version ' + __version__ +
1570                                     " (Note: use '%(prog)s version' to get server version)")
1571
1572     subparsers = main_parser.add_subparsers(help='commands')
1573
1574     parent_parser = argparse.ArgumentParser(add_help=False)
1575     parent_parser.add_argument('--verbose', '-v', action='count', help="increase verbosity level. Use several times")
1576     parent_parser.add_argument('--debug', '-d', action='store_true', help="show debug information")
1577
1578     config_parser = subparsers.add_parser('config', parents=[parent_parser], help="prints configuration values")
1579     config_parser.add_argument("-n", action="store_true", help="resolves tenant and datacenter names")
1580     config_parser.set_defaults(func=config)
1581
1582     version_parser = subparsers.add_parser('version', parents=[parent_parser], help="get server version")
1583     version_parser.set_defaults(func=version)
1584
1585     vnf_create_parser = subparsers.add_parser('vnf-create', parents=[parent_parser], help="adds a vnf into the catalogue")
1586     vnf_create_parser.add_argument("file", action="store", help="location of the JSON file describing the VNF").completer = FilesCompleter
1587     vnf_create_parser.add_argument("--name", action="store", help="name of the VNF (if it exists in the VNF descriptor, it is overwritten)")
1588     vnf_create_parser.add_argument("--description", action="store", help="description of the VNF (if it exists in the VNF descriptor, it is overwritten)")
1589     vnf_create_parser.add_argument("--image-path", action="store",  help="change image path locations (overwritten)")
1590     vnf_create_parser.add_argument("--image-name", action="store",  help="change image name (overwritten)")
1591     vnf_create_parser.add_argument("--image-checksum", action="store",  help="change image checksum (overwritten)")
1592     vnf_create_parser.set_defaults(func=vnf_create)
1593
1594     vnf_list_parser = subparsers.add_parser('vnf-list', parents=[parent_parser], help="lists information about a vnf")
1595     vnf_list_parser.add_argument("name", nargs='?', help="name of the VNF")
1596     vnf_list_parser.add_argument("-a", "--all", action="store_true", help="shows all vnfs, not only the owned or public ones")
1597     #vnf_list_parser.add_argument('--descriptor', help="prints the VNF descriptor", action="store_true")
1598     vnf_list_parser.set_defaults(func=vnf_list)
1599
1600     vnf_delete_parser = subparsers.add_parser('vnf-delete', parents=[parent_parser], help="deletes a vnf from the catalogue")
1601     vnf_delete_parser.add_argument("name", action="store", help="name or uuid of the VNF to be deleted")
1602     vnf_delete_parser.add_argument("-f", "--force", action="store_true", help="forces deletion without asking")
1603     vnf_delete_parser.add_argument("-a", "--all", action="store_true", help="allow delete not owned or privated one")
1604     vnf_delete_parser.set_defaults(func=vnf_delete)
1605
1606     scenario_create_parser = subparsers.add_parser('scenario-create', parents=[parent_parser], help="adds a scenario into the OPENMANO DB")
1607     scenario_create_parser.add_argument("file", action="store", help="location of the YAML file describing the scenario").completer = FilesCompleter
1608     scenario_create_parser.add_argument("--name", action="store", help="name of the scenario (if it exists in the YAML scenario, it is overwritten)")
1609     scenario_create_parser.add_argument("--description", action="store", help="description of the scenario (if it exists in the YAML scenario, it is overwritten)")
1610     scenario_create_parser.set_defaults(func=scenario_create)
1611
1612     scenario_list_parser = subparsers.add_parser('scenario-list', parents=[parent_parser], help="lists information about a scenario")
1613     scenario_list_parser.add_argument("name", nargs='?', help="name of the scenario")
1614     #scenario_list_parser.add_argument('--descriptor', help="prints the scenario descriptor", action="store_true")
1615     scenario_list_parser.add_argument("-a", "--all", action="store_true", help="shows all scenarios, not only the owned or public ones")
1616     scenario_list_parser.set_defaults(func=scenario_list)
1617
1618     scenario_delete_parser = subparsers.add_parser('scenario-delete', parents=[parent_parser], help="deletes a scenario from the OPENMANO DB")
1619     scenario_delete_parser.add_argument("name", action="store", help="name or uuid of the scenario to be deleted")
1620     scenario_delete_parser.add_argument("-f", "--force", action="store_true", help="forces deletion without asking")
1621     scenario_delete_parser.add_argument("-a", "--all", action="store_true", help="allow delete not owned or privated one")
1622     scenario_delete_parser.set_defaults(func=scenario_delete)
1623
1624     scenario_deploy_parser = subparsers.add_parser('scenario-deploy', parents=[parent_parser], help="deploys a scenario")
1625     scenario_deploy_parser.add_argument("scenario", action="store", help="name or uuid of the scenario to be deployed")
1626     scenario_deploy_parser.add_argument("name", action="store", help="name of the instance")
1627     scenario_deploy_parser.add_argument("--nostart", action="store_true", help="does not start the vms, just reserve resources")
1628     scenario_deploy_parser.add_argument("--datacenter", action="store", help="specifies the datacenter. Needed if several datacenters are available")
1629     scenario_deploy_parser.add_argument("--description", action="store", help="description of the instance")
1630     scenario_deploy_parser.set_defaults(func=scenario_deploy)
1631
1632     scenario_deploy_parser = subparsers.add_parser('scenario-verify', help="verifies if a scenario can be deployed (deploys it and deletes it)")
1633     scenario_deploy_parser.add_argument("scenario", action="store", help="name or uuid of the scenario to be verified")
1634     scenario_deploy_parser.add_argument('--debug', '-d', action='store_true', help="show debug information")
1635     scenario_deploy_parser.set_defaults(func=scenario_verify)
1636
1637     instance_scenario_create_parser = subparsers.add_parser('instance-scenario-create', parents=[parent_parser], help="deploys a scenario")
1638     instance_scenario_create_parser.add_argument("file", nargs='?', help="descriptor of the instance. Must be a file or yaml/json text")
1639     instance_scenario_create_parser.add_argument("--scenario", action="store", help="name or uuid of the scenario to be deployed")
1640     instance_scenario_create_parser.add_argument("--name", action="store", help="name of the instance")
1641     instance_scenario_create_parser.add_argument("--nostart", action="store_true", help="does not start the vms, just reserve resources")
1642     instance_scenario_create_parser.add_argument("--datacenter", action="store", help="specifies the datacenter. Needed if several datacenters are available")
1643     instance_scenario_create_parser.add_argument("--netmap-use", action="append", type=str, dest="netmap_use", help="indicates a datacenter network to map a scenario network 'scenario-network=datacenter-network'. Can be used several times")
1644     instance_scenario_create_parser.add_argument("--netmap-create", action="append", type=str, dest="netmap_create", help="the scenario network must be created at datacenter 'scenario-network[=datacenter-network-name]' . Can be used several times")
1645     instance_scenario_create_parser.add_argument("--keypair", action="append", type=str, dest="keypair", help="public key for ssh access. Format '[user:]key1[,key2...]'. Can be used several times")
1646     instance_scenario_create_parser.add_argument("--keypair-auto", action="store_true", dest="keypair_auto", help="Inject the user ssh-keys found at $HOME/.ssh directory")
1647     instance_scenario_create_parser.add_argument("--description", action="store", help="description of the instance")
1648     instance_scenario_create_parser.set_defaults(func=instance_create)
1649
1650     instance_scenario_list_parser = subparsers.add_parser('instance-scenario-list', parents=[parent_parser], help="lists information about a scenario instance")
1651     instance_scenario_list_parser.add_argument("name", nargs='?', help="name of the scenario instance")
1652     instance_scenario_list_parser.add_argument("-a", "--all", action="store_true", help="shows all instance-scenarios, not only the owned")
1653     instance_scenario_list_parser.set_defaults(func=instance_scenario_list)
1654
1655     instance_scenario_delete_parser = subparsers.add_parser('instance-scenario-delete', parents=[parent_parser], help="deletes a scenario instance (and deletes all VM and net instances in VIM)")
1656     instance_scenario_delete_parser.add_argument("name", action="store", help="name or uuid of the scenario instance to be deleted")
1657     instance_scenario_delete_parser.add_argument("-f", "--force", action="store_true", help="forces deletion without asking")
1658     instance_scenario_delete_parser.add_argument("-a", "--all", action="store_true", help="allow delete not owned or privated one")
1659     instance_scenario_delete_parser.set_defaults(func=instance_scenario_delete)
1660
1661     instance_scenario_action_parser = subparsers.add_parser('instance-scenario-action', parents=[parent_parser], help="invoke an action over part or the whole scenario instance")
1662     instance_scenario_action_parser.add_argument("name", action="store", help="name or uuid of the scenario instance")
1663     instance_scenario_action_parser.add_argument("action", action="store", type=str, \
1664             choices=["start","pause","resume","shutoff","shutdown","forceOff","rebuild","reboot", "console"],\
1665             help="action to send")
1666     instance_scenario_action_parser.add_argument("param", nargs='?', help="addional param of the action. e.g. console type (novnc, ...), reboot type (TODO)")
1667     instance_scenario_action_parser.add_argument("--vnf", action="append", help="VNF to act on (can use several entries)")
1668     instance_scenario_action_parser.add_argument("--vm", action="append", help="VM to act on (can use several entries)")
1669     instance_scenario_action_parser.set_defaults(func=instance_scenario_action)
1670
1671     #instance_scenario_status_parser = subparsers.add_parser('instance-scenario-status', help="show the status of a scenario instance")
1672     #instance_scenario_status_parser.add_argument("name", action="store", help="name or uuid of the scenario instance")
1673     #instance_scenario_status_parser.set_defaults(func=instance_scenario_status)
1674
1675     tenant_create_parser = subparsers.add_parser('tenant-create', parents=[parent_parser], help="creates a new tenant")
1676     tenant_create_parser.add_argument("name", action="store", help="name for the tenant")
1677     tenant_create_parser.add_argument("--description", action="store", help="description of the tenant")
1678     tenant_create_parser.set_defaults(func=tenant_create)
1679
1680     tenant_delete_parser = subparsers.add_parser('tenant-delete', parents=[parent_parser], help="deletes a tenant from the catalogue")
1681     tenant_delete_parser.add_argument("name", action="store", help="name or uuid of the tenant to be deleted")
1682     tenant_delete_parser.add_argument("-f", "--force", action="store_true", help="forces deletion without asking")
1683     tenant_delete_parser.set_defaults(func=tenant_delete)
1684
1685     tenant_list_parser = subparsers.add_parser('tenant-list', parents=[parent_parser], help="lists information about a tenant")
1686     tenant_list_parser.add_argument("name", nargs='?', help="name or uuid of the tenant")
1687     tenant_list_parser.set_defaults(func=tenant_list)
1688
1689     element_edit_parser = subparsers.add_parser('tenant-edit', parents=[parent_parser], help="edits one tenant")
1690     element_edit_parser.add_argument("name", help="name or uuid of the tenant")
1691     element_edit_parser.add_argument("file", help="json/yaml text or file with the changes").completer = FilesCompleter
1692     element_edit_parser.add_argument("-f","--force", action="store_true", help="do not prompt for confirmation")
1693     element_edit_parser.set_defaults(func=element_edit, element='tenants')
1694
1695     datacenter_create_parser = subparsers.add_parser('datacenter-create', parents=[parent_parser], help="creates a new datacenter")
1696     datacenter_create_parser.add_argument("name", action="store", help="name for the datacenter")
1697     datacenter_create_parser.add_argument("url", action="store", help="url for the datacenter")
1698     datacenter_create_parser.add_argument("--url_admin", action="store", help="url for administration for the datacenter")
1699     datacenter_create_parser.add_argument("--type", action="store", help="datacenter type: openstack or openvim (default)")
1700     datacenter_create_parser.add_argument("--config", action="store", help="aditional configuration in json/yaml format")
1701     datacenter_create_parser.add_argument("--description", action="store", help="description of the datacenter")
1702     datacenter_create_parser.add_argument("--sdn-controller", action="store", help="Name or uuid of the SDN controller to be used", dest='sdn_controller')
1703     datacenter_create_parser.set_defaults(func=datacenter_create)
1704
1705     datacenter_delete_parser = subparsers.add_parser('datacenter-delete', parents=[parent_parser], help="deletes a datacenter from the catalogue")
1706     datacenter_delete_parser.add_argument("name", action="store", help="name or uuid of the datacenter to be deleted")
1707     datacenter_delete_parser.add_argument("-f", "--force", action="store_true", help="forces deletion without asking")
1708     datacenter_delete_parser.set_defaults(func=datacenter_delete)
1709
1710     datacenter_edit_parser = subparsers.add_parser('datacenter-edit', parents=[parent_parser], help="Edit datacenter")
1711     datacenter_edit_parser.add_argument("name", help="name or uuid of the datacenter")
1712     datacenter_edit_parser.add_argument("--file", help="json/yaml text or file with the changes").completer = FilesCompleter
1713     datacenter_edit_parser.add_argument("--sdn-controller", action="store",
1714                                           help="Name or uuid of the SDN controller to be used. Specify 'null' to clear entry", dest='sdn_controller')
1715     datacenter_edit_parser.add_argument("-f", "--force", action="store_true", help="do not prompt for confirmation")
1716     datacenter_edit_parser.set_defaults(func=datacenter_edit)
1717
1718     datacenter_list_parser = subparsers.add_parser('datacenter-list', parents=[parent_parser], help="lists information about a datacenter")
1719     datacenter_list_parser.add_argument("name", nargs='?', help="name or uuid of the datacenter")
1720     datacenter_list_parser.add_argument("-a", "--all", action="store_true", help="shows all datacenters, not only datacenters attached to tenant")
1721     datacenter_list_parser.set_defaults(func=datacenter_list)
1722
1723     datacenter_attach_parser = subparsers.add_parser('datacenter-attach', parents=[parent_parser], help="associates a datacenter to the operating tenant")
1724     datacenter_attach_parser.add_argument("name", help="name or uuid of the datacenter")
1725     datacenter_attach_parser.add_argument('--vim-tenant-id', action='store', help="specify a datacenter tenant to use. A new one is created by default")
1726     datacenter_attach_parser.add_argument('--vim-tenant-name', action='store', help="specify a datacenter tenant name.")
1727     datacenter_attach_parser.add_argument("--user", action="store", help="user credentials for the datacenter")
1728     datacenter_attach_parser.add_argument("--password", action="store", help="password credentials for the datacenter")
1729     datacenter_attach_parser.add_argument("--config", action="store", help="aditional configuration in json/yaml format")
1730     datacenter_attach_parser.set_defaults(func=datacenter_attach)
1731
1732     datacenter_edit_vim_tenant_parser = subparsers.add_parser('datacenter-edit-vim-tenant', parents=[parent_parser],
1733                                                      help="Edit the association of a datacenter to the operating tenant")
1734     datacenter_edit_vim_tenant_parser.add_argument("name", help="name or uuid of the datacenter")
1735     datacenter_edit_vim_tenant_parser.add_argument('--vim-tenant-id', action='store',
1736                                           help="specify a datacenter tenant to use. A new one is created by default")
1737     datacenter_edit_vim_tenant_parser.add_argument('--vim-tenant-name', action='store', help="specify a datacenter tenant name.")
1738     datacenter_edit_vim_tenant_parser.add_argument("--user", action="store", help="user credentials for the datacenter")
1739     datacenter_edit_vim_tenant_parser.add_argument("--password", action="store", help="password credentials for the datacenter")
1740     datacenter_edit_vim_tenant_parser.add_argument("--config", action="store",
1741                                           help="aditional configuration in json/yaml format")
1742     datacenter_edit_vim_tenant_parser.set_defaults(func=datacenter_edit_vim_tenant)
1743
1744     datacenter_detach_parser = subparsers.add_parser('datacenter-detach', parents=[parent_parser], help="removes the association between a datacenter and the operating tenant")
1745     datacenter_detach_parser.add_argument("name", help="name or uuid of the datacenter")
1746     datacenter_detach_parser.add_argument("-a", "--all", action="store_true", help="removes all associations from this datacenter")
1747     datacenter_detach_parser.set_defaults(func=datacenter_detach)
1748
1749     #=======================datacenter_sdn_port_mapping_xxx section=======================
1750     #datacenter_sdn_port_mapping_set
1751     datacenter_sdn_port_mapping_set_parser = subparsers.add_parser('datacenter-sdn-port-mapping-set',
1752                                                                    parents=[parent_parser],
1753                                                                    help="Load a file with the mapping of physical ports "
1754                                                                         "and the ports of the dataplaneswitch controlled "
1755                                                                         "by a datacenter")
1756     datacenter_sdn_port_mapping_set_parser.add_argument("name", action="store", help="specifies the datacenter")
1757     datacenter_sdn_port_mapping_set_parser.add_argument("file",
1758                                                         help="json/yaml text or file with the port mapping").completer = FilesCompleter
1759     datacenter_sdn_port_mapping_set_parser.add_argument("-f", "--force", action="store_true",
1760                                                           help="forces overwriting without asking")
1761     datacenter_sdn_port_mapping_set_parser.set_defaults(func=datacenter_sdn_port_mapping_set)
1762
1763     #datacenter_sdn_port_mapping_list
1764     datacenter_sdn_port_mapping_list_parser = subparsers.add_parser('datacenter-sdn-port-mapping-list',
1765                                                                     parents=[parent_parser],
1766                                                                     help="Show the SDN port mapping in a datacenter")
1767     datacenter_sdn_port_mapping_list_parser.add_argument("name", action="store", help="specifies the datacenter")
1768     datacenter_sdn_port_mapping_list_parser.set_defaults(func=datacenter_sdn_port_mapping_list)
1769
1770     # datacenter_sdn_port_mapping_clear
1771     datacenter_sdn_port_mapping_clear_parser = subparsers.add_parser('datacenter-sdn-port-mapping-clear',
1772                                                                     parents=[parent_parser],
1773                                                                     help="Clean the the SDN port mapping in a datacenter")
1774     datacenter_sdn_port_mapping_clear_parser.add_argument("name", action="store",
1775                                                          help="specifies the datacenter")
1776     datacenter_sdn_port_mapping_clear_parser.add_argument("-f", "--force", action="store_true",
1777                                               help="forces clearing without asking")
1778     datacenter_sdn_port_mapping_clear_parser.set_defaults(func=datacenter_sdn_port_mapping_clear)
1779     # =======================
1780
1781     # =======================sdn_controller_xxx section=======================
1782     # sdn_controller_create
1783     sdn_controller_create_parser = subparsers.add_parser('sdn-controller-create', parents=[parent_parser],
1784                                                         help="Creates an SDN controller entity within RO")
1785     sdn_controller_create_parser.add_argument("name", help="name of the SDN controller")
1786     sdn_controller_create_parser.add_argument("--description", action="store", help="description of the SDN controller")
1787     sdn_controller_create_parser.add_argument("--ip", action="store", help="IP of the SDN controller")
1788     sdn_controller_create_parser.add_argument("--port", action="store", help="Port of the SDN controller")
1789     sdn_controller_create_parser.add_argument("--dpid", action="store",
1790                                              help="DPID of the dataplane switch controlled by this SDN controller")
1791     sdn_controller_create_parser.add_argument("--type", action="store",
1792                                              help="Specify the SDN controller type. Valid types are 'opendaylight' and 'floodlight'")
1793     sdn_controller_create_parser.add_argument("--user", action="store", help="user credentials for the SDN controller")
1794     sdn_controller_create_parser.add_argument("--passwd", action="store", dest='password',
1795                                              help="password credentials for the SDN controller")
1796     sdn_controller_create_parser.set_defaults(func=sdn_controller_create)
1797
1798     # sdn_controller_edit
1799     sdn_controller_edit_parser = subparsers.add_parser('sdn-controller-edit', parents=[parent_parser],
1800                                                         help="Update one or more options of a SDN controller")
1801     sdn_controller_edit_parser.add_argument("name", help="name or uuid of the SDN controller", )
1802     sdn_controller_edit_parser.add_argument("--name", action="store", help="Update the name of the SDN controller",
1803                                               dest='new_name')
1804     sdn_controller_edit_parser.add_argument("--description", action="store", help="description of the SDN controller")
1805     sdn_controller_edit_parser.add_argument("--ip", action="store", help="IP of the SDN controller")
1806     sdn_controller_edit_parser.add_argument("--port", action="store", help="Port of the SDN controller")
1807     sdn_controller_edit_parser.add_argument("--dpid", action="store",
1808                                              help="DPID of the dataplane switch controlled by this SDN controller")
1809     sdn_controller_edit_parser.add_argument("--type", action="store",
1810                                              help="Specify the SDN controller type. Valid types are 'opendaylight' and 'floodlight'")
1811     sdn_controller_edit_parser.add_argument("--user", action="store", help="user credentials for the SDN controller")
1812     sdn_controller_edit_parser.add_argument("--password", action="store",
1813                                              help="password credentials for the SDN controller", dest='password')
1814     sdn_controller_edit_parser.add_argument("-f", "--force", action="store_true", help="do not prompt for confirmation")
1815     #TODO: include option --file
1816     sdn_controller_edit_parser.set_defaults(func=sdn_controller_edit)
1817
1818     #sdn_controller_list
1819     sdn_controller_list_parser = subparsers.add_parser('sdn-controller-list',
1820                                                                     parents=[parent_parser],
1821                                                                     help="List the SDN controllers")
1822     sdn_controller_list_parser.add_argument("name", nargs='?', help="name or uuid of the SDN controller")
1823     sdn_controller_list_parser.set_defaults(func=sdn_controller_list)
1824
1825     # sdn_controller_delete
1826     sdn_controller_delete_parser = subparsers.add_parser('sdn-controller-delete',
1827                                                                     parents=[parent_parser],
1828                                                                     help="Delete the the SDN controller")
1829     sdn_controller_delete_parser.add_argument("name", help="name or uuid of the SDN controller")
1830     sdn_controller_delete_parser.add_argument("-f", "--force", action="store_true", help="forces deletion without asking")
1831     sdn_controller_delete_parser.set_defaults(func=sdn_controller_delete)
1832     # =======================
1833
1834     action_dict={'net-update': 'retrieves external networks from datacenter',
1835                  'net-edit': 'edits an external network',
1836                  'net-delete': 'deletes an external network',
1837                  'net-list': 'lists external networks from a datacenter'
1838                  }
1839     for item in action_dict:
1840         datacenter_action_parser = subparsers.add_parser('datacenter-'+item, parents=[parent_parser], help=action_dict[item])
1841         datacenter_action_parser.add_argument("datacenter", help="name or uuid of the datacenter")
1842         if item=='net-edit' or item=='net-delete':
1843             datacenter_action_parser.add_argument("net", help="name or uuid of the datacenter net")
1844         if item=='net-edit':
1845             datacenter_action_parser.add_argument("file", help="json/yaml text or file with the changes").completer = FilesCompleter
1846         if item!='net-list':
1847             datacenter_action_parser.add_argument("-f","--force", action="store_true", help="do not prompt for confirmation")
1848         datacenter_action_parser.set_defaults(func=datacenter_net_action, action=item)
1849
1850
1851     action_dict={'netmap-import': 'create network senario netmap base on the datacenter networks',
1852                  'netmap-create': 'create a new network senario netmap',
1853                  'netmap-edit':   'edit name of a network senario netmap',
1854                  'netmap-delete': 'deletes a network scenario netmap (--all for clearing all)',
1855                  'netmap-list':   'list/show network scenario netmaps'
1856                  }
1857     for item in action_dict:
1858         datacenter_action_parser = subparsers.add_parser('datacenter-'+item, parents=[parent_parser], help=action_dict[item])
1859         datacenter_action_parser.add_argument("--datacenter", help="name or uuid of the datacenter")
1860         #if item=='net-add':
1861         #    datacenter_action_parser.add_argument("net", help="name of the network")
1862         if item=='netmap-delete':
1863             datacenter_action_parser.add_argument("netmap", nargs='?',help="name or uuid of the datacenter netmap to delete")
1864             datacenter_action_parser.add_argument("--all", action="store_true", help="delete all netmap of this datacenter")
1865             datacenter_action_parser.add_argument("-f","--force", action="store_true", help="do not prompt for confirmation")
1866         if item=='netmap-edit':
1867             datacenter_action_parser.add_argument("netmap", help="name or uuid of the datacenter netmap do edit")
1868             datacenter_action_parser.add_argument("file", nargs='?', help="json/yaml text or file with the changes").completer = FilesCompleter
1869             datacenter_action_parser.add_argument("--name", action='store', help="name to assign to the datacenter netmap")
1870             datacenter_action_parser.add_argument('--vim-id', action='store', help="specify vim network uuid")
1871             datacenter_action_parser.add_argument("-f","--force", action="store_true", help="do not prompt for confirmation")
1872         if item=='netmap-list':
1873             datacenter_action_parser.add_argument("netmap", nargs='?',help="name or uuid of the datacenter netmap to show")
1874         if item=='netmap-create':
1875             datacenter_action_parser.add_argument("file", nargs='?', help="json/yaml text or file descriptor with the changes").completer = FilesCompleter
1876             datacenter_action_parser.add_argument("--name", action='store', help="name to assign to the datacenter netmap, by default same as vim-name")
1877             datacenter_action_parser.add_argument('--vim-id', action='store', help="specify vim network uuid")
1878             datacenter_action_parser.add_argument('--vim-name', action='store', help="specify vim network name")
1879         if item=='netmap-import':
1880             datacenter_action_parser.add_argument("-f","--force", action="store_true", help="do not prompt for confirmation")
1881         datacenter_action_parser.set_defaults(func=datacenter_netmap_action, action=item)
1882
1883     # =======================vim_net_sdn_xxx section=======================
1884     # vim_net_sdn_attach
1885     vim_net_sdn_attach_parser = subparsers.add_parser('vim-net-sdn-attach',
1886                                                       parents=[parent_parser],
1887                                                       help="Specify the port to access to an external network using SDN")
1888     vim_net_sdn_attach_parser.add_argument("vim_net", action="store",
1889                                                 help="Name/id of the network in the vim that will be used to connect to the external network")
1890     vim_net_sdn_attach_parser.add_argument("port", action="store", help="Specifies the port in the dataplane switch to access to the external network")
1891     vim_net_sdn_attach_parser.add_argument("--vlan", action="store", help="Specifies the vlan (if any) to use in the defined port")
1892     vim_net_sdn_attach_parser.add_argument("--mac", action="store", help="Specifies the MAC (if known) of the physical device that will be reachable by this external port")
1893     vim_net_sdn_attach_parser.add_argument("--datacenter", action="store", help="specifies the datacenter")
1894     vim_net_sdn_attach_parser.set_defaults(func=vim_net_sdn_attach)
1895
1896     # vim_net_sdn_detach
1897     vim_net_sdn_detach_parser = subparsers.add_parser('vim-net-sdn-detach',
1898                                                            parents=[parent_parser],
1899                                                            help="Remove the port information to access to an external network using SDN")
1900
1901     vim_net_sdn_detach_parser.add_argument("vim_net", action="store", help="Name/id of the vim network")
1902     vim_net_sdn_detach_parser.add_argument("--id", action="store",help="Specify the uuid of the external ports from this network to be detached")
1903     vim_net_sdn_detach_parser.add_argument("--all", action="store_true", help="Detach all external ports from this network")
1904     vim_net_sdn_detach_parser.add_argument("-f", "--force", action="store_true", help="forces clearing without asking")
1905     vim_net_sdn_detach_parser.add_argument("--datacenter", action="store", help="specifies the datacenter")
1906     vim_net_sdn_detach_parser.set_defaults(func=vim_net_sdn_detach)
1907     # =======================
1908
1909     for item in ("network", "tenant", "image"):
1910         if item=="network":
1911             command_name = 'vim-net'
1912         else:
1913             command_name = 'vim-'+item
1914         vim_item_list_parser = subparsers.add_parser(command_name + '-list', parents=[parent_parser], help="list the vim " + item + "s")
1915         vim_item_list_parser.add_argument("name", nargs='?', help="name or uuid of the " + item + "s")
1916         vim_item_list_parser.add_argument("--datacenter", action="store", help="specifies the datacenter")
1917         vim_item_list_parser.set_defaults(func=vim_action, item=item, action="list")
1918
1919         vim_item_del_parser = subparsers.add_parser(command_name + '-delete', parents=[parent_parser], help="list the vim " + item + "s")
1920         vim_item_del_parser.add_argument("name", help="name or uuid of the " + item + "s")
1921         vim_item_del_parser.add_argument("--datacenter", action="store", help="specifies the datacenter")
1922         vim_item_del_parser.set_defaults(func=vim_action, item=item, action="delete")
1923
1924         if item == "network" or item == "tenant":
1925             vim_item_create_parser = subparsers.add_parser(command_name + '-create', parents=[parent_parser], help="create a "+item+" at vim")
1926             vim_item_create_parser.add_argument("file", nargs='?', help="descriptor of the %s. Must be a file or yaml/json text" % item).completer = FilesCompleter
1927             vim_item_create_parser.add_argument("--name", action="store", help="name of the %s" % item  )
1928             vim_item_create_parser.add_argument("--datacenter", action="store", help="specifies the datacenter")
1929             if item=="network":
1930                 vim_item_create_parser.add_argument("--type", action="store", help="type of network, data, ptp, bridge")
1931                 vim_item_create_parser.add_argument("--shared", action="store_true", help="Private or shared")
1932                 vim_item_create_parser.add_argument("--bind-net", action="store", help="For openvim datacenter type, net to be bind to, for vlan type, use sufix ':<vlan_tag>'")
1933             else:
1934                 vim_item_create_parser.add_argument("--description", action="store", help="description of the %s" % item)
1935             vim_item_create_parser.set_defaults(func=vim_action, item=item, action="create")
1936
1937     argcomplete.autocomplete(main_parser)
1938
1939     try:
1940         args = main_parser.parse_args()
1941         #logging info
1942         level = logging.CRITICAL
1943         streamformat = "%(asctime)s %(name)s %(levelname)s: %(message)s"
1944         if "debug" in args and args.debug:
1945             level = logging.DEBUG
1946         logging.basicConfig(format=streamformat, level= level)
1947         logger = logging.getLogger('mano')
1948         logger.setLevel(level)
1949         result = args.func(args)
1950         if result == None:
1951             result = 0
1952         #for some reason it fails if call exit inside try instance. Need to call exit at the end !?
1953     except (requests.exceptions.ConnectionError):
1954         print "Connection error: not possible to contact OPENMANO-SERVER (openmanod)"
1955         result = -2
1956     except (KeyboardInterrupt):
1957         print 'Exiting openmano'
1958         result = -3
1959     except (SystemExit, ArgumentParserError):
1960         result = -4
1961     except OpenmanoCLIError as e:
1962         print str(e)
1963         result = -5
1964
1965     #print result
1966     exit(result)
1967