+ # Deploy charms for each VDU that supports one.
+ for vdu_index, vdu in enumerate(get_iterable(vnfd, 'vdu')):
+ vdu_config = vdu.get('vdu-configuration')
+ proxy_charm = None
+
+ if vdu_config and vdu_config.get("juju"):
+ proxy_charm = vdu_config["juju"]["charm"]
+ if vdu_config["juju"].get("proxy") is False:
+ # native_charm, will be deployed after VM. Skip
+ proxy_charm = None
+
+ if proxy_charm:
+ if not vca_model_name:
+ step = "creating VCA model name"
+ await self.n2vc.CreateNetworkService(nsr_id)
+ vca_model_name = nsr_id
+ db_nsr_update["_admin.deployed.VCA-model-name"] = nsr_id
+ self.update_db_2("nsrs", nsr_id, db_nsr_update)
+ step = "deploying proxy charm to configure member_vnf_index={} vdu={}".format(vnf_index,
+ vdu["id"])
+ await self.n2vc.login()
+ vdur = db_vnfrs[vnf_index]["vdur"][vdu_index]
+ # TODO for the moment only first vdu_id contains a charm deployed
+ if vdur["vdu-id-ref"] != vdu["id"]:
+ raise LcmException("Mismatch vdur {}, vdu {} at index {} for member_vnf_index={}"
+ .format(vdur["vdu-id-ref"], vdu["id"], vdu_index, vnf_index))
+ vnfr_params["rw_mgmt_ip"] = vdur["ip-address"]
+ charm_params = {
+ "user_values": vnfr_params,
+ "rw_mgmt_ip": vdur["ip-address"],
+ "initial-config-primitive": {} # vdu_config.get('initial-config-primitive') or {}
+ }
+ deploy_charm(vnf_index, vdu["id"], vdur.get("name"), vdur["count-index"],
+ charm_params, n2vc_info)
+ number_to_configure += 1
+
+ # Check if this NS has a charm configuration
+
+ ns_config = nsd.get("ns-configuration")
+ if ns_config and ns_config.get("juju"):
+ proxy_charm = ns_config["juju"]["charm"]
+ if ns_config["juju"].get("proxy") is False:
+ # native_charm, will be deployed after VM. Skip
+ proxy_charm = None
+
+ if proxy_charm:
+ step = "deploying proxy charm to configure ns"
+ # TODO is NS magmt IP address needed?
+
+ # Get additional parameters
+ additional_params = {}
+ if db_nsr.get("additionalParamsForNs"):
+ additional_params = db_nsr["additionalParamsForNs"].copy()
+ for k, v in additional_params.items():
+ if isinstance(v, str) and v.startswith("!!yaml "):
+ additional_params[k] = yaml.safe_load(v[7:])
+
+ # additional_params["rw_mgmt_ip"] = db_nsr["ip-address"]
+ charm_params = {
+ "user_values": additional_params,
+ # "rw_mgmt_ip": db_nsr["ip-address"],
+ "initial-config-primitive": {} # ns_config.get('initial-config-primitive') or {}
+ }
+
+ # Login to the VCA. If there are multiple calls to login(),
+ # subsequent calls will be a nop and return immediately.
+ await self.n2vc.login()
+ deploy_charm(None, None, None, None, charm_params, n2vc_info)
+ number_to_configure += 1
+
+ db_nsr_update["operational-status"] = "running"
+
+ # Wait until all charms has reached blocked or active status
+ step = "waiting proxy charms to be ready"
+ if number_to_configure:
+ # wait until all charms are configured.
+ # steps are:
+ # initial-deploy
+ # get-ssh-public-key
+ # generate-ssh-key
+ # retry-get-ssh-public-key
+ # ssh-public-key-obtained
+ while time() <= start_deploy + self.total_deploy_timeout:
+ if db_nsr_update:
+ self.update_db_2("nsrs", nsr_id, db_nsr_update)
+ if db_nslcmop_update:
+ self.update_db_2("nslcmops", nslcmop_id, db_nslcmop_update)
+
+ all_active = True
+ for vca_index, vca_deployed in enumerate(vca_deployed_list):
+ database_entry = "_admin.deployed.VCA.{}.".format(vca_index)
+ if vca_deployed["step"] == "initial-deploy":
+ if vca_deployed["operational-status"] in ("active", "blocked"):
+ step = "execute charm primitive get-ssh-public-key for member_vnf_index={} vdu_id={}" \
+ .format(vca_deployed["member-vnf-index"],
+ vca_deployed["vdu_id"])
+ self.logger.debug(logging_text + step)
+ try:
+ primitive_id = await self.n2vc.ExecutePrimitive(
+ vca_deployed["model"],
+ vca_deployed["application"],
+ "get-ssh-public-key",
+ None,
+ )
+ vca_deployed["step"] = db_nsr_update[database_entry + "step"] = "get-ssh-public-key"
+ vca_deployed["primitive_id"] = db_nsr_update[database_entry + "primitive_id"] =\
+ primitive_id
+ db_nsr_update[database_entry + "operational-status"] =\
+ vca_deployed["operational-status"]
+ except PrimitiveDoesNotExist:
+ ssh_public_key = None
+ vca_deployed["step"] = db_nsr_update[database_entry + "step"] =\
+ "ssh-public-key-obtained"
+ vca_deployed["ssh-public-key"] = db_nsr_update[database_entry + "ssh-public-key"] =\
+ ssh_public_key
+ step = "charm ssh-public-key for member_vnf_index={} vdu_id={} not needed".format(
+ vca_deployed["member-vnf-index"], vca_deployed["vdu_id"])
+ self.logger.debug(logging_text + step)
+
+ elif vca_deployed["step"] in ("get-ssh-public-key", "retry-get-ssh-public-key"):
+ primitive_id = vca_deployed["primitive_id"]
+ primitive_status = await self.n2vc.GetPrimitiveStatus(vca_deployed["model"],
+ primitive_id)
+ if primitive_status in ("completed", "failed"):
+ primitive_result = await self.n2vc.GetPrimitiveOutput(vca_deployed["model"],
+ primitive_id)
+ vca_deployed["primitive_id"] = db_nsr_update[database_entry + "primitive_id"] = None
+ if primitive_status == "completed" and isinstance(primitive_result, dict) and \
+ primitive_result.get("pubkey"):
+ ssh_public_key = primitive_result.get("pubkey")
+ vca_deployed["step"] = db_nsr_update[database_entry + "step"] =\
+ "ssh-public-key-obtained"
+ vca_deployed["ssh-public-key"] = db_nsr_update[database_entry + "ssh-public-key"] =\
+ ssh_public_key
+ n2vc_key_list.append(ssh_public_key)
+ step = "charm ssh-public-key for member_vnf_index={} vdu_id={} is '{}'".format(
+ vca_deployed["member-vnf-index"], vca_deployed["vdu_id"], ssh_public_key)
+ self.logger.debug(logging_text + step)
+ else: # primitive_status == "failed":
+ if vca_deployed["step"] == "get-ssh-public-key":
+ step = "execute charm primitive generate-ssh-public-key for member_vnf_index="\
+ "{} vdu_id={}".format(vca_deployed["member-vnf-index"],
+ vca_deployed["vdu_id"])
+ self.logger.debug(logging_text + step)
+ vca_deployed["step"] = db_nsr_update[database_entry + "step"] =\
+ "generate-ssh-key"
+ primitive_id = await self.n2vc.ExecutePrimitive(
+ vca_deployed["model"],
+ vca_deployed["application"],
+ "generate-ssh-key",
+ None,
+ )
+ vca_deployed["primitive_id"] = db_nsr_update[database_entry + "primitive_id"] =\
+ primitive_id
+ else: # failed for second time
+ raise LcmException(
+ "error executing primitive get-ssh-public-key: {}".format(primitive_result))
+
+ elif vca_deployed["step"] == "generate-ssh-key":
+ primitive_id = vca_deployed["primitive_id"]
+ primitive_status = await self.n2vc.GetPrimitiveStatus(vca_deployed["model"],
+ primitive_id)
+ if primitive_status in ("completed", "failed"):
+ primitive_result = await self.n2vc.GetPrimitiveOutput(vca_deployed["model"],
+ primitive_id)
+ vca_deployed["primitive_id"] = db_nsr_update[
+ database_entry + "primitive_id"] = None
+ if primitive_status == "completed":
+ step = "execute primitive get-ssh-public-key again for member_vnf_index={} "\
+ "vdu_id={}".format(vca_deployed["member-vnf-index"],
+ vca_deployed["vdu_id"])
+ self.logger.debug(logging_text + step)
+ vca_deployed["step"] = db_nsr_update[database_entry + "step"] = \
+ "retry-get-ssh-public-key"
+ primitive_id = await self.n2vc.ExecutePrimitive(
+ vca_deployed["model"],
+ vca_deployed["application"],
+ "get-ssh-public-key",
+ None,
+ )
+ vca_deployed["primitive_id"] = db_nsr_update[database_entry + "primitive_id"] =\
+ primitive_id
+
+ else: # primitive_status == "failed":
+ raise LcmException("error executing primitive generate-ssh-key: {}"
+ .format(primitive_result))
+
+ if vca_deployed["step"] != "ssh-public-key-obtained":
+ all_active = False
+
+ if all_active:
+ break
+ await asyncio.sleep(5)
+ else: # total_deploy_timeout
+ raise LcmException("Timeout waiting charm to be initialized for member_vnf_index={} vdu_id={}"
+ .format(vca_deployed["member-vnf-index"], vca_deployed["vdu_id"]))
+
+ # deploy RO
+ RO = ROclient.ROClient(self.loop, **self.ro_config)