mapper.rb 16.0 KB
Newer Older
J
Joshua Peek 已提交
1 2
module ActionDispatch
  module Routing
J
Joshua Peek 已提交
3
    class Mapper
4
      class Constraints
5
        def self.new(app, constraints = [])
6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21
          if constraints.any?
            super(app, constraints)
          else
            app
          end
        end

        def initialize(app, constraints = [])
          @app, @constraints = app, constraints
        end

        def call(env)
          req = Rack::Request.new(env)

          @constraints.each { |constraint|
            if constraint.respond_to?(:matches?) && !constraint.matches?(req)
J
Joshua Peek 已提交
22
              return [ 404, {'X-Cascade' => 'pass'}, [] ]
23
            elsif constraint.respond_to?(:call) && !constraint.call(req)
J
Joshua Peek 已提交
24
              return [ 404, {'X-Cascade' => 'pass'}, [] ]
25 26 27 28 29 30 31
            end
          }

          @app.call(env)
        end
      end

32 33 34 35
      class Mapping
        def initialize(set, scope, args)
          @set, @scope    = set, scope
          @path, @options = extract_path_and_options(args)
36
        end
J
Joshua Peek 已提交
37

38 39
        def to_route
          [ app, conditions, requirements, defaults, @options[:as] ]
40
        end
J
Joshua Peek 已提交
41

42 43
        private
          def extract_path_and_options(args)
44
            options = args.extract_options!
45

46 47
            case
            when using_to_shorthand?(args, options)
48 49
              path, to = options.find { |name, value| name.is_a?(String) }
              options.merge!(:to => to).delete(path) if path
50 51 52
            when using_match_shorthand?(args, options)
              path = args.first
              options = { :to => path.gsub("/", "#"), :as => path.gsub("/", "_") }
53 54 55
            else
              path = args.first
            end
J
Joshua Peek 已提交
56

57
            [ normalize_path(path), options ]
58
          end
59

60 61 62 63
          # match "account" => "account#index"
          def using_to_shorthand?(args, options)
            args.empty? && options.present?
          end
64

65 66
          # match "account/overview"
          def using_match_shorthand?(args, options)
67
            args.present? && options.except(:via).empty? && !args.first.include?(':')
68
          end
69

70 71 72
          def normalize_path(path)
            path = nil if path == ""
            path = "#{@scope[:path]}#{path}" if @scope[:path]
J
Joshua Peek 已提交
73
            path = Rack::Mount::Utils.normalize_path(path) if path
74

75
            raise ArgumentError, "path is required" unless path
J
Joshua Peek 已提交
76 77

            path
78
          end
79

80 81 82 83 84
          def app
            Constraints.new(
              to.respond_to?(:call) ? to : Routing::RouteSet::Dispatcher.new(:defaults => defaults),
              blocks
            )
85 86
          end

87 88 89
          def conditions
            { :path_info => @path }.merge(constraints).merge(request_method_condition)
          end
J
Joshua Peek 已提交
90

91 92 93 94 95 96 97
          def requirements
            @requirements ||= returning(@options[:constraints] || {}) do |requirements|
              requirements.reverse_merge!(@scope[:constraints]) if @scope[:constraints]
              @options.each { |k, v| requirements[k] = v if v.is_a?(Regexp) }
              requirements[:controller] ||= @set.controller_constraints
            end
          end
98

99 100 101 102 103 104 105 106 107
          def defaults
            @defaults ||= if to.respond_to?(:call)
              { }
            else
              defaults = case to
              when String
                controller, action = to.split('#')
                { :controller => controller, :action => action }
              when Symbol
108
                { :action => to.to_s }.merge(default_controller ? { :controller => default_controller } : {})
109
              else
110
                default_controller ? { :controller => default_controller } : {}
111
              end
J
Joshua Peek 已提交
112

113 114 115
              if defaults[:controller].blank? && segment_keys.exclude?("controller")
                raise ArgumentError, "missing :controller"
              end
J
Joshua Peek 已提交
116

117 118 119
              if defaults[:action].blank? && segment_keys.exclude?("action")
                raise ArgumentError, "missing :action"
              end
J
Joshua Peek 已提交
120

121 122 123
              defaults
            end
          end
124

125 126 127 128 129 130
          def blocks
            if @options[:constraints].present? && !@options[:constraints].is_a?(Hash)
              block = @options[:constraints]
            else
              block = nil
            end
J
Joshua Peek 已提交
131 132

            ((@scope[:blocks] || []) + [ block ]).compact
