summaryrefslogtreecommitdiffstats
path: root/share
diff options
context:
space:
mode:
Diffstat (limited to 'share')
-rw-r--r--share/newton_base/openoapi/server.py83
1 files changed, 82 insertions, 1 deletions
diff --git a/share/newton_base/openoapi/server.py b/share/newton_base/openoapi/server.py
index 0c2382ae..7dc229f0 100644
--- a/share/newton_base/openoapi/server.py
+++ b/share/newton_base/openoapi/server.py
@@ -555,7 +555,7 @@ class ServerAction(APIView):
endpoint_filter=self.service,
headers={"Content-Type": "application/json",
"Accept": "application/json"})
- resp_body = {}
+ resp_body = resp.json()
return Response(data=resp_body, status=resp.status_code)
except VimDriverKiloException as e:
@@ -568,9 +568,90 @@ class ServerAction(APIView):
return Response(data={'error': str(e)},
status=status.HTTP_500_INTERNAL_SERVER_ERROR)
+
class APIv1ServerAction(ServerAction):
def post(self, request, cloud_owner="", cloud_region_id="", tenantid="", serverid=""):
self._logger.info("%s, %s" % (cloud_owner, cloud_region_id))
vimid = extsys.encode_vim_id(cloud_owner, cloud_region_id)
return super(APIv1ServerAction, self).post(request, vimid, tenantid, serverid)
+
+
+class ServerOsInterface(APIView):
+ service = {'service_type': 'compute',
+ 'interface': 'public'}
+ def post(self, request, vimid="", tenantid="", serverid=""):
+ logger.debug("ServerOsInterface--post::> %s" % request.data)
+ logger.debug("vimid=%s, tenantid=%s, serverid=%s", vimid, tenantid, serverid)
+ try:
+ # prepare request resource to vim instance
+ vim = VimDriverUtils.get_vim_info(vimid)
+ sess = VimDriverUtils.get_session(vim, tenantid)
+
+ # operate server now
+ req_resouce = "servers/{server_id}/os-interface".format(server_id=serverid)
+ req_body = json.JSONEncoder().encode(request.data)
+ resp = sess.post(req_resouce, data=req_body,
+ endpoint_filter=self.service,
+ headers={"Content-Type": "application/json",
+ "Accept": "application/json"})
+ resp_body = resp.json()
+
+ return Response(data=resp_body, status=resp.status_code)
+ except VimDriverKiloException as e:
+ return Response(data={'error': e.content}, status=e.status_code)
+ except HttpError as e:
+ logger.error("HttpError: status:%s, response:%s" % (e.http_status, e.response.json()))
+ return Response(data=e.response.json(), status=e.http_status)
+ except Exception as e:
+ logger.error(traceback.format_exc())
+ return Response(data={'error': str(e)},
+ status=status.HTTP_500_INTERNAL_SERVER_ERROR)
+
+
+class APIv1ServerOsInterface(ServerOsInterface):
+ def post(self, request, cloud_owner="", cloud_region_id="", tenantid="", serverid=""):
+ self._logger.info("%s, %s" % (cloud_owner, cloud_region_id))
+
+ vimid = extsys.encode_vim_id(cloud_owner, cloud_region_id)
+ return super(APIv1ServerOsInterface, self).post(request, vimid, tenantid, serverid)
+
+
+class ServerOsInterfacePort(APIView):
+ service = {'service_type': 'compute',
+ 'interface': 'public'}
+ def delete(self, request, vimid="", tenantid="", serverid="", portid=""):
+ logger.debug("ServerOsInterfacePort--delete::portid=%s", portid)
+ logger.debug("vimid=%s, tenantid=%s, serverid=%s", vimid, tenantid, serverid)
+ try:
+ # prepare request resource to vim instance
+ vim = VimDriverUtils.get_vim_info(vimid)
+ sess = VimDriverUtils.get_session(vim, tenantid)
+
+ # operate server now
+ req_resfmt = "servers/{server_id}/os-interface/{port_id}"
+ req_resouce = req_resfmt.format(server_id=serverid, port_id=portid)
+ resp = sess.delete(req_resouce,
+ endpoint_filter=self.service,
+ headers={"Content-Type": "application/json",
+ "Accept": "application/json"})
+ resp_body = {}
+
+ return Response(data=resp_body, status=resp.status_code)
+ except VimDriverKiloException as e:
+ return Response(data={'error': e.content}, status=e.status_code)
+ except HttpError as e:
+ logger.error("HttpError: status:%s, response:%s" % (e.http_status, e.response.json()))
+ return Response(data=e.response.json(), status=e.http_status)
+ except Exception as e:
+ logger.error(traceback.format_exc())
+ return Response(data={'error': str(e)},
+ status=status.HTTP_500_INTERNAL_SERVER_ERROR)
+
+
+class APIv1ServerOsInterfacePort(ServerOsInterfacePort):
+ def delete(self, request, cloud_owner="", cloud_region_id="", tenantid="", serverid="", portid=""):
+ self._logger.info("%s, %s" % (cloud_owner, cloud_region_id))
+
+ vimid = extsys.encode_vim_id(cloud_owner, cloud_region_id)
+ return super(APIv1ServerOsInterfacePort, self).post(request, vimid, tenantid, serverid, portid)