Class: Rack::Cascade

Inherits:
Object
  • Object
show all
Defined in:
lib/rack/cascade.rb

Overview

Rack::Cascade tries a request on several apps, and returns the first response that is not 404 or 405 (or in a list of configured status codes). If all applications tried return one of the configured status codes, return the last response.

Constant Summary collapse

NotFound =

deprecated, no longer used

[404, { CONTENT_TYPE => "text/plain" }, []]

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(apps, cascade_for = [404, 405]) ⇒ Cascade

Set the apps to send requests to, and what statuses result in cascading. Arguments:

apps: An enumerable of rack applications. cascade_for: The statuses to use cascading for. If a response is received

from an app, the next app is tried.



24
25
26
27
28
29
30
 
# File 'lib/rack/cascade.rb', line 24

def initialize(apps, cascade_for = [404, 405])
  @apps = []
  apps.each { |app| add app }

  @cascade_for = {}
  [*cascade_for].each { |status| @cascade_for[status] = true }
end

Instance Attribute Details

#apps ⇒ Object (readonly)

An array of applications to try in order.



16
17
18
 
# File 'lib/rack/cascade.rb', line 16

def apps
  @apps
end

Instance Method Details

#add(app) ⇒ Object Also known as: <<

Append an app to the list of apps to cascade. This app will be tried last.



59
60
61
 
# File 'lib/rack/cascade.rb', line 59

def add(app)
  @apps << app
end

#call(env) ⇒ Object

Call each app in order. If the responses uses a status that requires cascading, try the next app. If all responses require cascading, return the response from the last app.



35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
 
# File 'lib/rack/cascade.rb', line 35

def call(env)
  return [404, { CONTENT_TYPE => "text/plain" }, []] if @apps.empty?
  result = nil
  last_body = nil

  @apps.each do |app|
    # The SPEC says that the body must be closed after it has been iterated
    # by the server, or if it is replaced by a middleware action. Cascade
    # replaces the body each time a cascade happens. It is assumed that nil
    # does not respond to close, otherwise the previous application body
    # will be closed. The final application body will not be closed, as it
    # will be passed to the server as a result.
    last_body.close if last_body.respond_to? :close

    result = app.call(env)
    return result unless @cascade_for.include?(result[0].to_i)
    last_body = result[2]
  end

  result
end

#include?(app) ⇒ Boolean

Whether the given app is one of the apps to cascade to.

Returns:

  • (Boolean) 


64
65
66
 
# File 'lib/rack/cascade.rb', line 64

def include?(app)
  @apps.include?(app)
end