scaffolding.rb 8.3 KB
Newer Older
1 2
require 'ostruct'
require 'uri'
3
require 'benchmark'
4
require 'pathname'
5 6 7

module ActionWebService
  module Scaffolding # :nodoc:
8 9 10
    class ScaffoldingError < ActionWebServiceError # :nodoc:
    end

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 41 42 43 44 45 46 47
    def self.append_features(base)
      super
      base.extend(ClassMethods)
    end

    # Web service invocation scaffolding provides a way to quickly invoke web service methods in a controller. The
    # generated scaffold actions have default views to let you enter the method parameters and view the
    # results.
    #
    # Example:
    #
    #   class ApiController < ActionController
    #     web_service_scaffold :invoke
    #   end
    #
    # This example generates an +invoke+ action in the +ApiController+ that you can navigate to from
    # your browser, select the API method, enter its parameters, and perform the invocation.
    #
    # If you want to customize the default views, create the following views in "app/views":
    #
    # * <tt>action_name/methods.rhtml</tt>
    # * <tt>action_name/parameters.rhtml</tt>
    # * <tt>action_name/result.rhtml</tt>
    # * <tt>action_name/layout.rhtml</tt>
    #
    # Where <tt>action_name</tt> is the name of the action you gave to ClassMethods#web_service_scaffold.
    #
    # You can use the default views in <tt>RAILS_DIR/lib/action_web_service/templates/scaffolds</tt> as
    # a guide.
    module ClassMethods
      # Generates web service invocation scaffolding for the current controller. The given action name
      # can then be used as the entry point for invoking API methods from a web browser.
      def web_service_scaffold(action_name)
        add_template_helper(Helpers)
        module_eval <<-END, __FILE__, __LINE__
          def #{action_name}
            if @request.method == :get
48 49
              setup_invocation_assigns
              render_invocation_scaffold 'methods'
50 51 52 53 54
            end
          end

          def #{action_name}_method_params
            if @request.method == :get
55 56
              setup_invocation_assigns
              render_invocation_scaffold 'parameters'
57 58 59 60 61
            end
          end

          def #{action_name}_submit
            if @request.method == :post
62
              setup_invocation_assigns
63 64 65 66 67 68 69
              protocol_name = @params['protocol'] ? @params['protocol'].to_sym : :soap
              case protocol_name
              when :soap
                protocol = Protocol::Soap::SoapProtocol.new
              when :xmlrpc
                protocol = Protocol::XmlRpc::XmlRpcProtocol.new
              end
70
              @invocation_cgi = @request.respond_to?(:cgi) ? @request.cgi : nil
71
              bm = Benchmark.measure do
72 73 74 75
                protocol.register_api(@scaffold_service.api)
                params = @params['method_params'] ? @params['method_params'].dup : nil
                params = @scaffold_method.cast_expects(params)
                @method_request_xml = protocol.encode_request(@scaffold_method.public_name, params, @scaffold_method.expects)
76 77 78
                new_request = protocol.encode_action_pack_request(@scaffold_service.name, @scaffold_method.public_name, @method_request_xml)
                new_request.parameters.update(@request.parameters)
                @request = new_request
79 80
                dispatch_web_service_request
                @method_response_xml = @response.body
81
                method_name, obj = protocol.decode_response(@method_response_xml)
82
                return if handle_invocation_exception(obj)
83
                @method_return_value = @scaffold_method.cast_returns(obj)
84 85
              end
              @method_elapsed = bm.real
86
              add_instance_variables_to_assigns
87 88
              reset_invocation_response
              render_invocation_scaffold 'result'
89 90 91 92
            end
          end

          private
93
            def setup_invocation_assigns
94 95 96 97 98 99 100 101 102 103
              @scaffold_class = self.class
              @scaffold_action_name = "#{action_name}"
              @scaffold_container = WebServiceModel::Container.new(self)
              if @params['service'] && @params['method']
                @scaffold_service = @scaffold_container.services.find{ |x| x.name == @params['service'] }
                @scaffold_method = @scaffold_service.api_methods[@params['method']]
              end
              add_instance_variables_to_assigns
            end

104
            def render_invocation_scaffold(action)
105 106 107 108 109 110 111
              customized_template = "\#{self.class.controller_path}/#{action_name}/\#{action}"
              default_template = scaffold_path(action)
              @content_for_layout = template_exists?(customized_template) ? @template.render_file(customized_template) : @template.render_file(default_template, false)
              self.active_layout ? render_file(self.active_layout, "200 OK", true) : render_file(scaffold_path("layout"))
            end

            def scaffold_path(template_name)
112
              Pathname.new(File.dirname(__FILE__) + "/templates/scaffolds/" + template_name + ".rhtml").realpath.to_s
113
            end
114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137

            def reset_invocation_response
              template = @response.template
              if @invocation_cgi
                @response = ::ActionController::CgiResponse.new(@invocation_cgi)
              else
                @response = ::ActionController::TestResponse.new
              end
              @response.template = template
              @performed_render = false
            end

            def handle_invocation_exception(obj)
              exception = nil
              if obj.respond_to?(:detail) && obj.detail.respond_to?(:cause) && obj.detail.cause.is_a?(Exception)
                exception = obj.detail.cause
              elsif obj.is_a?(XMLRPC::FaultException)
                exception = obj
              end
              return unless exception
              reset_invocation_response
              rescue_action(exception)
              true
            end
138 139 140 141 142
        END
      end
    end

    module Helpers # :nodoc:
143 144 145 146
      def method_parameter_input_fields(method, type)
        name = type.name.to_s
        type_name = type.type
        unless type_name.is_a?(Symbol)
147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185
          raise "Parameter #{name}: Structured/array types not supported in scaffolding input fields yet"
        end
        field_name = "method_params[]"
        case type_name
        when :int
          text_field_tag field_name
        when :string
          text_field_tag field_name
        when :bool
          radio_button_tag field_name, "True"
          radio_button_tag field_name, "False"
        when :float
          text_field_tag field_name
        when :time
          select_datetime Time.now, 'name' => field_name
        when :date
          select_date Date.today, 'name' => field_name
        end
      end

      def service_method_list(service)
        action = @scaffold_action_name + '_method_params'
        methods = service.api_methods_full.map do |desc, name|
          content_tag("li", link_to(desc, :action => action, :service => service.name, :method => name))
        end
        content_tag("ul", methods.join("\n"))
      end
    end

    module WebServiceModel # :nodoc:
      class Container # :nodoc:
        attr :services

        def initialize(real_container)
          @real_container = real_container
          @services = []
          if @real_container.class.web_service_dispatching_mode == :direct
            @services << Service.new(@real_container.controller_name, @real_container)
          else
186
            @real_container.class.web_services.each do |name, obj|
187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203
              @services << Service.new(name, @real_container.instance_eval{ web_service_object(name) })
            end
          end
        end
      end

      class Service # :nodoc:
        attr :name
        attr :object
        attr :api
        attr :api_methods
        attr :api_methods_full

        def initialize(name, real_service)
          @name = name.to_s
          @object = real_service
          @api = @object.class.web_service_api
204 205 206
          if @api.nil?
            raise ScaffoldingError, "No web service API attached to #{object.class}"
          end
207 208 209 210 211 212 213 214 215 216 217 218 219 220 221
          @api_methods = {}
          @api_methods_full = []
          @api.api_methods.each do |name, method|
            @api_methods[method.public_name.to_s] = method
            @api_methods_full << [method.to_s, method.public_name.to_s]
          end
        end

        def to_s
          self.name.camelize
        end
      end
    end
  end
end