133
          end
J
Joshua Peek 已提交
134

135 136 137
          def constraints
            @constraints ||= requirements.reject { |k, v| segment_keys.include?(k.to_s) || k == :controller }
          end
138

139 140 141 142 143 144
          def request_method_condition
            if via = @options[:via]
              via = Array(via).map { |m| m.to_s.upcase }
              { :request_method => Regexp.union(*via) }
            else
              { }
145
            end
146
          end
J
Joshua Peek 已提交
147

148 149 150 151 152
          def segment_keys
            @segment_keys ||= Rack::Mount::RegexpWithNamedGroups.new(
                Rack::Mount::Strexp.compile(@path, requirements, SEPARATORS)
              ).names
          end
153

154 155 156
          def to
            @options[:to]
          end
J
Joshua Peek 已提交
157

158 159
          def default_controller
            @scope[:controller].to_s if @scope[:controller]
160
          end
161
      end
162

163 164 165 166
      module Base
        def initialize(set)
          @set = set
        end
167

168 169 170
        def root(options = {})
          match '/', options.reverse_merge(:as => :root)
        end
171

172 173 174 175
        def match(*args)
          @set.add_route(*Mapping.new(@set, @scope, args).to_route)
          self
        end
176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194
      end

      module HttpHelpers
        def get(*args, &block)
          map_method(:get, *args, &block)
        end

        def post(*args, &block)
          map_method(:post, *args, &block)
        end

        def put(*args, &block)
          map_method(:put, *args, &block)
        end

        def delete(*args, &block)
          map_method(:delete, *args, &block)
        end

195 196 197
        def redirect(*args, &block)
          options = args.last.is_a?(Hash) ? args.pop : {}

198 199 200
          path      = args.shift || block
          path_proc = path.is_a?(Proc) ? path : proc { |params| path % params }
          status    = options[:status] || 301
201
          body      = 'Moved Permanently'
202 203

          lambda do |env|
204 205
            req = Request.new(env)

206
            uri = URI.parse(path_proc.call(req.params.symbolize_keys))
207 208
            uri.scheme ||= req.scheme
            uri.host   ||= req.host
209
            uri.port   ||= req.port unless req.port == 80
210 211 212 213 214 215 216

            headers = {
              'Location' => uri.to_s,
              'Content-Type' => 'text/html',
              'Content-Length' => body.length.to_s
            }
            [ status, headers, [body] ]
217
          end
218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247
        end

        private
          def map_method(method, *args, &block)
            options = args.extract_options!
            options[:via] = method
            args.push(options)
            match(*args, &block)
            self
          end
      end

      module Scoping
        def initialize(*args)
          @scope = {}
          super
        end

        def scope(*args)
          options = args.extract_options!

          case args.first
          when String
            options[:path] = args.first
          when Symbol
            options[:controller] = args.first
          end

          if path = options.delete(:path)
            path_set = true
J
Joshua Peek 已提交
248
            path, @scope[:path] = @scope[:path], Rack::Mount::Utils.normalize_path(@scope[:path].to_s + path.to_s)
249 250 251 252 253 254
          else
            path_set = false
          end

          if name_prefix = options.delete(:name_prefix)
            name_prefix_set = true
255
            name_prefix, @scope[:name_prefix] = @scope[:name_prefix], (@scope[:name_prefix] ? "#{@scope[:name_prefix]}_#{name_prefix}" : name_prefix)
256 257 258
          else
            name_prefix_set = false
          end
259

260 261
          if namespace = options.delete(:namespace)
            namespace_set = true
262
            namespace, @scope[:namespace] = @scope[:namespace], (@scope[:namespace] ? "#{@scope[:namespace]}/#{namespace}" : namespace)
263 264 265
          else
            namespace_set = false
          end
266 267 268

          if controller = options.delete(:controller)
            controller_set = true
269
            controller, @scope[:controller] = @scope[:controller], (@scope[:namespace] ? "#{@scope[:namespace]}/#{controller}" : controller)
270 271 272 273 274 275 276 277
          else
            controller_set = false
          end

          constraints = options.delete(:constraints) || {}
          unless constraints.is_a?(Hash)
            block, constraints = constraints, {}
          end
278

279 280 281 282 283 284 285
          constraints, @scope[:constraints] = @scope[:constraints], (@scope[:constraints] || {}).merge(constraints)
          blocks, @scope[:blocks] = @scope[:blocks], (@scope[:blocks] || []) + [block]
          options, @scope[:options] = @scope[:options], (@scope[:options] || {}).merge(options)

          yield
          self
        ensure
