Class: ConvenientService::Core::Entities::Config::Entities::MethodMiddlewares::Entities::Middlewares::Chain::Commands::CreateObservableMiddleware

Inherits:
Support::Command
  • Object
show all
Defined in:
lib/convenient_service/core/entities/config/entities/method_middlewares/entities/middlewares/chain/commands/create_observable_middleware.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods inherited from Support::Command

[], call

Constructor Details

#initialize(middleware:) ⇒ void

Parameters:

  • middleware (Class) 


24
25
26
 
# File 'lib/convenient_service/core/entities/config/entities/method_middlewares/entities/middlewares/chain/commands/create_observable_middleware.rb', line 24

def initialize(middleware:)
  @middleware = middleware
end

Instance Attribute Details

#middleware ⇒ Object (readonly)

Returns the value of attribute middleware.



18
19
20
 
# File 'lib/convenient_service/core/entities/config/entities/method_middlewares/entities/middlewares/chain/commands/create_observable_middleware.rb', line 18

def middleware
  @middleware
end

Instance Method Details

#call ⇒ Class

Returns:

  • (Class) 


31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
 
# File 'lib/convenient_service/core/entities/config/entities/method_middlewares/entities/middlewares/chain/commands/create_observable_middleware.rb', line 31

def call
  ::Class.new(middleware) do
    class << self
      def chain_class
        ::Class.new(super) do
          def initialize(**kwargs)
            arguments = Support::Arguments.new(**Utils::Hash.except(kwargs, [:middleware_events]))

            @__middleware_events__ = kwargs[:middleware_events]

            @__middleware_events__[:before_chain_initialize].notify_observers(arguments)

            super(**arguments.kwargs)

            @__middleware_events__[:after_chain_initialize].notify_observers(arguments)
          end

          def next(...)
            arguments = Support::Arguments.new(...)

            @__middleware_events__[:before_chain_next].notify_observers(arguments)

            value = super

            @__middleware_events__[:after_chain_next].notify_observers(value, arguments)

            value
          end
        end
      end
    end

    def next(...)
      arguments = Support::Arguments.new(...)

      @__middleware_events__[:before_next].notify_observers(arguments)

      value = super

      @__middleware_events__[:after_next].notify_observers(value, arguments)

      value
    end

    def chain
      @__chain__ ||= self.class.chain_class.new(stack: @__stack__, middleware_events: @__middleware_events__)
    end
  end
end