require 'sequel'
require 'pact_broker/repositories/helpers'
require 'pact_broker/webhooks/execution'

module PactBroker
  module Webhooks
    class TriggeredWebhook < Sequel::Model(:triggered_webhooks)

      TRIGGER_TYPE_PUBLICATION = 'pact_publication'
      TRIGGER_TYPE_USER = 'user'

      STATUS_NOT_RUN = 'not_run'.freeze
      STATUS_RETRYING = 'retrying'.freeze
      STATUS_SUCCESS = 'success'.freeze
      STATUS_FAILURE = 'failure'.freeze

      dataset_module do
        include PactBroker::Repositories::Helpers

        def retrying
          where(status: STATUS_RETRYING)
        end

        def successful
          where(status: STATUS_SUCCESS)
        end

        def failed
          where(status: STATUS_FAILURE)
        end

        def not_run
          where(status: STATUS_NOT_RUN)
        end
      end

      associate(:one_to_many, :webhook_executions, :class => "PactBroker::Webhooks::Execution", :key => :triggered_webhook_id, :primary_key => :id, :order => :id)
      associate(:many_to_one, :webhook, :class => "PactBroker::Webhooks::Webhook", :key => :webhook_id, :primary_key => :id)
      associate(:many_to_one, :pact_publication, :class => "PactBroker::Pacts::PactPublication", :key => :pact_publication_id, :primary_key => :id)
      associate(:many_to_one, :provider, :class => "PactBroker::Domain::Pacticipant", :key => :provider_id, :primary_key => :id)
      associate(:many_to_one, :consumer, :class => "PactBroker::Domain::Pacticipant", :key => :consumer_id, :primary_key => :id)


      def request_description
        webhook.to_domain.request_description
      end

      def execute options
        webhook.to_domain.execute pact_publication.to_domain, options
      end

      def consumer_name
        consumer && consumer.name
      end

      def provider_name
        provider && provider.name
      end

      def success?
        status == STATUS_SUCCESS
      end

      def failure?
        status == STATUS_FAILURE
      end

      def retrying?
        status == STATUS_RETRYING
      end

      def not_run?
        status == STATUS_NOT_RUN
      end

      def number_of_attempts_made
        webhook_executions.size
      end

      def finished?
        success? || failure?
      end

      def number_of_attempts_remaining
        if finished?
          0
        else
          (PactBroker.configuration.webhook_retry_schedule.size + 1) - number_of_attempts_made
        end
      end
    end

    TriggeredWebhook.plugin :timestamps, update_on_create: true

  end
end