--- /dev/null
+
+
+class DbException(Exception):
+
+ def __init__(self, message, http_code=404):
+ self.http_code = http_code
+ Exception.__init__(self, message)
+
+class dbbase(object):
+
+ def __init__(self):
+ pass
+
+ def db_connect(self, config):
+ pass
+
+ def db_disconnect(self):
+ pass
+
+ def get_list(self, table, filter={}):
+ pass
+
+ def get_one(self, table, filter={}, fail_on_empty=True, fail_on_more=True):
+ pass
+
+ def create(self, table, indata):
+ pass
+
+ def del_list(self, table, filter={}):
+ pass
+
+ def del_one(self, table, filter={}, fail_on_empty=True):
+ pass
+
+
class RO_Exception(Exception):
pass
+
async def CreateNS(loop, nsr_id):
logger.debug("CreateNS task nsr_id={} Enter".format(nsr_id))
nsr_lcm = {
base_folder = vnfd["_admin"]["storage"]
path = base_folder + "/charms/" + proxy_charm
mgmt_ip = nsr_lcm['nsr_ip'][vnfd_index]
+<<<<<<< HEAD
# task = asyncio.ensure_future(DeployCharm(loop, path, mgmt_ip, config_primitive))
pass
# TODO launch VCA charm
+=======
+ # TODO launch VCA charm
+ # task = asyncio.ensure_future(DeployCharm(loop, path, mgmt_ip, config_primitive))
+>>>>>>> 6ce7cc879dda3b729b10d563bd26df613dc9f70f
nsr_lcm["status"] = "DONE"
db.replace("nsr_lcm", {"id": nsr_id}, nsr_lcm)
nsr_lcm["status"] = "DELETING"
nsr_lcm["status_detailed"] = "Deleting charms"
db.replace("nsr_lcm", {"id": nsr_id}, nsr_lcm)
+<<<<<<< HEAD
# TODO destroy charms
+=======
+ # TODO destroy VCA charm
+>>>>>>> 6ce7cc879dda3b729b10d563bd26df613dc9f70f
# remove from RO
RO = ROclient.ROClient(loop, endpoint_url=ro_account["url"], tenant=ro_account["tenant"],
db.create("ns_request", ns_request)
# lcm2()
lcm()
-
-
-