Could not find pdftk in any of /usr/bin, /usr/local/bin
Extracted source (around line #73):
71
72
73
74
75
76
|
return program_path if File.file? program_path and File.executable? program_path
end
raise "Could not find #{program_name} in any of #{search_path.join(', ')}"
end
end
end
|
Extracted source (around line #30):
28
29
30
31
32
33
|
end
program_path = find_program(program_name)
xc = ExternalCommand.new(program_path, *args)
begin
xc.run
|
Extracted source (around line #49):
47
48
49
50
51
52
|
def uncompress_pdf(text)
AlaveteliExternalCommand.run("pdftk", "-", "output", "-", "uncompress", :stdin_string => text)
end
def compress_pdf(text)
|
Extracted source (around line #70):
68
69
70
71
72
73
|
def apply_pdf_masks(text, options = {})
uncompressed_text = uncompress_pdf(text)
# if we managed to uncompress the PDF...
if uncompressed_text.blank?
text
|
Extracted source (around line #36):
34
35
36
37
38
39
|
case content_type
when 'application/pdf'
apply_pdf_masks(text, options)
when *TextMask
apply_text_masks(text, options)
when *DoNotBinaryMask
|
Extracted source (around line #291):
289
290
291
292
293
294
|
mask_options = { :censor_rules => info_request.applicable_censor_rules,
:masks => info_request.masks }
AlaveteliTextMasker.apply_masks(text, content_type, mask_options)
end
# Lotus notes quoting yeuch!
|
Extracted source (around line #17):
15
16
17
18
19
20
|
# Prevent spam to magic request address. Note that the binary
# substitution method used depends on the content type
body = @incoming_message.apply_masks(
@attachment.default_body,
@attachment.content_type
)
|
Extracted source (around line #4):
2
3
4
5
6
7
|
module BasicImplicitRender # :nodoc:
def send_action(method, *args)
super.tap { default_render unless performed? }
end
def default_render(*args)
|
Extracted source (around line #186):
184
185
186
187
188
189
|
# 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 #20):
18
19
20
21
22
23
|
def process_action(*args)
run_callbacks(:process_action) do
super
end
end
|
Extracted source (around line #108):
106
107
108
109
110
111
|
current.invoke_before(env)
if current.final?
env.value = !env.halted && (!block_given? || yield)
elsif current.skip?(env)
(skipped ||= []) << current
next_sequence = next_sequence.nested
|
Extracted source (around line #129):
127
128
129
130
131
132
|
end
yield
if params[:skip_cache].nil? && response.status == 200
# write it to the filesystem ourselves, so is just a plain file. (The
|
Extracted source (around line #117):
115
116
117
118
119
120
|
begin
target, block, method, *arguments = current.expand_call_template(env, invoke_sequence)
target.send(method, *arguments, &block)
ensure
next_sequence = current
end
|
Extracted source (around line #117):
115
116
117
118
119
120
|
logger.info("PID: #{Process.pid}\tCONSUME MEMORY: #{rss_after_action - rss_before_action} KB\tNow: #{rss_after_action} KB\t#{request.url}")
else
yield
end
end
|
Extracted source (around line #117):
115
116
117
118
119
120
|
begin
target, block, method, *arguments = current.expand_call_template(env, invoke_sequence)
target.send(method, *arguments, &block)
ensure
next_sequence = current
end
|
Extracted source (around line #135):
133
134
135
136
137
138
|
env.value
else
invoke_sequence.call
end
end
end
|
Extracted source (around line #19):
17
18
19
20
21
22
|
# process_action callbacks around the normal behavior.
def process_action(*args)
run_callbacks(:process_action) do
super
end
end
|
Extracted source (around line #20):
18
19
20
21
22
23
|
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 #32):
30
31
32
33
34
35
|
ActiveSupport::Notifications.instrument("process_action.action_controller", raw_payload) do |payload|
begin
result = super
payload[:status] = response.status
result
ensure
|
Extracted source (around line #166):
164
165
166
167
168
169
|
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 #21):
19
20
21
22
23
24
|
listeners_state = start name, payload
begin
yield payload
rescue Exception => e
payload[:exception] = [e.class.name, e.message]
payload[:exception_object] = e
|
Extracted source (around line #166):
164
165
166
167
168
169
|
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 #30):
28
29
30
31
32
33
|
ActiveSupport::Notifications.instrument("start_processing.action_controller", raw_payload.dup)
ActiveSupport::Notifications.instrument("process_action.action_controller", raw_payload) do |payload|
begin
result = super
payload[:status] = response.status
|
Extracted source (around line #252):
250
251
252
253
254
255
|
request.filtered_parameters.merge! wrapped_filtered_hash
end
super
end
private
|
Extracted source (around line #22):
20
21
22
23
24
25
|
# 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 #124):
122
123
124
125
126
127
|
@_response_body = nil
process_action(action_name, *args)
end
# Delegates to the class' ::controller_path
|
Extracted source (around line #30):
28
29
30
31
32
33
|
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 #189):
187
188
189
190
191
192
|
set_request!(request)
set_response!(response)
process(name)
request.commit_flash
to_a
end
|
Extracted source (around line #253):
251
252
253
254
255
256
|
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 #49):
47
48
49
50
51
52
|
def dispatch(controller, action, req, res)
controller.dispatch(action, req, res)
end
end
|
Extracted source (around line #31):
29
30
31
32
33
34
|
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 #50):
48
49
50
51
52
53
|
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 #33):
31
32
33
34
35
36
|
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 #33):
31
32
33
34
35
36
|
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 #844):
842
843
844
845
846
847
|
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 #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #12):
10
11
12
13
14
15
|
def call(env)
return @app.call(env) unless Bullet.enable?
Bullet.start_request
status, headers, response = @app.call(env)
|
Extracted source (around line #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #30):
28
29
30
31
32
33
|
def traced_call(env)
@app.call(env)
end
end
end
|
Extracted source (around line #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #32):
30
31
32
33
34
35
|
def traced_call(env)
result = @app.call(env)
(status, headers, response) = result
js_to_inject = NewRelic::Agent.browser_timing_header
|
Extracted source (around line #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #25):
23
24
25
26
27
28
|
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 #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
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 #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
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 #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #259):
257
258
259
260
261
262
|
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 #253):
251
252
253
254
255
256
|
def call(env)
context(env)
end
def context(env, app=@app)
|
Extracted source (around line #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #613):
611
612
613
614
615
616
|
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 #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #13):
11
12
13
14
15
16
|
def call(env)
status, headers, body = @app.call(env)
session_data = env[ENV_SESSION_KEY]
set_cookie = headers[HTTP_SET_COOKIE]
if session_data
|
Extracted source (around line #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #556):
554
555
556
557
558
559
|
@last_check = mtime
end
@app.call(env)
end
private
|
Extracted source (around line #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #26):
24
25
26
27
28
29
|
result = run_callbacks :call do
begin
@app.call(env)
rescue => error
end
end
|
Extracted source (around line #97):
95
96
97
98
99
100
|
if callbacks.empty?
yield if block_given?
else
env = Filters::Environment.new(self, false, nil)
next_sequence = callbacks.compile
|
Extracted source (around line #24):
22
23
24
25
26
27
|
def call(env)
error = nil
result = run_callbacks :call do
begin
@app.call(env)
rescue => error
|
Extracted source (around line #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #12):
10
11
12
13
14
15
|
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 #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #59):
57
58
59
60
61
62
|
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 #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #135):
133
134
135
136
137
138
|
def call_app(env)
@app.call(env)
rescue => e
throw :app_exception, e
end
|
Extracted source (around line #22):
20
21
22
23
24
25
|
app_exception = catch :app_exception do
request = create_regular_or_whiny_request(env)
return call_app(env) unless request.from_whitelisted_ip?
if id = id_for_repl_session_update(request)
return update_repl_session(id, request)
|
Extracted source (around line #20):
18
19
20
21
22
23
|
def call(env)
app_exception = catch :app_exception do
request = create_regular_or_whiny_request(env)
return call_app(env) unless request.from_whitelisted_ip?
|
Extracted source (around line #20):
18
19
20
21
22
23
|
def call(env)
app_exception = catch :app_exception do
request = create_regular_or_whiny_request(env)
return call_app(env) unless request.from_whitelisted_ip?
|
Extracted source (around line #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #31):
29
30
31
32
33
34
|
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 #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #36):
34
35
36
37
38
39
|
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 #24):
22
23
24
25
26
27
|
if logger.respond_to?(:tagged)
logger.tagged(compute_tags(request)) { call_app(request, env) }
else
call_app(request, env)
end
|
Extracted source (around line #69):
67
68
69
70
71
72
|
def tagged(*tags)
formatter.tagged(*tags) { yield self }
end
def flush
|
Extracted source (around line #26):
24
25
26
27
28
29
|
def tagged(*tags)
new_tags = push_tags(*tags)
yield self
ensure
pop_tags(new_tags.size)
end
|
Extracted source (around line #69):
67
68
69
70
71
72
|
def tagged(*tags)
formatter.tagged(*tags) { yield self }
end
def flush
|
Extracted source (around line #24):
22
23
24
25
26
27
|
if logger.respond_to?(:tagged)
logger.tagged(compute_tags(request)) { call_app(request, env) }
else
call_app(request, env)
end
|
Extracted source (around line #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
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 #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #79):
77
78
79
80
81
82
|
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 #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #19):
17
18
19
20
21
22
|
RequestStore.begin!
response = @app.call(env)
returned = response << Rack::BodyProxy.new(response.pop) do
RequestStore.end!
|
Extracted source (around line #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #25):
23
24
25
26
27
28
|
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 #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #22):
20
21
22
23
24
25
|
end
@app.call(env)
end
def method_override(env)
|
Extracted source (around line #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
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)
request_time = Utils.clock_time - start_time
unless headers.has_key?(@header_name)
|
Extracted source (around line #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #27):
25
26
27
28
29
30
|
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 #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #12):
10
11
12
13
14
15
|
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 #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #125):
123
124
125
126
127
128
|
end
@app.call(req.env)
end
end
end
|
Extracted source (around line #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #111):
109
110
111
112
113
114
|
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 #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #19):
17
18
19
20
21
22
|
def call(env)
@app.call(sanitize(env))
end
# http://rack.rubyforge.org/doc/SPEC.html
|
Extracted source (around line #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #12):
10
11
12
13
14
15
|
def call(env)
req = Rack::Request.new(env)
status, headers, response = @app.call(env)
config = SecureHeaders.config_for(req)
if config.hpkp_report_host == req.host
|
Extracted source (around line #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #522):
520
521
522
523
524
525
|
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 #99):
97
98
99
100
101
102
|
events.notify(:before_call, env) if first_middleware
result = (target == self) ? traced_call(env) : target.call(env)
if first_middleware
capture_response_attributes(state, result)
|
Extracted source (around line #81):
79
80
81
82
83
84
|
catch(:async) do
# Process the request calling the Rack adapter
response = @app.call(@request.env)
end
response
rescue Exception
|
Extracted source (around line #79):
77
78
79
80
81
82
|
# 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 #79):
77
78
79
80
81
82
|
# 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 #54):
52
53
54
55
56
57
|
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 "!! Invalid request"
log_error e
|
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 #63):
61
62
63
64
65
66
|
starter.call
else
EventMachine.run(&starter)
end
end
|
Extracted source (around line #159):
157
158
159
160
161
162
|
log ">> Listening on #{@backend}, CTRL+C to stop"
@backend.start
end
alias :start! :start
|
Extracted source (around line #22):
20
21
22
23
24
25
|
server = ::Thin::Server.new(*args)
yield server if block_given?
server.start
end
def self.valid_options
|
Extracted source (around line #297):
295
296
297
298
299
300
|
end
server.run wrapped_app, options, &blk
end
def server
|
Extracted source (around line #44):
42
43
44
45
46
47
|
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 #135):
133
134
135
136
137
138
|
require APP_PATH
Dir.chdir(Rails.application.root)
server.start
end
end
|
Extracted source (around line #130):
128
129
130
131
132
133
|
def perform
set_application_directory!
Rails::Server.new(server_options).tap do |server|
# Require application after server sets environment to propagate
# the --environment option.
require APP_PATH
|
Extracted source (around line #130):
128
129
130
131
132
133
|
def perform
set_application_directory!
Rails::Server.new(server_options).tap do |server|
# Require application after server sets environment to propagate
# the --environment option.
require APP_PATH
|
Extracted source (around line #27):
25
26
27
28
29
30
|
elsif public_method?(instance)
arity = instance.method(name).arity
instance.__send__(name, *args)
elsif local_method?(instance, :method_missing)
instance.__send__(:method_missing, name.to_sym, *args)
else
|
Extracted source (around line #126):
124
125
126
127
128
129
|
unless current.include?(command.name)
current << command.name
command.run(self, *args)
end
end
alias_method :invoke_task, :invoke_command
|
Extracted source (around line #369):
367
368
369
370
371
372
|
args = instance.args
trailing = args[Range.new(arguments.size, -1)]
instance.invoke_command(command, trailing || [])
end
# The banner for this class. You can customize it if you are invoking the
|
Extracted source (around line #63):
61
62
63
64
65
66
|
end
dispatch(command, args.dup, nil, config)
end
def printing_commands
|
Extracted source (around line #44):
42
43
44
45
46
47
|
command = find_by_namespace(namespace, command_name)
if command && command.all_commands[command_name]
command.perform(command_name, args, config)
else
find_by_namespace("rake").perform(full_namespace, args, config)
end
|
Extracted source (around line #16):
14
15
16
|
command = aliases[command] || command
Rails::Command.invoke command, ARGV
|
Extracted source (around line #4):
2
3
4
|
APP_PATH = File.expand_path('../config/application', __dir__)
require_relative '../config/boot'
require 'rails/commands'
|
Extracted source (around line #4):
2
3
4
|
APP_PATH = File.expand_path('../config/application', __dir__)
require_relative '../config/boot'
require 'rails/commands'
|
Rails.root: /opt/alaveteli
Request
Parameters:
{"id"=>"119", "incoming_message_id"=>"92", "part"=>"2", "file_name"=>"34 190.PDF.pdf"}
locale: "mk_MK"
session_id: "44ba17dfa51a16bd6d8407c096b98112"
GATEWAY_INTERFACE: "CGI/1.2"
HTTP_ACCEPT: "*/*"
HTTP_VERSION: "HTTP/1.0"
HTTP_X_FORWARDED_FOR: "slobodenpristap.mk"
ORIGINAL_SCRIPT_NAME: ""
REMOTE_ADDR: "192.168.1.4"
SERVER_NAME: "slobodenpristap.mk"
SERVER_PROTOCOL: "HTTP/1.1"
Response
Headers:
None