Class: Fluent::HttpEnhanced

Inherits:
HttpInput
  • Object
show all
Defined in:
lib/fluent/plugin/in_httpenhanced.rb

Constant Summary collapse

CROSSDOMAIN_XML = 
<<EOF
<?xml version="1.0"?>
<!DOCTYPE cross-domain-policy SYSTEM "http://www.macromedia.com/xml/dtds/cross-domain-policy.dtd">
<cross-domain-policy>
    <allow-access-from domain="*" />
</cross-domain-policy>
EOF

Instance Method Summary collapse

Instance Method Details

#on_request(path_info, params) ⇒ Object 



9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
 
# File 'lib/fluent/plugin/in_httpenhanced.rb', line 9

def on_request(path_info, params)
  if @full_query_string_record == true
    begin
      path = path_info[1..-1] # remove /
      tag = path.split('/').join('.')
      return ["200 OK", {'Content-type'=>'text/xml'}, CROSSDOMAIN_XML]unless tag.downcase.match("crossdomain.xml").nil?

      tag = @default_tag if tag == '' && @default_tag != ''
      record = params
      time = (params['time'] || params['t'] || Engine.now).to_i
      # Just make sure that it's a 10-digit epoch time in seconds not milliseconds
      if time >= 10**10
        time /= 1000
      end
    rescue
      return ["400 Bad Request", {'Content-type'=>'text/plain'}, "400 Bad Request\n#{$!}\n"]
    end
    begin
      Engine.emit(tag, time, record)
    rescue
      return ["500 Internal Server Error", {'Content-type'=>'text/plain'}, "500 Internal Server Error\n#{$!}\n"]
    end

    if @respond_with_empty_img == true
      return ["200 OK", {'Content-type'=>'image/gif'}, "GIF89a\u0001\u0000\u0001\u0000\x80\xFF\u0000\xFF\xFF\xFF\u0000\u0000\u0000,\u0000\u0000\u0000\u0000\u0001\u0000\u0001\u0000\u0000\u0002\u0002D\u0001\u0000;"]
    else
      return ["200 OK", {'Content-type'=>'text/plain'}, ""]
    end
  else
    super(path_info, params)
  end
end