mirror of
https://github.com/chatmail/relay.git
synced 2026-05-15 02:14:36 +00:00
Compare commits
6 Commits
betterbenc
...
forged_fro
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
801b035f18 | ||
|
|
6f8823cbeb | ||
|
|
c0673cc43f | ||
|
|
6dcd686701 | ||
|
|
087ae78edc | ||
|
|
7e93299bce |
@@ -173,33 +173,6 @@ def _configure_dovecot(mail_server: str, debug: bool = False) -> bool:
|
|||||||
return need_restart
|
return need_restart
|
||||||
|
|
||||||
|
|
||||||
def _configure_nginx(domain: str, debug: bool = False) -> bool:
|
|
||||||
"""Configures nginx HTTP server."""
|
|
||||||
need_restart = False
|
|
||||||
|
|
||||||
main_config = files.template(
|
|
||||||
src=importlib.resources.files(__package__).joinpath("nginx.conf.j2"),
|
|
||||||
dest="/etc/nginx/nginx.conf",
|
|
||||||
user="root",
|
|
||||||
group="root",
|
|
||||||
mode="644",
|
|
||||||
config={"domain_name": domain},
|
|
||||||
)
|
|
||||||
need_restart |= main_config.changed
|
|
||||||
|
|
||||||
autoconfig = files.template(
|
|
||||||
src=importlib.resources.files(__package__).joinpath("autoconfig.xml.j2"),
|
|
||||||
dest="/var/www/html/.well-known/autoconfig/mail/config-v1.1.xml",
|
|
||||||
user="root",
|
|
||||||
group="root",
|
|
||||||
mode="644",
|
|
||||||
config={"domain_name": domain},
|
|
||||||
)
|
|
||||||
need_restart |= autoconfig.changed
|
|
||||||
|
|
||||||
return need_restart
|
|
||||||
|
|
||||||
|
|
||||||
def deploy_chatmail(mail_domain: str, mail_server: str, dkim_selector: str) -> None:
|
def deploy_chatmail(mail_domain: str, mail_server: str, dkim_selector: str) -> None:
|
||||||
"""Deploy a chat-mail instance.
|
"""Deploy a chat-mail instance.
|
||||||
|
|
||||||
@@ -221,7 +194,7 @@ def deploy_chatmail(mail_domain: str, mail_server: str, dkim_selector: str) -> N
|
|||||||
)
|
)
|
||||||
|
|
||||||
# Deploy acmetool to have TLS certificates.
|
# Deploy acmetool to have TLS certificates.
|
||||||
deploy_acmetool(nginx_hook=True, domains=[mail_server])
|
deploy_acmetool(domains=[mail_server])
|
||||||
|
|
||||||
apt.packages(
|
apt.packages(
|
||||||
name="Install Postfix",
|
name="Install Postfix",
|
||||||
@@ -241,17 +214,11 @@ def deploy_chatmail(mail_domain: str, mail_server: str, dkim_selector: str) -> N
|
|||||||
],
|
],
|
||||||
)
|
)
|
||||||
|
|
||||||
apt.packages(
|
|
||||||
name="Install nginx",
|
|
||||||
packages=["nginx"],
|
|
||||||
)
|
|
||||||
|
|
||||||
_install_chatmaild()
|
_install_chatmaild()
|
||||||
debug = False
|
debug = False
|
||||||
dovecot_need_restart = _configure_dovecot(mail_server, debug=debug)
|
dovecot_need_restart = _configure_dovecot(mail_server, debug=debug)
|
||||||
postfix_need_restart = _configure_postfix(mail_domain, debug=debug)
|
postfix_need_restart = _configure_postfix(mail_domain, debug=debug)
|
||||||
opendkim_need_restart = _configure_opendkim(mail_domain, dkim_selector)
|
opendkim_need_restart = _configure_opendkim(mail_domain, dkim_selector)
|
||||||
nginx_need_restart = _configure_nginx(mail_domain)
|
|
||||||
|
|
||||||
systemd.service(
|
systemd.service(
|
||||||
name="Start and enable OpenDKIM",
|
name="Start and enable OpenDKIM",
|
||||||
@@ -277,14 +244,6 @@ def deploy_chatmail(mail_domain: str, mail_server: str, dkim_selector: str) -> N
|
|||||||
restarted=dovecot_need_restart,
|
restarted=dovecot_need_restart,
|
||||||
)
|
)
|
||||||
|
|
||||||
systemd.service(
|
|
||||||
name="Start and enable nginx",
|
|
||||||
service="nginx.service",
|
|
||||||
running=True,
|
|
||||||
enabled=True,
|
|
||||||
restarted=nginx_need_restart,
|
|
||||||
)
|
|
||||||
|
|
||||||
# This file is used by auth proxy.
|
# This file is used by auth proxy.
|
||||||
# https://wiki.debian.org/EtcMailName
|
# https://wiki.debian.org/EtcMailName
|
||||||
server.shell(
|
server.shell(
|
||||||
|
|||||||
@@ -38,13 +38,22 @@ def deploy_acmetool(nginx_hook=False, email="", domains=[]):
|
|||||||
email=email,
|
email=email,
|
||||||
)
|
)
|
||||||
|
|
||||||
files.template(
|
service_file = files.put(
|
||||||
src=importlib.resources.files(__package__).joinpath("target.yaml.j2"),
|
src=importlib.resources.files(__package__)
|
||||||
dest="/var/lib/acme/conf/target",
|
.joinpath("acmetool-redirector.service")
|
||||||
|
.open("rb"),
|
||||||
|
dest="/etc/systemd/system/acmetool-redirector.service",
|
||||||
user="root",
|
user="root",
|
||||||
group="root",
|
group="root",
|
||||||
mode="644",
|
mode="644",
|
||||||
)
|
)
|
||||||
|
systemd.service(
|
||||||
|
name="Setup acmetool-redirector service",
|
||||||
|
service="acmetool-redirector.service",
|
||||||
|
running=False,
|
||||||
|
enabled=False,
|
||||||
|
restarted=service_file.changed,
|
||||||
|
)
|
||||||
|
|
||||||
for domain in domains:
|
for domain in domains:
|
||||||
server.shell(
|
server.shell(
|
||||||
|
|||||||
@@ -0,0 +1,11 @@
|
|||||||
|
[Unit]
|
||||||
|
Description=acmetool HTTP redirector
|
||||||
|
|
||||||
|
[Service]
|
||||||
|
Type=notify
|
||||||
|
ExecStart=/usr/bin/acmetool redirector --service.uid=daemon
|
||||||
|
Restart=always
|
||||||
|
RestartSec=30
|
||||||
|
|
||||||
|
[Install]
|
||||||
|
WantedBy=multi-user.target
|
||||||
@@ -1,7 +0,0 @@
|
|||||||
request:
|
|
||||||
provider: https://acme-v02.api.letsencrypt.org/directory
|
|
||||||
key:
|
|
||||||
type: rsa
|
|
||||||
challenge:
|
|
||||||
webroot-paths:
|
|
||||||
- /var/www/html/.well-known/acme-challenge
|
|
||||||
@@ -1,37 +0,0 @@
|
|||||||
<?xml version="1.0" encoding="UTF-8"?>
|
|
||||||
|
|
||||||
<clientConfig version="1.1">
|
|
||||||
<emailProvider id="{{ config.domain_name }}">
|
|
||||||
<domain>{{ config.domain_name }}</domain>
|
|
||||||
<displayName>{{ config.domain_name }} chatmail</displayName>
|
|
||||||
<displayShortName>{{ config.domain_name }}</displayShortName>
|
|
||||||
<incomingServer type="imap">
|
|
||||||
<hostname>{{ config.domain_name }}</hostname>
|
|
||||||
<port>993</port>
|
|
||||||
<socketType>SSL</socketType>
|
|
||||||
<authentication>password-cleartext</authentication>
|
|
||||||
<username>%EMAILADDRESS%</username>
|
|
||||||
</incomingServer>
|
|
||||||
<incomingServer type="imap">
|
|
||||||
<hostname>{{ config.domain_name }}</hostname>
|
|
||||||
<port>143</port>
|
|
||||||
<socketType>STARTTLS</socketType>
|
|
||||||
<authentication>password-cleartext</authentication>
|
|
||||||
<username>%EMAILADDRESS%</username>
|
|
||||||
</incomingServer>
|
|
||||||
<outgoingServer type="smtp">
|
|
||||||
<hostname>{{ config.domain_name }}</hostname>
|
|
||||||
<port>465</port>
|
|
||||||
<socketType>SSL</socketType>
|
|
||||||
<authentication>password-cleartext</authentication>
|
|
||||||
<username>%EMAILADDRESS%</username>
|
|
||||||
</outgoingServer>
|
|
||||||
<outgoingServer type="smtp">
|
|
||||||
<hostname>{{ config.domain_name }}</hostname>
|
|
||||||
<port>587</port>
|
|
||||||
<socketType>STARTTLS</socketType>
|
|
||||||
<authentication>password-cleartext</authentication>
|
|
||||||
<username>%EMAILADDRESS%</username>
|
|
||||||
</outgoingServer>
|
|
||||||
</emailProvider>
|
|
||||||
</clientConfig>
|
|
||||||
@@ -1,47 +0,0 @@
|
|||||||
user www-data;
|
|
||||||
worker_processes auto;
|
|
||||||
pid /run/nginx.pid;
|
|
||||||
error_log /var/log/nginx/error.log;
|
|
||||||
|
|
||||||
events {
|
|
||||||
worker_connections 768;
|
|
||||||
# multi_accept on;
|
|
||||||
}
|
|
||||||
|
|
||||||
http {
|
|
||||||
sendfile on;
|
|
||||||
tcp_nopush on;
|
|
||||||
|
|
||||||
# Do not emit nginx version on error pages.
|
|
||||||
server_tokens off;
|
|
||||||
|
|
||||||
include /etc/nginx/mime.types;
|
|
||||||
default_type application/octet-stream;
|
|
||||||
|
|
||||||
ssl_protocols TLSv1 TLSv1.1 TLSv1.2 TLSv1.3;
|
|
||||||
ssl_prefer_server_ciphers on;
|
|
||||||
ssl_certificate /var/lib/acme/live/{{ config.domain_name }}/fullchain;
|
|
||||||
ssl_certificate_key /var/lib/acme/live/{{ config.domain_name }}/privkey;
|
|
||||||
|
|
||||||
gzip on;
|
|
||||||
|
|
||||||
server {
|
|
||||||
listen 80 default_server;
|
|
||||||
listen [::]:80 default_server;
|
|
||||||
listen 443 ssl default_server;
|
|
||||||
listen [::]:443 ssl default_server;
|
|
||||||
|
|
||||||
root /var/www/html;
|
|
||||||
|
|
||||||
index index.html index.htm;
|
|
||||||
|
|
||||||
server_name _;
|
|
||||||
|
|
||||||
location / {
|
|
||||||
# First attempt to serve request as file, then
|
|
||||||
# as directory, then fall back to displaying a 404.
|
|
||||||
try_files $uri $uri/ =404;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@@ -1,60 +1,34 @@
|
|||||||
def test_tls_imap(benchmark, imap):
|
def test_tls_serialized_connect(benchmark, imap_or_smtp):
|
||||||
def imap_connect():
|
def connect():
|
||||||
imap.connect()
|
imap_or_smtp.connect()
|
||||||
|
|
||||||
benchmark(imap_connect, 10)
|
benchmark(connect)
|
||||||
|
|
||||||
|
|
||||||
def test_login_imap(benchmark, imap, gencreds):
|
def test_login(benchmark, imap_or_smtp, gencreds):
|
||||||
def imap_connect_and_login():
|
cls = imap_or_smtp.__class__
|
||||||
imap.connect()
|
conns = []
|
||||||
imap.login(*gencreds())
|
for i in range(20):
|
||||||
|
conn = cls(imap_or_smtp.host)
|
||||||
|
conn.connect()
|
||||||
|
conns.append(conn)
|
||||||
|
|
||||||
benchmark(imap_connect_and_login, 10)
|
def login():
|
||||||
|
conn = conns.pop()
|
||||||
|
conn.login(*gencreds())
|
||||||
|
|
||||||
|
benchmark(login)
|
||||||
|
|
||||||
|
|
||||||
def test_tls_smtp(benchmark, smtp):
|
def test_send_and_receive_10(benchmark, cmfactory, lp):
|
||||||
def smtp_connect():
|
"""send many messages between two accounts"""
|
||||||
smtp.connect()
|
ac1, ac2 = cmfactory.get_online_accounts(2)
|
||||||
|
chat = cmfactory.get_accepted_chat(ac1, ac2)
|
||||||
|
|
||||||
benchmark(smtp_connect, 10)
|
def send_10_receive_all():
|
||||||
|
for i in range(10):
|
||||||
|
chat.send_text(f"hello {i}")
|
||||||
|
for i in range(10):
|
||||||
|
ac2.wait_next_incoming_message()
|
||||||
|
|
||||||
|
benchmark(send_10_receive_all)
|
||||||
def test_login_smtp(benchmark, smtp, gencreds):
|
|
||||||
def smtp_connect_and_login():
|
|
||||||
smtp.connect()
|
|
||||||
smtp.login(*gencreds())
|
|
||||||
|
|
||||||
benchmark(smtp_connect_and_login, 10)
|
|
||||||
|
|
||||||
|
|
||||||
class TestDC:
|
|
||||||
def test_autoconfigure(self, benchmark, cmfactory):
|
|
||||||
def autoconfig_and_idle_ready():
|
|
||||||
cmfactory.get_online_accounts(1)
|
|
||||||
|
|
||||||
benchmark(autoconfig_and_idle_ready, 5)
|
|
||||||
|
|
||||||
def test_ping_pong(self, benchmark, cmfactory):
|
|
||||||
ac1, ac2 = cmfactory.get_online_accounts(2)
|
|
||||||
chat = cmfactory.get_accepted_chat(ac1, ac2)
|
|
||||||
|
|
||||||
def ping_pong():
|
|
||||||
chat.send_text("ping")
|
|
||||||
msg = ac2.wait_next_incoming_message()
|
|
||||||
msg.chat.send_text("pong")
|
|
||||||
ac1.wait_next_incoming_message()
|
|
||||||
|
|
||||||
benchmark(ping_pong, 3)
|
|
||||||
|
|
||||||
def test_send_10_receive_10(self, benchmark, cmfactory, lp):
|
|
||||||
ac1, ac2 = cmfactory.get_online_accounts(2)
|
|
||||||
chat = cmfactory.get_accepted_chat(ac1, ac2)
|
|
||||||
|
|
||||||
def send_10_receive_10():
|
|
||||||
for i in range(10):
|
|
||||||
chat.send_text(f"hello {i}")
|
|
||||||
for i in range(10):
|
|
||||||
ac2.wait_next_incoming_message()
|
|
||||||
|
|
||||||
benchmark(send_10_receive_10, 1)
|
|
||||||
|
|||||||
@@ -1,6 +1,5 @@
|
|||||||
import os
|
import os
|
||||||
import io
|
import io
|
||||||
import time
|
|
||||||
import random
|
import random
|
||||||
import subprocess
|
import subprocess
|
||||||
import imaplib
|
import imaplib
|
||||||
@@ -15,10 +14,6 @@ def pytest_addoption(parser):
|
|||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
def pytest_configure(config):
|
|
||||||
config._benchresults = {}
|
|
||||||
|
|
||||||
|
|
||||||
def pytest_runtest_setup(item):
|
def pytest_runtest_setup(item):
|
||||||
markers = list(item.iter_markers(name="slow"))
|
markers = list(item.iter_markers(name="slow"))
|
||||||
if markers:
|
if markers:
|
||||||
@@ -59,35 +54,6 @@ def pytest_report_header():
|
|||||||
return ["-" * len(text), text, "-" * len(text)]
|
return ["-" * len(text), text, "-" * len(text)]
|
||||||
|
|
||||||
|
|
||||||
@pytest.fixture
|
|
||||||
def benchmark(request):
|
|
||||||
def bench(func, num, name=None):
|
|
||||||
if name is None:
|
|
||||||
name = func.__name__
|
|
||||||
durations = []
|
|
||||||
for i in range(num):
|
|
||||||
now = time.time()
|
|
||||||
func()
|
|
||||||
durations.append(time.time() - now)
|
|
||||||
durations.sort()
|
|
||||||
request.config._benchresults[name] = durations
|
|
||||||
|
|
||||||
return bench
|
|
||||||
|
|
||||||
|
|
||||||
def pytest_terminal_summary(terminalreporter):
|
|
||||||
tr = terminalreporter
|
|
||||||
results = tr.config._benchresults
|
|
||||||
tr.section("benchmark results")
|
|
||||||
headers = f"{'benchmark name': <30} {'median': >6}"
|
|
||||||
tr.write_line(headers)
|
|
||||||
tr.write_line("-" * len(headers))
|
|
||||||
for name, durations in results.items():
|
|
||||||
median = sorted(durations)[len(durations) // 2]
|
|
||||||
median = f"{median:2.4f}"
|
|
||||||
tr.write_line(f"{name: <30} {median: >6}")
|
|
||||||
|
|
||||||
|
|
||||||
@pytest.fixture
|
@pytest.fixture
|
||||||
def imap(maildomain):
|
def imap(maildomain):
|
||||||
return ImapConn(maildomain)
|
return ImapConn(maildomain)
|
||||||
|
|||||||
@@ -11,4 +11,4 @@ chatmaild/venv/bin/pip install --upgrade pytest build 'setuptools>=68'
|
|||||||
chatmaild/venv/bin/pip install -e chatmaild
|
chatmaild/venv/bin/pip install -e chatmaild
|
||||||
|
|
||||||
python3 -m venv online-tests/venv
|
python3 -m venv online-tests/venv
|
||||||
online-tests/venv/bin/pip install pytest pytest-timeout pdbpp deltachat
|
online-tests/venv/bin/pip install pytest pytest-timeout pdbpp deltachat pytest-benchmark
|
||||||
|
|||||||
Reference in New Issue
Block a user