Contents

class Hook < ActiveRecord::Base
  default_scope { order :id }

  CONTENT_TYPES = {
    'json' => 'application/json',
    'form' => 'application/x-www-form-urlencoded',
  }.freeze

  EVENTS = %w(
    task
    deploy
    rollback
    lock
    commit_status
    deployable_status
  ).freeze

  belongs_to :stack, required: false
  has_many :deliveries

  validates :url, presence: true, url: {no_local: true, allow_blank: true}
  validates :content_type, presence: true, inclusion: {in: CONTENT_TYPES.keys}
  validates :events, presence: true, subset: {of: EVENTS}

  serialize :events, Shipit::CSVSerializer

  scope :global, -> { where(stack_id: nil) }
  scope :scoped_to, -> (stack) { where(stack_id: stack.id) }
  scope :for_stack, -> (stack_id) { where(stack_id: [nil, stack_id]) }

  class << self
    def emit(event, stack, payload)
      EmitEventJob.perform_later(
        event: event.to_s,
        stack_id: stack.try!(:id),
        payload: coerce_payload(payload),
      )
    end

    def deliver(event, stack_id, payload)
      for_stack(stack_id).listening_event(event).each do |hook|
        hook.deliver!(event, payload)
      end
    end

    def listening_event(event)
      event = event.to_s
      all.to_a.select { |h| h.events.include?(event) }
    end

    def coerce_payload(payload)
      coerced_payload = payload.dup
      payload.each do |key, value|
        if serializer = ActiveModel::Serializer.serializer_for(value)
          coerced_payload[key] = serializer.new(value)
        end
      end
      coerced_payload.to_json
    end
  end

  def scoped?
    stack_id?
  end

  def deliver!(event, payload)
    deliveries.create!(
      event: event,
      url: url,
      content_type: CONTENT_TYPES[content_type],
      payload: serialize_payload(payload),
    ).schedule!
  end

  private

  def serialize_payload(payload)
    if content_type == 'form'
      payload.to_query
    else
      JSON.pretty_generate(payload)
    end
  end
end

Version data entries

14 entries across 14 versions & 1 rubygems

Version	Path
shipit-engine-0.5.2	app/models/hook.rb
shipit-engine-0.5.1	app/models/hook.rb
shipit-engine-0.5.0	app/models/hook.rb
shipit-engine-0.4.10	app/models/hook.rb
shipit-engine-0.4.9	app/models/hook.rb
shipit-engine-0.4.8	app/models/hook.rb
shipit-engine-0.4.7	app/models/hook.rb
shipit-engine-0.4.6	app/models/hook.rb
shipit-engine-0.4.5	app/models/hook.rb
shipit-engine-0.4.4	app/models/hook.rb
shipit-engine-0.4.3	app/models/hook.rb
shipit-engine-0.4.2	app/models/hook.rb
shipit-engine-0.4.1	app/models/hook.rb
shipit-engine-0.4.0	app/models/hook.rb