Compare commits
No commits in common. "cb15ec15e4933632e8b3f1450ccdcb6e939d7453" and "2c6d98ce2daadfadfaee176ae283e3d029e1311c" have entirely different histories.
cb15ec15e4
...
2c6d98ce2d
@ -56,14 +56,13 @@ class PopCfg(ServerCfg):
|
|||||||
|
|
||||||
class SmtpStartTLSCfg(ServerCfg):
|
class SmtpStartTLSCfg(ServerCfg):
|
||||||
server_type = "smtp_starttls"
|
server_type = "smtp_starttls"
|
||||||
require_starttls = True
|
smtputf8 = True # Not used yet
|
||||||
smtputf8 = True
|
|
||||||
port = 25
|
port = 25
|
||||||
|
|
||||||
|
|
||||||
class SmtpCfg(ServerCfg):
|
class SmtpCfg(ServerCfg):
|
||||||
server_type = "smtp"
|
server_type = "smtp_starttls"
|
||||||
smtputf8 = True
|
smtputf8 = True # Not used yet
|
||||||
port = 465
|
port = 465
|
||||||
|
|
||||||
|
|
||||||
|
@ -84,8 +84,6 @@ async def a_main(cfg: config.Config) -> None:
|
|||||||
mails_path=Path(cfg.mails_path),
|
mails_path=Path(cfg.mails_path),
|
||||||
mbox_finder=mbox_finder,
|
mbox_finder=mbox_finder,
|
||||||
ssl_context=stls_context,
|
ssl_context=stls_context,
|
||||||
require_starttls=stls.require_starttls,
|
|
||||||
smtputf8=stls.smtputf8,
|
|
||||||
)
|
)
|
||||||
servers.append(smtp_server_starttls)
|
servers.append(smtp_server_starttls)
|
||||||
elif scfg.server_type == "smtp":
|
elif scfg.server_type == "smtp":
|
||||||
@ -96,7 +94,6 @@ async def a_main(cfg: config.Config) -> None:
|
|||||||
mails_path=Path(cfg.mails_path),
|
mails_path=Path(cfg.mails_path),
|
||||||
mbox_finder=mbox_finder,
|
mbox_finder=mbox_finder,
|
||||||
ssl_context=get_tls_context(smtp.tls),
|
ssl_context=get_tls_context(smtp.tls),
|
||||||
smtputf8=smtp.smtputf8,
|
|
||||||
)
|
)
|
||||||
servers.append(smtp_server)
|
servers.append(smtp_server)
|
||||||
else:
|
else:
|
||||||
|
@ -59,20 +59,16 @@ class MyHandler(AsyncMessage):
|
|||||||
|
|
||||||
|
|
||||||
def protocol_factory_starttls(
|
def protocol_factory_starttls(
|
||||||
mails_path: Path,
|
mails_path: Path, mbox_finder: Callable[[str], list[str]], context: ssl.SSLContext
|
||||||
mbox_finder: Callable[[str], list[str]],
|
|
||||||
context: ssl.SSLContext,
|
|
||||||
require_starttls: bool,
|
|
||||||
smtputf8: bool,
|
|
||||||
):
|
):
|
||||||
logger.info("Got smtp client cb starttls")
|
logger.info("Got smtp client cb starttls")
|
||||||
try:
|
try:
|
||||||
handler = MyHandler(mails_path, mbox_finder)
|
handler = MyHandler(mails_path, mbox_finder)
|
||||||
smtp = SMTP(
|
smtp = SMTP(
|
||||||
handler=handler,
|
handler=handler,
|
||||||
require_starttls=require_starttls,
|
require_starttls=True,
|
||||||
tls_context=context,
|
tls_context=context,
|
||||||
enable_SMTPUTF8=smtputf8,
|
enable_SMTPUTF8=True,
|
||||||
)
|
)
|
||||||
except:
|
except:
|
||||||
logger.exception("Something went wrong")
|
logger.exception("Something went wrong")
|
||||||
@ -80,13 +76,11 @@ def protocol_factory_starttls(
|
|||||||
return smtp
|
return smtp
|
||||||
|
|
||||||
|
|
||||||
def protocol_factory(
|
def protocol_factory(mails_path: Path, mbox_finder: Callable[[str], list[str]]):
|
||||||
mails_path: Path, mbox_finder: Callable[[str], list[str]], smtputf8: bool
|
|
||||||
):
|
|
||||||
logger.info("Got smtp client cb")
|
logger.info("Got smtp client cb")
|
||||||
try:
|
try:
|
||||||
handler = MyHandler(mails_path, mbox_finder)
|
handler = MyHandler(mails_path, mbox_finder)
|
||||||
smtp = SMTP(handler=handler, enable_SMTPUTF8=smtputf8)
|
smtp = SMTP(handler=handler, enable_SMTPUTF8=True)
|
||||||
except:
|
except:
|
||||||
logger.exception("Something went wrong")
|
logger.exception("Something went wrong")
|
||||||
raise
|
raise
|
||||||
@ -99,22 +93,13 @@ async def create_smtp_server_starttls(
|
|||||||
mails_path: Path,
|
mails_path: Path,
|
||||||
mbox_finder: Callable[[str], list[str]],
|
mbox_finder: Callable[[str], list[str]],
|
||||||
ssl_context: ssl.SSLContext,
|
ssl_context: ssl.SSLContext,
|
||||||
require_starttls: bool,
|
|
||||||
smtputf8: bool,
|
|
||||||
) -> asyncio.Server:
|
) -> asyncio.Server:
|
||||||
logging.info(
|
logging.info(
|
||||||
f"Starting SMTP STARTTLS server {host=}, {port=}, {mails_path=!s}, {ssl_context != None=}"
|
f"Starting SMTP STARTTLS server {host=}, {port=}, {mails_path=!s}, {ssl_context != None=}"
|
||||||
)
|
)
|
||||||
loop = asyncio.get_event_loop()
|
loop = asyncio.get_event_loop()
|
||||||
return await loop.create_server(
|
return await loop.create_server(
|
||||||
partial(
|
partial(protocol_factory_starttls, mails_path, mbox_finder, ssl_context),
|
||||||
protocol_factory_starttls,
|
|
||||||
mails_path,
|
|
||||||
mbox_finder,
|
|
||||||
ssl_context,
|
|
||||||
require_starttls,
|
|
||||||
smtputf8,
|
|
||||||
),
|
|
||||||
host=host,
|
host=host,
|
||||||
port=port,
|
port=port,
|
||||||
start_serving=False,
|
start_serving=False,
|
||||||
@ -126,15 +111,14 @@ async def create_smtp_server(
|
|||||||
port: int,
|
port: int,
|
||||||
mails_path: Path,
|
mails_path: Path,
|
||||||
mbox_finder: Callable[[str], list[str]],
|
mbox_finder: Callable[[str], list[str]],
|
||||||
ssl_context: Optional[ssl.SSLContext],
|
ssl_context: Optional[ssl.SSLContext] = None,
|
||||||
smtputf8: bool,
|
|
||||||
) -> asyncio.Server:
|
) -> asyncio.Server:
|
||||||
logging.info(
|
logging.info(
|
||||||
f"Starting SMTP server {host=}, {port=}, {mails_path=!s}, {ssl_context != None=}"
|
f"Starting SMTP server {host=}, {port=}, {mails_path=!s}, {ssl_context != None=}"
|
||||||
)
|
)
|
||||||
loop = asyncio.get_event_loop()
|
loop = asyncio.get_event_loop()
|
||||||
return await loop.create_server(
|
return await loop.create_server(
|
||||||
partial(protocol_factory, mails_path, mbox_finder, smtputf8),
|
partial(protocol_factory, mails_path, mbox_finder),
|
||||||
host=host,
|
host=host,
|
||||||
port=port,
|
port=port,
|
||||||
ssl=ssl_context,
|
ssl=ssl_context,
|
||||||
|
@ -33,8 +33,6 @@ class TestSMTP(unittest.IsolatedAsyncioTestCase):
|
|||||||
port=7996,
|
port=7996,
|
||||||
mails_path=MAILS_PATH,
|
mails_path=MAILS_PATH,
|
||||||
mbox_finder=lambda addr: [TEST_MBOX],
|
mbox_finder=lambda addr: [TEST_MBOX],
|
||||||
ssl_context=None,
|
|
||||||
smtputf8=True,
|
|
||||||
)
|
)
|
||||||
self.task = asyncio.create_task(smtp_server.serve_forever())
|
self.task = asyncio.create_task(smtp_server.serve_forever())
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user