Showing /home/s.reinhold/www/hoe/app/views/library/_small_media.html.erb where line #5 raised:
ActiveStorage::FileNotFoundError
Extracted source (around line #140):
138
139
140
141
142
143
|
end
rescue Errno::ENOENT
raise ActiveStorage::FileNotFoundError
end
def folder_for(key)
|
Extracted source (around line #133):
131
132
133
134
135
136
|
private
def stream(key)
File.open(path_for(key), "rb") do |file|
while data = file.read(5.megabytes)
yield data
|
Extracted source (around line #28):
26
27
28
29
30
31
|
if block_given?
instrument :streaming_download, key: key do
stream key, &block
end
else
instrument :download, key: key do
|
Extracted source (around line #180):
178
179
180
181
182
183
|
def instrument(name, payload = {})
if notifier.listening?(name)
instrumenter.instrument(name, payload) { yield payload if block_given? }
else
yield payload if block_given?
end
|
Extracted source (around line #24):
22
23
24
25
26
27
|
listeners_state = start name, payload
begin
yield payload if block_given?
rescue Exception => e
payload[:exception] = [e.class.name, e.message]
payload[:exception_object] = e
|
Extracted source (around line #180):
178
179
180
181
182
183
|
def instrument(name, payload = {})
if notifier.listening?(name)
instrumenter.instrument(name, payload) { yield payload if block_given? }
else
yield payload if block_given?
end
|
Extracted source (around line #126):
124
125
126
127
128
129
|
private
def instrument(operation, payload = {}, &block)
ActiveSupport::Notifications.instrument(
"service_#{operation}.active_storage",
payload.merge(service: service_name), &block)
end
|
Extracted source (around line #27):
25
26
27
28
29
30
|
def download(key, &block)
if block_given?
instrument :streaming_download, key: key do
stream key, &block
end
else
|
Extracted source (around line #32):
30
31
32
33
34
35
|
def download(key, file)
file.binmode
service.download(key) { |chunk| file.write(chunk) }
file.flush
file.rewind
end
|
Extracted source (around line #13):
11
12
13
14
15
16
|
def open(key, checksum:, name: "ActiveStorage-", tmpdir: nil)
open_tempfile(name, tmpdir) do |file|
download key, file
verify_integrity_of file, checksum: checksum
yield file
end
|
Extracted source (around line #24):
22
23
24
25
26
27
|
begin
yield file
ensure
file.close!
end
|
Extracted source (around line #12):
10
11
12
13
14
15
|
def open(key, checksum:, name: "ActiveStorage-", tmpdir: nil)
open_tempfile(name, tmpdir) do |file|
download key, file
verify_integrity_of file, checksum: checksum
yield file
|
Extracted source (around line #86):
84
85
86
87
88
89
|
def open(*args, &block)
ActiveStorage::Downloader.new(self).open(*args, &block)
end
# Delete the file at the +key+.
|
Extracted source (around line #206):
204
205
206
207
208
209
|
# Raises ActiveStorage::IntegrityError if the downloaded data does not match the blob's checksum.
def open(tmpdir: nil, &block)
service.open key, checksum: checksum,
name: [ "ActiveStorage-#{id}-", filename.extension_with_delimiter ], tmpdir: tmpdir, &block
end
|
Extracted source (around line #99):
97
98
99
100
101
102
|
def process
blob.open do |image|
transform(image) { |output| upload(output) }
end
end
|
Extracted source (around line #67):
65
66
67
68
69
70
|
# Returns the variant instance itself after it's been processed or an existing processing has been found on the service.
def processed
process unless processed?
self
end
|
Extracted source (around line #28):
26
27
28
29
30
31
|
def thumbnail
self.image.attached? ? self.image.variant(combine_options: { auto_orient: true, gravity: "northwest", resize: "640x360^", crop: "640x360+0" }, quality: 80, strip: true).processed.service_url : ""
end
has_many_attached :gallery
|
Extracted source (around line #5):
3
4
5
6
7
8
|
<div class="video-preview">
<a href="<%= @lang_link %><%= post.link%>" class="video-preview-poster">
<%= image_tag post.thumbnail, class: "video-preview-poster__img" %>
<span class="video-icon-category <%= categories[post.media_type-1] %>"></span>
<% if !post.duration.blank?%><span class="video-duration"><%= post.duration%></span><% end %>
|
Extracted source (around line #274):
272
273
274
275
276
277
|
@current_template = template
@output_buffer = buffer
send(method, locals, buffer, &block)
ensure
@output_buffer, @virtual_path, @current_template = _old_output_buffer, _old_virtual_path, _old_template
end
|
Extracted source (around line #185):
183
184
185
186
187
188
|
instrument_render_template do
compile!(view)
view._run(method_name, self, locals, buffer, &block)
end
rescue => e
handle_render_error(view, e)
|
Extracted source (around line #182):
180
181
182
183
184
185
|
instrumenter.instrument(name, payload) { yield payload if block_given? }
else
yield payload if block_given?
end
end
|
Extracted source (around line #386):
384
385
386
387
388
389
|
def instrument_render_template(&block)
ActiveSupport::Notifications.instrument("!render_template.action_view", instrument_payload, &block)
end
def instrument_payload
|
Extracted source (around line #183):
181
182
183
184
185
186
|
# consume this in production. This is only slow if it's being listened to.
def render(view, locals, buffer = ActionView::OutputBuffer.new, &block)
instrument_render_template do
compile!(view)
view._run(method_name, self, locals, buffer, &block)
end
|
Extracted source (around line #358):
356
357
358
359
360
361
|
locals[as] = object if @has_object
content = template.render(view, locals) do |*name|
view._layout_for(*name, &block)
end
|
Extracted source (around line #89):
87
88
89
90
91
92
|
def instrument(name, **options) # :doc:
ActiveSupport::Notifications.instrument("render_#{name}.action_view", options) do |payload|
yield payload
end
end
|
Extracted source (around line #180):
178
179
180
181
182
183
|
def instrument(name, payload = {})
if notifier.listening?(name)
instrumenter.instrument(name, payload) { yield payload if block_given? }
else
yield payload if block_given?
end
|
Extracted source (around line #24):
22
23
24
25
26
27
|
listeners_state = start name, payload
begin
yield payload if block_given?
rescue Exception => e
payload[:exception] = [e.class.name, e.message]
payload[:exception_object] = e
|
Extracted source (around line #180):
178
179
180
181
182
183
|
def instrument(name, payload = {})
if notifier.listening?(name)
instrumenter.instrument(name, payload) { yield payload if block_given? }
else
yield payload if block_given?
end
|
Extracted source (around line #88):
86
87
88
89
90
91
|
def instrument(name, **options) # :doc:
ActiveSupport::Notifications.instrument("render_#{name}.action_view", options) do |payload|
yield payload
end
end
|
Extracted source (around line #347):
345
346
347
348
349
350
|
def render_partial(view, template)
instrument(:partial, identifier: template.identifier) do |payload|
locals, block = @locals, @block
object, as = @object, @variable
|
Extracted source (around line #317):
315
316
317
318
319
320
|
render_collection(context, template)
else
render_partial(context, template)
end
end
|
Extracted source (around line #65):
63
64
65
66
67
68
|
def render_partial_to_object(context, options, &block) #:nodoc:
PartialRenderer.new(@lookup_context).render(context, options, block)
end
end
end
|
Extracted source (around line #27):
25
26
27
28
29
30
|
def render_to_object(context, options) # :nodoc:
if options.key?(:partial)
render_partial_to_object(context, options)
else
render_template_to_object(context, options)
end
|
Extracted source (around line #22):
20
21
22
23
24
25
|
# Main render entry point shared by Action View and Action Controller.
def render(context, options)
render_to_object(context, options).body
end
def render_to_object(context, options) # :nodoc:
|
Extracted source (around line #34):
32
33
34
35
36
37
|
view_renderer.render_partial(self, options.merge(partial: options[:layout]), &block)
else
view_renderer.render(self, options)
end
end
else
|
Extracted source (around line #304):
302
303
304
305
306
307
|
end
yield @view_renderer
ensure
@view_renderer = old_view_renderer
@lookup_context = old_lookup_context
|
Extracted source (around line #30):
28
29
30
31
32
33
|
case options
when Hash
in_rendering_context(options) do |renderer|
if block_given?
view_renderer.render_partial(self, options.merge(partial: options[:layout]), &block)
else
|
Extracted source (around line #96):
94
95
96
97
98
99
|
<% @posts.each do |post| %>
<%= render partial: 'small_media', locals: {post: post, categories: categories}%>
<% end %>
<% if @posts.count == 0 %>
<div class='no_result'><%= @translate[37] %></div>
|
Extracted source (around line #85):
83
84
85
86
87
88
|
# for each different klass, and the delegations are compiled into that subclass only.
delegate :to_xml, :encode_with, :length, :each, :join,
:[], :&, :|, :+, :-, :sample, :reverse, :rotate, :compact, :in_groups, :in_groups_of,
:to_sentence, :to_formatted_s, :as_json,
:shuffle, :split, :slice, :index, :rindex, to: :records
|
Extracted source (around line #85):
83
84
85
86
87
88
|
# for each different klass, and the delegations are compiled into that subclass only.
delegate :to_xml, :encode_with, :length, :each, :join,
:[], :&, :|, :+, :-, :sample, :reverse, :rotate, :compact, :in_groups, :in_groups_of,
:to_sentence, :to_formatted_s, :as_json,
:shuffle, :split, :slice, :index, :rindex, to: :records
|
Extracted source (around line #95):
93
94
95
96
97
98
|
<ul class="video-list" id='library_videos'>
<% @posts.each do |post| %>
<%= render partial: 'small_media', locals: {post: post, categories: categories}%>
<% end %>
<% if @posts.count == 0 %>
|
Extracted source (around line #45):
43
44
45
46
47
48
|
def capture(*args)
value = nil
buffer = with_output_buffer { value = yield(*args) }
if (string = buffer.presence || value) && string.is_a?(String)
ERB::Util.html_escape string
end
|
Extracted source (around line #209):
207
208
209
210
211
212
|
end
self.output_buffer, old_buffer = buf, output_buffer
yield
output_buffer
ensure
self.output_buffer = old_buffer
|
Extracted source (around line #45):
43
44
45
46
47
48
|
def capture(*args)
value = nil
buffer = with_output_buffer { value = yield(*args) }
if (string = buffer.presence || value) && string.is_a?(String)
ERB::Util.html_escape string
end
|
Extracted source (around line #74):
72
73
74
75
76
77
|
html_options = html_options_for_form(url_for_options, options)
if block_given?
form_tag_with_body(html_options, capture(&block))
else
form_tag_html(html_options)
end
|
Extracted source (around line #42):
40
41
42
43
44
45
|
<!-- new layout -->
<div class="content content_inside content_library border-box">
<%= form_tag "#{@lang_link}/library", method: :get, id: 'library_form', remote: true do %>
<% @selected_opportunity_tags.each do |tag| %>
<input type="hidden" name="tags[]" id="ftag<%= tag.id %>" value="<%= tag.id %>">
<% end %>
|
Extracted source (around line #274):
272
273
274
275
276
277
|
@current_template = template
@output_buffer = buffer
send(method, locals, buffer, &block)
ensure
@output_buffer, @virtual_path, @current_template = _old_output_buffer, _old_virtual_path, _old_template
end
|
Extracted source (around line #185):
183
184
185
186
187
188
|
instrument_render_template do
compile!(view)
view._run(method_name, self, locals, buffer, &block)
end
rescue => e
handle_render_error(view, e)
|
Extracted source (around line #182):
180
181
182
183
184
185
|
instrumenter.instrument(name, payload) { yield payload if block_given? }
else
yield payload if block_given?
end
end
|
Extracted source (around line #386):
384
385
386
387
388
389
|
def instrument_render_template(&block)
ActiveSupport::Notifications.instrument("!render_template.action_view", instrument_payload, &block)
end
def instrument_payload
|
Extracted source (around line #183):
181
182
183
184
185
186
|
# consume this in production. This is only slow if it's being listened to.
def render(view, locals, buffer = ActionView::OutputBuffer.new, &block)
instrument_render_template do
compile!(view)
view._run(method_name, self, locals, buffer, &block)
end
|
Extracted source (around line #59):
57
58
59
60
61
62
|
render_with_layout(view, template, layout_name, locals) do |layout|
instrument(:template, identifier: template.identifier, layout: layout.try(:virtual_path)) do
template.render(view, locals) { |*name| view._layout_for(*name) }
end
end
end
|
Extracted source (around line #89):
87
88
89
90
91
92
|
def instrument(name, **options) # :doc:
ActiveSupport::Notifications.instrument("render_#{name}.action_view", options) do |payload|
yield payload
end
end
|
Extracted source (around line #180):
178
179
180
181
182
183
|
def instrument(name, payload = {})
if notifier.listening?(name)
instrumenter.instrument(name, payload) { yield payload if block_given? }
else
yield payload if block_given?
end
|
Extracted source (around line #24):
22
23
24
25
26
27
|
listeners_state = start name, payload
begin
yield payload if block_given?
rescue Exception => e
payload[:exception] = [e.class.name, e.message]
payload[:exception_object] = e
|
Extracted source (around line #180):
178
179
180
181
182
183
|
def instrument(name, payload = {})
if notifier.listening?(name)
instrumenter.instrument(name, payload) { yield payload if block_given? }
else
yield payload if block_given?
end
|
Extracted source (around line #88):
86
87
88
89
90
91
|
def instrument(name, **options) # :doc:
ActiveSupport::Notifications.instrument("render_#{name}.action_view", options) do |payload|
yield payload
end
end
|
Extracted source (around line #58):
56
57
58
59
60
61
|
def render_template(view, template, layout_name, locals)
render_with_layout(view, template, layout_name, locals) do |layout|
instrument(:template, identifier: template.identifier, layout: layout.try(:virtual_path)) do
template.render(view, locals) { |*name| view._layout_for(*name) }
end
end
|
Extracted source (around line #66):
64
65
66
67
68
69
|
def render_with_layout(view, template, path, locals)
layout = path && find_layout(path, locals.keys, [formats.first])
content = yield(layout)
body = if layout
view.view_flow.set(:layout, content)
|
Extracted source (around line #57):
55
56
57
58
59
60
|
# supplied as well.
def render_template(view, template, layout_name, locals)
render_with_layout(view, template, layout_name, locals) do |layout|
instrument(:template, identifier: template.identifier, layout: layout.try(:virtual_path)) do
template.render(view, locals) { |*name| view._layout_for(*name) }
end
|
Extracted source (around line #13):
11
12
13
14
15
16
|
prepend_formats(template.format)
render_template(context, template, options[:layout], options[:locals] || {})
end
private
|
Extracted source (around line #61):
59
60
61
62
63
64
|
def render_template_to_object(context, options) #:nodoc:
TemplateRenderer.new(@lookup_context).render(context, options)
end
def render_partial_to_object(context, options, &block) #:nodoc:
|
Extracted source (around line #29):
27
28
29
30
31
32
|
render_partial_to_object(context, options)
else
render_template_to_object(context, options)
end
end
|
Extracted source (around line #118):
116
117
118
119
120
121
|
rendered_template = context.in_rendering_context(options) do |renderer|
renderer.render_to_object(context, options)
end
rendered_format = rendered_template.format || lookup_context.formats.first
|
Extracted source (around line #304):
302
303
304
305
306
307
|
end
yield @view_renderer
ensure
@view_renderer = old_view_renderer
@lookup_context = old_lookup_context
|
Extracted source (around line #117):
115
116
117
118
119
120
|
lookup_context.variants = variant if variant
rendered_template = context.in_rendering_context(options) do |renderer|
renderer.render_to_object(context, options)
end
|
Extracted source (around line #219):
217
218
219
220
221
222
|
Rack::Chunked::Body.new view_renderer.render_body(view_context, options)
else
super
end
end
end
|
Extracted source (around line #103):
101
102
103
104
105
106
|
def render_to_body(options = {})
_process_options(options)
_render_template(options)
end
private
|
Extracted source (around line #52):
50
51
52
53
54
55
|
def render_to_body(options = {})
super || _render_in_priorities(options) || " "
end
private
|
Extracted source (around line #142):
140
141
142
143
144
145
|
# <tt>ActionView::Rendering.render_to_body</tt>, if present.
def render_to_body(options)
_render_to_body_with_renderer(options) || super
end
def _render_to_body_with_renderer(options)
|
Extracted source (around line #25):
23
24
25
26
27
28
|
def render(*args, &block)
options = _normalize_render(*args, &block)
rendered_body = render_to_body(options)
if options[:html]
_set_html_content_type
else
|
Extracted source (around line #36):
34
35
36
37
38
39
|
def render(*args) #:nodoc:
raise ::AbstractController::DoubleRenderError if response_body
super
end
# Overwrite render_to_string because body can now be set to a Rack body.
|
Extracted source (around line #44):
42
43
44
45
46
47
|
render_output = nil
self.view_runtime = cleanup_view_runtime do
Benchmark.ms { render_output = super }
end
render_output
end
|
Extracted source (around line #14):
12
13
14
15
16
|
# # => 0.074
def ms
1000 * realtime { yield }
end
end
|
Extracted source (around line #308):
306
307
308
309
310
311
|
def realtime # :yield:
r0 = Process.clock_gettime(Process::CLOCK_MONOTONIC)
yield
Process.clock_gettime(Process::CLOCK_MONOTONIC) - r0
end
|
Extracted source (around line #14):
12
13
14
15
16
|
# # => 0.074
def ms
1000 * realtime { yield }
end
end
|
Extracted source (around line #44):
42
43
44
45
46
47
|
render_output = nil
self.view_runtime = cleanup_view_runtime do
Benchmark.ms { render_output = super }
end
render_output
end
|
Extracted source (around line #85):
83
84
85
86
87
88
|
# end
def cleanup_view_runtime # :doc:
yield
end
# Every time after an action is processed, this method is invoked
|
Extracted source (around line #34):
32
33
34
35
36
37
|
db_rt_before_render = ActiveRecord::LogSubscriber.reset_runtime
self.db_runtime = (db_runtime || 0) + db_rt_before_render
runtime = super
db_rt_after_render = ActiveRecord::LogSubscriber.reset_runtime
self.db_runtime += db_rt_after_render
runtime - db_rt_after_render
|
Extracted source (around line #43):
41
42
43
44
45
46
|
def render(*args)
render_output = nil
self.view_runtime = cleanup_view_runtime do
Benchmark.ms { render_output = super }
end
render_output
|
Extracted source (around line #17):
15
16
17
18
19
20
|
def render_with_remotipart(*args, &block)
render_return_value = render_without_remotipart(*args, &block)
if remotipart_submitted?
response.body = %{<script type="text/javascript">try{window.parent.document;}catch(err){document.domain=document.domain;}</script><textarea data-type="#{response.content_type}" data-status="#{response.response_code}" data-statusText="#{response.message}"></textarea><script type="text/javascript">document.querySelector("textarea").value="#{escape_javascript(response.body)}";</script>}
response.content_type = ::Rails.version >= '5' ? Mime[:html] : Mime::HTML
|
Extracted source (around line #35):
33
34
35
36
37
38
|
def default_render
if template_exists?(action_name.to_s, _prefixes, variants: request.variant)
render
elsif any_templates?(action_name.to_s, _prefixes)
message = "#{self.class.name}\##{action_name} is missing a template " \
"for this request format and variant.\n" \
|
Extracted source (around line #6):
4
5
6
7
8
9
|
module BasicImplicitRender # :nodoc:
def send_action(method, *args)
super.tap { default_render unless performed? }
end
def default_render
|
Extracted source (around line #6):
4
5
6
7
8
9
|
module BasicImplicitRender # :nodoc:
def send_action(method, *args)
super.tap { default_render unless performed? }
end
def default_render
|
Extracted source (around line #6):
4
5
6
7
8
9
|
module BasicImplicitRender # :nodoc:
def send_action(method, *args)
super.tap { default_render unless performed? }
end
def default_render
|
Extracted source (around line #196):
194
195
196
197
198
199
|
# which is *not* necessarily the same as the action name.
def process_action(method_name, *args)
send_action(method_name, *args)
end
# Actually call the method associated with the action. Override
|
Extracted source (around line #30):
28
29
30
31
32
33
|
def process_action(*) #:nodoc:
self.formats = request.formats.map(&:ref).compact
super
end
# Check for double render errors and set the content_type after rendering.
|
Extracted source (around line #42):
40
41
42
43
44
45
|
def process_action(*args)
run_callbacks(:process_action) do
super
end
end
|
Extracted source (around line #135):
133
134
135
136
137
138
|
if next_sequence.final?
next_sequence.invoke_before(env)
env.value = !env.halted && (!block_given? || yield)
next_sequence.invoke_after(env)
env.value
else
|
Extracted source (around line #41):
39
40
41
42
43
44
|
# <tt>process_action</tt> callbacks around the normal behavior.
def process_action(*args)
run_callbacks(:process_action) do
super
end
end
|
Extracted source (around line #22):
20
21
22
23
24
25
|
private
def process_action(*args)
super
rescue Exception => exception
request.env["action_dispatch.show_detailed_exceptions"] ||= show_detailed_exceptions?
rescue_with_handler(exception) || raise
|
Extracted source (around line #33):
31
32
33
34
35
36
|
ActiveSupport::Notifications.instrument("process_action.action_controller", raw_payload) do |payload|
super.tap do
payload[:status] = response.status
end
ensure
|
Extracted source (around line #180):
178
179
180
181
182
183
|
def instrument(name, payload = {})
if notifier.listening?(name)
instrumenter.instrument(name, payload) { yield payload if block_given? }
else
yield payload if block_given?
end
|
Extracted source (around line #24):
22
23
24
25
26
27
|
listeners_state = start name, payload
begin
yield payload if block_given?
rescue Exception => e
payload[:exception] = [e.class.name, e.message]
payload[:exception_object] = e
|
Extracted source (around line #180):
178
179
180
181
182
183
|
def instrument(name, payload = {})
if notifier.listening?(name)
instrumenter.instrument(name, payload) { yield payload if block_given? }
else
yield payload if block_given?
end
|
Extracted source (around line #32):
30
31
32
33
34
35
|
ActiveSupport::Notifications.instrument("start_processing.action_controller", raw_payload.dup)
ActiveSupport::Notifications.instrument("process_action.action_controller", raw_payload) do |payload|
super.tap do
payload[:status] = response.status
end
|
Extracted source (around line #245):
243
244
245
246
247
248
|
def process_action(*args)
_perform_parameter_wrapping if _wrapper_enabled?
super
end
private
|
Extracted source (around line #27):
25
26
27
28
29
30
|
# and it won't be cleaned up by the method below.
ActiveRecord::LogSubscriber.reset_runtime
super
end
def cleanup_view_runtime
|
Extracted source (around line #136):
134
135
136
137
138
139
|
@_response_body = nil
process_action(action_name, *args)
end
# Delegates to the class' ::controller_path
|
Extracted source (around line #39):
37
38
39
40
41
42
|
def process(*) #:nodoc:
old_config, I18n.config = I18n.config, I18nProxy.new(I18n.config, lookup_context)
super
ensure
I18n.config = old_config
end
|
Extracted source (around line #191):
189
190
191
192
193
194
|
set_request!(request)
set_response!(response)
process(name)
request.commit_flash
to_a
end
|
Extracted source (around line #252):
250
251
252
253
254
255
|
middleware_stack.build(name) { |env| new.dispatch(name, req, res) }.call req.env
else
new.dispatch(name, req, res)
end
end
end
|
Extracted source (around line #51):
49
50
51
52
53
54
|
def dispatch(controller, action, req, res)
controller.dispatch(action, req, res)
end
end
|
Extracted source (around line #33):
31
32
33
34
35
36
|
controller = controller req
res = controller.make_response! req
dispatch(controller, params[:action], req, res)
rescue ActionController::RoutingError
if @raise_on_name_error
raise
|
Extracted source (around line #49):
47
48
49
50
51
52
|
req.path_parameters = set_params.merge parameters
status, headers, body = route.app.serve(req)
if "pass" == headers["X-Cascade"]
req.script_name = script_name
|
Extracted source (around line #32):
30
31
32
33
34
35
|
def serve(req)
find_routes(req).each do |match, parameters, route|
set_params = req.path_parameters
path_info = req.path_info
script_name = req.script_name
|
Extracted source (around line #32):
30
31
32
33
34
35
|
def serve(req)
find_routes(req).each do |match, parameters, route|
set_params = req.path_parameters
path_info = req.path_info
script_name = req.script_name
|
Extracted source (around line #837):
835
836
837
838
839
840
|
req = make_request(env)
req.path_info = Journey::Router::Utils.normalize_path(req.path_info)
@router.serve(req)
end
def recognize_path(path, environment = {})
|
Extracted source (around line #13):
11
12
13
14
15
16
|
app_request = AppRequest.new env["action_dispatch.request_id"]
app_request.current!
@app.call(env)
rescue Exception => exception
if defined?(ActionDispatch::ExceptionWrapper)
wrapper = if ActionDispatch::ExceptionWrapper.method_defined? :env
|
Extracted source (around line #13):
11
12
13
14
15
16
|
events_json(request_id)
else
@app.call(env)
end
end
|
Extracted source (around line #42):
40
41
42
43
44
45
|
# Default just move to next chain in Rack callstack
# calling with downcased uri if needed
@app.call(env)
end
private
|
Extracted source (around line #9):
7
8
9
10
11
12
|
def call(env)
dup._call(env)
end
def _call(env)
|
Extracted source (around line #32):
30
31
32
33
34
35
|
end
@app.call(env)
end
end
end
|
Extracted source (around line #36):
34
35
36
37
38
39
|
result = catch(:warden) do
env['warden'].on_request
@app.call(env)
end
result ||= {}
|
Extracted source (around line #34):
32
33
34
35
36
37
|
env['warden'] = Proxy.new(env, self)
result = catch(:warden) do
env['warden'].on_request
@app.call(env)
end
|
Extracted source (around line #34):
32
33
34
35
36
37
|
env['warden'] = Proxy.new(env, self)
result = catch(:warden) do
env['warden'].on_request
@app.call(env)
end
|
Extracted source (around line #15):
13
14
15
16
17
18
|
def call(env)
env[RACK_TEMPFILES] ||= []
status, headers, body = @app.call(env)
body_proxy = BodyProxy.new(body) do
env[RACK_TEMPFILES].each(&:close!) unless env[RACK_TEMPFILES].nil?
end
|
Extracted source (around line #27):
25
26
27
28
29
30
|
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 #27):
25
26
27
28
29
30
|
case env[REQUEST_METHOD]
when "GET", "HEAD"
status, headers, body = @app.call(env)
headers = Utils::HeaderHash[headers]
if status == 200 && fresh?(env, headers)
status = 304
|
Extracted source (around line #12):
10
11
12
13
14
15
|
def call(env)
status, headers, body = @app.call(env)
if env[REQUEST_METHOD] == HEAD
[
|
Extracted source (around line #18):
16
17
18
19
20
21
|
def call(env)
request = ActionDispatch::Request.new env
_, headers, _ = response = @app.call(env)
return response unless html_response?(headers)
return response if policy_present?(headers)
|
Extracted source (around line #266):
264
265
266
267
268
269
|
req = make_request env
prepare_session(req)
status, headers, body = app.call(req.env)
res = Rack::Response::Raw.new status, headers
commit_session(req, res)
[status, headers, body]
|
Extracted source (around line #260):
258
259
260
261
262
263
|
def call(env)
context(env)
end
def context(env, app = @app)
|
Extracted source (around line #648):
646
647
648
649
650
651
|
request = ActionDispatch::Request.new env
status, headers, body = @app.call(env)
if request.have_cookie_jar?
cookie_jar = request.cookie_jar
|
Extracted source (around line #567):
565
566
567
568
569
570
|
@last_check = mtime
end
@app.call(env)
end
private
|
Extracted source (around line #27):
25
26
27
28
29
30
|
error = nil
result = run_callbacks :call do
@app.call(env)
rescue => error
end
raise error if error
|
Extracted source (around line #101):
99
100
101
102
103
104
|
if callbacks.empty?
yield if block_given?
else
env = Filters::Environment.new(self, false, nil)
next_sequence = callbacks.compile
|
Extracted source (around line #26):
24
25
26
27
28
29
|
def call(env)
error = nil
result = run_callbacks :call do
@app.call(env)
rescue => error
end
|
Extracted source (around line #14):
12
13
14
15
16
17
|
state = @executor.run!
begin
response = @app.call(env)
returned = response << ::Rack::BodyProxy.new(response.pop) { state.complete! }
ensure
state.complete! unless returned
|
Extracted source (around line #17):
15
16
17
18
19
20
|
def call(env)
request = ActionDispatch::Request.new(env)
return @app.call(env) unless actionable_request?(request)
ActiveSupport::ActionableError.dispatch(request.params[:error].to_s.safe_constantize, request.params[:action])
|
Extracted source (around line #32):
30
31
32
33
34
35
|
def call(env)
request = ActionDispatch::Request.new env
_, headers, body = response = @app.call(env)
if headers["X-Cascade"] == "pass"
body.close if body.respond_to?(:close)
|
Extracted source (around line #132):
130
131
132
133
134
135
|
def call_app(env)
@app.call(env)
rescue => e
throw :app_exception, e
end
|
Extracted source (around line #19):
17
18
19
20
21
22
|
app_exception = catch :app_exception do
request = create_regular_or_whiny_request(env)
return call_app(env) unless request.permitted?
if id = id_for_repl_session_update(request)
return update_repl_session(id, request)
|
Extracted source (around line #17):
15
16
17
18
19
20
|
def call(env)
app_exception = catch :app_exception do
request = create_regular_or_whiny_request(env)
return call_app(env) unless request.permitted?
|
Extracted source (around line #17):
15
16
17
18
19
20
|
def call(env)
app_exception = catch :app_exception do
request = create_regular_or_whiny_request(env)
return call_app(env) unless request.permitted?
|
Extracted source (around line #17):
15
16
17
18
19
20
|
def call(env)
response = @app.call(env)
headers = Utils::HeaderHash.new(response[1])
@block.call(headers)
response[1] = headers
|
Extracted source (around line #16):
14
15
16
17
18
19
|
headers['X-Meta-Request-Version'] = MetaRequest::VERSION unless skip?(request_path)
end
middleware.call(env)
end
private
|
Extracted source (around line #33):
31
32
33
34
35
36
|
def call(env)
request = ActionDispatch::Request.new env
@app.call(env)
rescue Exception => exception
if request.show_exceptions?
render_exception(request, 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) }
status, headers, body = @app.call(env)
body = ::Rack::BodyProxy.new(body) { finish(request) }
[status, headers, body]
rescue Exception
|
Extracted source (around line #26):
24
25
26
27
28
29
|
if logger.respond_to?(:tagged)
logger.tagged(compute_tags(request)) { call_app(request, env) }
else
call_app(request, env)
end
|
Extracted source (around line #80):
78
79
80
81
82
83
|
def tagged(*tags)
formatter.tagged(*tags) { yield self }
end
def flush
|
Extracted source (around line #28):
26
27
28
29
30
31
|
def tagged(*tags)
new_tags = push_tags(*tags)
yield self
ensure
pop_tags(new_tags.size)
end
|
Extracted source (around line #80):
78
79
80
81
82
83
|
def tagged(*tags)
formatter.tagged(*tags) { yield self }
end
def flush
|
Extracted source (around line #26):
24
25
26
27
28
29
|
if logger.respond_to?(:tagged)
logger.tagged(compute_tags(request)) { call_app(request, env) }
else
call_app(request, env)
end
|
Extracted source (around line #13):
11
12
13
14
15
16
|
::Rails.logger.silence { @app.call(env) }
else
@app.call(env)
end
end
end
|
Extracted source (around line #81):
79
80
81
82
83
84
|
req = ActionDispatch::Request.new env
req.remote_ip = GetIp.new(req, check_ip, proxies)
@app.call(req.env)
end
# The GetIp class exists as a way to defer processing of the request data
|
Extracted source (around line #27):
25
26
27
28
29
30
|
req = ActionDispatch::Request.new env
req.request_id = make_request_id(req.x_request_id)
@app.call(env).tap { |_status, headers, _body| headers[X_REQUEST_ID] = req.request_id }
end
private
|
Extracted source (around line #24):
22
23
24
25
26
27
|
end
@app.call(env)
end
def method_override(env)
|
Extracted source (around line #22):
20
21
22
23
24
25
|
def call(env)
start_time = Utils.clock_time
status, headers, body = @app.call(env)
headers = Utils::HeaderHash[headers]
request_time = Utils.clock_time - start_time
|
Extracted source (around line #29):
27
28
29
30
31
32
|
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 #14):
12
13
14
15
16
17
|
state = @executor.run!
begin
response = @app.call(env)
returned = response << ::Rack::BodyProxy.new(response.pop) { state.complete! }
ensure
state.complete! unless returned
|
Extracted source (around line #126):
124
125
126
127
128
129
|
end
@app.call(req.env)
end
end
end
|
Extracted source (around line #110):
108
109
110
111
112
113
|
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 #83):
81
82
83
84
85
86
|
if authorized?(request)
mark_as_authorized(request)
@app.call(env)
else
@response_app.call(env)
end
|
Extracted source (around line #29):
27
28
29
30
31
32
|
super(env)
else
@app.call(env)
end
end
|
Extracted source (around line #57):
55
56
57
58
59
60
|
def call(env)
rewrite_response(perform_request(rewrite_env(env)))
end
# Return modified env
|
Extracted source (around line #526):
524
525
526
527
528
529
|
def call(env)
req = build_request env
app.call req.env
end
# Defines additional Rack env configuration that is added on each call.
|
Extracted source (around line #107):
105
106
107
108
109
110
|
begin
status, headers, body = @app.call(env)
rescue => e
if !should_swallow_app_error?(e, socket_wrapper)
# It's a good idea to catch application exceptions here because
|
Extracted source (around line #149):
147
148
149
150
151
152
|
begin
if headers[REQUEST_METHOD] == GET
process_request(headers, connection, socket_wrapper, @protocol == :http)
elsif headers[REQUEST_METHOD] == PING
process_ping(headers, connection)
false
|
Extracted source (around line #110):
108
109
110
111
112
113
|
finish_callback.call
while true
hijacked = accept_and_process_next_request(socket_wrapper, channel, buffer)
socket_wrapper = Utils::UnseekableSocket.new if hijacked
end
rescue Interrupted
|
Extracted source (around line #419):
417
418
419
420
421
422
|
handler = thread_handler.new(self, main_socket_options)
handler.install
handler.main_loop(set_initialization_state_to_true)
ensure
set_initialization_state.call(false)
unregister_current_thread
|
Extracted source (around line #113):
111
112
113
114
115
116
|
Thread.current.abort_on_exception = true
begin
yield(*args)
rescue SystemExit
raise
rescue Exception => e
|
Trace of template inclusion: #<ActionView::Template app/views/library/index.html.erb locals=[]>
Rails.root: /home/s.reinhold/www/hoe
Request
Parameters:
None
lang: "uk"
session_id: "887d43d0dfc834244435711d49d8e7dd"
HTTP_ACCEPT: "*/*"
HTTP_VERSION: "HTTP/1.1"
ORIGINAL_SCRIPT_NAME: ""
REMOTE_ADDR: "3.229.122.112"
SERVER_NAME: "devhoe.rein.dev.studio7.com.ua"
SERVER_PROTOCOL: "HTTP/1.1"
Response
Headers:
None