def do_POST()

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)