harmacist/healthchecks
1
0
Fork 0
forked from GithubBackups/healthchecks
Code Issues Pull Requests Projects Releases Wiki Activity

smtpd: get a new db connection for every incoming email. cc: #213

Browse Source
This commit is contained in:
Pēteris Caune 2019-02-27 16:44:03 +02:00
parent 100bc3c5e7
commit cb1b792d6c
No known key found for this signature in database
GPG Key ID: E28D7679E9A9EDE2
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hc/api/management/commands/smtpd.py
View File

@ -4,6 +4,7 @@ import re
from smtpd import SMTPServer from smtpd import SMTPServer
from django.core.management.base import BaseCommand from django.core.management.base import BaseCommand
from django.db import connections
from hc.api.models import Check from hc.api.models import Check
RE_UUID = re.compile("^[a-fA-F0-9]{8}-[a-fA-F0-9]{4}-4[a-fA-F0-9]{3}-[8|9|aA|bB][a-fA-F0-9]{3}-[a-fA-F0-9]{12}$") RE_UUID = re.compile("^[a-fA-F0-9]{8}-[a-fA-F0-9]{4}-4[a-fA-F0-9]{3}-[8|9|aA|bB][a-fA-F0-9]{3}-[a-fA-F0-9]{12}$")
@ -15,6 +16,9 @@ class Listener(SMTPServer):
super(Listener, self).__init__(localaddr, None) super(Listener, self).__init__(localaddr, None)
def process_message(self, peer, mailfrom, rcpttos, data, mail_options=None, rcpt_options=None): def process_message(self, peer, mailfrom, rcpttos, data, mail_options=None, rcpt_options=None):
# get a new db connection in case the old one has timed out:
connections.close_all()
to_parts = rcpttos[0].split("@") to_parts = rcpttos[0].split("@")
code = to_parts[0] code = to_parts[0]