403 Forbidden
Extracted source (around line #270):
268
269
270
271
272
273
|
token_request(http_method, uri.path, token, request_options, arguments)
when (400..499)
raise OAuth::Unauthorized, response
else
response.error!
end
|
Extracted source (around line #179):
177
178
179
180
181
182
|
)
else
token_request(http_method, (request_token_url? ? request_token_url : request_token_path), nil,
request_options, *arguments)
end
OAuth::RequestToken.from_hash(self, response)
|
Extracted source (around line #28):
26
27
28
29
30
31
|
def request_phase # rubocop:disable MethodLength
request_token = consumer.get_request_token({:oauth_callback => callback_url}, options.request_params)
session["oauth"] ||= {}
session["oauth"][name.to_s] = {"callback_confirmed" => request_token.callback_confirmed?, "request_token" => request_token.token, "request_secret" => request_token.secret}
|
Extracted source (around line #61):
59
60
61
62
63
64
|
end
old_request_phase
end
alias :old_callback_url :callback_url
|
Extracted source (around line #226):
224
225
226
227
228
229
|
end
request_phase
end
end
|
Extracted source (around line #188):
186
187
188
189
190
191
|
return mock_call!(env) if OmniAuth.config.test_mode
return options_call if on_auth_path? && options_request?
return request_call if on_request_path? && OmniAuth.config.allowed_request_methods.include?(request.request_method.downcase.to_sym)
return callback_call if on_callback_path?
return other_phase if respond_to?(:other_phase)
|
Extracted source (around line #169):
167
168
169
170
171
172
|
# @param [Hash] The Rack environment.
def call(env)
dup.call!(env)
end
# The logic for dispatching any additional actions that need
|
Extracted source (around line #45):
43
44
45
46
47
48
|
def call(env)
to_app.call(env)
end
end
end
|
Extracted source (around line #192):
190
191
192
193
194
195
|
return other_phase if respond_to?(:other_phase)
@app.call(env)
end
# Responds to an OPTIONS request.
|
Extracted source (around line #169):
167
168
169
170
171
172
|
# @param [Hash] The Rack environment.
def call(env)
dup.call!(env)
end
# The logic for dispatching any additional actions that need
|
Extracted source (around line #45):
43
44
45
46
47
48
|
def call(env)
to_app.call(env)
end
end
end
|
Extracted source (around line #24):
22
23
24
25
26
27
|
def call(env)
status, headers, body = @app.call(env)
if etag_status?(status) && etag_body?(body) && !skip_caching?(headers)
original_body = body
|
Extracted source (around line #25):
23
24
25
26
27
28
|
case env[REQUEST_METHOD]
when "GET", "HEAD"
status, headers, body = @app.call(env)
headers = Utils::HeaderHash.new(headers)
if status == 200 && fresh?(env, headers)
status = 304
|
Extracted source (around line #13):
11
12
13
14
15
16
|
def call(env)
status, headers, body = @app.call(env)
if env[REQUEST_METHOD] == HEAD
[
|
Extracted source (around line #27):
25
26
27
28
29
30
|
end
@app.call(env)
end
private
|
Extracted source (around line #260):
258
259
260
261
262
263
|
def call(env)
@app.call(env)
ensure
session = Request::Session.find(env) || {}
flash_hash = env[KEY]
|
Extracted source (around line #252):
250
251
252
253
254
255
|
def context(env, app=@app)
prepare_session(env)
status, headers, body = app.call(env)
commit_session(env, status, headers, body)
end
|
Extracted source (around line #247):
245
246
247
248
249
250
|
def call(env)
context(env)
end
def context(env, app=@app)
|
Extracted source (around line #560):
558
559
560
561
562
563
|
def call(env)
status, headers, body = @app.call(env)
if cookie_jar = env['action_dispatch.cookies']
unless cookie_jar.committed?
|
Extracted source (around line #36):
34
35
36
37
38
39
|
connection.enable_query_cache!
response = @app.call(env)
response[2] = Rack::BodyProxy.new(response[2]) do
restore_query_cache_settings(connection_id, enabled)
end
|
Extracted source (around line #34):
32
33
34
35
36
37
|
begin
response = @app.call(env)
rescue Exception => ex # rubocop:disable Lint/RescueException
notify_airbrake(ex)
raise ex
|
Extracted source (around line #23):
21
22
23
24
25
26
|
# @see https://github.com/airbrake/airbrake/issues/904
def call(env)
dup.call!(env)
end
# Rescues any exceptions, sends them to Airbrake and re-raises the
|
Extracted source (around line #653):
651
652
653
654
655
656
|
testing = env['rack.test']
response = @app.call(env)
response[2] = ::Rack::BodyProxy.new(response[2]) do
ActiveRecord::Base.clear_active_connections! unless testing
end
|
Extracted source (around line #29):
27
28
29
30
31
32
|
result = run_callbacks :call do
begin
@app.call(env)
rescue => error
end
end
|
Extracted source (around line #88):
86
87
88
89
90
91
|
def __run_callbacks__(callbacks, &block)
if callbacks.empty?
yield if block_given?
else
runner = callbacks.compile
e = Filters::Environment.new(self, false, nil, block)
|
Extracted source (around line #778):
776
777
778
779
780
781
|
module_eval <<-RUBY, __FILE__, __LINE__ + 1
def _run_#{name}_callbacks(&block)
__run_callbacks__(_#{name}_callbacks, &block)
end
RUBY
end
|
Extracted source (around line #81):
79
80
81
82
83
84
|
# end
def run_callbacks(kind, &block)
send "_run_#{kind}_callbacks", &block
end
private
|
Extracted source (around line #27):
25
26
27
28
29
30
|
def call(env)
error = nil
result = run_callbacks :call do
begin
@app.call(env)
rescue => error
|
Extracted source (around line #78):
76
77
78
79
80
81
|
def call(env)
env["action_dispatch.remote_ip"] = GetIp.new(env, self)
@app.call(env)
end
# The GetIp class exists as a way to defer processing of the request data
|
Extracted source (around line #17):
15
16
17
18
19
20
|
def call(env)
_, headers, body = response = @app.call(env)
if headers['X-Cascade'] == 'pass'
body.close if body.respond_to?(:close)
|
Extracted source (around line #30):
28
29
30
31
32
33
|
def call(env)
@app.call(env)
rescue Exception => exception
if env['action_dispatch.show_exceptions'] == false
raise exception
|
Extracted source (around line #38):
36
37
38
39
40
41
|
instrumenter.start 'request.action_dispatch', request: request
logger.info { started_request_message(request) }
resp = @app.call(env)
resp[2] = ::Rack::BodyProxy.new(resp[2]) { finish(request) }
resp
rescue Exception
|
Extracted source (around line #22):
20
21
22
23
24
25
|
logger.tagged(compute_tags(request)) { call_app(request, env) }
else
call_app(request, env)
end
end
|
Extracted source (around line #19):
17
18
19
20
21
22
|
RequestStore.begin!
status, headers, body = @app.call(env)
body = Rack::BodyProxy.new(body) do
RequestStore.end!
|
Extracted source (around line #21):
19
20
21
22
23
24
|
def call(env)
env["action_dispatch.request_id"] = external_request_id(env) || internal_request_id
@app.call(env).tap { |_status, headers, _body| headers["X-Request-Id"] = env["action_dispatch.request_id"] }
end
private
|
Extracted source (around line #22):
20
21
22
23
24
25
|
end
@app.call(env)
end
def method_override(env)
|
Extracted source (around line #18):
16
17
18
19
20
21
|
def call(env)
start_time = clock_time
status, headers, body = @app.call(env)
request_time = clock_time - start_time
if !headers.has_key?(@header_name)
|
Extracted source (around line #28):
26
27
28
29
30
31
|
def call(env)
LocalCacheRegistry.set_cache_for(local_cache_key, LocalStore.new)
response = @app.call(env)
response[2] = ::Rack::BodyProxy.new(response[2]) do
LocalCacheRegistry.set_cache_for(local_cache_key, nil)
end
|
Extracted source (around line #120):
118
119
120
121
122
123
|
end
@app.call(env)
end
end
end
|
Extracted source (around line #113):
111
112
113
114
115
116
|
def call(env)
status, headers, body = @app.call(env)
if body.respond_to?(:to_path)
case type = variation(env)
when 'X-Accel-Redirect'
|
Extracted source (around line #10):
8
9
10
11
12
13
|
begin
transaction = Opbeat.transaction "Rack", "app.rack.request"
resp = @app.call env
resp[2] = BodyProxy.new(resp[2]) { transaction.submit(resp[0]) } if transaction
rescue Error
raise # Don't report Opbeat errors
|
Extracted source (around line #518):
516
517
518
519
520
521
|
env["ROUTES_#{routes.object_id}_SCRIPT_NAME"] = env['SCRIPT_NAME'].dup
end
app.call(env)
end
# Defines additional Rack env configuration that is added on each call.
|
Extracted source (around line #165):
163
164
165
166
167
168
|
env["ORIGINAL_FULLPATH"] = build_original_fullpath(env)
env["ORIGINAL_SCRIPT_NAME"] = env["SCRIPT_NAME"]
super(env)
end
# Reload application routes regardless if they changed or not.
|
Extracted source (around line #15):
13
14
15
16
17
18
|
def call(env)
status, headers, body = @app.call(env)
headers = HeaderHash.new(headers)
if !STATUS_WITH_NO_ENTITY_BODY.include?(status.to_i) &&
|
Extracted source (around line #86):
84
85
86
87
88
89
|
catch(:async) do
# Process the request calling the Rack adapter
response = @app.call(@request.env)
end
response
rescue Exception => e
|
Extracted source (around line #84):
82
83
84
85
86
87
|
# in removing this.
response = AsyncResponse
catch(:async) do
# Process the request calling the Rack adapter
response = @app.call(@request.env)
end
|
Extracted source (around line #84):
82
83
84
85
86
87
|
# in removing this.
response = AsyncResponse
catch(:async) do
# Process the request calling the Rack adapter
response = @app.call(@request.env)
end
|
Extracted source (around line #53):
51
52
53
54
55
56
|
else
@request.threaded = false
post_process(pre_process)
end
end
|
Extracted source (around line #39):
37
38
39
40
41
42
|
@idle = false
trace data
process if @request.parse(data)
rescue InvalidRequest => e
log_error("Invalid request", e)
post_process Response::BAD_REQUEST
|
Extracted source (around line #195):
193
194
195
196
197
198
|
while run_machine_once; end
else
run_machine
end
ensure
|
Extracted source (around line #195):
193
194
195
196
197
198
|
while run_machine_once; end
else
run_machine
end
ensure
|
Extracted source (around line #75):
73
74
75
76
77
78
|
else
@started_reactor = true
EventMachine.run(&starter)
end
end
|
Extracted source (around line #162):
160
161
162
163
164
165
|
log_info "Listening on #{@backend}, CTRL+C to stop"
@backend.start { setup_signals if @setup_signals }
end
alias :start! :start
|
Extracted source (around line #22):
20
21
22
23
24
25
|
yield server if block_given?
server.start
end
def self.valid_options
|
Extracted source (around line #287):
285
286
287
288
289
290
|
end
server.run wrapped_app, options, &blk
end
def server
|
Extracted source (around line #80):
78
79
80
81
82
83
|
log_to_stdout if options[:log_stdout]
super
ensure
# The '-h' option calls exit before @options is set.
# If we call 'options' with it unset, we get double help banners.
|
Extracted source (around line #80):
78
79
80
81
82
83
|
require APP_PATH
Dir.chdir(Rails.application.root)
server.start
end
end
|
Extracted source (around line #75):
73
74
75
76
77
78
|
require_command!("server")
Rails::Server.new.tap do |server|
# We need to require application after the server sets environment,
# otherwise the --environment option given to the server won't propagate.
require APP_PATH
|
Extracted source (around line #75):
73
74
75
76
77
78
|
require_command!("server")
Rails::Server.new.tap do |server|
# We need to require application after the server sets environment,
# otherwise the --environment option given to the server won't propagate.
require APP_PATH
|
Extracted source (around line #39):
37
38
39
40
41
42
|
command = parse_command(command)
if COMMAND_WHITELIST.include?(command)
send(command)
else
write_error_message(command)
end
|
Extracted source (around line #17):
15
16
17
|
require 'rails/commands/commands_tasks'
Rails::CommandsTasks.new(ARGV).run_command!(command)
|
Extracted source (around line #4):
2
3
4
|
APP_PATH = File.expand_path('../../config/application', __FILE__)
require_relative '../config/boot'
require 'rails/commands'
|
Extracted source (around line #4):
2
3
4
|
APP_PATH = File.expand_path('../../config/application', __FILE__)
require_relative '../config/boot'
require 'rails/commands'
|
Rails.root: /app
Request
Parameters:
None
omniauth.params: {}
session_id: "cbe351667dae6623f47a73d4429f2df2"
GATEWAY_INTERFACE: "CGI/1.2"
HTTP_ACCEPT: "*/*"
HTTP_ACCEPT_ENCODING: "gzip, br"
REMOTE_ADDR: "10.1.82.110"
SERVER_NAME: "digiramp.com"
SERVER_PROTOCOL: "HTTP/1.1"
Response
Headers:
None