Feature 10926 - Subscription feature for SOL003 VNF-LCM

[osm/NBI.git] / osm_nbi / osm_vnfm / vnf_instances.py

diff --git a/osm_nbi/osm_vnfm/vnf_instances.py b/osm_nbi/osm_vnfm/vnf_instances.py
index a41f6d5..a6a57fc 100644 (file)
--- a/osm_nbi/osm_vnfm/vnf_instances.py
+++ b/osm_nbi/osm_vnfm/vnf_instances.py
@@ -224,6 +224,11 @@ class NewVnfInstance(BaseMethod):
         nsr_id, _ = self.__create_nsr(rollback, session, formatted_indata, kwargs, headers)
         nsr = self.nsrtopic.show(session, nsr_id)
         vnfr_id =  nsr['constituent-vnfr-ref'][0]
+        if vnfr_id:
+            links = {"vnfInstance": "/osm/vnflcm/v1/vnf_instances/" + vnfr_id}
+            indata["vnfInstanceId"] = vnfr_id
+            indata["_links"] = links
+            self.msg.write("vnf", "create", indata)
         return vnfr_id, None
 
     def action(self, rollback, session, indata=None, kwargs=None, headers=None):
@@ -305,5 +310,10 @@ class DeleteVnfInstance(BaseMethod):
         ns_id = vnfr.get("nsr-id-ref")
         nsr = self.nsrtopic.show(session, ns_id)
         nsd_to_del = nsr['nsd']['_id']
+        links = {"vnfInstance": "/osm/vnflcm/v1/vnf_instances/" + _id}
+        params = {"vnfdId": vnfr["vnfd-ref"],
+                  "vnfInstanceId": _id,
+                  "_links": links}
+        self.msg.write("vnf", "delete", params)
         self.nsrtopic.delete(session, ns_id, dry_run, not_send_msg)
         return self.nsdtopic.delete(session, nsd_to_del, dry_run, not_send_msg)