debian package 0.1-1

debian/changelog

@@ -0,0 +1,11 @@
+pqm (0.1-1) unstable; urgency=medium
+
+  * Initial release.
+
+ -- Stefan Bühler <stefan.buehler@tik.uni-stuttgart.de>  Thu, 12 Jan 2023 10:14:06 +0100
+
+pqm (0.1-0) unstable; urgency=medium
+
+  * Initial release (fake ITP).
+
+ -- Stefan Bühler <stefan.buehler@tik.uni-stuttgart.de>  Thu, 12 Jan 2023 10:14:05 +0100

debian/control

@@ -0,0 +1,21 @@
+Source: pqm
+Section: mail
+Priority: optional
+Maintainer: Stefan Bühler <stefan.buehler@tik.uni-stuttgart.de>
+Rules-Requires-Root: no
+Build-Depends:
+ debhelper-compat (= 13),
+Standards-Version: 4.6.1
+Homepage: https://git-nks-public.tik.uni-stuttgart.de/mail/pqm
+
+Package: pqm
+Architecture: all
+Depends:
+ python3:any,
+ python3-trio,
+ python3-pyparsing,
+ python3-yaml,
+ ${misc:Depends},
+Description: postfix (cluster) queue manager
+ CLI tool to manage postfix queues (optionally across multiple hosts through
+ ssh).

debian/copyright

@@ -0,0 +1,28 @@
+Format: https://www.debian.org/doc/packaging-manuals/copyright-format/1.0/
+Source: https://git-nks-public.tik.uni-stuttgart.de/mail/pqm
+Upstream-Name: pqm
+
+Files:
+ *
+Copyright:
+ 2023 Universität Stuttgart <no-support-by-mail@uni-stuttgart.de>
+License: MIT
+
+License: MIT
+ Permission is hereby granted, free of charge, to any person obtaining a copy
+ of this software and associated documentation files (the "Software"), to deal
+ in the Software without restriction, including without limitation the rights
+ to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+ copies of the Software, and to permit persons to whom the Software is
+ furnished to do so, subject to the following conditions:
+ .
+ The above copyright notice and this permission notice shall be included in all
+ copies or substantial portions of the Software.
+ .
+ THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+ AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+ OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+ SOFTWARE.

debian/gbp.conf

@@ -0,0 +1,5 @@
+[DEFAULT]
+debian-branch = debian
+upstream-branch = main
+upstream-tag = v%(version)s
+pristine-tar = False

debian/pqm.docs

@@ -0,0 +1,2 @@
+README.md
+pqm.example.yaml

debian/pqm.install

@@ -0,0 +1 @@
+pqm /usr/bin

debian/pqm.lintian-overrides

@@ -0,0 +1 @@
+pqm: no-manual-page [usr/bin/pqm]

debian/rules

@@ -0,0 +1,4 @@
+#!/usr/bin/make -f
+
+%:
+	dh $@

debian/source/format

@@ -0,0 +1 @@
+3.0 (quilt)

debian/source/options

@@ -0,0 +1 @@
+extend-diff-ignore = "(^|/)(venv|.mypy_cache)(/|$)"

pqm

@@ -14,7 +14,6 @@ import datetime
 import enum
 import functools
 import inspect
-import io
 import json
 import os
 import os.path
@@ -29,33 +28,18 @@ import sys
 import traceback
 import trio
 import typing
-import uuid
 import yaml
 
 T = typing.TypeVar('T')
 
 
-@dataclasses.dataclass(slots=True)
+@dataclasses.dataclass
 class Config:
-    DEFAULT_FORWARD_NOTE: str = """\
-The postmaster decided you should know about the following mails in
-the queue, probably because you need to fix something in your setup.
-
-The postmaster will probably delete the queued message afterwards,
-or have them expire (i.e. send a bounce message about failed delivery
-to the sender).
-"""
-
     # if not remote_sources are configured -> use local queue
     remote_sources: dict[str, str] = dataclasses.field(default_factory=dict)
-    forward_note: str = DEFAULT_FORWARD_NOTE
-    forward_sender: str = 'MAILER-DAEMON'
-    forward_sender_name: str = 'Mail Delivery System'
 
     @staticmethod
     def load(filename: str = '') -> Config:
