require 'cgi' require 'pact_broker/api/resources/base_resource' require 'pact_broker/api/resources/pacticipant_resource_methods' require 'pact_broker/api/decorators/pact_decorator' require 'pact_broker/json' require 'pact_broker/pacts/pact_params' require 'pact_broker/api/contracts/put_pact_params_contract' module Webmachine class Request def patch? method == "PATCH" end end end module PactBroker module Api module Resources class Pact < BaseResource include PacticipantResourceMethods def content_types_provided [["application/hal+json", :to_json], ["application/json", :to_json], ["text/html", :to_html]] end def content_types_accepted [["application/json", :from_json]] end def allowed_methods ["GET", "PUT", "DELETE", "PATCH"] end def known_methods super + ['PATCH'] end def is_conflict? merge_conflict = request.patch? && resource_exists? && Pacts::Merger.conflict?(pact.json_content, pact_params.json_content) potential_duplicate_pacticipants?(pact_params.pacticipant_names) || merge_conflict end def malformed_request? if request.patch? || request.put? invalid_json? || contract_validation_errors?(Contracts::PutPactParamsContract.new(pact_params), pact_params) else false end end def resource_exists? !!pact end def from_json response_code = pact ? 200 : 201 if request.patch? && resource_exists? @pact = pact_service.merge_pact(pact_params) else @pact = pact_service.create_or_update_pact(pact_params) end response.body = to_json response_code end def to_json PactBroker::Api::Decorators::PactDecorator.new(pact).to_json(user_options: { base_url: base_url }) end def to_html PactBroker.configuration.html_pact_renderer.call( pact, { base_url: base_url, badge_url: badge_url_for_latest_pact(pact, base_url) }) end def delete_resource pact_service.delete(pact_params) true end private def pact @pact ||= pact_service.find_pact(pact_params) end def pact_params @pact_params ||= PactBroker::Pacts::PactParams.from_request request, path_info end end end end end