286
          @scope[:path]        = path        if path_set
287
          @scope[:name_prefix] = name_prefix if name_prefix_set
288
          @scope[:namespace]   = namespace   if namespace_set
289 290 291
          @scope[:controller]  = controller  if controller_set
          @scope[:options]     = options
          @scope[:blocks]      = blocks
292 293 294 295 296 297 298 299
          @scope[:constraints] = constraints
        end

        def controller(controller)
          scope(controller.to_sym) { yield }
        end

        def namespace(path)
300
          scope("/#{path}", :name_prefix => path.to_s, :namespace => path.to_s) { yield }
301 302 303 304 305 306 307 308 309 310 311
        end

        def constraints(constraints = {})
          scope(:constraints => constraints) { yield }
        end

        def match(*args)
          options = args.extract_options!

          options = (@scope[:options] || {}).merge(options)

312 313
          if @scope[:name_prefix] && !options[:as].blank?
            options[:as] = "#{@scope[:name_prefix]}_#{options[:as]}"
314
          elsif @scope[:name_prefix] && options[:as] == ""
315
            options[:as] = @scope[:name_prefix].to_s
316 317 318 319 320 321 322
          end

          args.push(options)
          super(*args)
        end
      end

J
Joshua Peek 已提交
323
      module Resources
324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342
        class Resource #:nodoc:
          attr_reader :plural, :singular

          def initialize(entities, options = {})
            entities = entities.to_s

            @plural   = entities.pluralize
            @singular = entities.singularize
          end

          def name
            plural
          end

          def controller
            plural
          end

          def member_name
343
            singular
344 345 346
          end

          def collection_name
347
            plural
348
          end
349 350 351 352

          def id_segment
            ":#{singular}_id"
          end
353 354 355 356
        end

        class SingletonResource < Resource #:nodoc:
          def initialize(entity, options = {})
357
            super
358 359 360 361 362 363 364
          end

          def name
            singular
          end
        end

J
Joshua Peek 已提交
365
        def resource(*resources, &block)
J
Joshua Peek 已提交
366
          options = resources.extract_options!
J
Joshua Peek 已提交
367 368 369 370 371 372

          if resources.length > 1
            raise ArgumentError if block_given?
            resources.each { |r| resource(r, options) }
            return self
          end
373

374
          resource = SingletonResource.new(resources.pop)
375

J
Joshua Peek 已提交
376
          if @scope[:scope_level] == :resources
377 378
            nested do
              resource(resource.name, options, &block)
379
            end
J
Joshua Peek 已提交
380
            return self
381 382
          end

J
Joshua Peek 已提交
383
          scope(:path => "/#{resource.name}", :controller => resource.controller) do
384 385 386
            with_scope_level(:resource, resource) do
              yield if block_given?

387 388 389 390 391 392
              get    "(.:format)",      :to => :show, :as => resource.member_name
              post   "(.:format)",      :to => :create
              put    "(.:format)",      :to => :update
              delete "(.:format)",      :to => :destroy
              get    "/new(.:format)",  :to => :new,  :as => "new_#{resource.singular}"
              get    "/edit(.:format)", :to => :edit, :as => "edit_#{resource.singular}"
393 394 395
            end
          end

J
Joshua Peek 已提交
396
          self
397 398
        end

J
Joshua Peek 已提交
399
        def resources(*resources, &block)
J
Joshua Peek 已提交
400
          options = resources.extract_options!
401

J
Joshua Peek 已提交
402 403 404 405
          if resources.length > 1
            raise ArgumentError if block_given?
            resources.each { |r| resources(r, options) }
            return self
406 407
          end

408
          resource = Resource.new(resources.pop)
409

J
Joshua Peek 已提交
410
          if @scope[:scope_level] == :resources
411 412
            nested do
              resources(resource.name, options, &block)
413
            end
J
Joshua Peek 已提交
414
            return self
415 416
          end

J
Joshua Peek 已提交
417
          scope(:path => "/#{resource.name}", :controller => resource.controller) do
418 419
            with_scope_level(:resources, resource) do
              yield if block_given?
J
Joshua Peek 已提交
420

421
              with_scope_level(:collection) do
422
                get  "(.:format)", :to => :index, :as => resource.collection_name
J
Joshua Peek 已提交
423
                post "(.:format)", :to => :create
424

425 426 427
                with_exclusive_name_prefix :new do
                  get "/new(.:format)", :to => :new, :as => resource.singular
                end
