x/valence
Code Issues Proposed changes

Support proxy POST, DELETE and PATCH request to podm

Browse Source 
Besides GET request, now API service support directly proxy POST,
DELETE and PATCH request to pod manager.

Change-Id: I7349b883a3f488053af59ef9687fa240af5487c4
Closes-Bug: #1640964
This commit is contained in:
Lin Yang 2016-11-11 21:08:21 -08:00
parent 7e2216219e
commit b3dbea5a7a
1 changed files with 43 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
valence/api/root.py
View File

@ -12,7 +12,6 @@
# License for the specific language governing permissions and limitations
# under the License.
from flask import abort
from flask import request
from flask_restful import Resource
@ -89,16 +88,51 @@ class Root(Resource):
class PODMProxy(Resource):
"""Passthrough Proxy for PODM.
This function byepasses valence processing
and calls PODM directly. This function may be temperory
This function bypasses valence processing
and calls PODM directly. This function may be temporary
"""
def get(self, url):
op = url.split("/")[0]
@staticmethod
def check_url(url):
# The url will be routed to PODMProxy resource if it didn't match
# others. So filter out these incorrect url.
# Only support proxy request of below podm API
resource = url.split("/")[0]
filterext = ["Chassis", "Services", "Managers", "Systems",
"EventService", "Nodes", "EthernetSwitches"]
if op in filterext:
resp = rfs.send_request(url)
return resp.json()
else:
if resource not in filterext:
abort(404)
def get(self, url):
self.check_url(url)
resp = rfs.send_request(url)
return (resp.json() if resp.text else resp.text,
resp.status_code,
resp.headers.items())
def post(self, url):
self.check_url(url)
resp = rfs.send_request(url,
"POST",
headers={'Content-type': 'application/json'},
data=request.data)
return (resp.json() if resp.text else resp.text,
resp.status_code,
resp.headers.items())
def delete(self, url):
self.check_url(url)
resp = rfs.send_request(url, "DELETE")
return (resp.json() if resp.text else resp.text,
resp.status_code,
resp.headers.items())
def patch(self, url):
self.check_url(url)
resp = rfs.send_request(url,
"PATCH",
headers={'Content-type': 'application/json'},
data=request.data)
return (resp.json() if resp.text else resp.text,
resp.status_code,
resp.headers.items())