Class: WashOut::Router

Inherits:
Object
  • Object
show all
Defined in:
lib/wash_out/router.rb

Overview

This class is a Rack middleware used to route SOAP requests to a proper action of a given SOAP controller.

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(controller_name) ⇒ Router

Returns a new instance of Router.



41
42
43
 
# File 'lib/wash_out/router.rb', line 41

def initialize(controller_name)
  @controller_name = "#{controller_name.to_s}_controller".camelize
end

Class Method Details

.lookup_soap_routes(controller_name, routes, path = [], &block) ⇒ Object 



7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
 
# File 'lib/wash_out/router.rb', line 7

def self.lookup_soap_routes(controller_name, routes, path=[], &block)
  routes.each do |x|
    defaults = x.defaults
    defaults = defaults[:defaults] if defaults.include?(:defaults) # Rails 5
    if defaults[:controller] == controller_name && defaults[:action] == 'soap'
      yield path+[x]
    end

    app = x.app
    app = app.app if app.respond_to?(:app)
    if app.respond_to?(:routes) && app.routes.respond_to?(:routes)
      lookup_soap_routes(controller_name, app.routes.routes, path+[x], &block)
    end
  end
end

.url(request, controller_name) ⇒ Object 



23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
 
# File 'lib/wash_out/router.rb', line 23

def self.url(request, controller_name)
  lookup_soap_routes(controller_name, Rails.application.routes.routes) do |routes|

    path = if routes.first.respond_to?(:optimized_path)      # Rails 4
      routes.map(&:optimized_path)
    elsif routes.first.path.respond_to?(:build_formatter)    # Rails 5
      routes.map{|x| x.path.build_formatter.evaluate(nil)}
    else
      routes.map{|x| x.format({})}                           # Rails 3.2
    end

    if Rails.application.config.relative_url_root.present?
      path.prepend Rails.application.config.relative_url_root
    end
    return request.protocol + request.host_with_port + path.flatten.join('')
  end
end

Instance Method Details

#call(env) ⇒ Object 



107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
 
# File 'lib/wash_out/router.rb', line 107

def call(env)
  @controller = @controller_name.constantize

  soap_action = parse_soap_action(env)

  action = if soap_action.blank?
    '_invalid_request'
  else
    soap_parameters = parse_soap_parameters(env)
    action_spec     = controller.soap_actions[soap_action]

    if action_spec
      action_spec[:to]
    else
      '_invalid_action'
    end
  end
  env["action_dispatch.request.content_type"] = Mime[:soap]
  controller.action(action).call(env)
end

#controller ⇒ Object 



45
46
47
 
# File 'lib/wash_out/router.rb', line 45

def controller
  @controller
end

#nori(snakecase = false) ⇒ Object 



74
75
76
77
78
79
80
81
82
83
84
 
# File 'lib/wash_out/router.rb', line 74

def nori(snakecase=false)
  Nori.new(
    :parser => controller.soap_config.parser,
    :strip_namespaces => true,
    :advanced_typecasting => true,
    :convert_tags_to => (
      snakecase ? lambda { |tag| tag.snakecase.to_sym }
                : lambda { |tag| tag.to_sym }
    )
  )
end

#parse_soap_action(env) ⇒ Object 



49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
 
# File 'lib/wash_out/router.rb', line 49

def parse_soap_action(env)
  return env['wash_out.soap_action'] if env['wash_out.soap_action']

  soap_action = controller.soap_config.soap_action_routing ? env['HTTP_SOAPACTION'].to_s.gsub(/^"(.*)"$/, '\1')
                                                           : ''
  if soap_action.blank?
    parsed_soap_body = nori(controller.soap_config.snakecase_input).parse(soap_body env)
    return nil if parsed_soap_body.blank?

    soap_action = parsed_soap_body.values_at(:envelope, :Envelope).try(:compact).try(:first)
    soap_action = soap_action.values_at(:body, :Body).try(:compact).try(:first) if soap_action
    soap_action = soap_action.keys.first.to_s if soap_action
  end

  # RUBY18 1.8 does not have force_encoding.
  soap_action.force_encoding('UTF-8') if soap_action.respond_to? :force_encoding

  if controller.soap_config.namespace
    namespace = Regexp.escape controller.soap_config.namespace.to_s
    soap_action.gsub!(/^(#{namespace}(\/|#)?)?([^"]*)$/, '\3')
  end

  env['wash_out.soap_action'] = soap_action
end

#parse_soap_parameters(env) ⇒ Object 



94
95
96
97
98
99
100
101
102
103
104
105
 
# File 'lib/wash_out/router.rb', line 94

def parse_soap_parameters(env)
  return env['wash_out.soap_data'] if env['wash_out.soap_data']
  env['wash_out.soap_data'] = nori(controller.soap_config.snakecase_input).parse(soap_body env)
  references = WashOut::Dispatcher.deep_select(env['wash_out.soap_data']){|v| v.is_a?(Hash) && v.has_key?(:@id)}

  unless references.blank?
    replaces = {}; references.each{|r| replaces['#'+r[:@id]] = r}
    env['wash_out.soap_data'] = WashOut::Dispatcher.deep_replace_href(env['wash_out.soap_data'], replaces)
  end

  env['wash_out.soap_data']
end

#soap_body(env) ⇒ Object 



86
87
88
89
90
91
92
 
# File 'lib/wash_out/router.rb', line 86

def soap_body(env)
  body = env['rack.input']
  body.rewind if body.respond_to? :rewind
  body.respond_to?(:string) ? body.string : body.read
ensure
  body.rewind if body.respond_to? :rewind
end