Source code for fmn.sender.handler

# SPDX-FileCopyrightText: Contributors to the Fedora Project
#
# SPDX-License-Identifier: MIT

import asyncio
from functools import cached_property


class Handler:
    def __init__(self, config):
        self._config = config

    async def setup(self):
        # Here we connect to the destination server if relevant.
        pass

    async def stop(self):
        pass

    @cached_property
    def closed(self):
        """Default `closed` Future, can be overridden in child classes.

        It should be triggered when there is an error and the app should stop.
        """
        return asyncio.get_event_loop().create_future()

    async def handle(self, message):
        raise NotImplementedError


class HandlerError(Exception):
    pass


class PrintHandler(Handler):
    async def handle(self, message):
        print("Received:", message)