Contents

require "dry/monads/either"
require "wisper"
require "dry/transaction/step_failure"

module Dry
  class Transaction
    # @api private
    class Step
      include Wisper::Publisher
      include Dry::Monads::Either::Mixin

      attr_reader :step_adapter
      attr_reader :step_name
      attr_reader :operation_name
      attr_reader :operation
      attr_reader :options
      attr_reader :block
      attr_reader :call_args

      def initialize(step_adapter, step_name, operation_name, operation, options, call_args = [], &block)
        @step_adapter = step_adapter
        @step_name = step_name
        @operation_name = operation_name
        @operation = operation
        @options = options
        @block = block
        @call_args = call_args
      end

      def with_call_args(*call_args)
        self.class.new(step_adapter, step_name, operation_name, operation, options, call_args, &block)
      end

      def call(input)
        args = [input] + call_args
        result = step_adapter.call(self, *args, &block)

        result.fmap { |value|
          broadcast :"#{step_name}_success", value
          value
        }.or { |value|
          broadcast :"#{step_name}_failure", *args, value
          Left(StepFailure.new(self, value))
        }
      end

      def arity
        operation.is_a?(Proc) ? operation.arity : operation.method(:call).arity
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
dry-transaction-0.9.0	lib/dry/transaction/step.rb