Class: Utopia::Middleware::Requester

Inherits:
Object
  • Object
show all
Defined in:
lib/utopia/middleware/requester.rb

Defined Under Namespace

Classes: NoRequesterError, RecursiveRequestError, Response

Constant Summary collapse

TTL_KEY = 
"utopia.requestor.ttl"
REQUESTOR_KEY = 
"utopia.requestor"
PATH_VARIABLES = 
Set.new
MAXIMUM_DEPTH = 
5

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(app, env = {}) ⇒ Requester

Returns a new instance of Requester.



79
80
81
82
83
 
# File 'lib/utopia/middleware/requester.rb', line 79

def initialize(app, env = {})
  @app = app
  @env = env
  @env[TTL_KEY] = 0
end

Instance Attribute Details

#env ⇒ Object

Returns the value of attribute env.



85
86
87
 
# File 'lib/utopia/middleware/requester.rb', line 85

def env
  @env
end

Class Method Details

.[](env) ⇒ Object 



70
71
72
73
74
75
76
77
 
# File 'lib/utopia/middleware/requester.rb', line 70

def self.[](env)
  requestor = env[REQUESTOR_KEY]
  if requestor
    return requestor
  else
    raise NoRequesterError
  end
end

Instance Method Details

#[](path, method = "GET", env = {}) ⇒ Object 



110
111
112
113
114
115
116
 
# File 'lib/utopia/middleware/requester.rb', line 110

def [](path, method = "GET", env = {})
  path_env = {
    "REQUEST_METHOD" => method,
    "PATH_INFO" => path.to_s
  }
  request(env.merge(path_env))
end

#call(env) ⇒ Object 



87
88
89
90
91
92
93
94
 
# File 'lib/utopia/middleware/requester.rb', line 87

def call(env)
  requestor = dup
  env[REQUESTOR_KEY] = requestor
  requestor.env = env.merge(@env)
  requestor.env.delete("rack.request")

  @app.call(env)
end

#inspect ⇒ Object

Avoid a huge amount of junk being printed when inspecting env.



119
120
121
 
# File 'lib/utopia/middleware/requester.rb', line 119

def inspect
  to_s
end

#request(env) ⇒ Object 



99
100
101
102
103
104
105
106
107
108
 
# File 'lib/utopia/middleware/requester.rb', line 99

def request(env)
  env = @env.merge(env)
  env[TTL_KEY] += 1

  if env[TTL_KEY].to_i > MAXIMUM_DEPTH
    raise RecursiveRequestError, env["PATH_INFO"]
  end

  return Response.new(*@app.call(env))
end