Sha256: 299523fc15e19ef641f5864f23738163891805ab1073cd030063a18dbaf77256

Contents?: true

Size: 1.66 KB

Versions: 3

Compression:

Stored size: 1.66 KB

Contents

require 'uri'
require 'delegate'

module Pact
  module Hal
    class Link
      attr_reader :request_method, :href

      def initialize(attrs, http_client)
        @attrs = attrs
        @request_method = attrs.fetch(:method, :get).to_sym
        @href = attrs.fetch('href')
        @http_client = http_client
      end

      def run(payload = nil)
        response = case request_method
          when :get
            get(payload)
          when :put
            put(payload)
          when :post
            post(payload)
          end
      end

      def get(payload = {}, headers = {})
        wrap_response(@http_client.get(href, payload, headers))
      end

      def put(payload = nil, headers = {})
        wrap_response(@http_client.put(href, payload ? JSON.dump(payload) : nil, headers))
      end

      def post(payload = nil, headers = {})
        wrap_response(@http_client.post(href, payload ? JSON.dump(payload) : nil, headers))
      end

      def expand(params)
        expanded_url = expand_url(params, href)
        new_attrs = @attrs.merge('href' => expanded_url)
        Link.new(new_attrs, @http_client)
      end

      private

      def wrap_response(http_response)
        require 'pact/hal/entity' # avoid circular reference
        if http_response.success?
          Entity.new(http_response.body, @http_client, http_response)
        else
          ErrorEntity.new(http_response.raw_body, @http_client, http_response)
        end
      end

      def expand_url(params, url)
        new_url = url
        params.each do | key, value |
          new_url = new_url.gsub('{' + key.to_s + '}', URI.escape(value))
        end
        new_url
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version Path
pact-1.29.0 lib/pact/hal/link.rb
pact-1.28.0 lib/pact/hal/link.rb
pact-1.28.0.rc1 lib/pact/hal/link.rb