From 2b67d09f052cda429efa35fe0d79520b9e2ac81f Mon Sep 17 00:00:00 2001 From: mehernosh Date: Tue, 7 Jul 2020 11:17:30 +0530 Subject: [PATCH] Fixed debugging --- daphne/http_protocol.py | 25 ++++++++++++++++++++----- daphne/server.py | 2 +- 2 files changed, 21 insertions(+), 6 deletions(-) diff --git a/daphne/http_protocol.py b/daphne/http_protocol.py index 0968718..937b3f6 100755 --- a/daphne/http_protocol.py +++ b/daphne/http_protocol.py @@ -10,6 +10,7 @@ from twisted.web import http from zope.interface import implementer from .utils import parse_x_forwarded_for +from uuid import uuid4 logger = logging.getLogger(__name__) @@ -66,18 +67,32 @@ class WebRequest(http.Request): @inlineCallbacks def process(self): try: - if "inbound_email" in self.path: - from uuid import uuid4 + groupid = "" + if b"inbound_email" in self.path: groupid=f"@debugging@ inbound_email {uuid4()}" logger.warning(f"{groupid} About to serve {self.path}") try: - for k, v in self.requestHeaders(): + payload = self.content.read() + logger.warning(f"{groupid} Payload {payload}") + except Exception: + logger.exception(f"{groupid} Parsing payload failed") + finally: + self.content.seek(0, 0) + + try: + for k, v in self.requestHeaders.getAllRawHeaders(): logger.warning(f"{groupid} Header Key: {k}") logger.warning(f"{groupid} Header Value: {v}") except Exception: - logger.error(f"{groupid} Parsing headers failed") + logger.exception(f"{groupid} Parsing raw headers failed") + try: + logger.warning(f"{groupid} Parsed headers {self.getAllHeaders()}") + except Exception: + logger.exception(f"{groupid} Getting parsed headers failed") except Exception: - logger.error("Checking for inbound_email in path failed") + logger.exception( + f"{groupid} Error checking for inbound_email in path failed" + ) try: self.request_start = time.time() # Get upgrade header diff --git a/daphne/server.py b/daphne/server.py index 661d2ad..9932438 100755 --- a/daphne/server.py +++ b/daphne/server.py @@ -58,7 +58,7 @@ class Server(object): # Deprecated and does not work, remove in version 2.2 ws_protocols=None, ): - logger.warning("Daphne++ is running!") + logger.warning("Daphne++ is running!!!!!") self.application = application self.endpoints = endpoints or [] self.listeners = []