Sha256: 4ceec76c594e75786994b589e905602e6ee32b1a405b059da810b4895a4807e1

Contents?: true

Size: 1.61 KB

Versions: 15

Compression:

Stored size: 1.61 KB

Contents

module Dynflow
  class Middleware::World

    include Algebrick::TypeCheck

    def initialize
      @register = Middleware::Register.new
      clear_cache!
    end

    def use(*args)
      clear_cache!
      @register.use(*args)
    end

    def execute(method, action_or_class, *args, &block)
      Match! method, :delay, :plan, :run, :finalize, :plan_phase, :finalize_phase, :present, :hook
      if Child? action_or_class, Dynflow::Action
        action = nil
        action_class = action_or_class
      elsif Type? action_or_class, Dynflow::Action
        action = action_or_class
        action_class = action.class
      else
        Algebrick::TypeCheck.error action_or_class, 'is not instance or child class', Dynflow::Action
      end

      classes = middleware_classes(action_class)
      stack   = Middleware::Stack.build(classes, method, action, &block)
      stack.call(*args)
    end

    def clear_cache!
      @middleware_classes_cache = {}
    end

    private

    def cumulate_register(action_class, register = Middleware::Register.new)
      register.merge!(@register)
      unless action_class == Dynflow::Action
        cumulate_register(action_class.superclass, register)
      end
      register.merge!(action_class.middleware)
      return register
    end

    def middleware_classes(action_class)
      unless @middleware_classes_cache.key?(action_class)
        register = cumulate_register(action_class)
        resolver = Dynflow::Middleware::Resolver.new(register)
        @middleware_classes_cache[action_class] = resolver.result
      end
      return @middleware_classes_cache[action_class]
    end

  end
end

Version data entries

15 entries across 15 versions & 1 rubygems

Version Path
dynflow-1.3.0 lib/dynflow/middleware/world.rb
dynflow-1.2.3 lib/dynflow/middleware/world.rb
dynflow-1.2.2 lib/dynflow/middleware/world.rb
dynflow-1.2.1 lib/dynflow/middleware/world.rb
dynflow-1.2.0 lib/dynflow/middleware/world.rb
dynflow-1.2.0.pre1 lib/dynflow/middleware/world.rb
dynflow-1.1.6 lib/dynflow/middleware/world.rb
dynflow-1.1.5 lib/dynflow/middleware/world.rb
dynflow-1.1.4 lib/dynflow/middleware/world.rb
dynflow-1.1.3 lib/dynflow/middleware/world.rb
dynflow-1.1.2 lib/dynflow/middleware/world.rb
dynflow-1.1.1 lib/dynflow/middleware/world.rb
dynflow-1.1.0 lib/dynflow/middleware/world.rb
dynflow-1.0.5 lib/dynflow/middleware/world.rb
dynflow-1.0.4 lib/dynflow/middleware/world.rb