django/daphne
1
1
Fork 0
mirror of https://github.com/django/daphne.git synced 2025-04-20 00:32:09 +03:00
Code Issues Packages Projects Releases Wiki Activity

Fixed debugging

Browse Source
This commit is contained in:
mehernosh 2020-07-07 11:17:30 +05:30
parent 34491bc474
commit 2b67d09f05
2 changed files with 21 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
daphne/http_protocol.py
View File

@ -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

2
daphne/server.py
View File

@ -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 = []