mirror of
https://github.com/chatmail/relay.git
synced 2026-05-10 16:04:37 +00:00
Compare commits
4 Commits
link2xt/av
...
hpk/persis
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
bcd9d615d4 | ||
|
|
d820644f66 | ||
|
|
4e97e4dc3d | ||
|
|
92a27983be |
@@ -2,7 +2,7 @@
|
||||
Description=Chatmail dict proxy for IMAP METADATA
|
||||
|
||||
[Service]
|
||||
ExecStart={execpath} /run/dovecot/metadata.socket vmail {config_path}
|
||||
ExecStart={execpath} /run/dovecot/metadata.socket vmail {config_path} /home/vmail/metadata
|
||||
Restart=always
|
||||
RestartSec=30
|
||||
|
||||
|
||||
@@ -1,5 +1,6 @@
|
||||
import pwd
|
||||
|
||||
import pathlib
|
||||
from queue import Queue
|
||||
from threading import Thread
|
||||
from socketserver import (
|
||||
@@ -12,6 +13,7 @@ import sys
|
||||
import logging
|
||||
import os
|
||||
import requests
|
||||
import marshal
|
||||
|
||||
|
||||
DICTPROXY_LOOKUP_CHAR = "L"
|
||||
@@ -23,12 +25,37 @@ DICTPROXY_TRANSACTION_CHARS = "SBC"
|
||||
|
||||
|
||||
class Notifier:
|
||||
def __init__(self):
|
||||
self.guid2token = {}
|
||||
def __init__(self, metadata_dir):
|
||||
self.metadata_dir = metadata_dir
|
||||
self.to_notify_queue = Queue()
|
||||
|
||||
def get_metadata(self, guid):
|
||||
guid_path = self.metadata_dir.joinpath(guid)
|
||||
if guid_path.exists():
|
||||
with guid_path.open("rb") as f:
|
||||
return marshal.load(f)
|
||||
return {}
|
||||
|
||||
def set_metadata(self, guid, guid_data):
|
||||
guid_path = self.metadata_dir.joinpath(guid)
|
||||
write_path = guid_path.with_suffix(".tmp")
|
||||
with write_path.open("wb") as f:
|
||||
marshal.dump(guid_data, f)
|
||||
os.rename(write_path, guid_path)
|
||||
|
||||
def set_token(self, guid, token):
|
||||
self.guid2token[guid] = token
|
||||
guid_data = self.get_metadata(guid)
|
||||
guid_data["token"] = token
|
||||
self.set_metadata(guid, guid_data)
|
||||
|
||||
def del_token(self, guid):
|
||||
guid_data = self.get_metadata(guid)
|
||||
if "token" in guid_data:
|
||||
del guid_data["token"]
|
||||
self.set_metadata(guid, guid_data)
|
||||
|
||||
def get_token(self, guid):
|
||||
return self.get_metadata(guid).get("token")
|
||||
|
||||
def new_message_for_guid(self, guid):
|
||||
self.to_notify_queue.put(guid)
|
||||
@@ -40,7 +67,7 @@ class Notifier:
|
||||
|
||||
def thread_run_one(self, requests_session):
|
||||
guid = self.to_notify_queue.get()
|
||||
token = self.guid2token.get(guid)
|
||||
token = self.get_token(guid)
|
||||
if token:
|
||||
response = requests_session.post(
|
||||
"https://notifications.delta.chat/notify",
|
||||
@@ -50,7 +77,7 @@ class Notifier:
|
||||
if response.status_code == 410:
|
||||
# 410 Gone status code
|
||||
# means the token is no longer valid.
|
||||
del self.guid2token[guid]
|
||||
self.del_token(guid)
|
||||
|
||||
|
||||
def handle_dovecot_protocol(rfile, wfile, notifier):
|
||||
@@ -119,12 +146,15 @@ class ThreadedUnixStreamServer(ThreadingMixIn, UnixStreamServer):
|
||||
|
||||
|
||||
def main():
|
||||
socket, username, config = sys.argv[1:]
|
||||
socket, username, config, metadata_dir = sys.argv[1:]
|
||||
passwd_entry = pwd.getpwnam(username)
|
||||
|
||||
# XXX config is not currently used
|
||||
config = read_config(config)
|
||||
notifier = Notifier()
|
||||
metadata_dir = pathlib.Path(metadata_dir)
|
||||
if not metadata_dir.exists():
|
||||
metadata_dir.mkdir()
|
||||
notifier = Notifier(metadata_dir)
|
||||
|
||||
class Handler(StreamRequestHandler):
|
||||
def handle(self):
|
||||
|
||||
@@ -1,4 +1,5 @@
|
||||
import io
|
||||
import pytest
|
||||
|
||||
from chatmaild.metadata import (
|
||||
handle_dovecot_request,
|
||||
@@ -7,40 +8,60 @@ from chatmaild.metadata import (
|
||||
)
|
||||
|
||||
|
||||
def test_handle_dovecot_request_lookup_fails():
|
||||
notifier = Notifier()
|
||||
@pytest.fixture
|
||||
def notifier(tmp_path):
|
||||
metadata_dir = tmp_path.joinpath("metadata")
|
||||
metadata_dir.mkdir()
|
||||
return Notifier(metadata_dir)
|
||||
|
||||
|
||||
def test_notifier_persistence(tmp_path):
|
||||
metadata_dir = tmp_path.joinpath("metadata")
|
||||
metadata_dir.mkdir()
|
||||
notifier1 = Notifier(metadata_dir)
|
||||
notifier2 = Notifier(metadata_dir)
|
||||
assert notifier1.get_token(guid="guid00") is None
|
||||
assert notifier2.get_token(guid="guid00") is None
|
||||
|
||||
notifier1.set_token("guid00", "01234")
|
||||
notifier1.set_token("guid03", "456")
|
||||
assert notifier2.get_token("guid00") == "01234"
|
||||
assert notifier2.get_token("guid03") == "456"
|
||||
notifier2.del_token("guid00")
|
||||
assert notifier1.get_token("guid00") is None
|
||||
|
||||
|
||||
def test_handle_dovecot_request_lookup_fails(notifier):
|
||||
res = handle_dovecot_request("Lpriv/123/chatmail", {}, notifier)
|
||||
assert res == "N\n"
|
||||
|
||||
|
||||
def test_handle_dovecot_request_happy_path():
|
||||
notifier = Notifier()
|
||||
def test_handle_dovecot_request_happy_path(notifier):
|
||||
transactions = {}
|
||||
|
||||
# lookups return the same NOTFOUND result
|
||||
res = handle_dovecot_request("Lpriv/123/chatmail", transactions, notifier)
|
||||
assert res == "N\n"
|
||||
assert not notifier.guid2token and not transactions
|
||||
assert notifier.get_token("guid00") is None and not transactions
|
||||
|
||||
# set device token in a transaction
|
||||
tx = "1111"
|
||||
msg = f"B{tx}\tuser"
|
||||
res = handle_dovecot_request(msg, transactions, notifier)
|
||||
assert not res and not notifier.guid2token
|
||||
assert not res and notifier.get_token("guid00") is None
|
||||
assert transactions == {tx: "O\n"}
|
||||
|
||||
msg = f"S{tx}\tpriv/guid00/devicetoken\t01234"
|
||||
res = handle_dovecot_request(msg, transactions, notifier)
|
||||
assert not res
|
||||
assert len(transactions) == 1
|
||||
assert len(notifier.guid2token) == 1
|
||||
assert notifier.guid2token["guid00"] == "01234"
|
||||
assert notifier.get_token("guid00") == "01234"
|
||||
|
||||
msg = f"C{tx}"
|
||||
res = handle_dovecot_request(msg, transactions, notifier)
|
||||
assert res == "O\n"
|
||||
assert len(transactions) == 0
|
||||
assert notifier.guid2token["guid00"] == "01234"
|
||||
assert notifier.get_token("guid00") == "01234"
|
||||
|
||||
# trigger notification for incoming message
|
||||
assert handle_dovecot_request(f"B{tx}\tuser", transactions, notifier) is None
|
||||
@@ -52,7 +73,7 @@ def test_handle_dovecot_request_happy_path():
|
||||
assert not transactions
|
||||
|
||||
|
||||
def test_handle_dovecot_protocol_set_devicetoken():
|
||||
def test_handle_dovecot_protocol_set_devicetoken(notifier):
|
||||
rfile = io.BytesIO(
|
||||
b"\n".join(
|
||||
[
|
||||
@@ -64,13 +85,12 @@ def test_handle_dovecot_protocol_set_devicetoken():
|
||||
)
|
||||
)
|
||||
wfile = io.BytesIO()
|
||||
notifier = Notifier()
|
||||
handle_dovecot_protocol(rfile, wfile, notifier)
|
||||
assert notifier.guid2token["guid00"] == "01234"
|
||||
assert notifier.get_token("guid00") == "01234"
|
||||
assert wfile.getvalue() == b"O\n"
|
||||
|
||||
|
||||
def test_handle_dovecot_protocol_iterate():
|
||||
def test_handle_dovecot_protocol_iterate(notifier):
|
||||
rfile = io.BytesIO(
|
||||
b"\n".join(
|
||||
[
|
||||
@@ -80,12 +100,11 @@ def test_handle_dovecot_protocol_iterate():
|
||||
)
|
||||
)
|
||||
wfile = io.BytesIO()
|
||||
notifier = Notifier()
|
||||
handle_dovecot_protocol(rfile, wfile, notifier)
|
||||
assert wfile.getvalue() == b"\n"
|
||||
|
||||
|
||||
def test_handle_dovecot_protocol_messagenew():
|
||||
def test_handle_dovecot_protocol_messagenew(notifier):
|
||||
rfile = io.BytesIO(
|
||||
b"\n".join(
|
||||
[
|
||||
@@ -97,14 +116,13 @@ def test_handle_dovecot_protocol_messagenew():
|
||||
)
|
||||
)
|
||||
wfile = io.BytesIO()
|
||||
notifier = Notifier()
|
||||
handle_dovecot_protocol(rfile, wfile, notifier)
|
||||
assert wfile.getvalue() == b"O\n"
|
||||
assert notifier.to_notify_queue.get() == "guid00"
|
||||
assert notifier.to_notify_queue.qsize() == 0
|
||||
|
||||
|
||||
def test_notifier_thread_run():
|
||||
def test_notifier_thread_run(notifier):
|
||||
requests = []
|
||||
|
||||
class ReqMock:
|
||||
@@ -116,16 +134,15 @@ def test_notifier_thread_run():
|
||||
|
||||
return Result()
|
||||
|
||||
notifier = Notifier()
|
||||
notifier.set_token("guid00", "01234")
|
||||
notifier.new_message_for_guid("guid00")
|
||||
notifier.thread_run_one(ReqMock())
|
||||
url, data, timeout = requests[0]
|
||||
assert data == "01234"
|
||||
assert len(notifier.guid2token) == 1
|
||||
assert notifier.get_token("guid00") == "01234"
|
||||
|
||||
|
||||
def test_notifier_thread_run_gone_removes_token():
|
||||
def test_notifier_thread_run_gone_removes_token(notifier):
|
||||
requests = []
|
||||
|
||||
class ReqMock:
|
||||
@@ -137,11 +154,10 @@ def test_notifier_thread_run_gone_removes_token():
|
||||
|
||||
return Result()
|
||||
|
||||
notifier = Notifier()
|
||||
notifier.set_token("guid00", "01234")
|
||||
notifier.new_message_for_guid("guid00")
|
||||
assert notifier.guid2token["guid00"] == "01234"
|
||||
assert notifier.get_token("guid00") == "01234"
|
||||
notifier.thread_run_one(ReqMock())
|
||||
url, data, timeout = requests[0]
|
||||
assert data == "01234"
|
||||
assert len(notifier.guid2token) == 0
|
||||
assert notifier.get_token("guid00") is None
|
||||
|
||||
Reference in New Issue
Block a user