-        config = Config()
-
         if not filename:
             default_paths = [
                 os.path.expanduser('~/.config/pqm.yaml'),
@@ -67,13 +51,13 @@ to the sender).
                     break
             else:
                 # no configfile -> default config
-                return config
+                return Config()
         with open(filename) as file:
             data = yaml.safe_load(file)
         assert isinstance(data, dict), f"Config file (yaml) doesn't contain a dict: {data!r}"
-
-        rs_list = data.pop('remote-sources', [])
+        rs_list = data.get('remote-sources', [])
         assert isinstance(rs_list, list), f"remote-source must be a list of strings: {rs_list!r}"
+        remote_sources: dict[str, str] = {}
         for entry in rs_list:
             assert isinstance(entry, str), f"remote-source entries must be strings: {entry!r}"
             if ':' in entry:
@@ -82,33 +66,16 @@ to the sender).
                 target = entry
                 alias = entry.split('.', maxsplit=1)[0]
             assert not '/' in alias, f"Alias for entry must not contain /: {alias!r}"
-            if alias in config.remote_sources:
-                raise ValueError(
-                    f'Duplicate alias {alias!r} in remote-sources'
-                    f' (have: {config.remote_sources[alias]!r}, new: {target!r}',
-                )
-            config.remote_sources[alias] = target
-
-        config.forward_note = data.pop('forward-note', config.forward_note)
-        config.forward_sender = data.pop('forward-sender', config.forward_sender)
-        config.forward_sender_name = data.pop('forward-sender-name', config.forward_sender_name)
-
-        assert not data, f"Unknown config options: {data}"
-
-        return config
-
-    def forward_build_from(self, *, hostname: str) -> str:
-        if '@' in self.forward_sender:
-            sender = self.forward_sender
-        else:
-            sender = f'{self.forward_sender}@{hostname}'
-        return f'{self.forward_sender_name} <{sender}>'
+            if alias in remote_sources:
+                raise ValueError(f'Duplicate alias {alias!r} in remote-sources (have: {remote_sources[alias]!r}, new: {target!r}')
+            remote_sources[alias] = target
+        return Config(remote_sources=remote_sources)
 
     def source(self) -> Source:
         if self.remote_sources:
-            return RemoteSource(config=self, remotes=self.remote_sources)
+            return RemoteSource(remotes=self.remote_sources)
         else:
-            return LocalSource(config=self)
+            return LocalSource()
 
 
 def input_ack(prompt: str) -> str:
@@ -131,62 +98,6 @@ def parser_action(act: typing.Callable[[pyparsing.ParseResults], T]) -> typing.C
     return wrapped
 
 
-def format_mail_forward(
-    *,
-    config: Config,
-    mails: dict[str, tuple[Mail, bytes | None]],
-    hostname: str,
-    recipients: typing.Iterable[str],
-) -> bytes:
-    bin_buf = io.BytesIO()
-    buf = io.TextIOWrapper(bin_buf, write_through=True)
-    buf.write(f'From: {config.forward_build_from(hostname=hostname)}\n')
-    for recp in recipients:
-        buf.write(f'To: <{recp}>\n')
-    buf.write(f"Subject: Deferred mails on {hostname}\n")
-    buf.write("MIME-Version: 1.0\n")
-    boundary = f"postmaster-forward-{uuid.uuid4().hex}"
-    buf.write(f"Content-Type: multipart/mixed; boundary=\"{boundary}\"\n")
-    buf.write("\n")
-    buf.write("This is a message with multiple parts in MIME format.\n")
-
-    buf.write(f"--{boundary}\n")
-    buf.write("Content-Type: text/plain\n")
-    buf.write("\n")
-    buf.write(config.forward_note)
-    if bytes(bin_buf.getbuffer()[-1:]) != b'\n':
-        buf.write("\n")
-
-    buf.write(f"--{boundary}\n")
-    buf.write("Content-Type: text/plain\n")
-    buf.write("Content-Disposition: inline; filename=\"queue-list.txt\"\n")
-    buf.write("\n")
-    for queue_id, (mail, _) in mails.items():
-        mail.print(verbose=True, out=buf)
-
-    for queue_id, (_, mail_message) in mails.items():
-        basename = queue_id.replace('/', '_')
-        if mail_message is None:
-            # this should be very unlikely unless you try to forward messages from the active queue
-            buf.write(f"--{boundary}\n")
-            buf.write("Content-Type: text/plain\n")
-            buf.write(f"Content-Disposition: inline; filename=\"{basename}.txt\"\n")
-            buf.write("\n")
-            buf.write(f"Message {queue_id} couldn't be found (anymore); may have been sent.")
-            continue
-        buf.write(f"--{boundary}\n")
-        buf.write("Content-Type: message/rfc822\n")
-        buf.write(f"Content-Disposition: inline; filename=\"{basename}.eml\"\n")
-        buf.write("\n")
-        bin_buf.write(mail_message)
-        # ensure parts are terminated by newline
-        if bytes(bin_buf.getbuffer()[-1:]) != b'\n':
-            buf.write("\n")
-
-    buf.write(f"--{boundary}--\n")
-    return bin_buf.getvalue()
-
-
 class TrioParallelOrdered(typing.Generic[T]):
     # used by trio_parallel_ordered below
 
