Sha256: 4563fc3b0cc45ceeabce0de7378c7bd58735c51a29b5edc77a31ea23cea44d9c

Contents?: true

Size: 1.77 KB

Versions: 9

Compression:

Stored size: 1.77 KB

Contents

# frozen_string_literal: true

module RailsWorkflow
  # DependencyResolver
  #
  # New operation can be added to process if all it's dependencies
  # are satisfied. For example current operation can depend on some
  # existing process operation which should be completed - then current
  # operation can be build
  class DependencyResolver
    attr_accessor :process

    delegate :template, :operations, :uncompleted_statuses, to: :process

    def initialize(process)
      @process = process
    end

    def build_new_operations(operation)
      [].tap do |new_operations|
        matched_templates(operation).each do |operation_template|
          completed_dependencies = [operation]

          new_operations << operation_builder.new(
            process, operation_template, completed_dependencies
          ).create_operation
        end
      end.compact
    rescue => exception
      handle_exception(exception, operation)
    end

    private

    def handle_exception(exception, operation)
      error_builder.handle(
        exception,
        parent: process, target: :dependency_resolver,
        method: :build_new_operations, args: [operation]
      )
    end

    def error_builder
      config.error_builder
    end

    def config
      RailsWorkflow.config
    end

    def operation_runner
      config.operation_runner
    end

    def operation_builder
      config.operation_builder
    end

    def matched_templates(operation)
      (dependent_templates(operation) - already_built_templates)
        .select do |operation_template|
          operation_template.resolve_dependency operation
        end
    end

    def dependent_templates(operation)
      template.dependent_operations(operation)
    end

    def already_built_templates
      operations.map(&:template)
    end
  end
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version Path
rails_workflow-0.7.3 lib/rails_workflow/dependency_resolver.rb
rails_workflow-0.7.2 lib/rails_workflow/dependency_resolver.rb
rails_workflow-0.7.1 lib/rails_workflow/dependency_resolver.rb
rails_workflow-0.7.0 lib/rails_workflow/dependency_resolver.rb
rails_workflow-0.4.4 lib/rails_workflow/dependency_resolver.rb
rails_workflow-0.4.3 lib/rails_workflow/dependency_resolver.rb
rails_workflow-0.4.2 lib/rails_workflow/dependency_resolver.rb
rails_workflow-0.4.1 lib/rails_workflow/dependency_resolver.rb
rails_workflow-0.4.0 lib/rails_workflow/dependency_resolver.rb