Contents

require 'wisper'

module Routemaster
  module Drain
    # Tiny Rack app to terminates a Routemaster middleware chain.
    # 
    # Respond 204 if a payload has been parsed (i.e. present in the environment)
    # and 400 if not.
    #
    # If an event payload has been placed in `env['routemaster.payload']`
    # by upper middleware, broadcasts the `:events_received` event with the
    # payload.
    #
    # Nothing will be broadcast if the payload is empty.
    #
    class Terminator
      include Wisper::Publisher

      def call(env)
        payload = env['routemaster.payload']
        if payload.nil?
          return [400, {'Content-Type' => 'text/plain'}, 'no payload parsed']
        end

        publish(:events_received, payload) if payload.any?
        [204, {}, []]
      end
    end
  end
end

Version data entries

41 entries across 41 versions & 1 rubygems

Version	Path
routemaster-drain-3.7.1	lib/routemaster/drain/terminator.rb
routemaster-drain-3.7.0	lib/routemaster/drain/terminator.rb
routemaster-drain-3.6.8	lib/routemaster/drain/terminator.rb
routemaster-drain-3.6.7	lib/routemaster/drain/terminator.rb
routemaster-drain-3.6.6	lib/routemaster/drain/terminator.rb
routemaster-drain-3.6.5	lib/routemaster/drain/terminator.rb
routemaster-drain-3.6.4	lib/routemaster/drain/terminator.rb
routemaster-drain-3.6.3	lib/routemaster/drain/terminator.rb
routemaster-drain-3.6.2	lib/routemaster/drain/terminator.rb
routemaster-drain-3.6.1	lib/routemaster/drain/terminator.rb
routemaster-drain-3.6.0	lib/routemaster/drain/terminator.rb
routemaster-drain-3.5.1	lib/routemaster/drain/terminator.rb
routemaster-drain-3.5.0	lib/routemaster/drain/terminator.rb
routemaster-drain-3.4.0	lib/routemaster/drain/terminator.rb
routemaster-drain-3.3.0	lib/routemaster/drain/terminator.rb
routemaster-drain-3.2.0	lib/routemaster/drain/terminator.rb
routemaster-drain-3.1.0	lib/routemaster/drain/terminator.rb
routemaster-drain-3.0.3	lib/routemaster/drain/terminator.rb
routemaster-drain-3.0.2	lib/routemaster/drain/terminator.rb
routemaster-drain-3.0.1	lib/routemaster/drain/terminator.rb