require "pact_broker/api/resources/base_resource" require "pact_broker/services" require "pact_broker/api/decorators/webhook_decorator" require "pact_broker/api/resources/webhook_resource_methods" module PactBroker module Api module Resources class Webhook < BaseResource include WebhookResourceMethods def content_types_accepted [["application/json", :from_json]] end def content_types_provided [["application/hal+json", :to_json]] end def allowed_methods ["GET", "PUT", "DELETE", "OPTIONS"] end def put_can_create? true end def resource_exists? !!webhook end def malformed_request? super || (request.put? && webhook_validation_errors?(parsed_webhook, uuid)) end def from_json if webhook @webhook = webhook_service.update_by_uuid(uuid, params(symbolize_names: false)) response.body = to_json else @webhook = webhook_service.create(uuid, parsed_webhook, consumer, provider) response.body = to_json 201 end end def to_json decorator_class(:webhook_decorator).new(webhook).to_json(decorator_options) end def delete_resource webhook_service.delete_by_uuid uuid true end def policy_name :'webhooks::webhook' end def action if request.put? webhook ? :update : :create else super end end def policy_record webhook || parsed_webhook end private def webhook @webhook ||= webhook_service.find_by_uuid uuid end def parsed_webhook @parsed_webhook ||= decorator_class(:webhook_decorator).new(PactBroker::Domain::Webhook.new).from_json(request_body) end def uuid identifier_from_path[:uuid] end end end end end