aboutsummaryrefslogtreecommitdiffstats
path: root/activeresource/test/http_mock.rb
blob: 1166a56af7a1dc29c8f15f27a52d1d0ac979f249 (plain) (blame)
1
2
3
4
5
6
7
8
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
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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
require 'active_resource/connection'

module ActiveResource
  class InvalidRequestError < StandardError; end
    
  class HttpMock
    class Responder
      def initialize(responses)
        @responses = responses
      end
      
      for method in [ :post, :put, :get, :delete ]
        module_eval <<-EOE
          def #{method}(path, request_headers = {}, body = nil, status = 200, response_headers = {})
            @responses[Request.new(:#{method}, path, nil, request_headers)] = Response.new(body || {}, status, response_headers)
          end
        EOE
      end
    end

    class << self
      def requests
        @@requests ||= []
      end

      def responses
        @@responses ||= {}
      end

      def respond_to(pairs = {})
        reset!
        pairs.each do |(path, response)|
          responses[path] = response
        end
        yield Responder.new(responses) if block_given?
      end

      def reset!
        requests.clear
        responses.clear
      end
    end

    for method in [ :post, :put ]
      module_eval <<-EOE
        def #{method}(path, body, headers)
          request = ActiveResource::Request.new(:#{method}, path, body, headers)
          self.class.requests << request
          self.class.responses[request] || raise(InvalidRequestError.new("No response recorded for: \#{request}"))
        end
      EOE
    end
    
    for method in [ :get, :delete ]
      module_eval <<-EOE
        def #{method}(path, headers)
          request = ActiveResource::Request.new(:#{method}, path, nil, headers)
          self.class.requests << request
          self.class.responses[request] || raise(InvalidRequestError.new("No response recorded for: \#{request}"))
        end
      EOE
    end
    
    def initialize(site)
      @site = site
    end
  end

  class Request
    attr_accessor :path, :method, :body, :headers
    
    def initialize(method, path, body = nil, headers = {})
      @method, @path, @body, @headers = method, path, body, headers
      @headers.update('Content-Type' => 'application/xml')
    end

    def ==(other_request)
      other_request.hash == hash
    end
    
    def eql?(other_request)
      self == other_request
    end
    
    def to_s
      "<#{method.to_s.upcase}: #{path} [#{headers}] (#{body})>"
    end
    
    def hash
      "#{path}#{method}#{headers}".hash
    end
  end
  
  class Response
    attr_accessor :body, :code, :headers
    
    def initialize(body, code = 200, headers = {})
      @body, @code, @headers = body, code, headers
    end
    
    def success?
      (200..299).include?(code)
    end

    def [](key)
      headers[key]
    end
    
    def []=(key, value)
      headers[key] = value
    end

  end

  class Connection
    private
      silence_warnings do
        def http
          @http ||= HttpMock.new(@site)
        end
      end
  end
end