mirror of
https://github.com/chatmail/relay.git
synced 2026-05-16 03:24:48 +00:00
Compare commits
1 Commits
shiftrenam
...
link2xt/no
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
15a9b4a2ef |
18
.github/workflows/ci.yaml
vendored
18
.github/workflows/ci.yaml
vendored
@@ -1,18 +0,0 @@
|
|||||||
name: CI
|
|
||||||
|
|
||||||
on:
|
|
||||||
pull_request:
|
|
||||||
push:
|
|
||||||
|
|
||||||
jobs:
|
|
||||||
lint:
|
|
||||||
name: Lint
|
|
||||||
runs-on: ubuntu-latest
|
|
||||||
steps:
|
|
||||||
- uses: actions/checkout@v3
|
|
||||||
- name: Lint chatmaild
|
|
||||||
working-directory: chatmaild
|
|
||||||
run: pipx run tox
|
|
||||||
- name: Lint deploy-chatmail
|
|
||||||
working-directory: deploy-chatmail
|
|
||||||
run: pipx run tox
|
|
||||||
@@ -1,6 +1,6 @@
|
|||||||
import importlib.resources
|
import importlib.resources
|
||||||
|
|
||||||
from pyinfra.operations import apt, files, server
|
from pyinfra.operations import apt, files, systemd, server
|
||||||
|
|
||||||
|
|
||||||
def deploy_acmetool(nginx_hook=False, email="", domains=[]):
|
def deploy_acmetool(nginx_hook=False, email="", domains=[]):
|
||||||
|
|||||||
@@ -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, 5)
|
|
||||||
|
|
||||||
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, 5)
|
|
||||||
|
|||||||
@@ -1,12 +1,10 @@
|
|||||||
import os
|
import os
|
||||||
import io
|
import io
|
||||||
import time
|
|
||||||
import random
|
import random
|
||||||
import subprocess
|
import subprocess
|
||||||
import imaplib
|
import imaplib
|
||||||
import smtplib
|
import smtplib
|
||||||
import itertools
|
import itertools
|
||||||
from math import ceil
|
|
||||||
import pytest
|
import pytest
|
||||||
|
|
||||||
|
|
||||||
@@ -16,13 +14,6 @@ def pytest_addoption(parser):
|
|||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
def pytest_configure(config):
|
|
||||||
config._benchresults = {}
|
|
||||||
config.addinivalue_line(
|
|
||||||
"markers", "slow: mark test to require --slow option to run"
|
|
||||||
)
|
|
||||||
|
|
||||||
|
|
||||||
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:
|
||||||
@@ -63,49 +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
|
|
||||||
if not results:
|
|
||||||
return
|
|
||||||
|
|
||||||
tr.section("benchmark results")
|
|
||||||
float_names = 'median min max'.split()
|
|
||||||
width = max(map(len, float_names))
|
|
||||||
|
|
||||||
def fcol(parts):
|
|
||||||
return " ".join(part.rjust(width) for part in parts)
|
|
||||||
|
|
||||||
headers = f"{'benchmark name': <30} " + fcol(float_names)
|
|
||||||
tr.write_line(headers)
|
|
||||||
tr.write_line("-" * len(headers))
|
|
||||||
for name, durations in results.items():
|
|
||||||
measures = [
|
|
||||||
sorted(durations)[len(durations) // 2],
|
|
||||||
min(durations),
|
|
||||||
max(durations),
|
|
||||||
]
|
|
||||||
line = f"{name: <30} "
|
|
||||||
line += fcol(f"{float: 2.2f}" for float in measures)
|
|
||||||
tr.write_line(line)
|
|
||||||
|
|
||||||
|
|
||||||
@pytest.fixture
|
@pytest.fixture
|
||||||
def imap(maildomain):
|
def imap(maildomain):
|
||||||
return ImapConn(maildomain)
|
return ImapConn(maildomain)
|
||||||
|
|||||||
@@ -1,2 +1,3 @@
|
|||||||
[pytest]
|
[pytest]
|
||||||
addopts = -vrsx --strict-markers
|
addopts = -vrsx --strict-markers
|
||||||
|
markers = slow: mark test as slow (requires --slow option to run)
|
||||||
|
|||||||
@@ -10,4 +10,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