Source code for aries_cloudagent.protocols.endorse_transaction.v1_0.handlers.transaction_job_to_send_handler

"""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")