in sample/topic/server.py [0:0]
def do_POST(self):
# content_length = int(self.headers.getheader('content-length', 0))
content_length = int(self.headers['content-length'])
self.req_body = self.rfile.read(content_length)
self.msg = NotifyMessage()
_LOGGER.info("Headers:%s\nBody:%s" % (self.headers, self.req_body))
if not self.authenticate():
res_code = 403
res_content = u"Access Forbidden"
_LOGGER.warning("Access Forbidden!\nHeaders:%s\nReqBody:%s\n" % (self.headers, self.req_body))
elif not self.validate_body(self.req_body, self.msg, self.msg_type):
res_code = 400
res_content = u"Invalid Notify Message"
_LOGGER.warning("Invalid Notify Message!\nHeaders:%s\nReqBody:%s\n" % (self.headers, self.req_body))
else:
res_code = 201
res_content = u"Notify Message Succeed!"
_LOGGER.info("Notify Message Succeed!\n%s" % self.msg)
self.access_log(res_code)
self.response(res_code, res_content)