You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
40 lines
695 B
Python
40 lines
695 B
Python
from __future__ import annotations
|
|
|
|
from abc import (
|
|
ABC,
|
|
abstractmethod,
|
|
)
|
|
from enum import (
|
|
Enum,
|
|
auto,
|
|
)
|
|
from typing import (
|
|
Awaitable,
|
|
Callable,
|
|
TypeAlias,
|
|
)
|
|
|
|
from ...our_types import (
|
|
JSON,
|
|
)
|
|
|
|
|
|
class TransmissionSuccess(Enum):
|
|
UNKNOWN_ERROR = auto()
|
|
EXCHANGE_UNAVAILABLE = auto()
|
|
SUBMITTED_SUCCESSFULLY = auto()
|
|
|
|
|
|
MessageHandler: TypeAlias = Callable[[JSON], Awaitable[None]]
|
|
|
|
|
|
class TransportMethod(ABC):
|
|
|
|
@abstractmethod
|
|
async def send(self, data: JSON) -> TransmissionSuccess: ...
|
|
|
|
@abstractmethod
|
|
def on_receive(self, handler: MessageHandler) -> None:
|
|
"""sets the handler, there can only be one set"""
|
|
...
|