module Bullet class Rack include Dependency def initialize(app) @app = app end def call(env) return @app.call(env) unless Bullet.enable? Bullet.start_request status, headers, response = @app.call(env) response_body = nil if Bullet.notification? if !file?(headers) && !sse?(headers) && !empty?(response) && status == 200 && !response_body(response).frozen? && html_request?(headers, response) response_body = response_body(response) append_to_html_body(response_body, footer_note) if Bullet.add_footer append_to_html_body(response_body, Bullet.gather_inline_notifications) headers['Content-Length'] = response_body.bytesize.to_s end Bullet.perform_out_of_channel_notifications(env) end [status, headers, response_body ? [response_body] : response] ensure Bullet.end_request end # fix issue if response's body is a Proc def empty?(response) # response may be ["Not Found"], ["Move Permanently"], etc. if rails? (response.is_a?(Array) && response.size <= 1) || !response.respond_to?(:body) || !response_body(response).respond_to?(:empty?) || response_body(response).empty? else body = response_body(response) body.nil? || body.empty? end end def append_to_html_body(response_body, content) if response_body.include?('') position = response_body.rindex('') response_body.insert(position, content) else response_body << content end end def footer_note "
" + Bullet.footer_info.uniq.join("
") + "
" end def file?(headers) headers["Content-Transfer-Encoding"] == "binary" end def sse?(headers) headers["Content-Type"] == "text/event-stream" end def html_request?(headers, response) headers['Content-Type'] && headers['Content-Type'].include?('text/html') && response_body(response).include?("