@@ -246,7 +157,7 @@ async def trio_parallel_ordered(
         await tpo.close()
 
 
-@dataclasses.dataclass(slots=True)
+@dataclasses.dataclass
 class Recipient:
     """Recipient in a postfix mail"""
     address: str
@@ -273,22 +184,7 @@ class QueueName(enum.Enum):
 ALL_QUEUE_NAMES: set[QueueName] = set(QueueName)
 
 
-def json_decode_stream(data: str):
-    decoder = json.JSONDecoder()
-    data_len = len(data)
-    data_pos = 0
-    while data_len > data_pos and data[data_len-1].isspace():
-        data_len -= 1
-    while True:
-        while data_pos < data_len and data[data_pos].isspace():
-            data_pos += 1
-        if data_pos >= data_len:
-            return
-        obj, data_pos = decoder.raw_decode(data, data_pos)
-        yield obj
-
-
-@dataclasses.dataclass(slots=True)
+@dataclasses.dataclass
 class Mail:
     """Metadata for mail in postfix queue"""
     queue_name: QueueName
@@ -313,49 +209,19 @@ class Mail:
     @staticmethod
     def read_postqueue_json(data: str, id_prefix: str = '') -> list[Mail]:
         queue = []
-        for obj in json_decode_stream(data):
+        decoder = json.JSONDecoder()
+        data = data.strip()
+        while data:
+            obj, end = decoder.raw_decode(data, 0)
+            data = data[end:].lstrip()
             mail = Mail.from_json(obj)
             mail.queue_id = id_prefix + mail.queue_id
             queue.append(mail)
         return queue
 
-    def print(self, *, verbose: bool, out: typing.TextIO = sys.stdout) -> None:
-        flag = CLI.QUEUE_FLAGS.get(self.queue_name, ' ')
-        if verbose:
-            print(
-                f"{self.queue_id + flag:<17s} {self.message_size:>8d} {self.arrival_time:%a %b %d %H:%M:%S} {self.sender:<60s}",
-                file=out,
-            )
-            if not self.recipients:
-                print(f"{'':21}No recipients listed for this mail?", file=out)
-            for recpt in self.recipients:
-                print(f"{'':21}{recpt.address}", file=out)
-                if recpt.delay_reason:
-                    print(f"{'':29}{recpt.delay_reason}", file=out)
-        else:
-            cnt_recpts = len(self.recipients)
-            if cnt_recpts:
-                last_recpt = self.recipients[-1].address
-                print(
-                    f"{self.queue_id + flag:<17s} {self.message_size:>8d} {self.arrival_time:%a %b %d %H:%M:%S} "
-                    f"{self.sender:<60s} (Targets: {cnt_recpts}, last: {last_recpt})",
-                    file=out,
-                )
-            else:
-                print(
-                    f"{self.queue_id + flag:<17s} {self.message_size:>8d} {self.arrival_time:%a %b %d %H:%M:%S} "
-                    f"{self.sender:<60s} (No recipients listed for this mail?)",
-                    file=out,
-                )
-
 
 # abstract collection/cluster of postfix nodes (or just a single one)
 class Source(abc.ABC):
-    __slots__ = ('config',)
-
-    def __init__(self, *, config: Config) -> None:
-        self.config = config
-
     # list of server names in collection
     @abc.abstractmethod
     def server_list(self) -> list[str]:
@@ -452,17 +318,8 @@ class Source(abc.ABC):
         """
         await self._postsuper('-f', queue_ids=queue_ids, from_queues=from_queues)
 
-    @abc.abstractmethod
-    async def forward_to(self, *, mails: typing.Iterable[Mail], recipients: list[str]) -> None:
-        raise NotImplementedError()
-
 
 class LocalSource(Source):
-    __slots__ = ()
-
-    def __init__(self, *, config: Config) -> None:
-        super().__init__(config=config)
-
     def server_list(self) -> list[str]:
         return [socket.gethostname()]
 
@@ -518,26 +375,10 @@ class LocalSource(Source):
         data = ''.join(f'{msg}\n' for msg in queue_ids)
         await trio.run_process(cmd, stdin=data.encode())
 
-    async def forward_to(self, *, mails: typing.Iterable[Mail], recipients: list[str]) -> None:
-        mail_messages: dict[str, tuple[Mail, bytes | None]] = {}
-        for mail in mails:
-            (mail_message, err) = await self.get_mail(mail.queue_id, flags=['-h', '-b'])
-            if mail_message is None:
-                print(f"Failed to get mail {mail.queue_id}: {err.decode()}")
-            mail_messages[mail.queue_id] = (mail, mail_message)
-        if not mail_messages:
-            print("No mails found to forward.")
-            return
-        message = format_mail_forward(config=self.config, mails=mail_messages, hostname=socket.getfqdn(), recipients=recipients)
-        cmd = ['sendmail', '-t', '-bm', '-f', '']
-        await trio.run_process(cmd, stdin=message)
-
 
 class RemoteSource(Source):
-    __slots__ = ('remotes',)
-
-    def __init__(self, *, config: Config, remotes: dict[str, str]) -> None:
-        super().__init__(config=config)
+    def __init__(self, remotes: dict[str, str]) -> None:
+        super().__init__()
         self.remotes = remotes
 
     def server_list(self) -> list[str]:
@@ -666,41 +507,8 @@ class RemoteSource(Source):
                 data = ''.join(f'{msg}\n' for msg in ids)
                 nursery.start_soon(run_host, remote_host, data)
 
-    async def forward_to(self, *, mails: typing.Iterable[Mail], recipients: list[str]) -> None:
-        mails_by_id = {
-            mail.queue_id: mail
-            for mail in mails
-        }
-
-        if not mails_by_id:
-            print("No mails found to forward.")
-
-        async def run_host(host: str, remote_host: str, queue_ids: list[str]) -> None:
-            mail_messages: dict[str, tuple[Mail, bytes | None]] = {}
-            for queue_id in queue_ids:
-                mail = mails_by_id[f'{host}/{queue_id}']
-                (mail_message, err) = await self.get_mail(mail.queue_id, flags=['-h', '-b'])
-                if mail_message is None:
-                    print(f"Failed to get mail {mail.queue_id}: {err.decode()}")
-                mail_messages[mail.queue_id] = (mail, mail_message)
-            if not mails:
-                return
-            message = format_mail_forward(config=self.config, mails=mail_messages, hostname=remote_host, recipients=recipients)
-            cmd = ['sendmail', '-t', '-bm', '-f', '']
-            cmd = ['/usr/bin/ssh', '-oBatchMode=yes', 'root@' + remote_host, shlex.join(cmd)]
-            await trio.run_process(cmd, stdin=message)
-
-        by_host = self.aggregate_by_host(queue_ids=mails_by_id.keys(), allow_all=True)
-
-        async with trio.open_nursery() as nursery:
-            for host, ids in by_host.items():
-                remote_host = self.remotes[host]
-                nursery.start_soon(run_host, host, remote_host, ids)
-
 
 class UserActivityStats:
-    __slots__ = ('count_mails', 'related_mails', 'cut_off')
-
     # find most active address for `health` command
 
     def __init__(self, cut_off: int = 10) -> None:
@@ -769,8 +577,6 @@ class UserActivityStats:
 class Filter(abc.ABC):
     """abstract base class for filter expressions"""
 
-    __slots__ = ()
-
     def __init__(self) -> None:
         pass
 
@@ -833,14 +639,11 @@ class Filter(abc.ABC):
 
 # abstract base class for filters that don't need (...) around in representations of members in combined filters
 class SingleExprFilter(Filter):
-    __slots__ = ()
+    pass
 
 
 class FalseFilter(SingleExprFilter):
     """constant false - matches no mail"""
-
-    __slots__ = ()
-
     def __repr__(self) -> str:
         return '0'
 
@@ -866,9 +669,6 @@ class FalseFilter(SingleExprFilter):
 
 class TrueFilter(SingleExprFilter):
     """constant true - matches all mail"""
-
-    __slots__ = ()
-
     def __repr__(self) -> str:
         return '1'
 
@@ -897,8 +697,6 @@ TRUE_FILTER = TrueFilter()
 
 
 class AndFilter(Filter):
-    __slots__ = ('expressions',)
-
     def __init__(self, expressions: list[Filter] | tuple[()] = ()) -> None:
         super().__init__()
         self.expressions: list[Filter] = expressions or []
@@ -952,8 +750,6 @@ class AndFilter(Filter):
 
 
 class OrFilter(Filter):
-    __slots__ = ('expressions',)
-
     def __init__(self, expressions: list[Filter] | tuple[()] = ()) -> None:
         super().__init__()
         self.expressions: list[Filter] = expressions or []
@@ -1007,8 +803,6 @@ class OrFilter(Filter):
 
 
 class NotFilter(SingleExprFilter):
-    __slots__ = ('expression',)
-
     def __init__(self, expression: Filter) -> None:
         super().__init__()
         self.expression = expression
@@ -1046,9 +840,6 @@ class NotFilter(SingleExprFilter):
 
 class QueueFilter(SingleExprFilter):
     """match mails based on queue they are in"""
-
-    __slots__ = ('select',)
-
     def __init__(self, select: list[QueueName]) -> None:
         self.select = set(select)
 
@@ -1107,8 +898,6 @@ class AddressSelector(enum.Enum):
 
 
 class BaseAddressPattern(abc.ABC):
-    __slots__ = ()
-
     # abstract base class of patterns to use to match a mail address
     # subclasses match either: full address, domain part, regex
     def __init__(self) -> None:
@@ -1141,8 +930,6 @@ class BaseAddressPattern(abc.ABC):
 
 
 class AddressPattern(BaseAddressPattern):
-    __slots__ = ('address',)
-
     # match full address exactly
     def __init__(self, address: str) -> None:
         super().__init__()
@@ -1165,8 +952,6 @@ class AddressPattern(BaseAddressPattern):
 
 
 class AddressDomainPattern(BaseAddressPattern):
-    __slots__ = ('domain',)
-
     # match address by domain
     def __init__(self, domain: str) -> None:
         super().__init__()
@@ -1184,8 +969,6 @@ class AddressDomainPattern(BaseAddressPattern):
 
 
 class AddressRegexMatch(BaseAddressPattern):
-    __slots__ = ('address',)
-
     # match address by regex
     def __init__(self, address: str | re.Pattern[str]) -> None:
         super().__init__()
@@ -1207,8 +990,6 @@ class AddressRegexMatch(BaseAddressPattern):
 
 
 class AddressFilter(SingleExprFilter):
-    __slots__ = ('selector', 'patterns')
-
     # match mails by address
     def __init__(self, selector: AddressSelector, patterns: list[BaseAddressPattern]) -> None:
         self.selector = selector
@@ -1507,6 +1288,32 @@ class CLI:
         QueueName.DEFERRED: ' ',
     }
 
+    def display_list_item(self, *, item: Mail, verbose: bool) -> None:
+        flag = CLI.QUEUE_FLAGS.get(item.queue_name, ' ')
+        if verbose:
+            print(
+                f"{item.queue_id + flag:<17s} {item.message_size:>8d} {item.arrival_time:%a %b %d %H:%M:%S} {item.sender:<60s}"
+            )
+            if not item.recipients:
+                print(f"{'':21}No recipients listed for this mail?")
+            for recpt in item.recipients:
+                print(f"{'':21}{recpt.address}")
+                if recpt.delay_reason:
+                    print(f"{'':29}{recpt.delay_reason}")
+        else:
+            cnt_recpts = len(item.recipients)
+            if cnt_recpts:
+                last_recpt = item.recipients[-1].address
+                print(
+                    f"{item.queue_id + flag:<17s} {item.message_size:>8d} {item.arrival_time:%a %b %d %H:%M:%S} "
+                    f"{item.sender:<60s} (Targets: {cnt_recpts}, last: {last_recpt})"
+                )
+            else:
+                print(
+                    f"{item.queue_id + flag:<17s} {item.message_size:>8d} {item.arrival_time:%a %b %d %H:%M:%S} "
+                    f"{item.sender:<60s} (No recipients listed for this mail?)"
+                )
+
     async def list_impl(self, *, args: str, verbose: bool, all: bool) -> None:
         flt: AndFilter
         if args:
@@ -1527,7 +1334,7 @@ class CLI:
         else:
             show_filter = flt
         for item in show_filter.filter(await self.source.get_list()):
-            item.print(verbose=verbose)
+            self.display_list_item(item=item, verbose=verbose)
 
     async def _print_mails_with_ids_for_ack(self, given_ids: typing.Iterable[str]) -> list[Mail]:
         mails = {
@@ -1539,7 +1346,7 @@ class CLI:
         for queue_id in given_ids:
             item = mails.get(queue_id, None)
             if item:
-                item.print(verbose=False)
+                self.display_list_item(item=item, verbose=False)
                 verified_list.append(item)
             else:
                 missing.append(queue_id)
@@ -1721,7 +1528,7 @@ class CLI:
     async def delete_impl(self, flt: Filter) -> None:
         mails = list(flt.filter(await self.source.get_list()))
         for item in mails:
-            item.print(verbose=False)
+            self.display_list_item(item=item, verbose=False)
         ack = input_ack("Really delete those mails (y/N)? ")
         if ack.lower()[:1] != "y":
             return
@@ -1828,7 +1635,7 @@ class CLI:
         flt = self.current_filter
         mails = list(flt.filter(await self.source.get_list()))
         for item in mails:
-            item.print(verbose=False)
+            self.display_list_item(item=item, verbose=False)
         ack = input_ack("Really expire and flush (if in deferred queue) those mails (y/N)? ")
         if ack.lower()[:1] != "y":
             return
@@ -1854,7 +1661,7 @@ class CLI:
         flt = self.current_filter
         mails = list(flt.filter(await self.source.get_list()))
         for item in mails:
-            item.print(verbose=False)
+            self.display_list_item(item=item, verbose=False)
         ack = input_ack("Really expire, release and flush (if in deferred/hold queue) those mails (y/N)? ")
         if ack.lower()[:1] != "y":
             return
@@ -1880,7 +1687,7 @@ class CLI:
         flt = self.current_filter
         mails = list(flt.filter(await self.source.get_list()))
         for item in mails:
-            item.print(verbose=False)
+            self.display_list_item(item=item, verbose=False)
         ack = input_ack("Really expire those mails (y/N)? ")
         if ack.lower()[:1] != "y":
             return
@@ -1896,26 +1703,6 @@ class CLI:
             return
         await self.source.expire((mail.queue_id for mail in mails))
 
-    @register_command(name="forward-to")
-    async def forward_to(self, args: str) -> None:
-        """
-        Forward mails to given recipients.
-
-        Specify recipients as simple mail addresses (e.g. `alice@example.com`, not `Alice <alice.example.com>`).
-        """
-        if not args:
-            print("No recipients given")
-            return
-        if not self.prompt_if_empty_filter():
-            return
-        mails = list(self.current_filter.filter(await self.source.get_list()))
-        for item in mails:
-            item.print(verbose=False)
-        ack = input_ack("Really forward those mails (y/N)? ")
-        if ack.lower()[:1] != "y":
-            return
-        await self.source.forward_to(mails=mails, recipients=args.split())
-
     async def prompt(self) -> None:
         # main loop of CLI
         while True:

pqm.example.yaml

@@ -12,14 +12,3 @@ remote-sources:
 # prefix with "alias:" if you don't want the first DNS label to be the alias
 - orgmx1:mx1.example.org
 - orgmx2:mx2.example.org
-
-forward-note: |
-  The postmaster decided you should know about the following mails in
-  the queue, probably because you need to fix something in your setup.
-
-  The postmaster will probably delete the queued message afterwards,
-  or have them expire (i.e. send a bounce message about failed delivery
-  to the sender).
-
-forward-sender: MAILER-DAEMON  # @$mx gets appended if it doesn't contain an '@'
-forward-sender-name: Mail Delivery System