"""Transaction Job to send handler."""
from .....messaging.base_handler import (
BaseHandler,
BaseResponder,
RequestContext,
)
from ..manager import TransactionManager, TransactionManagerError
from ..messages.transaction_job_to_send import TransactionJobToSend
[docs]class TransactionJobToSendHandler(BaseHandler):
"""Handler class for sending transaction jobs."""
[docs] async def handle(self, context: RequestContext, responder: BaseResponder):
"""Handle transaction jobs.
Args:
context: Request context
responder: Responder callback
"""
self._logger.debug(f"TransactionJobToSendHandler called with context {context}")
assert isinstance(context.message, TransactionJobToSend)
mgr = TransactionManager(context.profile)
try:
await mgr.set_transaction_their_job(
context.message, context.message_receipt
)
except TransactionManagerError:
self._logger.exception("Error receiving transaction jobs")