lcm/pub/msapi/sdncdriver.py

   1 # Copyright 2016 ZTE Corporation.
   2 #
   3 # Licensed under the Apache License, Version 2.0 (the "License");
   4 # you may not use this file except in compliance with the License.
   5 # You may obtain a copy of the License at
   6 #
   7 #         http://www.apache.org/licenses/LICENSE-2.0
   8 #
   9 # Unless required by applicable law or agreed to in writing, software
  10 # distributed under the License is distributed on an "AS IS" BASIS,
  11 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12 # See the License for the specific language governing permissions and
  13 # limitations under the License.
  14
  15 import json
  16 import logging
  17
  18 from lcm.pub.exceptions import NSLCMException
  19 from lcm.pub.utils.restcall import req_by_msb
  20
  21 logger = logging.getLogger(__name__)
  22
  23
  24 def delete_port_chain(req_param):
  25     url = "/api/sdncdriver/v1/delchain"
  26     desc = "delete port chain"
  27     delete_func(req_param, url, desc)
  28
  29
  30 def delete_flow_classifier(req_param):
  31     url = "/api/sdncdriver/v1/delclassifier"
  32     desc = "delete flow classifier"
  33     delete_func(req_param, url, desc)
  34
  35
  36 def delete_port_pair_group(req_param):
  37     url = "/api/sdncdriver/v1/delportpairgroup"
  38     desc = "delete port pair"
  39     delete_func(req_param, url, desc)
  40
  41
  42 def delete_port_pair(req_param):
  43     url = "/api/sdncdriver/v1/delportpair"
  44     desc = "delete port pair"
  45     delete_func(req_param, url, desc)
  46
  47
  48 def delete_func(req_param, url, str):
  49     ret = req_by_msb(url, "DELETE", json.JSONEncoder().encode(req_param))
  50     if ret[0] != 0:
  51         logger.error("Failed to %s to sdncdriver. detail is %s.", str, ret[1])
  52         raise NSLCMException('Failed to %s to sdncdriver.' % str)
  53
  54
  55 def create_flow_classfier(data):
  56     url = "/api/ztesdncdriver/v1/createflowclassfier"
  57     desc = "create flow classfier"
  58     return create(data, url, desc)
  59
  60
  61 def create_port_pair(data):
  62     url = "/api/ztesdncdriver/v1/createportpair"
  63     desc = "create port pair"
  64     return create(data, url, desc)
  65
  66
  67 def create_port_pair_group(data):
  68     url = "/api/ztesdncdriver/v1/createportpairgroup"
  69     desc = "create port pair group"
  70     return create(data, url, desc)
  71
  72
  73 def create_port_chain(data):
  74     url = "/api/ztesdncdriver/v1/createportchain"
  75     desc = "create port chain"
  76     return create(data, url, desc)
  77
  78
  79 def create(req_param, url, desc):
  80     ret = req_by_msb(url, "POST", json.dumps(req_param))
  81     if ret[0] != 0:
  82         logger.error("Failed to %s to sdncdriver. detail is %s.", desc, ret[1])
  83         raise NSLCMException('Failed to %s to sdncdriver.' % desc)
  84     resp_body = json.loads(ret[1])
  85     return resp_body["id"]