+ except (ROclient.ROClientException, DbException) as e:
+ self.logger.error(logging_text + "Exit Exception {}".format(e))
+ exc = e
+ except Exception as e:
+ self.logger.critical(logging_text + "Exit Exception {}".format(e), exc_info=True)
+ exc = e
+ finally:
+ if exc and db_sdn:
+ db_sdn["_admin"]["operationalState"] = "ERROR"
+ db_sdn["_admin"]["detailed-status"] = "ERROR {}: {}".format(step , exc)
+ self.update_db("sdns", sdn_id, db_sdn)
+
+ def vnfd2RO(self, vnfd, new_id=None):
+ """
+ Converts creates a new vnfd descriptor for RO base on input OSM IM vnfd
+ :param vnfd: input vnfd
+ :param new_id: overrides vnf id if provided
+ :return: copy of vnfd
+ """
+ ci_file = None
+ try:
+ vnfd_RO = deepcopy(vnfd)
+ vnfd_RO.pop("_id", None)
+ vnfd_RO.pop("_admin", None)
+ if new_id:
+ vnfd_RO["id"] = new_id
+ for vdu in vnfd_RO["vdu"]:
+ if "cloud-init-file" in vdu:
+ base_folder = vnfd["_admin"]["storage"]
+ clout_init_file = "{}/{}/cloud_init/{}".format(
+ base_folder["folder"],
+ base_folder["pkg-dir"],
+ vdu["cloud-init-file"]
+ )
+ ci_file = self.fs.file_open(clout_init_file, "r")
+ # TODO: detect if binary or text. Propose to read as binary and try to decode to utf8. If fails convert to base 64 or similar
+ clout_init_content = ci_file.read()
+ ci_file.close()
+ ci_file = None
+ vdu.pop("cloud-init-file", None)
+ vdu["cloud-init"] = clout_init_content
+ return vnfd_RO
+ except FsException as e:
+ raise LcmException("Error reading file at vnfd {}: {} ".format(vnfd["_id"], e))
+ finally:
+ if ci_file:
+ ci_file.close()
+
+ def n2vc_callback(self, model_name, application_name, workload_status, db_nsr, vnf_member_index, task=None):
+ """Update the lcm database with the status of the charm.
+
+ Updates the VNF's operational status with the state of the charm:
+ - blocked: The unit needs manual intervention
+ - maintenance: The unit is actively deploying/configuring
+ - waiting: The unit is waiting for another charm to be ready
+ - active: The unit is deployed, configured, and ready
+ - error: The charm has failed and needs attention.
+ - terminated: The charm has been destroyed
+ - removing,
+ - removed
+
+ Updates the network service's config-status to reflect the state of all
+ charms.
+ """
+ nsr_id = None
+ try:
+ nsr_id = db_nsr["_id"]
+ nsr_lcm = db_nsr["_admin"]["deploy"]
+ if task:
+ if task.cancelled():
+ self.logger.debug("[n2vc_callback] create_ns={} vnf_index={} task Cancelled".format(nsr_id, vnf_member_index))
+ return
+
+ if task.done():
+ exc = task.exception()
+ if exc:
+ self.logger.error(
+ "[n2vc_callback] create_ns={} vnf_index={} task Exception={}".format(nsr_id, vnf_member_index, exc))
+ nsr_lcm["VCA"][vnf_member_index]['operational-status'] = "error"
+ nsr_lcm["VCA"][vnf_member_index]['detailed-status'] = str(exc)
+ else:
+ self.logger.debug("[n2vc_callback] create_ns={} vnf_index={} task Done".format(nsr_id, vnf_member_index))
+ # TODO it seams that task Done, but callback is still ongoing. For the moment comment this two lines
+ # nsr_lcm["VCA"][vnf_member_index]['operational-status'] = "active"
+ # nsr_lcm["VCA"][vnf_member_index]['detailed-status'] = ""
+ elif workload_status:
+ self.logger.debug("[n2vc_callback] create_ns={} vnf_index={} Enter workload_status={}".format(nsr_id, vnf_member_index, workload_status))
+ if nsr_lcm["VCA"][vnf_member_index]['operational-status'] == workload_status:
+ return # same status, ignore
+ nsr_lcm["VCA"][vnf_member_index]['operational-status'] = workload_status
+ # TODO N2VC some error message in case of error should be obtained from N2VC
+ nsr_lcm["VCA"][vnf_member_index]['detailed-status'] = ""
+ else:
+ self.logger.critical("[n2vc_callback] create_ns={} vnf_index={} Enter with bad parameters".format(nsr_id, vnf_member_index), exc_info=True)
+ return
+
+ some_failed = False
+ all_active = True
+ status_map = {}
+ for vnf_index, vca_info in nsr_lcm["VCA"].items():
+ vca_status = vca_info["operational-status"]
+ if vca_status not in status_map:
+ # Initialize it
+ status_map[vca_status] = 0
+ status_map[vca_status] += 1
+
+ if vca_status != "active":
+ all_active = False
+ if vca_status == "error":
+ some_failed = True
+ db_nsr["config-status"] = "failed"
+ db_nsr["detailed-status"] = "fail configuring vnf_index={} {}".format(vnf_member_index,
+ vca_info["detailed-status"])
+ break
+
+ if all_active:
+ self.logger.debug("[n2vc_callback] create_ns={} vnf_index={} All active".format(nsr_id, vnf_member_index))
+ db_nsr["config-status"] = "configured"
+ db_nsr["detailed-status"] = "done"
+ elif some_failed:
+ pass
+ else:
+ cs = "configuring: "
+ separator = ""
+ for status, num in status_map.items():
+ cs += separator + "{}: {}".format(status, num)
+ separator = ", "
+ db_nsr["config-status"] = cs
+ self.update_db("nsrs", nsr_id, db_nsr)
+
+ except Exception as e:
+ self.logger.critical("[n2vc_callback] create_ns={} vnf_index={} Exception {}".format(nsr_id, vnf_member_index, e), exc_info=True)
+
+ async def create_ns(self, nsr_id, order_id):
+ logging_text = "Task create_ns={} ".format(nsr_id)
+ self.logger.debug(logging_text + "Enter")
+ # get all needed from database
+ db_nsr = None
+ exc = None
+ step = "Getting nsr from db"
+ try:
+ db_nsr = self.db.get_one("nsrs", {"_id": nsr_id})
+ nsd = db_nsr["nsd"]
+ nsr_name = db_nsr["name"] # TODO short-name??
+ needed_vnfd = {}
+ for c_vnf in nsd["constituent-vnfd"]:
+ vnfd_id = c_vnf["vnfd-id-ref"]
+ if vnfd_id not in needed_vnfd:
+ step = "Getting vnfd={} from db".format(vnfd_id)
+ needed_vnfd[vnfd_id] = self.db.get_one("vnfds", {"id": vnfd_id})
+
+ nsr_lcm = {
+ "id": nsr_id,
+ "RO": {"vnfd_id": {}, "nsd_id": None, "nsr_id": None, "nsr_status": "SCHEDULED"},
+ "nsr_ip": {},
+ "VCA": {},
+ }
+ db_nsr["_admin"]["deploy"] = nsr_lcm
+ db_nsr["detailed-status"] = "creating"
+ db_nsr["operational-status"] = "init"
+
+ deloyment_timeout = 120
+
+ RO = ROclient.ROClient(self.loop, datacenter=db_nsr["datacenter"], **self.ro_config)
+
+ # get vnfds, instantiate at RO
+ for vnfd_id, vnfd in needed_vnfd.items():
+ step = db_nsr["detailed-status"] = "Creating vnfd={} at RO".format(vnfd_id)
+ self.logger.debug(logging_text + step)
+ vnfd_id_RO = nsr_id + "." + vnfd_id[:200]
+
+ # look if present
+ vnfd_list = await RO.get_list("vnfd", filter_by={"osm_id": vnfd_id_RO})
+ if vnfd_list:
+ nsr_lcm["RO"]["vnfd_id"][vnfd_id] = vnfd_list[0]["uuid"]
+ self.logger.debug(logging_text + "RO vnfd={} exist. Using RO_id={}".format(
+ vnfd_id, vnfd_list[0]["uuid"]))
+ else:
+ vnfd_RO = self.vnfd2RO(vnfd, vnfd_id_RO)
+ desc = await RO.create("vnfd", descriptor=vnfd_RO)
+ nsr_lcm["RO"]["vnfd_id"][vnfd_id] = desc["uuid"]
+ self.update_db("nsrs", nsr_id, db_nsr)