428
              end
429

430
              with_scope_level(:member) do
J
Joshua Peek 已提交
431
                scope("/:id") do
432 433
                  get    "(.:format)", :to => :show, :as => resource.member_name
                  put    "(.:format)", :to => :update
J
Joshua Peek 已提交
434
                  delete "(.:format)", :to => :destroy
435

436 437 438
                  with_exclusive_name_prefix :edit do
                    get "/edit(.:format)", :to => :edit, :as => resource.singular
                  end
J
Joshua Peek 已提交
439
                end
440 441 442 443
              end
            end
          end

J
Joshua Peek 已提交
444
          self
445 446
        end

J
Joshua Peek 已提交
447 448 449
        def collection
          unless @scope[:scope_level] == :resources
            raise ArgumentError, "can't use collection outside resources scope"
450 451
          end

J
Joshua Peek 已提交
452
          with_scope_level(:collection) do
453
            scope(:name_prefix => parent_resource.collection_name, :as => "") do
454 455
              yield
            end
J
Joshua Peek 已提交
456
          end
457
        end
J
Joshua Peek 已提交
458

J
Joshua Peek 已提交
459 460 461 462
        def member
          unless @scope[:scope_level] == :resources
            raise ArgumentError, "can't use member outside resources scope"
          end
J
Joshua Peek 已提交
463

J
Joshua Peek 已提交
464
          with_scope_level(:member) do
J
Joshua Peek 已提交
465
            scope("/:id", :name_prefix => parent_resource.member_name, :as => "") do
J
Joshua Peek 已提交
466 467 468
              yield
            end
          end
J
Joshua Peek 已提交
469 470
        end

471 472 473 474 475 476
        def nested
          unless @scope[:scope_level] == :resources
            raise ArgumentError, "can't use nested outside resources scope"
          end

          with_scope_level(:nested) do
J
Joshua Peek 已提交
477
            scope("/#{parent_resource.id_segment}", :name_prefix => parent_resource.member_name) do
478 479 480 481 482
              yield
            end
          end
        end

J
Joshua Peek 已提交
483
        def match(*args)
J
Joshua Peek 已提交
484
          options = args.extract_options!
485 486 487 488 489 490 491

          if args.length > 1
            args.each { |path| match(path, options) }
            return self
          end

          if args.first.is_a?(Symbol)
492
            with_exclusive_name_prefix(args.first) do
J
Joshua Peek 已提交
493
              return match("/#{args.first}(.:format)", options.merge(:to => args.first.to_sym))
494 495 496
            end
          end

J
Joshua Peek 已提交
497
          args.push(options)
J
Joshua Peek 已提交
498

J
Joshua Peek 已提交
499 500 501 502 503 504
          case options.delete(:on)
          when :collection
            return collection { match(*args) }
          when :member
            return member { match(*args) }
          end
J
Joshua Peek 已提交
505

J
Joshua Peek 已提交
506 507 508
          if @scope[:scope_level] == :resources
            raise ArgumentError, "can't define route directly in resources scope"
          end
J
Joshua Peek 已提交
509

J
Joshua Peek 已提交
510
          super
J
Joshua Peek 已提交
511 512
        end

513 514 515 516 517
        protected
          def parent_resource
            @scope[:scope_level_resource]
          end

J
Joshua Peek 已提交
518
        private
519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534
          def with_exclusive_name_prefix(prefix)
            begin
              old_name_prefix = @scope[:name_prefix]

              if !old_name_prefix.blank?
                @scope[:name_prefix] = "#{prefix}_#{@scope[:name_prefix]}"
              else
                @scope[:name_prefix] = prefix.to_s
              end

              yield
            ensure
              @scope[:name_prefix] = old_name_prefix
            end
          end

535
          def with_scope_level(kind, resource = parent_resource)
J
Joshua Peek 已提交
536
            old, @scope[:scope_level] = @scope[:scope_level], kind
537
            old_resource, @scope[:scope_level_resource] = @scope[:scope_level_resource], resource
J
Joshua Peek 已提交
538 539 540
            yield
          ensure
            @scope[:scope_level] = old
541
            @scope[:scope_level_resource] = old_resource
J
Joshua Peek 已提交
542 543
          end
      end
J
Joshua Peek 已提交
544

545 546 547 548
      include Base
      include HttpHelpers
      include Scoping
      include Resources
J
Joshua Peek 已提交
549 550
    end
  end
J
Joshua Peek 已提交
551
end