ike18t/wiremock_mapper

require 'net/http'
require_relative 'configuration'

module WireMockMapper
  class << self
    def create_mapping(url = Configuration.wiremock_url, &block)
      create_mapping_with_priority(nil, url, &block)
    end

    def create_mapping_with_priority(priority = nil, url = Configuration.wiremock_url)
      request_builder = deep_clone(Configuration.request_builder)
      response_builder = deep_clone(Configuration.response_builder)
      scenario_builder = deep_clone(Configuration.scenario_builder)

      yield request_builder, response_builder, scenario_builder

      body = { request: request_builder, response: response_builder }.merge(scenario_builder)
      body[:priority] = priority if priority

      response = send_to_wiremock(url, body)

      JSON.parse(response.body).fetch('id')
    end

    def delete_mapping(mapping_id, url = Configuration.wiremock_url)
      delete_from_wiremock(url, mapping_id)
    end

    def clear_mappings(url = Configuration.wiremock_url)
      clear_wiremock_mappings(url)
    end

    def reset_scenarios(url = Configuration.wiremock_url)
      reset_wiremock_scenarios(url)
    end

    private

    WIREMOCK_MAPPINGS_PATH = '__admin/mappings'.freeze
    WIREMOCK_CLEAR_MAPPINGS_PATH = "#{WIREMOCK_MAPPINGS_PATH}/reset".freeze
    WIREMOCK_RESET_SCENARIOS_PATH = '__admin/scenarios/reset'.freeze

    def headers
      { 'Content-Type' => 'application/json' }.merge(Configuration.wiremock_headers)
    end

    def deep_clone(object)
      Marshal.load(Marshal.dump(object))
    end

    def clear_wiremock_mappings(url)
      uri = URI([url, WIREMOCK_CLEAR_MAPPINGS_PATH].join('/'))
      http = Net::HTTP.new(uri.host, uri.port)
      http.use_ssl = true if uri.port == 443
      request = Net::HTTP::Post.new(uri.path, headers)
      http.request(request)
    end

    def delete_from_wiremock(url, mapping_id)
      uri = URI([url, WIREMOCK_MAPPINGS_PATH, mapping_id].join('/'))
      http = Net::HTTP.new(uri.host, uri.port)
      http.use_ssl = true if uri.port == 443
      request = Net::HTTP::Delete.new(uri.path, headers)
      http.request(request)
    end

    def send_to_wiremock(url, body)
      uri = URI([url, WIREMOCK_MAPPINGS_PATH].join('/'))
      http = Net::HTTP.new(uri.host, uri.port)
      http.use_ssl = true if uri.port == 443
      request = Net::HTTP::Post.new(uri.path, headers)
      request.body = body.to_json
      http.request(request)
    end

    def reset_wiremock_scenarios(url)
      uri = URI([url, WIREMOCK_RESET_SCENARIOS_PATH].join('/'))
      http = Net::HTTP.new(uri.host, uri.port)
      http.use_ssl = true if uri.port == 443
      request = Net::HTTP::Post.new(uri.path, headers)
      http.request(request)
    end
  end
end