Contents

require 'routemaster/dirty/map'

module Routemaster
  module Middleware
    # If an event payload was place in the environment
    # (`env['routemaster.payload']`) by a previous middleware,
    # mark each corresponding entity as dirty.
    #
    # All events are passed through.
    #
    # The dirty map is passed as `:map` to the constructor and must respond to
    # `#mark` (like `Routemaster::Dirty::Map`).
    class Dirty
      def initialize(app, dirty_map:nil)
        @app = app
        @map = dirty_map || Routemaster::Dirty::Map.new
      end

      def call(env)
        env['routemaster.dirty'] = dirty = []
        env.fetch('routemaster.payload', []).each do |event|
          next if event['type'] == 'noop'
          next unless @map.mark(event['url'])
          dirty << event['url']
        end
        @app.call(env)
      end
    end
  end
end

Version data entries

15 entries across 15 versions & 1 rubygems

Version	Path
routemaster-drain-2.4.4	lib/routemaster/middleware/dirty.rb
routemaster-drain-2.4.3	lib/routemaster/middleware/dirty.rb
routemaster-drain-2.4.2	lib/routemaster/middleware/dirty.rb
routemaster-drain-2.4.1	lib/routemaster/middleware/dirty.rb
routemaster-drain-2.4.0	lib/routemaster/middleware/dirty.rb
routemaster-drain-2.3.0	lib/routemaster/middleware/dirty.rb
routemaster-drain-2.2.2	lib/routemaster/middleware/dirty.rb
routemaster-drain-2.0.0	lib/routemaster/middleware/dirty.rb
routemaster-drain-1.1.0	lib/routemaster/middleware/dirty.rb
routemaster-drain-1.0.5	lib/routemaster/middleware/dirty.rb
routemaster-drain-1.0.4	lib/routemaster/middleware/dirty.rb
routemaster-drain-1.0.3	lib/routemaster/middleware/dirty.rb
routemaster-drain-1.0.2	lib/routemaster/middleware/dirty.rb
routemaster-drain-1.0.1	lib/routemaster/middleware/dirty.rb
routemaster-drain-1.0.0	lib/routemaster/middleware/dirty.rb