Class: Netfira::WebConnect::RequestFilter

Inherits:
Object
  • Object
show all
Defined in:
lib/netfira/web_connect/request_filter.rb

Instance Method Summary collapse

Constructor Details

#initialize(app) ⇒ RequestFilter

Returns a new instance of RequestFilter.



7
8
9
 
# File 'lib/netfira/web_connect/request_filter.rb', line 7

def initialize(app)
  @app = app
end

Instance Method Details

#call(env) ⇒ Object 



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
 
# File 'lib/netfira/web_connect/request_filter.rb', line 11

def call(env)
  begin
    if (env['CONTENT_TYPE'] || env['HTTP_CONTENT_TYPE']) == 'application/x-netfira-webconnect-packed'
      begin
        unpack env
      rescue Zlib::GzipFile::Error, Zlib::DataError => e
        return [400, {}, {errorCode: 19, errorMessage: "Decompression error: #{e.message}"}]
      end
    end
    env['WC_ACCEPTABLE_REQUEST_TYPES'] = %w[packed unpacked]
    @app.call env
  rescue Exception => error
    # TODO: this mirrors code in rack_app.rb. Consolidate?
    [
        500,
        {'Content-Type' => 'application/json'},
        {
            errorCode: 1,
            errorMessage: 'Uncaught Exception',
            exception: {
                class: error.class.name,
                message: error.message,
                backtrace: error.backtrace
            }
        }
    ]
  end
end

#unpack(env) ⇒ Object 



40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
 
# File 'lib/netfira/web_connect/request_filter.rb', line 40

def unpack(env)
  env['original.rack.input'] = input = env['rack.input']

  input = case env['CONTENT_ENCODING'] || env['HTTP_CONTENT_ENCODING']
    when 'gzip' then Zlib::GzipReader.new(input)
    when 'deflate' then StringIO.new(Zlib::Inflate.inflate input.read)
    else input
  end

  method, path, query_string, headers, body = parse_request(input)

  %w[REQUEST_METHOD PATH_INFO QUERY_STRING].each{ |field| env["OUTER_#{field}"] = env[field] }

  env['REQUEST_METHOD'] = method
  env['PATH_INFO'] = path
  env['QUERY_STRING'] = query_string || ''

  headers.each do |key, value|
    field = key =~ /^content\b/i ? '' : 'HTTP_'
    field << key.upcase.gsub('-', '_')
    env["OUTER_#{field}"] = env[field] if env[field]
    env[field] = value
  end

  env['rack.input'] = StringIO.new(body || '')
end