Contents

require "dry/transaction/result_matcher"
require "dry/transaction/step"
require "dry/transaction/step_adapters"
require "dry/transaction/step_definition"

module Dry
  class Transaction
    # @api private
    class DSL < BasicObject
      attr_reader :container
      attr_reader :step_adapters
      attr_reader :steps
      attr_reader :matcher

      def initialize(options, &block)
        @container = options.fetch(:container)
        @step_adapters = options.fetch(:step_adapters) { StepAdapters }
        @steps = []
        @matcher = options.fetch(:matcher) { ResultMatcher }

        instance_eval(&block)
      end

      def respond_to_missing?(method_name)
        step_adapters.key?(method_name)
      end

      def method_missing(method_name, *args, &block)
        return super unless step_adapters.key?(method_name)

        step_adapter = step_adapters[method_name]
        step_name = args.first
        options = args.last.is_a?(::Hash) ? args.last : {}
        with = options.delete(:with)

        if with.respond_to?(:call)
          operation_name = step_name
          operation = StepDefinition.new(container, &with)
        else
          operation_name = with || step_name
          operation = container[operation_name]
        end

        steps << Step.new(step_adapter, step_name, operation_name, operation, options, &block)
      end

      def call
        Transaction.new(steps, matcher)
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

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