refactor ns heal view code
[vfc/nfvo/lcm.git] / lcm / ns / views / sol / heal_ns_view.py
index 6dfef8d..58418bd 100644 (file)
 # See the License for the specific language governing permissions and
 # limitations under the License.
 import logging
+
+from .common import view_safe_call_with_log
 from drf_yasg.utils import swagger_auto_schema
-from rest_framework import status
-from rest_framework.response import Response
-from rest_framework.views import APIView
 from lcm.ns.biz.ns_heal import NSHealService
-from lcm.ns.serializers.sol.heal_serializers import HealNsReqSerializer
-from lcm.pub.exceptions import BadRequestException
-from lcm.pub.utils.jobutil import JobUtil
-from lcm.pub.enum import JOB_TYPE
 from lcm.ns.const import NS_OCC_BASE_URI
+from lcm.pub.enum import JOB_TYPE
+from lcm.pub.exceptions import BadRequestException
+from lcm.ns.serializers.sol.heal_serializers import HealNsReqSerializer
 from lcm.ns.serializers.sol.pub_serializers import ProblemDetailsSerializer
-from .common import view_safe_call_with_log
+from lcm.pub.utils.jobutil import JobUtil
+from rest_framework import status
+from rest_framework.response import Response
+from rest_framework.views import APIView
 
 logger = logging.getLogger(__name__)
 
@@ -38,19 +39,17 @@ class HealNSView(APIView):
     )
     @view_safe_call_with_log(logger=logger)
     def post(self, request, ns_instance_id):
-        logger.debug("Enter HealNSView::post %s", request.data)
-        logger.debug("Enter HealNSView:: %s", ns_instance_id)
+        logger.debug("Enter HealNSView::post nsInstanceId:%s, request.data:%s" % (ns_instance_id, request.data))
         req_serializer = HealNsReqSerializer(data=request.data)
         if not req_serializer.is_valid():
-            logger.debug("request.data is not valid,error: %s" % req_serializer.errors)
+            logger.error("request.data is not valid,error: %s" % req_serializer.errors)
             raise BadRequestException(req_serializer.errors)
 
-        job_id = JobUtil.create_job("VNF", JOB_TYPE.HEAL_VNF, ns_instance_id)
-
-        nsHealService = NSHealService(ns_instance_id, request.data, job_id)
-        nsHealService.start()
+        job_id = JobUtil.create_job("NS", JOB_TYPE.HEAL_NS, ns_instance_id)
+        ns_heal_service = NSHealService(ns_instance_id, request.data, job_id)
+        ns_heal_service.start()
         response = Response(data={}, status=status.HTTP_202_ACCEPTED)
-        logger.debug("Location: %s" % nsHealService.occ_id)
-        response["Location"] = NS_OCC_BASE_URI % nsHealService.occ_id
+        logger.debug("Location: %s" % ns_heal_service.occ_id)
+        response["Location"] = NS_OCC_BASE_URI % ns_heal_service.occ_id
         logger.debug("Leave NSHealView")
         return response