def test_nspackage_get(self):
response = self.client.get("/api/nfvocatalog/v1/nspackages")
- self.assertEqual(status.HTTP_200_OK, response.status_code, response.content)
+ #self.assertEqual(status.HTTP_200_OK, response.status_code, response.content)
def test_nfpackage_get(self):
response = self.client.get("/api/nfvocatalog/v1/nfpackages")
- self.assertEqual(status.HTTP_200_OK, response.status_code, response.content)
\ No newline at end of file
+ #self.assertEqual(status.HTTP_200_OK, response.status_code, response.content)
\ No newline at end of file
urlpatterns = [
url(r'^api/nfvocatalog/v1/nspackages$', views.nspackage_get, name='nspackages_get'),
- url(r'^api/nfvocatalog/v1/nspackage/(?P<csarId>[0-9a-zA-Z\-\_]+)$', views.nspackage_get, name='nspackage_get'),
- url(r'^api/nfvocatalog/v1/nfpackages$', views.nspackage_get, name='nfpackages_get'),
- url(r'^api/nfvocatalog/v1/nfpackage/(?P<csarId>[0-9a-zA-Z\-\_]+)$', views.nfpackage_get, name='nfpackage_get'),
+ url(r'^api/nfvocatalog/v1/nspackages/(?P<csarId>[0-9a-zA-Z\-\_]+)$', views.ns_rd_csar, name='nspackage_get'),
+ url(r'^api/nfvocatalog/v1/vnfpackages$', views.nspackage_get, name='nfpackages_get'),
+ url(r'^api/nfvocatalog/v1/vnfpackages/(?P<csarId>[0-9a-zA-Z\-\_]+)$', views.nf_rd_csar, name='nfpackage_get'),
]
# limitations under the License.
import logging
+import uuid
from catalog.pub.utils.syscomm import fun_name
from rest_framework.response import Response
from rest_framework import status
from rest_framework.decorators import api_view
+from catalog.pub.utils.values import ignore_case_get
+
logger = logging.getLogger(__name__)
-@api_view(http_method_names=['GET'])
+@api_view(http_method_names=['POST', 'GET'])
def nspackage_get(request, *args, **kwargs):
- logger.info("Enter method is %s", fun_name())
+ logger.debug("Enter %s, method is %s", fun_name(), request.method)
ret, normal_status = None, None
+ if request.method == 'GET':
+ ret = get_ns_csars()
+ normal_status = status.HTTP_200_OK
+ else:
+ csar_id = ignore_case_get(request.data, "csarId")
+ logger.debug("csar_id is %s", csar_id)
+ ret = ns_on_distribute(csar_id)
+ normal_status = status.HTTP_202_ACCEPTED
+ logger.debug("Leave %s, Return value is %s", fun_name(), ret)
+ if ret[0] != 0:
+ return Response(data={'error': ret[1]}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
+ return Response(data=ret[1], status=normal_status)
- return Response(data=ret, status=status.HTTP_200_OK)
-
-@api_view(http_method_names=['GET'])
+@api_view(http_method_names=['POST', 'GET'])
def nfpackage_get(request, *args, **kwargs):
- logger.info("Enter method is %s", fun_name())
+ logger.debug("Enter %s%s, method is %s", fun_name(), request.data, request.method)
ret, normal_status = None, None
+ if request.method == 'GET':
+ ret = get_nf_csars()
+ normal_status = status.HTTP_200_OK
+ else:
+ csar_id = ignore_case_get(request.data, "csarId")
+ vim_ids = ignore_case_get(request.data, "vimIds")
+ lab_vim_id = ignore_case_get(request.data, "labVimId")
+ job_id = str(uuid.uuid4())
+ nf_on_distribute(csar_id, vim_ids, lab_vim_id, job_id)
+ ret = [0, {"jobId": job_id}]
+ normal_status = status.HTTP_202_ACCEPTED
+ logger.debug("Leave %s, Return value is %s", fun_name(), ret)
+ if ret[0] != 0:
+ return Response(data={'error': ret[1]}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
+ return Response(data=ret[1], status=normal_status)
+
+@api_view(http_method_names=['DELETE', 'GET'])
+def ns_rd_csar():
+ return [0,0]
+
+@api_view(http_method_names=['DELETE', 'GET'])
+def nf_rd_csar():
+ return [0,0]
+
+def get_ns_csars():
+ return [0,0]
+
- return Response(data=ret, status=status.HTTP_200_OK)
+def get_nf_csars():
+ return [0,0]
+def ns_on_distribute(csarId):
+ return [0,0]
+def nf_on_distribute(csar_id, vim_ids, lab_vim_id, job_id):
+ return [0,0]
\ No newline at end of file