Source code for minos.saga.executions.executors.response

from typing import (
    Optional,
)

from ...context import (
    SagaContext,
)
from ...definitions import (
    ResponseCallBack,
    SagaOperation,
)
from ...exceptions import (
    ExecutorException,
    SagaFailedExecutionStepException,
)
from ...messages import (
    SagaResponse,
)
from .abc import (
    Executor,
)


class ResponseExecutor(Executor):
    """Response Executor class."""

    # noinspection PyUnusedLocal,PyMethodOverriding
    async def exec(
        self,
        operation: Optional[SagaOperation[ResponseCallBack]],
        context: SagaContext,
        response: SagaResponse,
        *args,
        **kwargs
    ) -> SagaContext:
        """Execute the operation.

        :param operation: Operation to be executed.
        :param context: Actual execution context.
        :param response: SagaResponse containing the response content.
        :param args: Additional positional arguments.
        :param kwargs: Additional named arguments.
        :return: An updated context instance.
        """
        if operation is None:
            return context

        try:
            context = SagaContext(**context)  # Needed to avoid mutability issues.
            context = await super().exec(operation, context, response)
        except ExecutorException as exc:
            raise SagaFailedExecutionStepException(exc.exception)

        if isinstance(context, Exception):
            raise SagaFailedExecutionStepException(context)

        return context