Commit 25ed7ce8 authored by Łukasz Nowak's avatar Łukasz Nowak

Implement software instance bang.

parent 77af3b71
...@@ -100,6 +100,73 @@ class GenericPublisher(Implicit): ...@@ -100,6 +100,73 @@ class GenericPublisher(Implicit):
class InstancePublisher(GenericPublisher): class InstancePublisher(GenericPublisher):
"""Instance publisher""" """Instance publisher"""
@requireHeader({'Accept': 'application/json',
'Content-Type': 'application/json'})
def __bang(self):
self.REQUEST.stdin.seek(0)
try:
jbody = json.load(self.REQUEST.stdin)
except Exception:
self.REQUEST.response.setStatus(400)
self.REQUEST.response.setBody(json.dumps(
{'error': 'Data is not json object.'}))
return self.REQUEST.response
person = self.getPortalObject().ERP5Site_getAuthenticatedMemberPersonValue()
if person is None:
transaction.abort()
LOG('VifibRestApiV1Tool', ERROR,
'Currenty logged in user %r has no Person document.'%
self.getPortalObject().getAuthenticatedMember())
self.REQUEST.response.setStatus(500)
self.REQUEST.response.setBody(json.dumps({'error':
'There is system issue, please try again later.'}))
return self.REQUEST.response
instance_path = '/'.join(self.REQUEST['traverse_subpath'][:-1])
error_dict = {}
if 'log' not in jbody:
error_dict['log'] = "Missing."
elif not isinstance(jbody['log'], unicode):
error_dict['log'] = 'Not a string.'
else:
log = str(jbody['log'])
if error_dict:
self.REQUEST.response.setStatus(400)
self.REQUEST.response.setBody(json.dumps(error_dict))
return self.REQUEST.response
try:
software_instance = self.restrictedTraverse(instance_path)
if getattr(software_instance, 'getPortalType', None) is None or \
software_instance.getPortalType() not in ('Software Instance',
'Slave Instance'):
raise WrongRequest('%r is not an instance' % instance_path)
except WrongRequest:
LOG('VifibRestApiV1Tool', ERROR,
'Problem while trying to find instance:', error=True)
self.REQUEST.response.setStatus(404)
except (Unauthorized, KeyError):
self.REQUEST.response.setStatus(404)
except Exception:
LOG('VifibRestApiV1Tool', ERROR,
'Problem while trying to find instance:', error=True)
self.REQUEST.response.setStatus(500)
self.REQUEST.response.setBody(json.dumps({'error':
'There is system issue, please try again later.'}))
else:
try:
software_instance.reportComputerPartitionBang(comment=log)
except Exception:
LOG('VifibRestApiV1Tool', ERROR,
'Problem while trying to generate instance dict:', error=True)
self.REQUEST.response.setStatus(500)
self.REQUEST.response.setBody(json.dumps({'error':
'There is system issue, please try again later.'}))
else:
self.REQUEST.response.setStatus(204)
return self.REQUEST.response
@requireHeader({'Accept': 'application/json', @requireHeader({'Accept': 'application/json',
'Content-Type': 'application/json'}) 'Content-Type': 'application/json'})
def __request(self): def __request(self):
...@@ -230,6 +297,9 @@ class InstancePublisher(GenericPublisher): ...@@ -230,6 +297,9 @@ class InstancePublisher(GenericPublisher):
def __call__(self): def __call__(self):
"""Instance GET/POST support""" """Instance GET/POST support"""
if self.REQUEST['REQUEST_METHOD'] == 'POST': if self.REQUEST['REQUEST_METHOD'] == 'POST':
if self.REQUEST['traverse_subpath'][-1] == 'bang':
self.__bang()
else:
self.__request() self.__request()
elif self.REQUEST['REQUEST_METHOD'] == 'GET' and \ elif self.REQUEST['REQUEST_METHOD'] == 'GET' and \
self.REQUEST['traverse_subpath']: self.REQUEST['traverse_subpath']:
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment